Lines Matching refs:MessageLoop
7 // These are the common tests for all the brillo::MessageLoop implementations
31 using TaskId = MessageLoop::TaskId;
43 std::unique_ptr<MessageLoop> loop_;
46 // These MessageLoopSetUp() methods are used to setup each MessageLoop
71 EXPECT_FALSE(this->loop_->CancelTask(MessageLoop::kTaskIdNull));
79 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
102 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
112 // MessageLoop. This is important because only one of the two methods is
121 EXPECT_EQ(MessageLoop::kTaskIdNull, this->loop_->WatchFileDescriptor(
122 FROM_HERE, -1, MessageLoop::kWatchRead, true,
124 EXPECT_EQ(MessageLoop::kTaskIdNull, this->loop_->WatchFileDescriptor(
125 FROM_HERE, -1, MessageLoop::kWatchWrite, true,
135 FROM_HERE, pipe.reader, MessageLoop::kWatchRead, true,
137 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
154 FROM_HERE, pipe.reader, MessageLoop::kWatchRead, true,
156 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
172 FROM_HERE, pipe.reader, MessageLoop::kWatchRead, true,
174 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
189 FROM_HERE, pipe.reader, MessageLoop::kWatchRead, false,
191 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
208 FROM_HERE, socks.left, MessageLoop::kWatchRead, true,
213 EXPECT_NE(MessageLoop::kTaskIdNull, read_task_id);
216 FROM_HERE, socks.left, MessageLoop::kWatchWrite, true,
220 EXPECT_NE(MessageLoop::kTaskIdNull, write_task_id);
231 MessageLoop* loop_ptr = this->loop_.get();
247 FROM_HERE, pipe.writer, MessageLoop::kWatchWrite, false /* persistent */,
250 task_id = MessageLoop::kTaskIdNull;
252 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
254 EXPECT_EQ(MessageLoop::kTaskIdNull, task_id);
262 FROM_HERE, pipe.writer, MessageLoop::kWatchWrite, true /* persistent */,
265 task_id = MessageLoop::kTaskIdNull;
267 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
269 EXPECT_EQ(MessageLoop::kTaskIdNull, task_id);
283 FROM_HERE, pipes[i].writer, MessageLoop::kWatchWrite,
290 task_ids[j] = MessageLoop::kTaskIdNull;
296 EXPECT_EQ(MessageLoop::kTaskIdNull, task_ids[i]);
311 MessageLoop::TaskId timeout_task;
325 MessageLoop::TaskId tasks[kNumTasks];
339 FROM_HERE, pipes[i].reader, MessageLoop::kWatchRead,
