Searched refs:rpc_thread (Results 1 – 10 of 10) sorted by relevance
54 rpc_thread: ipccore::EventLoopThread, field77 let rpc_thread = ipccore::EventLoopThread::new( in init_threads() localVariable138 rpc_thread, in init_threads()200 let rpc_thread = wrapper.rpc_thread.handle(); in audioipc2_server_new_client() localVariable209 if let Err(e) = rpc_thread.bind_server(server, server_pipe) { in audioipc2_server_new_client()
44 rpc_thread: ipccore::EventLoopThread, field55 self.rpc_thread.handle() in rpc_handle()179 let rpc_thread = ipccore::EventLoopThread::new( in init() localVariable186 let rpc = rpc_thread in init()212 rpc_thread, in init()382 .field("core", &self.rpc_thread) in fmt()
310 std::thread rpc_thread{[&]() { in BOOST_AUTO_TEST_CASE() local341 rpc_thread.join(); in BOOST_AUTO_TEST_CASE()
289 std::thread rpc_thread{[&]() { in BOOST_AUTO_TEST_CASE() local320 rpc_thread.join(); in BOOST_AUTO_TEST_CASE()
308 std::thread rpc_thread{[&]() { in BOOST_AUTO_TEST_CASE() local339 rpc_thread.join(); in BOOST_AUTO_TEST_CASE()
289 std::thread rpc_thread{[&]() {320 rpc_thread.join();
161 pthread_t rpc_thread; member1892 pthread_cancel(this->rpc_thread); in vdr_plugin_dispose()1899 pthread_join(this->rpc_thread, 0); in vdr_plugin_dispose()2260 if ((err = pthread_create(&this->rpc_thread, NULL, in vdr_plugin_open()