| /frameworks/native/libs/binder/ |
| D | RpcTransportTls.cpp | 192 status_t pollForSslError(const android::RpcTransportFd& fd, int sslError, FdTrigger* fdTrigger, in pollForSslError() argument
197 return handlePoll(POLLIN | additionalEvent, fd, fdTrigger, fnString, altPoll); in pollForSslError()
199 return handlePoll(POLLOUT | additionalEvent, fd, fdTrigger, fnString, altPoll); in pollForSslError()
208 status_t handlePoll(int event, const android::RpcTransportFd& fd, FdTrigger* fdTrigger, in handlePoll() argument
214 if (fdTrigger->isTriggered()) ret = DEAD_OBJECT; in handlePoll()
216 ret = fdTrigger->triggerablePoll(fd, event); in handlePoll()
293 FdTrigger* fdTrigger, iovec* iovs, int niovs,
297 FdTrigger* fdTrigger, iovec* iovs, int niovs,
328 FdTrigger* fdTrigger, iovec* iovs, int niovs, in interruptableWriteFully() argument
339 if (fdTrigger->isTriggered()) return DEAD_OBJECT; in interruptableWriteFully()
[all …]
|
| D | RpcTransportUtils.h | 28 const android::RpcTransportFd& socket, FdTrigger* fdTrigger, iovec* iovs, int niovs, in interruptableReadOrWrite() argument
39 if (fdTrigger->isTriggered()) { in interruptableReadOrWrite()
98 if (fdTrigger->isTriggered()) { in interruptableReadOrWrite()
102 if (status_t status = fdTrigger->triggerablePoll(socket, event); status != OK) in interruptableReadOrWrite()
|
| D | RpcTransportRaw.cpp | 61 FdTrigger* fdTrigger, iovec* iovs, int niovs, in interruptableWriteFully() argument
71 return interruptableReadOrWrite(mSocket, fdTrigger, iovs, niovs, send, "sendmsg", POLLOUT, in interruptableWriteFully()
76 FdTrigger* fdTrigger, iovec* iovs, int niovs, in interruptableReadFully() argument
82 return interruptableReadOrWrite(mSocket, fdTrigger, iovs, niovs, recv, "recvmsg", POLLIN, in interruptableReadFully()
|
| D | RpcTransportTipcAndroid.cpp | 78 FdTrigger* fdTrigger, iovec* iovs, int niovs, in interruptableWriteFully() argument
89 status_t status = interruptableReadOrWrite(mSocket, fdTrigger, iovs, niovs, writeFn, in interruptableWriteFully()
95 FdTrigger* fdTrigger, iovec* iovs, int niovs, in interruptableReadFully() argument
124 status_t status = interruptableReadOrWrite(mSocket, fdTrigger, iovs, niovs, readFn, "read", in interruptableReadFully()
|
| /frameworks/native/libs/binder/include/binder/ |
| D | RpcTransport.h | 89 FdTrigger* fdTrigger, iovec* iovs, int niovs,
94 FdTrigger* fdTrigger, iovec* iovs, int niovs,
136 android::RpcTransportFd fd, FdTrigger *fdTrigger) const = 0;
|
| /frameworks/native/libs/binder/tests/ |
| D | binderRpcTest.cpp | 1634 std::function<AssertionResult(RpcTransport*, FdTrigger* fdTrigger)> fn) { in setPostConnect()
1650 std::function<AssertionResult(RpcTransport*, FdTrigger* fdTrigger)> mPostConnect =
1661 FdTrigger* fdTrigger) { in defaultPostConnect() argument
1664 auto status = serverTransport->interruptableWriteFully(fdTrigger, &messageIov, 1, in defaultPostConnect()
1912 auto serverPostConnect = [&](RpcTransport* serverTransport, FdTrigger* fdTrigger) { in TEST_P() argument
1915 auto status = serverTransport->interruptableWriteFully(fdTrigger, &messageIov, 1, in TEST_P()
1927 status = serverTransport->interruptableWriteFully(fdTrigger, &msg2Iov, 1, std::nullopt, in TEST_P()
1975 auto serverPostConnect = [&](RpcTransport* serverTransport, FdTrigger* fdTrigger) { in TEST_P() argument
1978 auto status = serverTransport->interruptableWriteFully(fdTrigger, &messageIov, 1, in TEST_P()
|