Searched refs:done_event (Results 1 – 6 of 6) sorted by relevance
45 base::WaitableEvent done_event( in Send() local51 &done_event); in Send()79 registry->RegisterEvent(&done_event, on_done_callback); in Send()85 "SyncMessageFilter::Send", &done_event); in Send()89 registry->UnregisterEvent(&done_event, on_done_callback); in Send()136 (*iter)->done_event); in OnMessageReceived()137 (*iter)->done_event->Signal(); in OnMessageReceived()174 (*iter)->done_event); in SignalAllEvents()175 (*iter)->done_event->Signal(); in SignalAllEvents()
407 delete msg.done_event; in Pop()408 msg.done_event = nullptr; in Pop()427 return deserializers_.back().done_event; in GetSendDoneEvent()454 base::WaitableEvent* done_event = deserializers_.back().done_event; in TryToUnblockListener() local457 "SyncChannel::SyncContext::TryToUnblockListener", done_event); in TryToUnblockListener()459 done_event->Signal(); in TryToUnblockListener()520 iter->done_event); in CancelPendingSends()521 iter->done_event->Signal(); in CancelPendingSends()
98 : id(id), deserializer(d), done_event(e), send_result(false) {} in PendingSyncMsg()102 base::WaitableEvent* done_event; member
143 WaitableEvent* done_event() { return done_.get(); } in done_event() function in IPC::__anon7ae8f74a0111::Worker283 workers[i]->done_event()->Wait(); in RunTest()1162 server.done_event()->Wait(); in TEST_F()1163 server.done_event()->Reset(); in TEST_F()1166 server.done_event()->Wait(); in TEST_F()
56 WaitableEvent* done_event() { return &done_event_; } in done_event() function in base::__anona643db7e0111::HangingReceiveThread155 EXPECT_TRUE(thread.done_event()->TimedWait(kReceiveTimeout)); in TEST_F()168 EXPECT_TRUE(thread.done_event()->TimedWait(kReceiveTimeout)); in TEST_F()
471 self.done_event = threading.Event()564 self.done_event.clear()567 self.process, self.done_event, self.write)659 completed_normally = self.done_event.wait(timeout_seconds)