capnp client fix bug

pans

2017-08-18 5cf652629fb40796cd2e0ab17c3617ed52365473

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

@@ -5,37 +5,20 @@
#include "RemoteFuncClient.h"

#include "RemoteFunc.h"

#include "RtspNativeCodecJNIClient.h"

#include "AppConfig.h"



#include <string>

#include <iostream>

using namespace std;



//#todo 修改服务线程构造参数传入方式

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

AppConfig config("data/config.cfg");

RemoteServer<RtspFaceDetectImpl> remoteServer(config.getStringValue("local_ip"), config.getIntValue("local_port"));

//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()

@@ -76,9 +59,8 @@
    if (rpcClient == nullptr) {

        try

        {

            //#todo ip modify

            rpcClient = new capnp::EzRpcClient("192.168.1.94", 8112);

            //rpcClient = new capnp::EzRpcClient("192.168.1.71", 8112);

            //rpcClient = new capnp::EzRpcClient("192.168.1.116", 8112);

            rpcClient = new capnp::EzRpcClient(config.getStringValue("server_ip"), config.getIntValue("server_port"));

        }

        catch (const kj::Exception& e)

        {

@@ -93,8 +75,8 @@
::kj::Promise<void> RtspFaceDetectImpl::fireFaceCountListener(FireFaceCountListenerContext context)

{

   auto results = context.getResults();

    LOG_ERROR << "!!!!!!!!!!!!!!!!!!!!!WHO  find face!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!" << LOG_ENDL;

    LOG_ERROR << "!!!!!!!!!!!!!!!!!!!!!WHO  find face!!!!!!!" << LOG_ENDL;

   remoteFireFaceCountListener(context.getParams(), results);

    context.setResults(results);

    //context.setResults(results);

    return kj::READY_NOW;

}