capnproto fix bug

pans

2017-08-15 e26a5550539fa0cad91313bf9670df605199a324

 VisitFace/RtspNativeCodec/app/src/main/cpp/RemoteFuncClient.cpp

@@ -5,22 +5,95 @@
#include "RemoteFuncClient.h"

#include "RemoteFunc.h"

#include "RtspNativeCodecJNIClient.h"

RemoteServer<RtspFaceDetectImpl> remoteServer("127.0.0.1",8111);

void startRemoteServer(){

    remoteServer.start();



#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 rtspFaceViewClient;

RtspFaceViewClient& RtspFaceViewClient(){

    return rtspFaceViewClient;



RtspFaceViewClient * getRtspFaceViewClient()

{

    if(rtspFaceViewClient == nullptr)

        rtspFaceViewClient = new RtspFaceViewClient;

   return rtspFaceViewClient;

}

RtspFaceViewClient::RtspFaceViewClient():rpcClient("127.0.0.1",8112),

                                         RtspFaceView::Client(rpcClient.getMain<RtspFaceView>())



RtspFaceViewClient::RtspFaceViewClient() :

        rpcClient(nullptr)

{}

::kj::WaitScope& RtspFaceViewClient::getWaitScope(){

    return rpcClient.getWaitScope();



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::Promise<void> RtspFaceDetectImpl::fireFaceCountListener(FireFaceCountListenerContext context) {

    auto results = context.getResults();

    remoteFireFaceCountListener(context.getParams(), results);

    context.setResults(results);

}


::kj::WaitScope &RtspFaceViewClient::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;

}