Lines Matching refs:Worker
42 class Worker : public Listener, public Sender { class
45 Worker(Channel::Mode mode, in Worker() function in IPC::__anon60820dc30111::Worker
64 Worker(mojo::ScopedMessagePipeHandle channel_handle, Channel::Mode mode) in Worker() function in IPC::__anon60820dc30111::Worker
80 ~Worker() override { in ~Worker()
93 FROM_HERE, base::Bind(&Worker::OnStart, base::Unretained(this))); in Start()
106 base::Bind(&Worker::OnListenerThreadShutdown1, base::Unretained(this), in Shutdown()
210 base::Bind(&Worker::OnIPCThreadShutdown, base::Unretained(this), in OnListenerThreadShutdown1()
220 FROM_HERE, base::Bind(&Worker::OnListenerThreadShutdown2, in OnIPCThreadShutdown()
230 IPC_BEGIN_MESSAGE_MAP(Worker, message) in OnMessageReceived()
259 DISALLOW_COPY_AND_ASSIGN(Worker);
265 void RunTest(std::vector<Worker*> workers) { in RunTest()
298 class SimpleServer : public Worker {
302 : Worker(Channel::MODE_SERVER, in SimpleServer()
314 class SimpleClient : public Worker {
317 : Worker(Channel::MODE_CLIENT, in SimpleClient()
328 std::vector<Worker*> workers; in Simple()
352 class TwoStepServer : public Worker {
356 : Worker(Channel::MODE_SERVER, in TwoStepServer()
379 class TwoStepClient : public Worker {
383 : Worker(Channel::MODE_CLIENT, in TwoStepClient()
407 std::vector<Worker*> workers; in TwoStep()
427 class DelayClient : public Worker {
430 : Worker(Channel::MODE_CLIENT, in DelayClient()
442 std::vector<Worker*> workers; in DelayReply()
458 class NoHangServer : public Worker {
463 : Worker(Channel::MODE_SERVER, in NoHangServer()
480 class NoHangClient : public Worker {
484 : Worker(Channel::MODE_CLIENT, in NoHangClient()
506 std::vector<Worker*> workers; in NoHang()
523 class UnblockServer : public Worker {
528 : Worker(Channel::MODE_SERVER, in UnblockServer()
559 class UnblockClient : public Worker {
563 : Worker(Channel::MODE_CLIENT, in UnblockClient()
578 std::vector<Worker*> workers; in Unblock()
611 class RecursiveServer : public Worker {
617 : Worker(Channel::MODE_SERVER, in RecursiveServer()
636 class RecursiveClient : public Worker {
641 : Worker(Channel::MODE_CLIENT, in RecursiveClient()
673 std::vector<Worker*> workers; in Recursive()
698 std::vector<Worker*> workers; in RecursiveNoHang()
722 class MultipleServer1 : public Worker {
726 : Worker(std::move(channel_handle), Channel::MODE_SERVER), in MultipleServer1()
737 class MultipleClient1 : public Worker {
742 : Worker(std::move(channel_handle), Channel::MODE_CLIENT), in MultipleClient1()
757 class MultipleServer2 : public Worker {
760 : Worker(std::move(channel_handle), Channel::MODE_SERVER) {} in MultipleServer2()
768 class MultipleClient2 : public Worker {
774 : Worker(std::move(channel_handle), Channel::MODE_CLIENT), in MultipleClient2()
792 std::vector<Worker*> workers; in Multiple()
808 Worker* worker; in Multiple()
844 class QueuedReplyServer : public Worker {
849 : Worker(std::move(channel_handle), Channel::MODE_SERVER), in QueuedReplyServer()
851 Worker::OverrideThread(listener_thread); in QueuedReplyServer()
871 class QueuedReplyClient : public Worker {
877 : Worker(std::move(channel_handle), Channel::MODE_CLIENT), in QueuedReplyClient()
880 Worker::OverrideThread(listener_thread); in QueuedReplyClient()
902 std::vector<Worker*> workers; in QueuedReply()
911 Worker* worker; in QueuedReply()
948 class ChattyClient : public Worker {
951 : Worker(Channel::MODE_CLIENT, in ChattyClient()
969 std::vector<Worker*> workers; in ChattyServer()
1002 void NestedCallback(Worker* server) { in NestedCallback()
1014 class DoneEventRaceServer : public Worker {
1017 : Worker(Channel::MODE_SERVER, in DoneEventRaceServer()
1046 std::vector<Worker*> workers; in TEST_F()
1059 Worker* worker, in TestSyncMessageFilter()
1084 Worker* worker_;
1088 class SyncMessageFilterServer : public Worker {
1091 : Worker(Channel::MODE_SERVER, in SyncMessageFilterServer()
1112 class ServerSendAfterClose : public Worker {
1115 : Worker(Channel::MODE_SERVER, in ServerSendAfterClose()
1139 send_result_ = Worker::Send(msg); in Send()
1149 std::vector<Worker*> workers; in TEST_F()
1175 class RestrictedDispatchServer : public Worker {
1180 : Worker(std::move(channel_handle), Channel::MODE_SERVER), in RestrictedDispatchServer()
1201 base::Thread* ListenerThread() { return Worker::ListenerThread(); } in ListenerThread()
1222 class NonRestrictedDispatchServer : public Worker {
1226 : Worker(std::move(channel_handle), Channel::MODE_SERVER), in NonRestrictedDispatchServer()
1229 base::Thread* ListenerThread() { return Worker::ListenerThread(); } in ListenerThread()
1250 class RestrictedDispatchClient : public Worker {
1259 : Worker(std::move(restricted_channel_handle), Channel::MODE_CLIENT), in RestrictedDispatchClient()
1373 std::vector<Worker*> workers; in TEST_F()
1413 class RestrictedDispatchDeadlockServer : public Worker {
1420 : Worker(std::move(channel_handle), Channel::MODE_SERVER), in RestrictedDispatchDeadlockServer()
1438 base::Thread* ListenerThread() { return Worker::ListenerThread(); } in ListenerThread()
1469 class RestrictedDispatchDeadlockClient2 : public Worker {
1476 : Worker(std::move(channel_handle), Channel::MODE_CLIENT), in RestrictedDispatchDeadlockClient2()
1499 base::Thread* ListenerThread() { return Worker::ListenerThread(); } in ListenerThread()
1529 class RestrictedDispatchDeadlockClient1 : public Worker {
1537 : Worker(std::move(channel_handle), Channel::MODE_CLIENT), in RestrictedDispatchDeadlockClient1()
1598 std::vector<Worker*> workers; in TEST_F()
1654 class RestrictedDispatchPipeWorker : public Worker {
1662 : Worker(std::move(channel_handle1), Channel::MODE_SERVER), in RestrictedDispatchPipeWorker()
1739 std::vector<Worker*> workers; in TEST_F()
1775 class ReentrantReplyServer1 : public Worker {
1780 : Worker(std::move(channel_handle1), Channel::MODE_SERVER), in ReentrantReplyServer1()
1821 class ReentrantReplyServer2 : public Worker {
1824 : Worker(std::move(channel_handle), Channel::MODE_SERVER), reply_(NULL) {} in ReentrantReplyServer2()
1853 class ReentrantReplyClient : public Worker {
1857 : Worker(std::move(channel_handle), Channel::MODE_CLIENT), in ReentrantReplyClient()
1871 std::vector<Worker*> workers; in TEST_F()