Lines Matching refs:pipe
33 ::pipe(fds); in Pipe()
97 DelayedWriteSignal(int delayMillis, Pipe* pipe) : in DelayedWriteSignal() argument
98 DelayedTask(delayMillis), mPipe(pipe) { in DelayedWriteSignal()
218 Pipe pipe; in TEST_F() local
221 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
236 Pipe pipe; in TEST_F() local
239 ASSERT_EQ(OK, pipe.writeSignal()); in TEST_F()
240 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
252 EXPECT_EQ(pipe.receiveFd, handler.fd) in TEST_F()
259 Pipe pipe; in TEST_F() local
262 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
277 Pipe pipe; in TEST_F() local
280 pipe.writeSignal(); in TEST_F()
281 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
287 ASSERT_EQ(OK, pipe.readSignal()) in TEST_F()
295 EXPECT_EQ(pipe.receiveFd, handler.fd) in TEST_F()
302 Pipe pipe; in TEST_F() local
304 sp<DelayedWriteSignal> delayedWriteSignal = new DelayedWriteSignal(100, & pipe); in TEST_F()
306 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
313 ASSERT_EQ(OK, pipe.readSignal()) in TEST_F()
321 EXPECT_EQ(pipe.receiveFd, handler.fd) in TEST_F()
328 Pipe pipe; in TEST_F() local
331 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
332 pipe.writeSignal(); // would cause FD to be considered signalled in TEST_F()
333 mLooper->removeFd(pipe.receiveFd); in TEST_F()
339 ASSERT_EQ(OK, pipe.readSignal()) in TEST_F()
350 Pipe pipe; in TEST_F() local
353 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
356 pipe.writeSignal(); in TEST_F()
362 ASSERT_EQ(OK, pipe.readSignal()) in TEST_F()
372 pipe.writeSignal(); in TEST_F()
378 ASSERT_EQ(OK, pipe.readSignal()) in TEST_F()
392 Pipe pipe; in TEST_F() local
394 pipe.writeSignal(); in TEST_F()
395 mLooper->addFd(pipe.receiveFd, expectedIdent, Looper::EVENT_INPUT, nullptr, expectedData); in TEST_F()
404 ASSERT_EQ(OK, pipe.readSignal()) in TEST_F()
410 EXPECT_EQ(pipe.receiveFd, fd) in TEST_F()
419 Pipe pipe; in TEST_F() local
420 int result = mLooper->addFd(pipe.receiveFd, 0, Looper::EVENT_INPUT, nullptr, nullptr); in TEST_F()
427 Pipe pipe; in TEST_F() local
428 int result = mLooper->addFd(pipe.receiveFd, -1, Looper::EVENT_INPUT, nullptr, nullptr); in TEST_F()
435 Pipe pipe; in TEST_F() local
437 int result = looper->addFd(pipe.receiveFd, 0, 0, nullptr, nullptr); in TEST_F()
451 Pipe pipe; in TEST_F() local
453 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
456 int result = mLooper->removeFd(pipe.receiveFd); in TEST_F()
462 result = mLooper->removeFd(pipe.receiveFd); in TEST_F()
469 Pipe pipe; in TEST_F() local
473 handler1.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
474 handler2.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); // replace it in TEST_F()
475 pipe.writeSignal(); // would cause FD to be considered signalled in TEST_F()
481 ASSERT_EQ(OK, pipe.readSignal()) in TEST_F()