| /frameworks/native/libs/binder/ |
| D | RpcTransportUtils.h | 28 const android::RpcTransportFd& socket, FdTrigger* fdTrigger, iovec* iovs, int niovs, in interruptableReadOrWrite() argument
33 if (niovs < 0) { in interruptableReadOrWrite()
50 while (niovs > 0 && iovs[niovs - 1].iov_len == 0) { in interruptableReadOrWrite()
51 niovs--; in interruptableReadOrWrite()
53 if (niovs == 0) { in interruptableReadOrWrite()
60 ssize_t processSize = sendOrReceiveFun(iovs, niovs); in interruptableReadOrWrite()
73 while (processSize > 0 && niovs > 0) { in interruptableReadOrWrite()
85 niovs--; in interruptableReadOrWrite()
87 if (niovs == 0) { in interruptableReadOrWrite()
|
| D | RpcTransportRaw.cpp | 61 FdTrigger* fdTrigger, iovec* iovs, int niovs, in interruptableWriteFully() argument
65 auto send = [&](iovec* iovs, int niovs) -> ssize_t { in interruptableWriteFully() argument
66 ssize_t ret = binder::os::sendMessageOnSocket(mSocket, iovs, niovs, in interruptableWriteFully()
71 return interruptableReadOrWrite(mSocket, fdTrigger, iovs, niovs, send, "sendmsg", POLLOUT, in interruptableWriteFully()
76 FdTrigger* fdTrigger, iovec* iovs, int niovs, in interruptableReadFully() argument
79 auto recv = [&](iovec* iovs, int niovs) -> ssize_t { in interruptableReadFully() argument
80 return binder::os::receiveMessageFromSocket(mSocket, iovs, niovs, ancillaryFds); in interruptableReadFully()
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
81 auto writeFn = [&](iovec* iovs, size_t niovs) -> ssize_t { in interruptableWriteFully() argument
86 return TEMP_FAILURE_RETRY(tipc_send(mSocket.fd.get(), iovs, niovs, nullptr, 0)); in interruptableWriteFully()
89 status_t status = interruptableReadOrWrite(mSocket, fdTrigger, iovs, niovs, writeFn, in interruptableWriteFully()
95 FdTrigger* fdTrigger, iovec* iovs, int niovs, in interruptableReadFully() argument
98 auto readFn = [&](iovec* iovs, size_t niovs) -> ssize_t { in interruptableReadFully() argument
113 for (size_t i = 0; i < niovs && mReadBufferPos < mReadBufferSize; i++) { in interruptableReadFully()
124 status_t status = interruptableReadOrWrite(mSocket, fdTrigger, iovs, niovs, readFn, "read", in interruptableReadFully()
|
| D | OS_unix_base.cpp | 72 ssize_t sendMessageOnSocket(const RpcTransportFd& socket, iovec* iovs, int niovs, in sendMessageOnSocket() argument
92 .msg_iovlen = static_cast<decltype(msg.msg_iovlen)>(niovs), in sendMessageOnSocket()
111 .msg_iovlen = static_cast<decltype(msg.msg_iovlen)>(niovs), in sendMessageOnSocket()
116 ssize_t receiveMessageFromSocket(const RpcTransportFd& socket, iovec* iovs, int niovs, in receiveMessageFromSocket() argument
124 .msg_iovlen = static_cast<decltype(msg.msg_iovlen)>(niovs), in receiveMessageFromSocket()
159 .msg_iovlen = static_cast<decltype(msg.msg_iovlen)>(niovs), in receiveMessageFromSocket()
|
| D | OS.h | 40 sendMessageOnSocket(const RpcTransportFd& socket, iovec* iovs, int niovs,
44 receiveMessageFromSocket(const RpcTransportFd& socket, iovec* iovs, int niovs,
|
| D | RpcTransportTls.cpp | 293 FdTrigger* fdTrigger, iovec* iovs, int niovs,
297 FdTrigger* fdTrigger, iovec* iovs, int niovs,
328 FdTrigger* fdTrigger, iovec* iovs, int niovs, in interruptableWriteFully() argument
335 if (niovs < 0) return BAD_VALUE; in interruptableWriteFully()
342 for (int i = 0; i < niovs; i++) { in interruptableWriteFully()
374 FdTrigger* fdTrigger, iovec* iovs, int niovs, in interruptableReadFully() argument
381 if (niovs < 0) return BAD_VALUE; in interruptableReadFully()
388 for (int i = 0; i < niovs; i++) { in interruptableReadFully()
|
| D | RpcState.cpp | 361 const sp<RpcSession>& session, const char* what, iovec* iovs, int niovs, in rpcSend() argument
364 for (int i = 0; i < niovs; i++) { in rpcSend()
366 what, i + 1, niovs, connection->rpcTransport.get(), in rpcSend()
372 iovs, niovs, altPoll, in rpcSend()
375 LOG_RPC_DETAIL("Failed to write %s (%d iovs) on RpcTransport %p, error: %s", what, niovs, in rpcSend()
385 const sp<RpcSession>& session, const char* what, iovec* iovs, int niovs, in rpcRec() argument
389 iovs, niovs, std::nullopt, in rpcRec()
392 LOG_RPC_DETAIL("Failed to read %s (%d iovs) on RpcTransport %p, error: %s", what, niovs, in rpcRec()
398 for (int i = 0; i < niovs; i++) { in rpcRec()
400 what, i + 1, niovs, connection->rpcTransport.get(), in rpcRec()
|
| D | RpcState.h | 193 const char* what, iovec* iovs, int niovs,
199 int niovs,
|
| /frameworks/native/libs/binder/trusty/ |
| D | RpcTransportTipcTrusty.cpp | 51 FdTrigger* /*fdTrigger*/, iovec* iovs, int niovs, in interruptableWriteFully() argument
54 if (niovs < 0) { in interruptableWriteFully()
59 for (int i = 0; i < niovs; i++) { in interruptableWriteFully()
65 .num_iov = static_cast<uint32_t>(niovs), in interruptableWriteFully()
120 FdTrigger* /*fdTrigger*/, iovec* iovs, int niovs, in interruptableReadFully() argument
123 if (niovs < 0) { in interruptableReadFully()
134 while (niovs > 0 && iovs[niovs - 1].iov_len == 0) { in interruptableReadFully()
135 niovs--; in interruptableReadFully()
137 if (niovs == 0) { in interruptableReadFully()
154 .num_iov = static_cast<uint32_t>(niovs), in interruptableReadFully()
[all …]
|
| /frameworks/native/libs/binder/include/binder/ |
| D | RpcTransport.h | 89 FdTrigger* fdTrigger, iovec* iovs, int niovs,
94 FdTrigger* fdTrigger, iovec* iovs, int niovs,
|