Home
last modified time | relevance | path

Searched refs:fileTransport (Results 1 – 2 of 2) sorted by relevance

/thrift-3.4.0/test/cpp/src/
DStressTestNonBlocking.cpp356 std::shared_ptr<TFileTransport> fileTransport(new TFileTransport(requestLogPath)); in main() local
357 fileTransport->setChunkSize(2 * 1024 * 1024); in main()
358 fileTransport->setMaxEventSize(1024 * 16); in main()
359 fileTransport->seekToEnd(); in main()
364 TFileProcessor fileProcessor(serviceProcessor, protocolFactory, fileTransport); in main()
382 std::shared_ptr<TFileTransport> fileTransport(new TFileTransport(requestLogPath)); in main() local
383 fileTransport->setChunkSize(2 * 1024 * 1024); in main()
384 fileTransport->setMaxEventSize(1024 * 16); in main()
387 = std::shared_ptr<TTransportFactory>(new TPipedTransportFactory(fileTransport)); in main()
DStressTest.cpp404 std::shared_ptr<TFileTransport> fileTransport(new TFileTransport(requestLogPath)); in main() local
405 fileTransport->setChunkSize(2 * 1024 * 1024); in main()
406 fileTransport->setMaxEventSize(1024 * 16); in main()
407 fileTransport->seekToEnd(); in main()
412 TFileProcessor fileProcessor(serviceProcessor, protocolFactory, fileTransport); in main()
433 std::shared_ptr<TFileTransport> fileTransport(new TFileTransport(requestLogPath)); in main() local
434 fileTransport->setChunkSize(2 * 1024 * 1024); in main()
435 fileTransport->setMaxEventSize(1024 * 16); in main()
438 = std::shared_ptr<TTransportFactory>(new TPipedTransportFactory(fileTransport)); in main()