554325746@qq.com
2019-06-27 6fd3413cfa70086864216c59718f7f4fc58b1acc
util/sqlite.go
@@ -4,7 +4,7 @@
   "fmt"
   "basic.com/pubsub/protomsg.git"
   "basic.com/r/dbapi.git"
   "basic.com/dbapi.git"
   "github.com/gogo/protobuf/proto"
   "github.com/long/test/gopherdiscovery"
)
@@ -24,13 +24,15 @@
var CameraTasks []protomsg.CameraAndTaskInfo
var TaskSdks []protomsg.TaskSdkInfo
var Sdklist []string
var Sdkinfos []protomsg.Sdk
//var urlServer = "tcp://192.168.1.11:40007"
//var urlPubSub = "tcp://192.168.1.11:50007"
var urlServer = "tcp://192.168.1.11:40007"
var urlPubSub = "tcp://192.168.1.11:50007"
var urlServer = "tcp://127.0.0.1:40007"
var urlPubSub = "tcp://127.0.0.1:50007"
//var urlServer = "tcp://127.0.0.1:40007"
//var urlPubSub = "tcp://127.0.0.1:50007"
var Sdkflag = make(chan bool)
var TaskSdkflag = make(chan bool)
@@ -48,6 +50,7 @@
   TaskSdks = taskapi.FindAll()
   Sdklist = sdkapi.GetAllSdkIds()
    Sdkinfos = sdkapi.FindAll("")
   initchan <- true
}
@@ -76,6 +79,7 @@
   case protomsg.TableChanged_T_Sdk:
      fmt.Println("update sdk")
      Sdklist = sdkapi.GetAllSdkIds()
        Sdkinfos = sdkapi.FindAll("")
      Sdkflag <- true
      fmt.Println("update finished!")
@@ -93,7 +97,6 @@
   peers, _ := clientOne.Peers()
   for x := range peers {
      fmt.Println("client: ", x)
      Getdata(x)
   }
}