You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@thrift.apache.org by jf...@apache.org on 2013/06/05 05:05:26 UTC
git commit: Thrift-1997:Add accept backlog configuration method to
TServerSocket Client: cpp Patch: Randy Abernethy
Updated Branches:
refs/heads/master 1b0bc0f42 -> 37e655c71
Thrift-1997:Add accept backlog configuration method to TServerSocket
Client: cpp
Patch: Randy Abernethy
TServerSocket hard codes the accept backlog to 1024. This patch adds a setAcceptBacklog() method which can be used to change the backlog size (must be called prior to listen()).
Project: http://git-wip-us.apache.org/repos/asf/thrift/repo
Commit: http://git-wip-us.apache.org/repos/asf/thrift/commit/37e655c7
Tree: http://git-wip-us.apache.org/repos/asf/thrift/tree/37e655c7
Diff: http://git-wip-us.apache.org/repos/asf/thrift/diff/37e655c7
Branch: refs/heads/master
Commit: 37e655c71bdce1b1bc20a06eeb00458f205ada8b
Parents: 1b0bc0f
Author: Jake Farrell <jf...@apache.org>
Authored: Tue Jun 4 23:04:16 2013 -0400
Committer: Jake Farrell <jf...@apache.org>
Committed: Tue Jun 4 23:04:16 2013 -0400
----------------------------------------------------------------------
lib/cpp/src/thrift/transport/TServerSocket.cpp | 10 +++++++---
lib/cpp/src/thrift/transport/TServerSocket.h | 3 +++
2 files changed, 10 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/thrift/blob/37e655c7/lib/cpp/src/thrift/transport/TServerSocket.cpp
----------------------------------------------------------------------
diff --git a/lib/cpp/src/thrift/transport/TServerSocket.cpp b/lib/cpp/src/thrift/transport/TServerSocket.cpp
index 20313ac..1000367 100644
--- a/lib/cpp/src/thrift/transport/TServerSocket.cpp
+++ b/lib/cpp/src/thrift/transport/TServerSocket.cpp
@@ -78,7 +78,7 @@ using boost::shared_ptr;
TServerSocket::TServerSocket(int port) :
port_(port),
serverSocket_(-1),
- acceptBacklog_(1024),
+ acceptBacklog_(DEFAULT_BACKLOG),
sendTimeout_(0),
recvTimeout_(0),
accTimeout_(-1),
@@ -92,7 +92,7 @@ TServerSocket::TServerSocket(int port) :
TServerSocket::TServerSocket(int port, int sendTimeout, int recvTimeout) :
port_(port),
serverSocket_(-1),
- acceptBacklog_(1024),
+ acceptBacklog_(DEFAULT_BACKLOG),
sendTimeout_(sendTimeout),
recvTimeout_(recvTimeout),
accTimeout_(-1),
@@ -107,7 +107,7 @@ TServerSocket::TServerSocket(string path) :
port_(0),
path_(path),
serverSocket_(-1),
- acceptBacklog_(1024),
+ acceptBacklog_(DEFAULT_BACKLOG),
sendTimeout_(0),
recvTimeout_(0),
accTimeout_(-1),
@@ -134,6 +134,10 @@ void TServerSocket::setAcceptTimeout(int accTimeout) {
accTimeout_ = accTimeout;
}
+void TServerSocket::setAcceptBacklog(int accBacklog) {
+ acceptBacklog_ = accBacklog;
+}
+
void TServerSocket::setRetryLimit(int retryLimit) {
retryLimit_ = retryLimit;
}
http://git-wip-us.apache.org/repos/asf/thrift/blob/37e655c7/lib/cpp/src/thrift/transport/TServerSocket.h
----------------------------------------------------------------------
diff --git a/lib/cpp/src/thrift/transport/TServerSocket.h b/lib/cpp/src/thrift/transport/TServerSocket.h
index 2ee7593..e562a19 100644
--- a/lib/cpp/src/thrift/transport/TServerSocket.h
+++ b/lib/cpp/src/thrift/transport/TServerSocket.h
@@ -37,6 +37,8 @@ class TSocket;
*/
class TServerSocket : public TServerTransport {
public:
+ const static int DEFAULT_BACKLOG = 1024;
+
TServerSocket(int port);
TServerSocket(int port, int sendTimeout, int recvTimeout);
TServerSocket(std::string path);
@@ -47,6 +49,7 @@ class TServerSocket : public TServerTransport {
void setRecvTimeout(int recvTimeout);
void setAcceptTimeout(int accTimeout);
+ void setAcceptBacklog(int accBacklog);
void setRetryLimit(int retryLimit);
void setRetryDelay(int retryDelay);