Lines Matching refs:workers
265 void RunTest(std::vector<Worker*> workers) { in RunTest() argument
268 for (size_t i = 0; i < workers.size(); ++i) { in RunTest()
269 if (workers[i]->mode() & Channel::MODE_SERVER_FLAG) { in RunTest()
270 workers[i]->Start(); in RunTest()
271 workers[i]->WaitForChannelCreation(); in RunTest()
276 for (size_t i = 0; i < workers.size(); ++i) { in RunTest()
277 if (workers[i]->mode() & Channel::MODE_CLIENT_FLAG) in RunTest()
278 workers[i]->Start(); in RunTest()
282 for (size_t i = 0; i < workers.size(); ++i) in RunTest()
283 workers[i]->done_event()->Wait(); in RunTest()
285 for (size_t i = 0; i < workers.size(); ++i) { in RunTest()
286 workers[i]->Shutdown(); in RunTest()
287 delete workers[i]; in RunTest()
328 std::vector<Worker*> workers; in Simple() local
330 workers.push_back( in Simple()
332 workers.push_back(new SimpleClient(std::move(pipe.handle1))); in Simple()
333 RunTest(workers); in Simple()
407 std::vector<Worker*> workers; in TwoStep() local
409 workers.push_back( in TwoStep()
411 workers.push_back( in TwoStep()
413 RunTest(workers); in TwoStep()
442 std::vector<Worker*> workers; in DelayReply() local
444 workers.push_back( in DelayReply()
446 workers.push_back(new DelayClient(std::move(pipe.handle1))); in DelayReply()
447 RunTest(workers); in DelayReply()
506 std::vector<Worker*> workers; in NoHang() local
508 workers.push_back(new NoHangServer(&got_first_reply, pump_during_send, in NoHang()
510 workers.push_back( in NoHang()
512 RunTest(workers); in NoHang()
578 std::vector<Worker*> workers; in Unblock() local
580 workers.push_back(new UnblockServer(server_pump, delete_during_send, in Unblock()
582 workers.push_back(new UnblockClient(client_pump, std::move(pipe.handle1))); in Unblock()
583 RunTest(workers); in Unblock()
673 std::vector<Worker*> workers; in Recursive() local
675 workers.push_back(new RecursiveServer( in Recursive()
677 workers.push_back( in Recursive()
679 RunTest(workers); in Recursive()
698 std::vector<Worker*> workers; in RecursiveNoHang() local
700 workers.push_back(new RecursiveServer( in RecursiveNoHang()
702 workers.push_back( in RecursiveNoHang()
704 RunTest(workers); in RecursiveNoHang()
792 std::vector<Worker*> workers; in Multiple() local
813 workers.push_back(worker); in Multiple()
817 workers.push_back(worker); in Multiple()
821 workers.push_back(worker); in Multiple()
825 workers.push_back(worker); in Multiple()
827 RunTest(workers); in Multiple()
902 std::vector<Worker*> workers; in QueuedReply() local
916 workers.push_back(worker); in QueuedReply()
920 workers.push_back(worker); in QueuedReply()
925 workers.push_back(worker); in QueuedReply()
930 workers.push_back(worker); in QueuedReply()
932 RunTest(workers); in QueuedReply()
969 std::vector<Worker*> workers; in ChattyServer() local
971 workers.push_back( in ChattyServer()
973 workers.push_back(new ChattyClient(std::move(pipe.handle1))); in ChattyServer()
974 RunTest(workers); in ChattyServer()
1046 std::vector<Worker*> workers; in TEST_F() local
1048 workers.push_back(new DoneEventRaceServer(std::move(pipe.handle0))); in TEST_F()
1049 workers.push_back(new SimpleClient(std::move(pipe.handle1))); in TEST_F()
1050 RunTest(workers); in TEST_F()
1149 std::vector<Worker*> workers; in TEST_F() local
1151 workers.push_back(new SyncMessageFilterServer(std::move(pipe.handle0))); in TEST_F()
1152 workers.push_back(new SimpleClient(std::move(pipe.handle1))); in TEST_F()
1153 RunTest(workers); in TEST_F()
1373 std::vector<Worker*> workers; in TEST_F() local
1374 workers.push_back(server); in TEST_F()
1375 workers.push_back(server2); in TEST_F()
1376 workers.push_back( in TEST_F()
1380 RunTest(workers); in TEST_F()
1598 std::vector<Worker*> workers; in TEST_F() local
1628 workers.push_back(server2); in TEST_F()
1632 workers.push_back(client2); in TEST_F()
1637 workers.push_back(server1); in TEST_F()
1641 workers.push_back(client1); in TEST_F()
1643 RunTest(workers); in TEST_F()
1739 std::vector<Worker*> workers; in TEST_F() local
1749 workers.push_back(new RestrictedDispatchPipeWorker( in TEST_F()
1752 workers.push_back(new RestrictedDispatchPipeWorker( in TEST_F()
1755 workers.push_back(new RestrictedDispatchPipeWorker( in TEST_F()
1758 workers.push_back(new RestrictedDispatchPipeWorker( in TEST_F()
1761 RunTest(workers); in TEST_F()
1871 std::vector<Worker*> workers; in TEST_F() local
1875 workers.push_back(new ReentrantReplyServer2(std::move(pipe2.handle0))); in TEST_F()
1876 workers.push_back(new ReentrantReplyServer1( in TEST_F()
1878 workers.push_back( in TEST_F()
1880 RunTest(workers); in TEST_F()