diff --git a/src/common/io.cc b/src/common/io.cc index b75fdcf37..e94a11127 100644 --- a/src/common/io.cc +++ b/src/common/io.cc @@ -49,7 +49,7 @@ int bind_inet_sock(const int port, bool shall_listen) { close(socket_fd); return -1; } - if (shall_listen && listen(socket_fd, 5) == -1) { + if (shall_listen && listen(socket_fd, 128) == -1) { LOG_ERROR("Could not listen to socket %d", port); close(socket_fd); return -1; @@ -90,7 +90,7 @@ int bind_ipc_sock(const char *socket_pathname, bool shall_listen) { close(socket_fd); return -1; } - if (shall_listen && listen(socket_fd, 5) == -1) { + if (shall_listen && listen(socket_fd, 128) == -1) { LOG_ERROR("Could not listen to socket %s", socket_pathname); close(socket_fd); return -1; diff --git a/src/plasma/plasma_io.cc b/src/plasma/plasma_io.cc index 7bad98518..323e703be 100644 --- a/src/plasma/plasma_io.cc +++ b/src/plasma/plasma_io.cc @@ -122,7 +122,7 @@ int bind_ipc_sock(const std::string &pathname, bool shall_listen) { close(socket_fd); return -1; } - if (shall_listen && listen(socket_fd, 5) == -1) { + if (shall_listen && listen(socket_fd, 128) == -1) { ARROW_LOG(ERROR) << "Could not listen to socket " << pathname; close(socket_fd); return -1; diff --git a/src/plasma/plasma_manager.cc b/src/plasma/plasma_manager.cc index 7412c589c..e9308a295 100644 --- a/src/plasma/plasma_manager.cc +++ b/src/plasma/plasma_manager.cc @@ -1619,8 +1619,8 @@ void start_server(const char *store_socket_name, redis_primary_addr, redis_primary_port); CHECK(g_manager_state); - CHECK(listen(remote_sock, 5) != -1); - CHECK(listen(local_sock, 5) != -1); + CHECK(listen(remote_sock, 128) != -1); + CHECK(listen(local_sock, 128) != -1); LOG_DEBUG("Started server connected to store %s, listening on port %d", store_socket_name, port);