Searched refs:transportFd (Results 1 – 6 of 6) sorted by relevance
| /frameworks/native/libs/binder/ |
| D | FdTrigger.cpp | 61 status_t FdTrigger::triggerablePoll(const android::RpcTransportFd& transportFd, int16_t event) { in triggerablePoll() argument
69 transportFd.fd.get()); in triggerablePoll()
71 {.fd = transportFd.fd.get(), .events = static_cast<int16_t>(event), .revents = 0}, in triggerablePoll()
77 LOG_ALWAYS_FATAL_IF(transportFd.isInPollingState() == true, in triggerablePoll()
80 transportFd.setPollingState(true); in triggerablePoll()
81 auto pollingStateGuard = make_scope_guard([&]() { transportFd.setPollingState(false); }); in triggerablePoll()
87 LOG_ALWAYS_FATAL_IF(ret == 0, "poll(%d) returns 0 with infinite timeout", transportFd.fd.get()); in triggerablePoll()
|
| D | RpcSession.cpp | 198 RpcTransportFd transportFd(std::move(fd)); in setupPreconnectedClient() local
199 status_t status = initAndAddConnection(std::move(transportFd), sessionId, incoming); in setupPreconnectedClient()
217 RpcTransportFd transportFd(std::move(serverFd)); in addNullDebuggingClient() local
218 auto server = mCtx->newTransport(std::move(transportFd), mShutdownTrigger.get()); in addNullDebuggingClient()
616 RpcTransportFd transportFd(std::move(serverFd)); in setupOneSocketConnection() local
618 if (0 != TEMP_FAILURE_RETRY(connect(transportFd.fd.get(), addr.addr(), addr.addrSize()))) { in setupOneSocketConnection()
623 status_t pollStatus = mShutdownTrigger->triggerablePoll(transportFd, POLLOUT); in setupOneSocketConnection()
631 int ret = getsockopt(transportFd.fd.get(), SOL_SOCKET, SO_ERROR, &connErrno, in setupOneSocketConnection()
655 transportFd.fd.get()); in setupOneSocketConnection()
657 return initAndAddConnection(std::move(transportFd), sessionId, incoming); in setupOneSocketConnection()
|
| D | FdTrigger.h | 57 [[nodiscard]] status_t triggerablePoll(const android::RpcTransportFd& transportFd,
|
| /frameworks/native/libs/binder/include/binder/ |
| D | RpcTransport.h | 188 RpcTransportFd(RpcTransportFd &&transportFd) noexcept in RpcTransportFd()
189 : isPolling(transportFd.isPolling), fd(std::move(transportFd.fd)) {} in RpcTransportFd()
191 RpcTransportFd &operator=(RpcTransportFd &&transportFd) noexcept {
192 fd = std::move(transportFd.fd);
193 isPolling = transportFd.isPolling;
|
| /frameworks/native/libs/binder/trusty/ |
| D | RpcServerTrusty.cpp | 137 android::RpcTransportFd transportFd(std::move(clientFd)); in handleConnectInternal() local
142 RpcServer::establishConnection(sp<RpcServer>::fromExisting(rpcServer), std::move(transportFd), in handleConnectInternal()
|
| /frameworks/native/libs/binder/tests/ |
| D | binderRpcTest.cpp | 224 static unique_fd connectToUnixBootstrap(const RpcTransportFd& transportFd) { in connectToUnixBootstrap() argument
235 if (binder::os::sendMessageOnSocket(transportFd, &iov, 1, &fds) < 0) { in connectToUnixBootstrap()
1622 RpcTransportFd transportFd(std::move(acceptedFd)); in handleOne() local
1623 auto serverTransport = mCtx->newTransport(std::move(transportFd), mFdTrigger.get()); in handleOne()
|