From 4d22d8d9332535a9c2f65e0e501a3eefbbd0ae30 Mon Sep 17 00:00:00 2001 From: chenke <chenke@454eff88-639b-444f-9e54-f578c98de674> Date: 星期三, 09 八月 2017 12:45:29 +0800 Subject: [PATCH] JsonCpp和CapnpProtocol功能初步实现 --- VisitFace/RtspNativeCodec/app/src/main/cpp/RemoteFunc.cpp | 53 ++++------------------------------------------------- 1 files changed, 4 insertions(+), 49 deletions(-) diff --git a/VisitFace/RtspNativeCodec/app/src/main/cpp/RemoteFunc.cpp b/VisitFace/RtspNativeCodec/app/src/main/cpp/RemoteFunc.cpp index b8ee965..2034887 100644 --- a/VisitFace/RtspNativeCodec/app/src/main/cpp/RemoteFunc.cpp +++ b/VisitFace/RtspNativeCodec/app/src/main/cpp/RemoteFunc.cpp @@ -1,49 +1,4 @@ -// -// Created by pansen on 2017/8/4. -// - -#include "RemoteFunc.h" -#include <logger.h> - - -bool RemoteServer::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_thd, NULL, RemoteServer::rServer_thd, this); - - if(retServer != 0) - { - LOGP(ERROR, "server_thd_create: %s/n", strerror(retServer)); - running = false; - return false; - } - return true; -} - -void RemoteServer::stop() { -// LOG_INFO << "server_thd::stop" << LOG_ENDL; -// if (!running) -// return; -// running = false; -// pthread_mutex_destroy(&mutexSerevr); - //#todo -} - -template <class T> -void *RemoteServer::rServer_thd(void *arg) { - LOG_INFO << "RemoteServer::rServer_thd start" << LOG_ENDL; - RemoteServer& rs = *(RemoteServer*)arg; - capnp::EzRpcServer trpcServer(kj::heap<T>(),rs.host, rs.port); - auto& serverLoop = trpcServer.getWaitScope(); - kj::NEVER_DONE.wait(serverLoop); - LOG_INFO << "RemoteServer::rServer_thd stop" << LOG_ENDL; -} - - +// +// Created by pansen on 2017/8/4. +// +#include "RemoteFunc.h" -- Gitblit v1.8.0