Lines Matching defs:workers
237 // Starts the test with the given workers. This function deletes the workers
239 void RunTest(std::vector<Worker*> workers) {
240 // First we create the workers that are channel servers, or else the other
241 // workers' channel initialization might fail because the pipe isn't created..
242 for (size_t i = 0; i < workers.size(); ++i) {
243 if (workers[i]->mode() & Channel::MODE_SERVER_FLAG) {
244 workers[i]->Start();
245 workers[i]->WaitForChannelCreation();
250 for (size_t i = 0; i < workers.size(); ++i) {
251 if (workers[i]->mode() & Channel::MODE_CLIENT_FLAG)
252 workers[i]->Start();
255 // wait for all the workers to finish
256 for (size_t i = 0; i < workers.size(); ++i)
257 workers[i]->done_event()->Wait();
259 for (size_t i = 0; i < workers.size(); ++i) {
260 workers[i]->Shutdown();
261 delete workers[i];
296 std::vector<Worker*> workers;
297 workers.push_back(new SimpleServer(pump_during_send));
298 workers.push_back(new SimpleClient());
299 RunTest(workers);
360 std::vector<Worker*> workers;
361 workers.push_back(new TwoStepServer(create_server_pipe_now));
362 workers.push_back(new TwoStepClient(create_client_pipe_now));
363 RunTest(workers);
389 std::vector<Worker*> workers;
390 workers.push_back(new SimpleServer(pump_during_send));
391 workers.push_back(new DelayClient());
392 RunTest(workers);
442 std::vector<Worker*> workers;
443 workers.push_back(new NoHangServer(&got_first_reply, pump_during_send));
444 workers.push_back(new NoHangClient(&got_first_reply));
445 RunTest(workers);
504 std::vector<Worker*> workers;
505 workers.push_back(new UnblockServer(server_pump, delete_during_send));
506 workers.push_back(new UnblockClient(client_pump));
507 RunTest(workers);
581 std::vector<Worker*> workers;
582 workers.push_back(
584 workers.push_back(new RecursiveClient(client_pump, false));
585 RunTest(workers);
604 std::vector<Worker*> workers;
605 workers.push_back(
607 workers.push_back(new RecursiveClient(client_pump, true));
608 RunTest(workers);
692 std::vector<Worker*> workers;
708 workers.push_back(worker);
712 workers.push_back(worker);
716 workers.push_back(worker);
720 workers.push_back(worker);
722 RunTest(workers);
797 std::vector<Worker*> workers;
811 workers.push_back(worker);
816 workers.push_back(worker);
822 workers.push_back(worker);
828 workers.push_back(worker);
830 RunTest(workers);
865 std::vector<Worker*> workers;
866 workers.push_back(new UnblockServer(pump_during_send, false));
867 workers.push_back(new ChattyClient());
868 RunTest(workers);
919 std::vector<Worker*> workers;
920 workers.push_back(new DoneEventRaceServer());
921 workers.push_back(new SimpleClient());
922 RunTest(workers);
1017 std::vector<Worker*> workers;
1018 workers.push_back(new SyncMessageFilterServer());
1019 workers.push_back(new SimpleClient());
1020 RunTest(workers);
1227 std::vector<Worker*> workers;
1228 workers.push_back(server);
1229 workers.push_back(server2);
1230 workers.push_back(new RestrictedDispatchClient(
1232 RunTest(workers);
1444 std::vector<Worker*> workers;
1467 workers.push_back(server2);
1471 workers.push_back(client2);
1476 workers.push_back(server1);
1480 workers.push_back(client1);
1482 RunTest(workers);
1488 // We create 4 workers that pipe to each other W1->W2->W3->W4->W1 then we send a
1577 std::vector<Worker*> workers;
1582 workers.push_back(new RestrictedDispatchPipeWorker(
1584 workers.push_back(new RestrictedDispatchPipeWorker(
1586 workers.push_back(new RestrictedDispatchPipeWorker(
1588 workers.push_back(new RestrictedDispatchPipeWorker(
1590 RunTest(workers);
1599 // We have 3 workers. Server1 will send a message to Server2 (which will block),
1699 std::vector<Worker*> workers;
1701 workers.push_back(new ReentrantReplyServer2());
1702 workers.push_back(new ReentrantReplyServer1(&server_ready));
1703 workers.push_back(new ReentrantReplyClient(&server_ready));
1704 RunTest(workers);
1763 std::vector<Worker*> workers;
1778 workers.push_back(worker);
1783 workers.push_back(worker);
1785 RunTest(workers);
