| | |
| | | ) |
| | | |
| | | const ( |
| | | Url_Service_PUSH = "ipc:///tmp///webserver_2.ipc" |
| | | Url_Service_PULL = "ipc:///tmp///webserver_1.ipc" |
| | | |
| | | Url_Service_PUSH = "ipc:///tmp///virtual-faceextract-sdk-pull_2.ipc" |
| | | Url_Service_PULL = "ipc:///tmp///virtual-faceextract-sdk-pull_1.ipc" |
| | | ) |
| | | var imgPushChan chan protomsg.Recvmsg |
| | | var client_push deliver.Deliver |
| | |
| | | fmt.Println("image is not compressible") |
| | | } |
| | | bc = bc[:n] |
| | | //for { |
| | | PushImgMsg(protomsg.Recvmsg{ |
| | | Id:uuid.NewV4().String(), |
| | | Addr:"", |
| | | Picdata:bc, |
| | | }) |
| | | fmt.Println("pushed img") |
| | | //time.Sleep(10*time.Second) |
| | | //} |
| | | |
| | | PushImgMsg(protomsg.Recvmsg{ |
| | | Id:uuid.NewV4().String(), |
| | | Addr:"", |
| | | Picdata:bc, |
| | | }) |
| | | fmt.Println("pushed img") |
| | | } |
| | | } |
| | | |
| | |
| | | continue |
| | | } |
| | | rMsg := protomsg.SdkMessage{} |
| | | if err := proto.Unmarshal(resultBytes, &rMsg);err !=nil{ |
| | | if err := proto.Unmarshal(resultBytes, &rMsg);err ==nil{ |
| | | fmt.Println("recv MSG:",rMsg) |
| | | resultMap[rMsg.Cid] = rMsg |
| | | } else { |
| | | fmt.Println("recv msg Err:",err) |
| | | } |
| | | |
| | | } |