//
|
// 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;
|
}
|
|
|
