/external/chromium_org/mojo/system/ |
waiter_list_unittest.cc | 31 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 0); 42 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_WRITABLE, 1); 52 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 2); 68 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 0); 81 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_WRITABLE, 1); 95 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 2); 114 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 0); 125 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_WRITABLE, 1); 137 waiter_list.AddWaiter(thread.waiter(), MOJO_WAIT_FLAG_READABLE, 2); 158 waiter_list.AddWaiter(thread_1.waiter(), MOJO_WAIT_FLAG_READABLE, 0) [all...] |
message_pipe_endpoint.cc | 26 MojoResult MessagePipeEndpoint::AddWaiter(Waiter* /*waiter*/,
|
simple_dispatcher.cc | 39 waiter_list_.AddWaiter(waiter, flags, wake_result);
|
waiter_list.h | 34 void AddWaiter(Waiter* waiter, MojoWaitFlags flags, MojoResult wake_result);
|
message_pipe_unittest.cc | 369 mp->AddWaiter(0, &waiter, MOJO_WAIT_FLAG_WRITABLE, 0)); 372 mp->AddWaiter(0, 380 mp->AddWaiter(0, &waiter, MOJO_WAIT_FLAG_READABLE, 1)); 395 mp->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 2)); 398 mp->AddWaiter(1, 405 mp->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_WRITABLE, 3)); 413 mp->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_WRITABLE, 4)); 418 mp->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 5)); 433 mp->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 6)); 451 mp->AddWaiter(1, thread.waiter(), MOJO_WAIT_FLAG_READABLE, 0)) [all...] |
message_pipe_endpoint.h | 70 virtual MojoResult AddWaiter(Waiter* waiter,
|
waiter_test_utils.cc | 50 *result_out_ = dispatcher_->AddWaiter(&waiter_,
|
simple_dispatcher_unittest.cc | 101 d->AddWaiter(&w, MOJO_WAIT_FLAG_READABLE, 0)); 107 EXPECT_EQ(MOJO_RESULT_OK, d->AddWaiter(&w, MOJO_WAIT_FLAG_WRITABLE, 1)); 118 EXPECT_EQ(MOJO_RESULT_OK, d->AddWaiter(&w, MOJO_WAIT_FLAG_WRITABLE, 2)); 129 EXPECT_EQ(MOJO_RESULT_OK, d->AddWaiter(&w, MOJO_WAIT_FLAG_WRITABLE, 3)); 140 EXPECT_EQ(MOJO_RESULT_OK, d->AddWaiter(&w, MOJO_WAIT_FLAG_WRITABLE, 4)); 151 EXPECT_EQ(MOJO_RESULT_OK, d->AddWaiter(&w, MOJO_WAIT_FLAG_WRITABLE, 4)); 174 d->AddWaiter(&w, MOJO_WAIT_FLAG_WRITABLE, 5)); 180 EXPECT_EQ(MOJO_RESULT_OK, d->AddWaiter(&w, MOJO_WAIT_FLAG_WRITABLE, 6)); 191 EXPECT_EQ(MOJO_RESULT_OK, d->AddWaiter(&w, MOJO_WAIT_FLAG_WRITABLE, 6)); 203 EXPECT_EQ(MOJO_RESULT_OK, d->AddWaiter(&w, MOJO_WAIT_FLAG_WRITABLE, 7)) [all...] |
message_pipe_dispatcher_unittest.cc | 55 d_0->AddWaiter(&w, MOJO_WAIT_FLAG_WRITABLE, 0)); 62 d_0->AddWaiter(&w, MOJO_WAIT_FLAG_READABLE, 1)); 77 d_0->AddWaiter(&w, MOJO_WAIT_FLAG_READABLE, 2)); 93 d_0->AddWaiter(&w, MOJO_WAIT_FLAG_READABLE, 3)); 103 d_0->AddWaiter(&w, MOJO_WAIT_FLAG_READABLE, 3)); 183 d_0->AddWaiter(&w, MOJO_WAIT_FLAG_READABLE, 0)); 199 d_0->AddWaiter(&w, MOJO_WAIT_FLAG_READABLE, 1)); 214 d_0->AddWaiter(&w, MOJO_WAIT_FLAG_READABLE, 2)); 229 d_0->AddWaiter(&w, MOJO_WAIT_FLAG_READABLE, 3)); 234 d_0->AddWaiter(&w, MOJO_WAIT_FLAG_WRITABLE, 4)) [all...] |
local_message_pipe_endpoint.h | 45 virtual MojoResult AddWaiter(Waiter* waiter,
|
message_pipe.h | 60 MojoResult AddWaiter(unsigned port,
|
waiter_list.cc | 39 void WaiterList::AddWaiter(Waiter* waiter,
|
remote_message_pipe_posix_unittest.cc | 193 mp_1->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 123)); 219 mp_0->AddWaiter(0, &waiter, MOJO_WAIT_FLAG_READABLE, 456)); 246 MojoResult result = mp_1->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 789); 290 mp_3->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 789)); 335 mp_1->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 123)); 411 mp_1->AddWaiter(1, &waiter, MOJO_WAIT_FLAG_READABLE, 123));
|
local_message_pipe_endpoint.cc | 171 MojoResult LocalMessagePipeEndpoint::AddWaiter(Waiter* waiter, 181 waiter_list_.AddWaiter(waiter, flags, wake_result);
|
message_pipe_dispatcher.cc | 92 return message_pipe_->AddWaiter(port_, waiter, flags, wake_result);
|
dispatcher_unittest.cc | 59 d->AddWaiter(&w, MOJO_WAIT_FLAG_EVERYTHING, 0)); 84 d->AddWaiter(&w, MOJO_WAIT_FLAG_EVERYTHING, 0)); 171 MojoResult r = dispatcher_->AddWaiter(&waiter_,
|
dispatcher.h | 82 MojoResult AddWaiter(Waiter* waiter,
|
data_pipe.cc | 105 producer_waiter_list_->AddWaiter(waiter, flags, wake_result); 207 consumer_waiter_list_->AddWaiter(waiter, flags, wake_result);
|
message_pipe.cc | 95 MojoResult MessagePipe::AddWaiter(unsigned port, 104 return endpoints_[port]->AddWaiter(waiter, flags, wake_result);
|
dispatcher.cc | 110 MojoResult Dispatcher::AddWaiter(Waiter* waiter,
|
multiprocess_message_pipe_unittest.cc | 138 MojoResult add_result = mp->AddWaiter(0, &waiter, flags, MOJO_RESULT_OK);
|
core_impl.cc | 540 rv = dispatchers[i]->AddWaiter(&waiter,
|