| | |
| | | |
| | | 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); |
| | | try { |
| | | RemoteServer &rs = *(RemoteServer *) arg; |
| | | capnp::EzRpcServer trpcServer(kj::heap<T>(), rs.host, rs.port); |
| | | auto &serverLoop = trpcServer.getWaitScope(); |
| | | kj::NEVER_DONE.wait(serverLoop); |
| | | } |
| | | catch (kj::Exception e){ |
| | | LOG_ERROR<<e.getLine()<<LOG_ENDL; |
| | | } |
| | | |
| | | |
| | | } |
| | | |
| | | pthread_t server_thid; |