Home
last modified time | relevance | path

Searched refs:pump_ (Results 1 – 12 of 12) sorted by relevance

/external/libchrome/base/message_loop/
Dmessage_loop.cc178 DCHECK((pump_ && MessageLoopCurrent::IsBoundToCurrentThreadInternal(this)) || in ~MessageLoop()
179 (!pump_ && !MessageLoopCurrent::IsBoundToCurrentThreadInternal(this))); in ~MessageLoop()
188 (!pump_ && !MessageLoopCurrent::IsBoundToCurrentThreadInternal(this)) || in ~MessageLoop()
341 DCHECK(!pump_); in BindToCurrentThread()
343 pump_ = std::move(pump_factory_).Run(); in BindToCurrentThread()
345 pump_ = CreateMessagePumpForType(type_); in BindToCurrentThread()
366 static_cast<MessagePumpForUI*>(pump_.get())->Attach(this); in BindToCurrentThread()
402 pump_->Run(this); in Run()
405 pump_->Run(this); in Run()
411 pump_->Quit(); in Quit()
[all …]
Dmessage_loop_current.cc82 current_->pump_->ScheduleWork(); in SetNestableTasksAllowed()
137 loop_for_ui, static_cast<MessagePumpForUI*>(loop_for_ui->pump_.get())); in Get()
160 return pump_->WatchFileDescriptor(fd, persistent, mode, controller, delegate); in WatchFileDescriptor()
188 loop_for_io, static_cast<MessagePumpForIO*>(loop_for_io->pump_.get())); in Get()
204 return pump_->RegisterIOHandler(file, handler); in RegisterIOHandler()
211 return pump_->RegisterJobObject(job, handler); in RegisterJobObject()
218 return pump_->WaitForIOCompletion(timeout, filter); in WaitForIOCompletion()
228 return pump_->WatchFileDescriptor(fd, persistent, mode, controller, delegate); in WatchFileDescriptor()
243 return pump_->WatchZxHandle(handle, persistent, signals, controller, in WatchZxHandle()
Dmessage_loop_current.h237 : MessageLoopCurrent(current), pump_(pump) { in MessageLoopCurrentForUI()
238 DCHECK(pump_); in MessageLoopCurrentForUI()
241 MessagePumpForUI* const pump_; variable
288 : MessageLoopCurrent(current), pump_(pump) { in MessageLoopCurrentForIO()
289 DCHECK(pump_); in MessageLoopCurrentForIO()
292 MessagePumpForIO* const pump_; variable
Dmessage_pump_libevent.h48 void set_pump(MessagePumpLibevent* pump) { pump_ = pump; } in set_pump()
49 MessagePumpLibevent* pump() const { return pump_; } in pump()
57 MessagePumpLibevent* pump_ = nullptr; variable
Dmessage_loop.h151 pump_->SetTimerSlack(timer_slack); in SetTimerSlack()
205 std::unique_ptr<MessagePump> pump_;
Dmessage_loop_task_runner_perftest.cc122 pump_->ScheduleWork(); in DidQueueTask()
134 std::unique_ptr<MessagePump> pump_{std::make_unique<StubMessagePump>()}; member in base::FakeObserverSimulatingOverhead
Dmessage_pump_libevent.cc67 pump_ = nullptr; in StopWatchingFileDescriptor()
/external/libchrome/base/task/sequence_manager/
Dthread_controller_with_message_pump_impl.cc19 pump_(new MessagePumpDefault()), in ThreadControllerWithMessagePumpImpl()
57 pump_->ScheduleWork(); in ScheduleWork()
76 pump_->ScheduleDelayedWork(run_time); in SetNextDelayedDoWork()
147 pump_->ScheduleWork(); in DoWork()
183 pump_->Run(this); in Run()
196 pump_->Quit(); in Quit()
Dthread_controller_with_message_pump_impl.h97 std::unique_ptr<MessagePump> pump_; variable
/external/webrtc/webrtc/libjingle/xmpp/
Dxmppthread.cc32 pump_ = new buzz::XmppPump(this); in XmppThread()
37 delete pump_; in ~XmppThread()
59 pump_->DoLogin(data->xcs, new XmppSocket(buzz::TLS_DISABLED), in OnMessage()
63 pump_->DoDisconnect(); in OnMessage()
Dxmppthread.h28 buzz::XmppClient* client() { return pump_->client(); } in client()
36 buzz::XmppPump* pump_;
/external/libbrillo/brillo/message_loops/
Dbase_message_loop.cc329 loop_->base_loop_->pump_.get())->WatchFileDescriptor( in StartWatching()