diff options
| author | 2022-11-17 08:43:22 +0000 | |
|---|---|---|
| committer | 2022-11-17 08:43:22 +0000 | |
| commit | 5144d4162ec1f42555998feb7682eea2eedd0011 (patch) | |
| tree | 4b37f72174fa38ae51622c4956d5aee7797604bb /libs | |
| parent | 6b972b11c22577db117fac5169b40cca0fa6c046 (diff) | |
| parent | 8353dd2639c9dc0e143f720427154d688b173cab (diff) | |
Merge "[rpc_binder] Use unique_fd directly for socket in raw socket setup" am: 8353dd2639
Original change: https://android-review.googlesource.com/c/platform/frameworks/native/+/2303772
Change-Id: Ic7f0b16b84cf990f6938228efd77ab7fb7177a25
Signed-off-by: Automerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
Diffstat (limited to 'libs')
| -rw-r--r-- | libs/binder/RpcServer.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/libs/binder/RpcServer.cpp b/libs/binder/RpcServer.cpp index e0b7d16d9f..0820cd1d5c 100644 --- a/libs/binder/RpcServer.cpp +++ b/libs/binder/RpcServer.cpp @@ -549,18 +549,17 @@ status_t RpcServer::setupSocketServer(const RpcSocketAddress& addr) { status_t RpcServer::setupRawSocketServer(unique_fd socket_fd) { LOG_ALWAYS_FATAL_IF(!socket_fd.ok(), "Socket must be setup to listen."); - RpcTransportFd transportFd(std::move(socket_fd)); // Right now, we create all threads at once, making accept4 slow. To avoid hanging the client, // the backlog is increased to a large number. // TODO(b/189955605): Once we create threads dynamically & lazily, the backlog can be reduced // to 1. - if (0 != TEMP_FAILURE_RETRY(listen(transportFd.fd.get(), 50 /*backlog*/))) { + if (0 != TEMP_FAILURE_RETRY(listen(socket_fd.get(), 50 /*backlog*/))) { int savedErrno = errno; ALOGE("Could not listen initialized Unix socket: %s", strerror(savedErrno)); return -savedErrno; } - if (status_t status = setupExternalServer(std::move(transportFd.fd)); status != OK) { + if (status_t status = setupExternalServer(std::move(socket_fd)); status != OK) { ALOGE("Another thread has set up server while calling setupSocketServer. Race?"); return status; } |