Lines Matching defs:injector

32     source_->injector = this;
97 EventInjector* injector;
114 *timeout_ms = static_cast<Source*>(source)->injector->HandlePrepare();
119 return static_cast<Source*>(source)->injector->HandleCheck();
125 static_cast<Source*>(source)->injector->HandleDispatch();
147 // Checks how many events have been processed by the injector.
148 void ExpectProcessedEvents(EventInjector* injector, int count) {
149 EXPECT_EQ(injector->processed_events(), count);
176 EventInjector* injector() const { return injector_; }
191 EXPECT_EQ(0, injector()->processed_events());
193 injector()->Reset();
195 injector()->AddEvent(0, MessageLoop::QuitWhenIdleClosure());
197 EXPECT_EQ(1, injector()->processed_events());
208 injector()->AddEventAsTask(0, Bind(&DoNothing));
210 Bind(&ExpectProcessedEvents, Unretained(injector()), 2);
213 injector()->AddEventAsTask(0, posted_task);
214 injector()->AddEventAsTask(0, Bind(&DoNothing));
215 injector()->AddEvent(0, MessageLoop::QuitWhenIdleClosure());
217 EXPECT_EQ(4, injector()->processed_events());
219 injector()->Reset();
220 injector()->AddEventAsTask(0, Bind(&DoNothing));
222 Bind(&ExpectProcessedEvents, Unretained(injector()), 2);
224 injector()->AddEventAsTask(0, posted_task);
225 injector()->AddEventAsTask(10, Bind(&DoNothing));
226 injector()->AddEvent(0, MessageLoop::QuitWhenIdleClosure());
228 EXPECT_EQ(4, injector()->processed_events());
242 Bind(&EventInjector::AddEvent, Unretained(injector()), 0,
246 EXPECT_EQ(1, injector()->processed_events());
249 injector()->Reset();
263 Bind(&EventInjector::AddEvent, Unretained(injector()), 10,
268 EXPECT_EQ(1, injector()->processed_events());
275 injector()->AddDummyEvent(0);
281 Bind(&ExpectProcessedEvents, Unretained(injector()), 11);
284 injector()->AddEventAsTask(10, posted_task);
287 injector()->AddEvent(10, MessageLoop::QuitWhenIdleClosure());
290 EXPECT_EQ(12, injector()->processed_events());
300 explicit ConcurrentHelper(EventInjector* injector)
301 : injector_(injector),
354 scoped_refptr<ConcurrentHelper> helper = new ConcurrentHelper(injector());
358 injector()->AddEventAsTask(
360 injector()->AddEventAsTask(
376 void AddEventsAndDrainGLib(EventInjector* injector) {
378 injector->AddDummyEvent(0);
379 injector->AddDummyEvent(0);
381 injector->AddEvent(0, MessageLoop::QuitWhenIdleClosure());
399 Bind(&AddEventsAndDrainGLib, Unretained(injector())));
402 EXPECT_EQ(3, injector()->processed_events());
440 void TestGLibLoopInternal(EventInjector* injector) {
447 injector->AddDummyEvent(0);
448 injector->AddDummyEvent(0);
455 injector->AddDummyEvent(10);
456 injector->AddDummyEvent(10);
471 EXPECT_EQ(4, injector->processed_events());
475 void TestGtkLoopInternal(EventInjector* injector) {
482 injector->AddDummyEvent(0);
483 injector->AddDummyEvent(0);
490 injector->AddDummyEvent(10);
491 injector->AddDummyEvent(10);
506 EXPECT_EQ(4, injector->processed_events());
519 Bind(&TestGLibLoopInternal, Unretained(injector())));
530 Bind(&TestGtkLoopInternal, Unretained(injector())));