Home
last modified time | relevance | path

Searched refs:mShutdownTrigger (Results 1 – 6 of 6) sorted by relevance

/frameworks/native/libs/binder/
DRpcServer.cpp54 LOG_ALWAYS_FATAL_IF(mShutdownTrigger != nullptr, "Must call shutdown() before destructor"); in ~RpcServer()
166 LOG_ALWAYS_FATAL_IF(mShutdownTrigger != nullptr, "Already joined"); in setConnectionFilter()
246 LOG_ALWAYS_FATAL_IF(mShutdownTrigger != nullptr, "Already joined"); in join()
248 mShutdownTrigger = FdTrigger::make(); in join()
249 LOG_ALWAYS_FATAL_IF(mShutdownTrigger == nullptr, "Cannot create join signaler"); in join()
253 while ((status = mShutdownTrigger->triggerablePoll(mServer, POLLIN)) == OK) { in join()
299 mShutdownTrigger = nullptr; in join()
306 if (mShutdownTrigger == nullptr) { in shutdown()
312 mShutdownTrigger->trigger(); in shutdown()
318 session->mShutdownTrigger->trigger(); in shutdown()
[all …]
DRpcSession.cpp149 mCtx->newTransport(RpcTransportFd(std::move(bootstrapFd)), mShutdownTrigger.get()); in setupUnixDomainSocketBootstrapClient()
164 status_t status = mBootstrapTransport->interruptableWriteFully(mShutdownTrigger.get(), &iov, in setupUnixDomainSocketBootstrapClient()
218 auto server = mCtx->newTransport(std::move(transportFd), mShutdownTrigger.get()); in addNullDebuggingClient()
244 LOG_ALWAYS_FATAL_IF(mShutdownTrigger == nullptr, "Shutdown trigger not installed"); in shutdownAndWait()
246 mShutdownTrigger->trigger(); in shutdownAndWait()
507 mShutdownTrigger = nullptr; in setupClient()
623 status_t pollStatus = mShutdownTrigger->triggerablePoll(transportFd, POLLOUT); in setupOneSocketConnection()
666 LOG_ALWAYS_FATAL_IF(mShutdownTrigger == nullptr); in initAndAddConnection()
667 auto server = mCtx->newTransport(std::move(fd), mShutdownTrigger.get()); in initAndAddConnection()
692 auto sendHeaderStatus = server->interruptableWriteFully(mShutdownTrigger.get(), &headerIov, 1, in initAndAddConnection()
[all …]
DRpcState.cpp371 connection->rpcTransport->interruptableWriteFully(session->mShutdownTrigger.get(), in rpcSend()
388 connection->rpcTransport->interruptableReadFully(session->mShutdownTrigger.get(), in rpcRec()
/frameworks/native/libs/binder/include/binder/
DRpcServer.h289 std::unique_ptr<FdTrigger> mShutdownTrigger; variable
DRpcSession.h373 std::unique_ptr<FdTrigger> mShutdownTrigger; variable
/frameworks/native/libs/binder/trusty/
DRpcServerTrusty.cpp105 rpcServer->mShutdownTrigger = FdTrigger::make(); in handleConnectInternal()