| | |
|---|
| | | #include "RemoteFunc.h"
|
|---|
| | | #include "RtspNativeCodecJNIClient.h"
|
|---|
| | |
|
|---|
| | | RemoteServer<RtspFaceDetectImpl> remoteServer("127.0.0.1", 8111);
|
|---|
| | | #include <string>
|
|---|
| | | #include <iostream>
|
|---|
| | | using namespace std;
|
|---|
| | |
|
|---|
| | | //#todo 修改服务线程构造参数传入方式
|
|---|
| | | RemoteServer<RtspFaceDetectImpl> remoteServer("192.168.1.97", 8111);
|
|---|
| | | static RtspFaceViewClient* rtspFaceViewClient = nullptr;
|
|---|
| | |
|
|---|
| | | void startRemoteServer()
|
|---|
| | | {
|
|---|
| | | LOG_ERROR << "pansen : this is clinet" << std::endl;
|
|---|
| | | remoteServer.start();
|
|---|
| | |
|
|---|
| | | //#todo 调用位置移动
|
|---|
| | | // try
|
|---|
| | | // {
|
|---|
| | | // RtspFaceViewClient rtspFaceViewClient = RtspFaceViewClient();
|
|---|
| | | // RtspFaceView::Client& rClient = rtspFaceViewClient.getClient();
|
|---|
| | | //
|
|---|
| | | // auto& waitScope = rtspFaceViewClient.getWaitScope();
|
|---|
| | | // //auto request = rClient.abcdef();
|
|---|
| | | // // auto sendAct = request.send();
|
|---|
| | | // // sendAct.wait(waitScope);
|
|---|
| | | // }
|
|---|
| | | // catch (const kj::Exception& e)
|
|---|
| | | // {
|
|---|
| | | // cout << e.getDescription().cStr() << endl;
|
|---|
| | | // return;
|
|---|
| | | // }
|
|---|
| | | //#end
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | RtspFaceViewClient* getRtspFaceViewClient()
|
|---|
| | | RtspFaceViewClient * getRtspFaceViewClient()
|
|---|
| | | {
|
|---|
| | | if (rtspFaceViewClient != nullptr)
|
|---|
| | | {
|
|---|
| | | try
|
|---|
| | | {
|
|---|
| | | rtspFaceViewClient = new RtspFaceViewClient;
|
|---|
| | | }
|
|---|
| | | catch(...)
|
|---|
| | | {
|
|---|
| | | delete rtspFaceViewClient;
|
|---|
| | | rtspFaceViewClient = nullptr;
|
|---|
| | | LOG_ERROR << "aaaaaaaa"<<LOG_ENDL;//#todo
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | if(rtspFaceViewClient == nullptr)
|
|---|
| | | rtspFaceViewClient = new RtspFaceViewClient;
|
|---|
| | | return rtspFaceViewClient;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | RtspFaceViewClient::RtspFaceViewClient() :
|
|---|
| | | rpcClient("127.0.0.1", 8112), RtspFaceView::Client(rpcClient.getMain<RtspFaceView>())
|
|---|
| | | rpcClient(nullptr)
|
|---|
| | | {}
|
|---|
| | |
|
|---|
| | | RtspFaceView::Client& RtspFaceViewClient::getClient()
|
|---|
| | | {
|
|---|
| | | if (client == nullptr) {
|
|---|
| | | try
|
|---|
| | | {
|
|---|
| | | client = new RtspFaceView::Client(getEzRpcClient()->getMain<RtspFaceView>());
|
|---|
| | | }
|
|---|
| | | catch (const kj::Exception& e)
|
|---|
| | | {
|
|---|
| | | delete client;
|
|---|
| | | client = nullptr;
|
|---|
| | | throw e;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | return *client;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | ::kj::WaitScope &RtspFaceViewClient::getWaitScope()
|
|---|
| | | {
|
|---|
| | | return rpcClient.getWaitScope();
|
|---|
| | | return getEzRpcClient()->getWaitScope();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | capnp::EzRpcClient * RtspFaceViewClient::getEzRpcClient()
|
|---|
| | | {
|
|---|
| | | if (rpcClient == nullptr) {
|
|---|
| | | try
|
|---|
| | | {
|
|---|
| | | //#todo ip modify
|
|---|
| | | rpcClient = new capnp::EzRpcClient("192.168.1.94", 8112);
|
|---|
| | | }
|
|---|
| | | catch (const kj::Exception& e)
|
|---|
| | | {
|
|---|
| | | delete rpcClient;
|
|---|
| | | rpcClient = nullptr;
|
|---|
| | | throw e;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | return rpcClient;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | ::kj::Promise<void> RtspFaceDetectImpl::fireFaceCountListener(FireFaceCountListenerContext context)
|
|---|
| | | {
|
|---|
| | | auto results = context.getResults();
|
|---|
| | | LOG_ERROR << "!!!!!!!!!!!!!!!!!!!!!WHO find face!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!" << LOG_ENDL;
|
|---|
| | | remoteFireFaceCountListener(context.getParams(), results);
|
|---|
| | | context.setResults(results);
|
|---|
| | | return kj::READY_NOW;
|
|---|
| | | }
|
|---|
