83 d_handler(new TserverClass()),
84 d_processor(new GNURadio::ControlPortProcessor(d_handler)),
87 d_protocolFactory(new thrift::protocol::TBinaryProtocolFactory())
92 unsigned int port, nthreads, buffersize;
93 std::string thrift_config_file =
96 if (thrift_config_file.length() > 0) {
116 d_serverTransport.reset(
new thrift::transport::TServerSocket(port));
118 d_transportFactory.reset(
119 new thrift_server_template::TBufferedTransportFactory(buffersize));
125 new thrift::server::TSimpleServer(
126 d_processor, d_serverTransport, d_transportFactory, d_protocolFactory));
129 std::shared_ptr<thrift::concurrency::ThreadManager> threadManager(
130 thrift::concurrency::ThreadManager::newSimpleThreadManager(nthreads));
132#ifdef THRIFT_HAS_THREADFACTORY_H
133 threadManager->threadFactory(std::shared_ptr<thrift::concurrency::ThreadFactory>(
134 new thrift::concurrency::ThreadFactory()));
136 threadManager->threadFactory(
137 std::shared_ptr<thrift::concurrency::PlatformThreadFactory>(
138 new thrift::concurrency::PlatformThreadFactory()));
141 threadManager->start();
144 new thrift::server::TThreadPoolServer(d_processor,