HomeSort by relevance Sort by last modified time
    Searched refs:MessageLoopForIO (Results 1 - 25 of 29) sorted by null

1 2

  /external/libchrome/base/test/
test_io_thread.h 44 base::MessageLoopForIO* message_loop() {
45 return static_cast<base::MessageLoopForIO*>(io_thread_.message_loop());
  /external/libchrome/base/files/
file_descriptor_watcher_posix.cc 21 // MessageLoopForIO used to watch file descriptors for which callbacks are
23 LazyInstance<ThreadLocalPointer<MessageLoopForIO>>::Leaky
31 // Delete |watcher_| on the MessageLoopForIO.
33 // If the MessageLoopForIO is deleted before Watcher::StartWatching() runs,
34 // |watcher_| is leaked. If the MessageLoopForIO is deleted after
44 : public MessageLoopForIO::Watcher,
47 Watcher(WeakPtr<Controller> controller, MessageLoopForIO::Mode mode, int fd);
55 // MessageLoopForIO::Watcher:
62 // Used to instruct the MessageLoopForIO to stop watching the file descriptor.
63 MessageLoopForIO::FileDescriptorWatcher file_descriptor_watcher_
    [all...]
file_descriptor_watcher_posix.h 40 Controller(MessageLoopForIO::Mode mode, int fd, const Closure& callback);
52 // TaskRunner associated with the MessageLoopForIO that watches the file
57 // Notified by the MessageLoopForIO associated with
62 // task posted to the MessageLoopForIO. This ensures that |watcher_| isn't
63 // deleted while it is being used by the MessageLoopForIO.
79 FileDescriptorWatcher(MessageLoopForIO* message_loop_for_io);
file_descriptor_watcher_posix_unittest.cc 52 ? new MessageLoopForIO
73 static_cast<MessageLoopForIO*>(message_loop_for_io));
146 // Thread running a MessageLoopForIO. Used when the test type is
151 // Determines which MessageLoopForIO is used to watch file descriptors for
294 // Delete the MessageLoopForIO.
303 // posted to the MessageLoopForIO thread.
  /external/libbrillo/brillo/message_loops/
base_message_loop.h 9 // base::MessageLoopForIO. This allows to mix new code using
10 // brillo::MessageLoop and legacy code using base::MessageLoopForIO in the
13 // since base::MessageLoopForIO doesn't provide a way to remove the event.
32 // Construct a base::MessageLoopForIO message loop instance and use it as
36 // Construct a brillo::BaseMessageLoop using the passed base::MessageLoopForIO
38 explicit BaseMessageLoop(base::MessageLoopForIO* base_loop);
72 // Called by base::MessageLoopForIO when is time to call the callback
95 class IOTask : public base::MessageLoopForIO::Watcher {
101 base::MessageLoopForIO::Mode base_mode,
133 base::MessageLoopForIO::Mode base_mode_
    [all...]
base_message_loop.cc 50 << "You can't create a base::MessageLoopForIO when another "
52 owned_base_loop_.reset(new base::MessageLoopForIO);
56 BaseMessageLoop::BaseMessageLoop(base::MessageLoopForIO* base_loop)
110 // base::MessageLoopForIO CHECKS that "fd >= 0", so we handle that case here.
114 base::MessageLoopForIO::Mode base_mode = base::MessageLoopForIO::WATCH_READ;
117 base_mode = base::MessageLoopForIO::WATCH_READ;
120 base_mode = base::MessageLoopForIO::WATCH_WRITE;
190 // delayed_tasks_ since we can't tell base::MessageLoopForIO to not run it.
198 base::RunLoop run_loop; // Uses the base::MessageLoopForIO implicitly
    [all...]
message_loop_unittest.cc 41 std::unique_ptr<base::MessageLoopForIO> base_loop_;
58 base_loop_.reset(new base::MessageLoopForIO());
59 loop_.reset(new BaseMessageLoop(base::MessageLoopForIO::current()));
  /external/libmojo/mojo/edk/system/
channel_posix.cc 88 public base::MessageLoopForIO::Watcher {
215 new base::MessageLoopForIO::FileDescriptorWatcher(FROM_HERE));
218 base::MessageLoopForIO::current()->WatchFileDescriptor(
220 base::MessageLoopForIO::WATCH_READ, read_watcher_.get(), this);
223 new base::MessageLoopForIO::FileDescriptorWatcher(FROM_HERE));
224 base::MessageLoopForIO::current()->WatchFileDescriptor(
226 base::MessageLoopForIO::WATCH_READ, read_watcher_.get(), this);
244 base::MessageLoopForIO::current()->WatchFileDescriptor(
246 base::MessageLoopForIO::WATCH_WRITE, write_watcher_.get(), this);
276 // base::MessageLoopForIO::Watcher
    [all...]
channel_win.cc 74 public base::MessageLoopForIO::IOHandler {
153 base::MessageLoopForIO::current()->RegisterIOHandler(
216 void OnIOCompleted(base::MessageLoopForIO::IOContext* context,
329 base::MessageLoopForIO::IOContext connect_context_;
330 base::MessageLoopForIO::IOContext read_context_;
331 base::MessageLoopForIO::IOContext write_context_;
  /external/libchrome/base/message_loop/
message_loop.h 98 // MessageLoopForIO.
554 // MessageLoopForIO extends MessageLoop with methods that are particular to a
558 // MessageLoopForIO::current()->...call some method...
560 class BASE_EXPORT MessageLoopForIO : public MessageLoop {
562 MessageLoopForIO() : MessageLoop(TYPE_IO) {
565 // Returns the MessageLoopForIO of the current thread.
566 static MessageLoopForIO* current() {
568 DCHECK(loop) << "Can't call MessageLoopForIO::current() when no message "
570 " MessageLoop::current() or MessageLoopForIO::IsCurrent().";
572 return static_cast<MessageLoopForIO*>(loop)
    [all...]
message_loop_unittest.cc 481 class TestIOHandler : public MessageLoopForIO::IOHandler {
485 void OnIOCompleted(MessageLoopForIO::IOContext* context,
496 MessageLoopForIO::IOContext context_;
512 MessageLoopForIO::current()->RegisterIOHandler(file_.Get(), this);
521 void TestIOHandler::OnIOCompleted(MessageLoopForIO::IOContext* context,
528 EXPECT_TRUE(MessageLoopForIO::current()->WaitForIOCompletion(300, this));
529 EXPECT_TRUE(MessageLoopForIO::current()->WaitForIOCompletion(400, this));
732 class QuitDelegate : public MessageLoopForIO::Watcher {
755 MessageLoopForIO::FileDescriptorWatcher controller(FROM_HERE);
757 MessageLoopForIO message_loop
    [all...]
message_loop.cc 642 // MessageLoopForIO
647 void MessageLoopForIO::RegisterIOHandler(HANDLE file, IOHandler* handler) {
651 bool MessageLoopForIO::RegisterJobObject(HANDLE job, IOHandler* handler) {
655 bool MessageLoopForIO::WaitForIOCompletion(DWORD timeout, IOHandler* filter) {
659 bool MessageLoopForIO::WatchFileDescriptor(int fd,
  /external/libbrillo/brillo/http/
http_transport_curl.cc 34 class Transport::SocketPollData : public base::MessageLoopForIO::Watcher {
47 base::MessageLoopForIO::FileDescriptorWatcher* GetWatcher() {
52 // Overrides from base::MessageLoopForIO::Watcher.
83 base::MessageLoopForIO::FileDescriptorWatcher file_descriptor_watcher_;
207 base::MessageLoopForIO::current()->task_runner()->PostTask(
357 base::MessageLoopForIO::current()->task_runner()->
362 base::MessageLoopForIO::Mode watch_mode = base::MessageLoopForIO::WATCH_READ;
365 watch_mode = base::MessageLoopForIO::WATCH_READ;
368 watch_mode = base::MessageLoopForIO::WATCH_WRITE
    [all...]
http_transport_curl_unittest.cc 193 base::MessageLoopForIO message_loop;
  /frameworks/native/services/nativeperms/
nativeperms.cpp 78 base::MessageLoopForIO messageLoopForIo;
79 brillo::BaseMessageLoop messageLoop{&messageLoopForIo};
  /external/libyuv/files/tools/ubsan/
vptr_blacklist.txt 17 type:*base*MessageLoopForIO*
  /system/tpm/trunks/
background_command_transceiver_test.cc 75 base::MessageLoopForIO message_loop_;
  /external/libchrome/base/threading/
thread.cc 303 // Allow threads running a MessageLoopForIO to use FileDescriptorWatcher API.
305 if (MessageLoopForIO::IsCurrent()) {
306 DCHECK_EQ(message_loop_, MessageLoopForIO::current());
308 new FileDescriptorWatcher(MessageLoopForIO::current()));
  /external/libbrillo/brillo/
asynchronous_signal_handler_unittest.cc 41 base::MessageLoopForIO base_loop_;
process_reaper_unittest.cc 55 base::MessageLoopForIO base_loop_;
  /external/libchrome/dbus/
bus.cc 64 base::MessageLoopForIO::Mode mode = base::MessageLoopForIO::WATCH_READ;
66 mode = base::MessageLoopForIO::WATCH_READ_WRITE;
68 mode = base::MessageLoopForIO::WATCH_READ;
70 mode = base::MessageLoopForIO::WATCH_WRITE;
75 const bool success = base::MessageLoopForIO::current()->WatchFileDescriptor(
    [all...]
  /system/update_engine/client_library/
client_dbus.cc 195 if (!base::MessageLoopForIO::current()) {
  /system/update_engine/common/
subprocess_unittest.cc 72 base::MessageLoopForIO base_loop_;
  /system/update_engine/payload_consumer/
postinstall_runner_action_unittest.cc 145 base::MessageLoopForIO base_loop_;
  /system/update_engine/
p2p_manager_unittest.cc 91 base::MessageLoopForIO base_loop_;

Completed in 2530 milliseconds

1 2