From 45d56965c29850ae8d86b7d822ee8f3169ab57f1 Mon Sep 17 00:00:00 2001
From: David Reiss <dreiss@apache.org>
Date: Sat, 14 Mar 2009 23:35:16 +0000
Subject: [PATCH] THRIFT-351. cpp: Allow a custom ThreadFactory in
 TThreadedServer

git-svn-id: https://svn.apache.org/repos/asf/incubator/thrift/trunk@754551 13f79535-47bb-0310-9956-ffa450edef68
---
 lib/cpp/src/server/TThreadedServer.cpp | 10 ++++++++++
 lib/cpp/src/server/TThreadedServer.h   |  6 ++++++
 2 files changed, 16 insertions(+)

diff --git a/lib/cpp/src/server/TThreadedServer.cpp b/lib/cpp/src/server/TThreadedServer.cpp
index 4840b7f2..3620d973 100644
--- a/lib/cpp/src/server/TThreadedServer.cpp
+++ b/lib/cpp/src/server/TThreadedServer.cpp
@@ -106,6 +106,16 @@ TThreadedServer::TThreadedServer(shared_ptr<TProcessor> processor,
   threadFactory_ = shared_ptr<PosixThreadFactory>(new PosixThreadFactory());
 }
 
+TThreadedServer::TThreadedServer(boost::shared_ptr<TProcessor> processor,
+                                 boost::shared_ptr<TServerTransport> serverTransport,
+                                 boost::shared_ptr<TTransportFactory> transportFactory,
+                                 boost::shared_ptr<TProtocolFactory> protocolFactory,
+                                 boost::shared_ptr<ThreadFactory> threadFactory):
+  TServer(processor, serverTransport, transportFactory, protocolFactory),
+  threadFactory_(threadFactory),
+  stop_(false) {
+}
+
 TThreadedServer::~TThreadedServer() {}
 
 void TThreadedServer::serve() {
diff --git a/lib/cpp/src/server/TThreadedServer.h b/lib/cpp/src/server/TThreadedServer.h
index 8294f699..7ff07d9d 100644
--- a/lib/cpp/src/server/TThreadedServer.h
+++ b/lib/cpp/src/server/TThreadedServer.h
@@ -32,6 +32,12 @@ class TThreadedServer : public TServer {
                   boost::shared_ptr<TTransportFactory> transportFactory,
                   boost::shared_ptr<TProtocolFactory> protocolFactory);
 
+  TThreadedServer(boost::shared_ptr<TProcessor> processor,
+                  boost::shared_ptr<TServerTransport> serverTransport,
+                  boost::shared_ptr<TTransportFactory> transportFactory,
+                  boost::shared_ptr<TProtocolFactory> protocolFactory,
+                  boost::shared_ptr<ThreadFactory> threadFactory);
+
   virtual ~TThreadedServer();
 
   virtual void serve();
-- 
2.17.1