Home
last modified time | relevance | path

Searched refs:threadFactory (Results 1 – 18 of 18) sorted by relevance

/thrift-3.4.0/lib/cpp/src/thrift/server/
DTThreadedServer.cpp46 const shared_ptr<ThreadFactory>& threadFactory) in TThreadedServer() argument
48 threadFactory_(threadFactory) { in TThreadedServer()
55 const shared_ptr<ThreadFactory>& threadFactory) in TThreadedServer() argument
57 threadFactory_(threadFactory) { in TThreadedServer()
66 const shared_ptr<ThreadFactory>& threadFactory) in TThreadedServer() argument
73 threadFactory_(threadFactory) { in TThreadedServer()
82 const shared_ptr<ThreadFactory>& threadFactory) in TThreadedServer() argument
89 threadFactory_(threadFactory) { in TThreadedServer()
DTThreadedServer.h45 const std::shared_ptr<apache::thrift::concurrency::ThreadFactory>& threadFactory
54 const std::shared_ptr<apache::thrift::concurrency::ThreadFactory>& threadFactory
65 const std::shared_ptr<apache::thrift::concurrency::ThreadFactory>& threadFactory
76 const std::shared_ptr<apache::thrift::concurrency::ThreadFactory>& threadFactory
/thrift-3.4.0/lib/cpp/test/processor/
DServerThread.cpp41 concurrency::ThreadFactory threadFactory; in start() local
42 threadFactory.setDetached(false); in start()
43 thread_ = threadFactory.newThread(helper_); in start()
DProcessorTest.cpp97 std::shared_ptr<ThreadFactory> threadFactory(new ThreadFactory); in createServer() local
99 threadManager->threadFactory(threadFactory); in createServer()
126 std::shared_ptr<ThreadFactory> threadFactory(new ThreadFactory); in createServer() local
128 threadManager->threadFactory(threadFactory); in createServer()
/thrift-3.4.0/lib/cpp/test/concurrency/
DThreadFactoryTests.h68 ThreadFactory threadFactory = ThreadFactory();
82 threadFactory.newThread(shared_ptr<Runnable>(new ReapNTask(*monitor, activeCount))));
161 ThreadFactory threadFactory = ThreadFactory(); in synchStartTest() local
163 shared_ptr<Thread> thread = threadFactory.newThread(task); in synchStartTest()
276 ThreadFactory threadFactory = ThreadFactory();
277 threadFactory.setDetached(true);
284 shared_ptr<Thread> thread = threadFactory.newThread(task);
DTimerManagerTests.h84 timerManager.threadFactory(shared_ptr<ThreadFactory>(new ThreadFactory()));
129 timerManager.threadFactory(shared_ptr<ThreadFactory>(new ThreadFactory()));
162 timerManager.threadFactory(shared_ptr<ThreadFactory>(new ThreadFactory()));
195 timerManager.threadFactory(shared_ptr<ThreadFactory>(new ThreadFactory()));
232 timerManager.threadFactory(shared_ptr<ThreadFactory>(new ThreadFactory()));
DThreadManagerTests.h110 shared_ptr<ThreadFactory> threadFactory variable
113 threadManager->threadFactory(threadFactory);
256 shared_ptr<ThreadFactory> threadFactory variable
259 threadManager->threadFactory(threadFactory);
401 bool apiTestWithThreadFactory(shared_ptr<ThreadFactory> threadFactory) in apiTestWithThreadFactory() argument
404 threadManager->threadFactory(threadFactory); in apiTestWithThreadFactory()
/thrift-3.4.0/lib/cpp/src/thrift/concurrency/
DThreadManager.h90 virtual std::shared_ptr<ThreadFactory> threadFactory() const = 0;
97 virtual void threadFactory(std::shared_ptr<ThreadFactory> value) = 0;
DTimerManager.h50 virtual std::shared_ptr<const ThreadFactory> threadFactory() const;
52 virtual void threadFactory(std::shared_ptr<const ThreadFactory> value);
DTimerManager.cpp227 shared_ptr<const ThreadFactory> TimerManager::threadFactory() const { in threadFactory() function in apache::thrift::concurrency::TimerManager
232 void TimerManager::threadFactory(shared_ptr<const ThreadFactory> value) { in threadFactory() function in apache::thrift::concurrency::TimerManager
DThreadManager.cpp74 shared_ptr<ThreadFactory> threadFactory() const override { in threadFactory() function in apache::thrift::concurrency::ThreadManager::Impl
79 void threadFactory(shared_ptr<ThreadFactory> value) override { in threadFactory() function in apache::thrift::concurrency::ThreadManager::Impl
/thrift-3.4.0/test/cpp/src/
DStressTestNonBlocking.cpp345 std::shared_ptr<ThreadFactory> threadFactory in main() local
398 serverThread = threadFactory->newThread(std::shared_ptr<TServer>( in main()
401 serverThread2 = threadFactory->newThread(std::shared_ptr<TServer>( in main()
409 threadManager->threadFactory(threadFactory); in main()
412 serverThread = threadFactory->newThread(std::shared_ptr<TServer>( in main()
415 serverThread2 = threadFactory->newThread(std::shared_ptr<TServer>( in main()
461 clientThreads.insert(threadFactory->newThread(std::shared_ptr<ClientThread>( in main()
DStressTest.cpp393 std::shared_ptr<ThreadFactory> threadFactory in main() local
458 threadManager->threadFactory(threadFactory); in main()
469 std::shared_ptr<Thread> serverThread = threadFactory->newThread(server); in main()
512 clientThreads.insert(threadFactory->newThread(std::shared_ptr<ClientThread>( in main()
523 clientThreads.insert(threadFactory->newThread(std::shared_ptr<ClientThread>( in main()
DTestServer.cpp781 std::shared_ptr<ThreadFactory> threadFactory in main() local
785 threadManager->threadFactory(threadFactory); in main()
/thrift-3.4.0/contrib/transport-sample/
DThriftCommon.h90 …boost::shared_ptr<ThreadFactory> threadFactory = boost::shared_ptr<ThreadFactory>(new ThreadFactor… in RunThriftServer() local
91 threadManager->threadFactory(threadFactory); in RunThriftServer()
/thrift-3.4.0/lib/cpp/test/
DTNonblockingServerTest.cpp150 shared_ptr<ThreadFactory> threadFactory( in startServer() local
152 thread = threadFactory->newThread(runner); in startServer()
DTServerIntegrationTest.cpp380 pServer->getThreadManager()->threadFactory( in BOOST_FIXTURE_TEST_CASE()
395 pServer->getThreadManager()->threadFactory( in BOOST_FIXTURE_TEST_CASE()
410 pServer->getThreadManager()->threadFactory( in BOOST_FIXTURE_TEST_CASE()
421 pServer->getThreadManager()->threadFactory( in BOOST_FIXTURE_TEST_CASE()
DTNonblockingSSLServerTest.cpp223 std::unique_ptr<apache::thrift::concurrency::ThreadFactory> threadFactory( in startServer() local
225 thread = threadFactory->newThread(runner); in startServer()