From: Haomai Wang <haomai@xsky.com>
Date: Sat, 17 Jun 2017 03:52:40 +0000 (+0800)
Subject: msg: make listen backlog become a option, increase from 128 to 512
X-Git-Tag: v12.1.1~158^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=226cd6f6fdc7b72a4272d2a5f6db8a792886e5d3;p=ceph.git

msg: make listen backlog become a option, increase from 128 to 512

Fixes: http://tracker.ceph.com/issues/20330
Signed-off-by: Haomai Wang <haomai@xsky.com>
---

diff --git a/src/common/config_opts.h b/src/common/config_opts.h
index f8af42a6756..dbecf1bb6b1 100644
--- a/src/common/config_opts.h
+++ b/src/common/config_opts.h
@@ -212,6 +212,7 @@ OPTION(ms_bind_retry_count, OPT_INT, 6) // If binding fails, how many times do w
 OPTION(ms_bind_retry_delay, OPT_INT, 6) // Delay between attemps to bind
 #endif
 OPTION(ms_bind_before_connect, OPT_BOOL, false)
+OPTION(ms_tcp_listen_backlog, OPT_INT, 512)
 OPTION(ms_rwthread_stack_bytes, OPT_U64, 1024 << 10)
 OPTION(ms_tcp_read_timeout, OPT_U64, 900)
 OPTION(ms_pq_max_tokens_per_priority, OPT_U64, 16777216)
diff --git a/src/msg/async/PosixStack.cc b/src/msg/async/PosixStack.cc
index cf52db9a775..d0e6b5af083 100644
--- a/src/msg/async/PosixStack.cc
+++ b/src/msg/async/PosixStack.cc
@@ -322,7 +322,7 @@ int PosixWorker::listen(entity_addr_t &sa, const SocketOptions &opt,
     return r;
   }
 
-  r = ::listen(listen_sd, 128);
+  r = ::listen(listen_sd, cct->_conf->ms_tcp_listen_backlog);
   if (r < 0) {
     r = -errno;
     lderr(cct) << __func__ << " unable to listen on " << sa << ": " << cpp_strerror(r) << dendl;
diff --git a/src/msg/async/rdma/RDMAServerSocketImpl.cc b/src/msg/async/rdma/RDMAServerSocketImpl.cc
index 8f5fd81d3dc..8d9858c0982 100644
--- a/src/msg/async/rdma/RDMAServerSocketImpl.cc
+++ b/src/msg/async/rdma/RDMAServerSocketImpl.cc
@@ -56,7 +56,7 @@ int RDMAServerSocketImpl::listen(entity_addr_t &sa, const SocketOptions &opt)
     goto err;
   }
 
-  rc = ::listen(server_setup_socket, 128);
+  rc = ::listen(server_setup_socket, cct->_conf->ms_tcp_listen_backlog);
   if (rc < 0) {
     rc = -errno;
     lderr(cct) << __func__ << " unable to listen on " << sa << ": " << cpp_strerror(errno) << dendl;
diff --git a/src/msg/simple/Accepter.cc b/src/msg/simple/Accepter.cc
index 16e6dfbfa31..5779cc7abec 100644
--- a/src/msg/simple/Accepter.cc
+++ b/src/msg/simple/Accepter.cc
@@ -211,7 +211,7 @@ int Accepter::bind(const entity_addr_t &bind_addr, const set<int>& avoid_ports)
   ldout(msgr->cct,10) <<  __func__ << " bound to " << listen_addr << dendl;
 
   // listen!
-  rc = ::listen(listen_sd, 128);
+  rc = ::listen(listen_sd, msgr->cct->_conf->ms_tcp_listen_backlog);
   if (rc < 0) {
     rc = -errno;
     lderr(msgr->cct) <<  __func__ << " unable to listen on " << listen_addr