From a0092014ee12abf06edb1788b189cc7c57336063 Mon Sep 17 00:00:00 2001 From: chenke <chenke@454eff88-639b-444f-9e54-f578c98de674> Date: 星期三, 09 八月 2017 13:42:00 +0800 Subject: [PATCH] Reverse merged revision(s) 988-987 from VisitFace/RtspNativeCodec: JsonCpp和CapnpProtocol功能初步实现 ........ --- VisitFace/RtspNativeCodec/app/src/main/cpp/RemoteFunc.h | 96 +++++++++++++++++------------------------------ 1 files changed, 35 insertions(+), 61 deletions(-) diff --git a/VisitFace/RtspNativeCodec/app/src/main/cpp/RemoteFunc.h b/VisitFace/RtspNativeCodec/app/src/main/cpp/RemoteFunc.h index 422237d..83c55c0 100644 --- a/VisitFace/RtspNativeCodec/app/src/main/cpp/RemoteFunc.h +++ b/VisitFace/RtspNativeCodec/app/src/main/cpp/RemoteFunc.h @@ -1,61 +1,35 @@ -// -// Created by pansen on 2017/8/4. -// - -#ifndef RTSPNATIVECODEC_REMOTEFUNC_H -#define RTSPNATIVECODEC_REMOTEFUNC_H - -#include <iostream> -#include <capnp/ez-rpc.h> -#include <logger.h> - -template <class T> class RemoteServer{ -public: - RemoteServer(std::string host,int port):host(host),port(port){}; - ~RemoteServer(){}; - - bool start() { - LOG_INFO << "server_thd::start" << LOG_ENDL; - - if(running == true){ - LOG_INFO << "The server_thd is already running" << LOG_ENDL; - return false; - } - running = true; - pthread_mutex_init(&mutexSerevr, NULL); // 鍒濆鍖栦簰鏂ュ璞�,鍔ㄦ�佸姞閿侊紝鐢ㄤ簬server - - int retServer = pthread_create(&server_thid, NULL, RemoteServer::rServer_thd, this); - - if(retServer != 0) - { - LOGP(ERROR, "server_thd_create: %s/n", strerror(retServer)); - running = false; - return false; - } - return true; - } - void stop(){ -// LOG_INFO << "server_thd::stop" << LOG_ENDL; -// if (!running) -// return; -// running = false; -// pthread_mutex_destroy(&mutexSerevr); - //#todo - } - - bool running; -private: - std::string host; - int port; - - static void *rServer_thd(void *arg) { - RemoteServer& rs = *(RemoteServer*)arg; - capnp::EzRpcServer trpcServer(kj::heap<T>(),rs.host, rs.port); - auto& serverLoop = trpcServer.getWaitScope(); - kj::NEVER_DONE.wait(serverLoop); - } - pthread_t server_thid; - pthread_mutex_t mutexSerevr; -}; -#endif //RTSPNATIVECODEC_REMOTEFUNC_H - +// +// Created by pansen on 2017/8/4. +// + +#ifndef RTSPNATIVECODEC_REMOTEFUNC_H +#define RTSPNATIVECODEC_REMOTEFUNC_H + +#include <iostream> +#include <capnp/ez-rpc.h> +#include "RemoteMethod.proto.h" + +//::capnp::Capability::Server +template <class T> class RemoteServer{ +public: +// RemoteServer(std::string host, int port, capnp::EzRpcServer rpcServer) : rpcServer(rpcServer) { +// this->rpcServer(kj::heap<T>(),host, port); +// //.rpcServer(kj::heap<T>(),host, port); +// }; + RemoteServer(std::string host,int port):host(host),port(port){}; + ~RemoteServer(){}; + + bool start(); + void stop(); + bool running; +private: + std::string host; + int port; + + static void *rServer_thd(void *arg); + + pthread_t server_thd; + pthread_mutex_t mutexSerevr; +}; +#endif //RTSPNATIVECODEC_REMOTEFUNC_H + -- Gitblit v1.8.0