| | |
| | | #include "RemoteFuncClient.h"
|
| | | #include "RemoteFunc.h"
|
| | | #include "RtspNativeCodecJNIClient.h"
|
| | | RemoteServer<RtspFaceDetectImpl> remoteServer("127.0.0.1",8111);
|
| | | void startRemoteServer(){
|
| | | remoteServer.start();
|
| | |
|
| | | RemoteServer<RtspFaceDetectImpl> remoteServer("127.0.0.1", 8111);
|
| | | static RtspFaceViewClient* rtspFaceViewClient = nullptr;
|
| | |
|
| | | void startRemoteServer()
|
| | | {
|
| | | remoteServer.start();
|
| | | }
|
| | | RtspFaceViewClient rtspFaceViewClient;
|
| | | RtspFaceViewClient& RtspFaceViewClient(){
|
| | | return rtspFaceViewClient;
|
| | |
|
| | | RtspFaceViewClient* getRtspFaceViewClient()
|
| | | {
|
| | | if (rtspFaceViewClient != nullptr)
|
| | | {
|
| | | try
|
| | | {
|
| | | rtspFaceViewClient = new RtspFaceViewClient;
|
| | | }
|
| | | catch(...)
|
| | | {
|
| | | delete rtspFaceViewClient;
|
| | | rtspFaceViewClient = nullptr;
|
| | | LOG_ERROR << "aaaaaaaa"<<LOG_ENDL;//#todo
|
| | | }
|
| | | }
|
| | | return rtspFaceViewClient;
|
| | | }
|
| | | RtspFaceViewClient::RtspFaceViewClient():rpcClient("127.0.0.1",8112),
|
| | | RtspFaceView::Client(rpcClient.getMain<RtspFaceView>())
|
| | |
|
| | | RtspFaceViewClient::RtspFaceViewClient() :
|
| | | rpcClient("127.0.0.1", 8112), RtspFaceView::Client(rpcClient.getMain<RtspFaceView>())
|
| | | {}
|
| | | ::kj::WaitScope& RtspFaceViewClient::getWaitScope(){
|
| | | return rpcClient.getWaitScope();
|
| | |
|
| | | ::kj::WaitScope &RtspFaceViewClient::getWaitScope()
|
| | | {
|
| | | return rpcClient.getWaitScope();
|
| | | }
|
| | | ::kj::Promise<void> RtspFaceDetectImpl::fireFaceCountListener(FireFaceCountListenerContext context) {
|
| | | auto results = context.getResults();
|
| | | remoteFireFaceCountListener(context.getParams(), results);
|
| | | context.setResults(results);
|
| | | } |
| | |
|
| | | ::kj::Promise<void> RtspFaceDetectImpl::fireFaceCountListener(FireFaceCountListenerContext context)
|
| | | {
|
| | | auto results = context.getResults();
|
| | | remoteFireFaceCountListener(context.getParams(), results);
|
| | | context.setResults(results);
|
| | | }
|