Home | History | Annotate | Download | only in tests

Lines Matching defs:mConsumer

35     InputConsumer* mConsumer;
43         mConsumer = new InputConsumer(clientChannel);
52         if (mConsumer) {
53             delete mConsumer;
54             mConsumer = NULL;
67     EXPECT_EQ(clientChannel.get(), mConsumer->getChannel().get());
92     status = mConsumer->consume(&mEventFactory, true /*consumeBatches*/, -1, &consumeSeq, &event);
114     status = mConsumer->sendFinishedSignal(seq, true);
175     status = mConsumer->consume(&mEventFactory, true /*consumeBatches*/, -1, &consumeSeq, &event);
229     status = mConsumer->sendFinishedSignal(seq, false);