| 57 | } |
| 58 | |
| 59 | void * /* static */ |
| 60 | RPCServer::run_thread(void *a) |
| 61 | { |
| 62 | void *ret = a; |
| 63 | if (jsonrpcServer->_init) { |
| 64 | jsonrpcServer->_rpcThread = jsonrpcServer->_init(); |
| 65 | } |
| 66 | jsonrpcServer->_socketImpl->run(); |
| 67 | Dbg(dbg_ctl, "Socket stopped"); |
| 68 | return ret; |
| 69 | } |
| 70 | |
| 71 | void |
| 72 | RPCServer::start_thread(std::function<TSThread()> const &cb_init, std::function<void(TSThread)> const &cb_destroy) |