Lines Matching refs:pipe
44 DelayedWriteSignal(int delayMillis, Pipe* pipe) :
45 DelayedTask(delayMillis), mPipe(pipe) {
165 Pipe pipe;
168 handler.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
183 Pipe pipe;
186 ASSERT_EQ(OK, pipe.writeSignal());
187 handler.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
199 EXPECT_EQ(pipe.receiveFd, handler.fd)
200 << "callback should have received pipe fd as parameter";
206 Pipe pipe;
209 handler.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
224 Pipe pipe;
227 pipe.writeSignal();
228 handler.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
234 ASSERT_EQ(OK, pipe.readSignal())
242 EXPECT_EQ(pipe.receiveFd, handler.fd)
243 << "callback should have received pipe fd as parameter";
249 Pipe pipe;
251 sp<DelayedWriteSignal> delayedWriteSignal = new DelayedWriteSignal(100, & pipe);
253 handler.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
260 ASSERT_EQ(OK, pipe.readSignal())
268 EXPECT_EQ(pipe.receiveFd, handler.fd)
269 << "callback should have received pipe fd as parameter";
275 Pipe pipe;
278 handler.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
279 pipe.writeSignal(); // would cause FD to be considered signalled
280 mLooper->removeFd(pipe.receiveFd);
286 ASSERT_EQ(OK, pipe.readSignal())
297 Pipe pipe;
300 handler.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
303 pipe.writeSignal();
309 ASSERT_EQ(OK, pipe.readSignal())
319 pipe.writeSignal();
325 ASSERT_EQ(OK, pipe.readSignal())
339 Pipe pipe;
341 pipe.writeSignal();
342 mLooper->addFd(pipe.receiveFd, expectedIdent, ALOOPER_EVENT_INPUT, NULL, expectedData);
351 ASSERT_EQ(OK, pipe.readSignal())
357 EXPECT_EQ(pipe.receiveFd, fd)
358 << "pollOnce should have returned the received pipe fd";
366 Pipe pipe;
367 int result = mLooper->addFd(pipe.receiveFd, 0, ALOOPER_EVENT_INPUT, NULL, NULL);
374 Pipe pipe;
375 int result = mLooper->addFd(pipe.receiveFd, -1, ALOOPER_EVENT_INPUT, NULL, NULL);
382 Pipe pipe;
384 int result = looper->addFd(pipe.receiveFd, 0, 0, NULL, NULL);
398 Pipe pipe;
400 handler.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
403 int result = mLooper->removeFd(pipe.receiveFd);
409 result = mLooper->removeFd(pipe.receiveFd);
416 Pipe pipe;
420 handler1.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
421 handler2.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT); // replace it
422 pipe.writeSignal(); // would cause FD to be considered signalled
428 ASSERT_EQ(OK, pipe.readSignal())