| | |
| | | "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" |
| | | ) |
| | |
| | | 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) |
| | |
| | | TaskSdks = taskapi.FindAll() |
| | | |
| | | Sdklist = sdkapi.GetAllSdkIds() |
| | | Sdkinfos = sdkapi.FindAll("") |
| | | initchan <- true |
| | | } |
| | | |
| | |
| | | case protomsg.TableChanged_T_Sdk: |
| | | fmt.Println("update sdk") |
| | | Sdklist = sdkapi.GetAllSdkIds() |
| | | Sdkinfos = sdkapi.FindAll("") |
| | | Sdkflag <- true |
| | | fmt.Println("update finished!") |
| | | |
| | |
| | | |
| | | peers, _ := clientOne.Peers() |
| | | for x := range peers { |
| | | fmt.Println("client: ", x) |
| | | Getdata(x) |
| | | } |
| | | } |