Searched refs:RpcMaybeThread (Results 1 – 8 of 8) sorted by relevance
70 class LIBBINDER_EXPORTED RpcMaybeThread {72 RpcMaybeThread() = default;75 RpcMaybeThread(Function&& f, Args&&... args) { in RpcMaybeThread() function119 static inline RpcMaybeThread::id get_id() { in get_id()120 return RpcMaybeThread::id(); in get_id()124 static inline void rpcJoinIfSingleThreaded(RpcMaybeThread& t) { in rpcJoinIfSingleThreaded()132 using RpcMaybeThread = std::thread;135 static inline void rpcJoinIfSingleThreaded(RpcMaybeThread&) {}
279 std::unique_ptr<RpcMaybeThread> mJoinThread;281 std::map<RpcMaybeThread::id, RpcMaybeThread> mConnectingThreads;
276 void preJoinThreadOwnership(RpcMaybeThread thread);397 std::map<RpcMaybeThread::id, RpcMaybeThread> mThreads;
197 std::make_unique<RpcMaybeThread>(&joinRpcServer, sp<RpcServer>::fromExisting(this)); in start()281 RpcMaybeThread thread = in join()282 RpcMaybeThread(&RpcServer::establishConnection, in join()449 RpcMaybeThread thisThread; in establishConnection()
334 void RpcSession::preJoinThreadOwnership(RpcMaybeThread thread) { in preJoinThreadOwnership()727 RpcMaybeThread thread; in addIncomingConnection()730 thread = RpcMaybeThread([&]() { in addIncomingConnection()
106 rpcServer->mConnectingThreads[rpc_this_thread::get_id()] = RpcMaybeThread(); in handleConnectInternal()
234 RpcMaybeThread([writeFd = std::move(writeFd), contents = std::move(contents)]() { in mockFileDescriptor()415 RpcMaybeThread([=, this]() { in doCallback()
44 RpcMaybeThread([=] { in scheduleShutdown()