| | |
| | | //"sync" |
| | | "taskpubsub/logger" |
| | | |
| | | "basic.com/pubsub/protomsg.git" |
| | | "github.com/gogo/protobuf/proto" |
| | | "taskpubsub/sdk" |
| | | "taskpubsub/util" |
| | | |
| | | "basic.com/pubsub/protomsg.git" |
| | | "github.com/gogo/protobuf/proto" |
| | | |
| | | // "golang.org/x/sys/unix" |
| | | |
| | |
| | | |
| | | url := fmt.Sprintf("ipc:///tmp/%s.ipc", id) |
| | | m := deliver.PushPull |
| | | if shm{ |
| | | if shm { |
| | | m = deliver.Shm |
| | | url = id |
| | | |
| | | // unix.Unlink("/dev/shm/" + url) |
| | | } |
| | | |
| | | fmt.Println("ipc url: ", url) |
| | | |
| | | fmt.Println("CAMERA URL : ", url) |
| | | socket, err := util.NewSocketListen(int(m), url, shm) |
| | | if err != nil { |
| | | logger.Error("create socket error") |