Lines Matching full:injector
27 source_->injector = this;
91 EventInjector* injector;
95 *timeout_ms = static_cast<Source*>(source)->injector->HandlePrepare();
100 return static_cast<Source*>(source)->injector->HandleCheck();
106 static_cast<Source*>(source)->injector->HandleDispatch();
132 // Checks how many events have been processed by the injector.
133 void ExpectProcessedEvents(EventInjector* injector, int count) {
134 EXPECT_EQ(injector->processed_events(), count);
171 EventInjector* injector() const { return injector_; }
190 EXPECT_EQ(0, injector()->processed_events());
192 injector()->Reset();
194 injector()->AddEvent(0, NewQuitTask());
196 EXPECT_EQ(1, injector()->processed_events());
207 injector()->AddEvent(0, NewRunnableFunction(DoNothing));
208 Task* check_task = NewRunnableFunction(ExpectProcessedEvents, injector(), 2);
211 injector()->AddEvent(0, posted_task);
212 injector()->AddEvent(0, NewRunnableFunction(DoNothing));
213 injector()->AddEvent(0, NewQuitTask());
215 EXPECT_EQ(4, injector()->processed_events());
217 injector()->Reset();
218 injector()->AddEvent(0, NewRunnableFunction(DoNothing));
219 check_task = NewRunnableFunction(ExpectProcessedEvents, injector(), 2);
221 injector()->AddEvent(0, posted_task);
222 injector()->AddEvent(10, NewRunnableFunction(DoNothing));
223 injector()->AddEvent(0, NewQuitTask());
225 EXPECT_EQ(4, injector()->processed_events());
238 FROM_HERE, NewRunnableMethod(injector(), &EventInjector::AddEvent,
242 EXPECT_EQ(1, injector()->processed_events());
245 injector()->Reset();
256 FROM_HERE, NewRunnableMethod(injector(), &EventInjector::AddEvent,
260 EXPECT_EQ(1, injector()->processed_events());
267 injector()->AddEvent(0, NULL);
272 Task* check_task = NewRunnableFunction(ExpectProcessedEvents, injector(), 11);
275 injector()->AddEvent(10, posted_task);
278 injector()->AddEvent(10, NewQuitTask());
281 EXPECT_EQ(12, injector()->processed_events());
291 explicit ConcurrentHelper(EventInjector* injector)
292 : injector_(injector),
345 scoped_refptr<ConcurrentHelper> helper = new ConcurrentHelper(injector());
349 injector()->AddEvent(
351 injector()->AddEvent(
367 void AddEventsAndDrainGLib(EventInjector* injector) {
369 injector->AddEvent(0, NULL);
370 injector->AddEvent(0, NULL);
372 injector->AddEvent(0, NewQuitTask());
389 FROM_HERE, NewRunnableFunction(AddEventsAndDrainGLib, injector()));
392 EXPECT_EQ(3, injector()->processed_events());
398 void AddEventsAndDrainGtk(EventInjector* injector) {
400 injector->AddEvent(0, NULL);
401 injector->AddEvent(0, NULL);
403 injector->AddEvent(0, NewQuitTask());
420 FROM_HERE, NewRunnableFunction(AddEventsAndDrainGtk, injector()));
423 EXPECT_EQ(3, injector()->processed_events());
461 void TestGLibLoopInternal(EventInjector* injector) {
468 injector->AddEvent(0, NULL);
469 injector->AddEvent(0, NULL);
476 injector->AddEvent(10, NULL);
477 injector->AddEvent(10, NULL);
488 EXPECT_EQ(4, injector->processed_events());
492 void TestGtkLoopInternal(EventInjector* injector) {
499 injector->AddEvent(0, NULL);
500 injector->AddEvent(0, NULL);
507 injector->AddEvent(10, NULL);
508 injector->AddEvent(10, NULL);
519 EXPECT_EQ(4, injector->processed_events());
531 NewRunnableFunction(TestGLibLoopInternal, injector()));
541 NewRunnableFunction(TestGtkLoopInternal, injector()));
