do work after dbserver init completed

liuxiaolong

2019-07-01 128337f410c55b49c933b0024e9ca01f55de8c7d

do work after dbserver init completed

 main.go

@@ -1,25 +1,38 @@
package main

import (
    "basic.com/dbapi.git"
    "basic.com/pubsub/protomsg.git"
    "basic.com/valib/deliver.git"
    "bufio"
    "bytes"
    "flag"
    "fmt"
    "github.com/golang/protobuf/proto"
    "gocv.io/x/gocv"
    "image"
    "image/color"
    "os"
    "ruleprocess/cache"
    "ruleprocess/insertdata"
    "ruleprocess/ruleserver"
    "ruleprocess/util"
    "sync"
)

var dbIp = flag.String("dbIp","127.0.0.1","dbserver ip")
var dbPort = flag.Int("dbPort",8001,"default dbPort=8001")
var surveyPort = flag.Int("surveyPort",40007,"survey port")
var pubPort = flag.Int("pubPort",50007,"pubsub port")
var initchan = make(chan bool)
func main() {
    flag.Parse()
    wg := sync.WaitGroup{}
    wg.Add(1)

    dbapi.Init(*dbIp,*dbPort)
    go cache.Init(initchan,*dbIp,*surveyPort,*pubPort)
    fmt.Println("cache init completed!!!",<- initchan)//dbserver初始化完毕

    go ruleserver.TimeTicker()
    nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1)
    wg.Wait()