48 using TaskId = MessageLoop::TaskId;
60   std::unique_ptr<MessageLoop> loop_;
81   EXPECT_FALSE(this->loop_->CancelTask(MessageLoop::kTaskIdNull));  in TYPED_TEST()
88   EXPECT_NE(MessageLoop::kTaskIdNull, task_id);  in TYPED_TEST()
108   EXPECT_NE(MessageLoop::kTaskIdNull, task_id);  in TYPED_TEST()
127   EXPECT_EQ(MessageLoop::kTaskIdNull, this->loop_->WatchFileDescriptor(  in TYPED_TEST()
128       FROM_HERE, -1, MessageLoop::kWatchRead, true,  in TYPED_TEST()
130   EXPECT_EQ(MessageLoop::kTaskIdNull, this->loop_->WatchFileDescriptor(  in TYPED_TEST()
131       FROM_HERE, -1, MessageLoop::kWatchWrite, true,  in TYPED_TEST()
141       FROM_HERE, pipe.reader, MessageLoop::kWatchRead, true,  in TYPED_TEST()
143   EXPECT_NE(MessageLoop::kTaskIdNull, task_id);  in TYPED_TEST()
160       FROM_HERE, pipe.reader, MessageLoop::kWatchRead, true,  in TYPED_TEST()
162   EXPECT_NE(MessageLoop::kTaskIdNull, task_id);  in TYPED_TEST()
178       FROM_HERE, pipe.reader, MessageLoop::kWatchRead, true,  in TYPED_TEST()
180   EXPECT_NE(MessageLoop::kTaskIdNull, task_id);  in TYPED_TEST()
195       FROM_HERE, pipe.reader, MessageLoop::kWatchRead, false,  in TYPED_TEST()
197   EXPECT_NE(MessageLoop::kTaskIdNull, task_id);  in TYPED_TEST()
214       FROM_HERE, socks.left, MessageLoop::kWatchRead, true,  in TYPED_TEST()
215       Bind([] (MessageLoop* loop, TaskId* read_task_id) {  in TYPED_TEST()
219   EXPECT_NE(MessageLoop::kTaskIdNull, read_task_id);  in TYPED_TEST()
222       FROM_HERE, socks.left, MessageLoop::kWatchWrite, true,  in TYPED_TEST()
223       Bind([] (MessageLoop* loop, TaskId* write_task_id) {  in TYPED_TEST()
226   EXPECT_NE(MessageLoop::kTaskIdNull, write_task_id);  in TYPED_TEST()
240       Bind([](bool* cancel_result, MessageLoop* loop, TaskId* task_id) {  in TYPED_TEST()
252       FROM_HERE, pipe.writer, MessageLoop::kWatchWrite, false /* persistent */,  in TYPED_TEST()
253       Bind([](MessageLoop* loop, TaskId* task_id) {  in TYPED_TEST()
255         *task_id = MessageLoop::kTaskIdNull;  in TYPED_TEST()
257   EXPECT_NE(MessageLoop::kTaskIdNull, task_id);  in TYPED_TEST()
259   EXPECT_EQ(MessageLoop::kTaskIdNull, task_id);  in TYPED_TEST()
267       FROM_HERE, pipe.writer, MessageLoop::kWatchWrite, true /* persistent */,  in TYPED_TEST()
268       Bind([](MessageLoop* loop, TaskId* task_id) {  in TYPED_TEST()
270         *task_id = MessageLoop::kTaskIdNull;  in TYPED_TEST()
272   EXPECT_NE(MessageLoop::kTaskIdNull, task_id);  in TYPED_TEST()
274   EXPECT_EQ(MessageLoop::kTaskIdNull, task_id);  in TYPED_TEST()
288         FROM_HERE, pipes[i].writer, MessageLoop::kWatchWrite,  in TYPED_TEST()
290         Bind([] (MessageLoop* loop, TaskId* task_ids) {  in TYPED_TEST()
295             task_ids[j] = MessageLoop::kTaskIdNull;  in TYPED_TEST()
301     EXPECT_EQ(MessageLoop::kTaskIdNull, task_ids[i]);  in TYPED_TEST()
316   MessageLoop::TaskId timeout_task;  in TYPED_TEST()
318       [](MessageLoop* loop, int* timeout_called, int* total_calls,  in TYPED_TEST()
319          base::Closure* timeout_callback, MessageLoop::TaskId* timeout_task) {  in TYPED_TEST()
333   MessageLoop::TaskId tasks[kNumTasks];  in TYPED_TEST()
337       [](MessageLoop* loop, ScopedPipe* pipes, int* reads,  in TYPED_TEST()
349         FROM_HERE, pipes[i].reader, MessageLoop::kWatchRead,  in TYPED_TEST()