| | |
|---|
| | | flag.BoolVar(&asServer, "server", false, "run ipc as server") |
|---|
| | | } |
|---|
| | | |
|---|
| | | // CameraInfo camera info |
|---|
| | | // cameraInfo camera info |
|---|
| | | type CameraInfo struct { |
|---|
| | | ID string `json:"Cameraid"` |
|---|
| | | URL string `json:"Rtsp"` |
|---|
| | |
|---|
| | | mapCameraInfo = make(map[string]CameraInfo) |
|---|
| | | |
|---|
| | | tcp = `tcp://192.168.1.124:` |
|---|
| | | port = 7000 |
|---|
| | | port = 7001 |
|---|
| | | ) |
|---|
| | | |
|---|
| | | func recvCameraInfoFromIPC(ctx context.Context, url string, ch chan<- CameraInfo) { |
|---|
| | |
|---|
| | | mapCameraInfo[c.ID] = c |
|---|
| | | ipcAddr := tcp + strconv.Itoa(port) |
|---|
| | | port++ |
|---|
| | | fmt.Printf("create ipc %s for decode : %s, on camera id %s\n", ipcAddr, c.URL, c.ID) |
|---|
| | | |
|---|
| | | url := strings.TrimSpace(c.URL) |
|---|
| | | id := strings.TrimSpace(c.ID) |
|---|
| | |
|---|
| | | } |
|---|
| | | d.RunAsClient() |
|---|
| | | } |
|---|
| | | |
|---|
| | | func test() { |
|---|
| | | fmt.Println("start test") |
|---|
| | | |
|---|
