| | |
| | | #include <iostream> |
| | | using namespace std; |
| | | |
| | | //#todo 修改服务线程构造参数传入方式 |
| | | RemoteServer<RtspFaceViewImpl> remoteServer("192.168.1.94", 8112); |
| | | AppConfig config("data/config.cfg"); |
| | | RemoteServer<RtspFaceViewImpl> remoteServer(config.getStringValue("local_ip"), config.getIntValue("local_port")); |
| | | //RemoteServer<RtspFaceViewImpl> remoteServer("192.168.1.97", 8112); |
| | | static RtspFaceDetectClient* rtspFaceDetectClient = nullptr; |
| | | |
| | | void startRemoteServer() |
| | | { |
| | | ; |
| | | AppConfig config; |
| | | config.loadConfig("data/config.cfg"); |
| | | remoteServer.start(); |
| | | // //#todo 调用位置移动 |
| | | // try |
| | | // { |
| | | // RtspFaceDetectClient rtspFaceDetectClient = RtspFaceDetectClient(); |
| | | // RtspFaceDetect::Client& rClient = rtspFaceDetectClient.getClient(); |
| | | // |
| | | // auto& waitScope = rtspFaceDetectClient.getWaitScope(); |
| | | // auto request = rClient.fireFaceCountListenerRequest(); |
| | | // auto sendAct = request.send(); |
| | | // sendAct.wait(waitScope); |
| | | // } |
| | | // catch (const kj::Exception& e) |
| | | // { |
| | | // cout << e.getDescription().cStr() << endl; |
| | | // return; |
| | | // } |
| | | //#end |
| | | } |
| | | |
| | | RtspFaceDetectClient * getRtspFaceDetectClient() |
| | |
| | | if (rpcClient == nullptr) { |
| | | try |
| | | { |
| | | //#todo ip test |
| | | //rpcClient = new capnp::EzRpcClient("192.168.1.89", 8111); |
| | | //client |
| | | rpcClient = new capnp::EzRpcClient("192.168.1.97", 8111); |
| | | // rpcClient = new capnp::EzRpcClient("192.168.1.97", 8111); |
| | | rpcClient = new capnp::EzRpcClient(config.getStringValue("server_ip"), config.getIntValue("server_port")); |
| | | } |
| | | catch (const kj::Exception& e) |
| | | { |
| | |
| | | |
| | | ::kj::Promise<void> RtspFaceViewImpl::getFaceList(GetFaceListContext context) |
| | | { |
| | | LOG_ERROR <<"getFaceList :start !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!"<< LOG_ENDL; |
| | | auto results = context.getResults(); |
| | | remoteGetFaceList(context.getParams(), results); |
| | | context.setResults(results); |
| | | LOG_ERROR <<"getFaceList : !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!"<< LOG_ENDL; |
| | | |
| | | return kj::READY_NOW; |
| | | } |
| | | |
| | | ::kj::Promise<void> RtspFaceViewImpl::getFaceImages(GetFaceImagesContext context) |
| | | { |
| | | auto results = context.getResults(); |
| | | auto results = context.getResults(); |
| | | remoteGetFaceListImage(context.getParams(), results); |
| | | context.setResults(results); |
| | | LOG_ERROR <<"getFaceImages : !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!"<< LOG_ENDL; |
| | | LOG_ERROR <<"getFaceImages : !!!!!!!!!!!!!!"<< LOG_ENDL; |
| | | return kj::READY_NOW; |
| | | } |
| | | |
| | | ::kj::Promise<void> RtspFaceViewImpl::setFaceLabel(SetFaceLabelContext context) |
| | | { |
| | | auto results = context.getResults(); |
| | | remoteSetFaceLabel(context.getParams(), results); |
| | | context.setResults(results); |
| | | LOG_ERROR <<"setFaceLabel : !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!"<< LOG_ENDL; |
| | | LOG_ERROR <<"setFaceLabel : !!!!!!!!!!!!"<< LOG_ENDL; |
| | | auto results = context.getResults(); |
| | | |
| | | remoteSetFaceLabel(context.getParams(), results); |
| | | |
| | | return kj::READY_NOW; |
| | | } |