diff options
| author | 2021-06-25 19:31:42 +0000 | |
|---|---|---|
| committer | 2021-06-25 19:31:42 +0000 | |
| commit | 68aa25522c24fd0193617507bb77341165904a88 (patch) | |
| tree | 79a146efb9b07c5108423c3c555f9b9c6778e5cc /libs/binder/RpcSession.cpp | |
| parent | d6afe2eb4bd674c524ae96b4b615671ccdf7f39e (diff) | |
| parent | b81767912e9101f8522b4393beaf3360dff3ec07 (diff) | |
Merge "libbinder: RPC flake mode"
Diffstat (limited to 'libs/binder/RpcSession.cpp')
| -rw-r--r-- | libs/binder/RpcSession.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/libs/binder/RpcSession.cpp b/libs/binder/RpcSession.cpp index 4f55eef2d1..ee5e8bb5bb 100644 --- a/libs/binder/RpcSession.cpp +++ b/libs/binder/RpcSession.cpp @@ -198,6 +198,8 @@ status_t RpcSession::FdTrigger::interruptableReadFully(base::borrowed_fd fd, voi uint8_t* buffer = reinterpret_cast<uint8_t*>(data); uint8_t* end = buffer + size; + MAYBE_WAIT_IN_FLAKE_MODE; + status_t status; while ((status = triggerablePollRead(fd)) == OK) { ssize_t readSize = TEMP_FAILURE_RETRY(recv(fd.get(), buffer, end - buffer, MSG_NOSIGNAL)); |