svn commit: r754551 - in /incubator/thrift/trunk/lib/cpp/src/server: TThreadedServer.cpp TThreadedServer.h

[dreiss]

Author: dreiss
Date: Sat Mar 14 23:35:16 2009
New Revision: 754551

URL: http://svn.apache.org/viewvc?rev=754551&view=rev
Log:
THRIFT-351. cpp: Allow a custom ThreadFactory in TThreadedServer

Modified:
    incubator/thrift/trunk/lib/cpp/src/server/TThreadedServer.cpp
    incubator/thrift/trunk/lib/cpp/src/server/TThreadedServer.h

Modified: incubator/thrift/trunk/lib/cpp/src/server/TThreadedServer.cpp
URL: 
http://svn.apache.org/viewvc/incubator/thrift/trunk/lib/cpp/src/server/TThreadedServer.cpp?rev=754551&r1=754550&r2=754551&view=diff
==============================================================================
--- incubator/thrift/trunk/lib/cpp/src/server/TThreadedServer.cpp (original)
+++ incubator/thrift/trunk/lib/cpp/src/server/TThreadedServer.cpp Sat Mar 14 
23:35:16 2009
@@ -106,6 +106,16 @@
   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() {

Modified: incubator/thrift/trunk/lib/cpp/src/server/TThreadedServer.h
URL: 
http://svn.apache.org/viewvc/incubator/thrift/trunk/lib/cpp/src/server/TThreadedServer.h?rev=754551&r1=754550&r2=754551&view=diff
==============================================================================
--- incubator/thrift/trunk/lib/cpp/src/server/TThreadedServer.h (original)
+++ incubator/thrift/trunk/lib/cpp/src/server/TThreadedServer.h Sat Mar 14 
23:35:16 2009
@@ -32,6 +32,12 @@
                   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();