| 336 | } |
| 337 | |
| 338 | inline bool Engine::flushStep(ProcessFlow::Node& step) { |
| 339 | if (step.v.m_component!=NULL) { |
| 340 | #ifdef DEBUG |
| 341 | if (verboseFlag) { |
| 342 | cerr << "flush step " << step.v.m_component->getIdentifier() << endl; |
| 343 | } |
| 344 | #endif |
| 345 | |
| 346 | #ifdef WITH_TIMERS |
| 347 | Timer* t = Timer::get_timer(step.v.m_component->getIdentifier()); |
| 348 | t->start(); |
| 349 | step.v.m_component->flush(step.v.m_input, step.v.m_output); |
| 350 | t->stop(); |
| 351 | #else |
| 352 | step.v.m_component->flush(step.v.m_input, step.v.m_output); |
| 353 | #endif |
| 354 | } |
| 355 | for (int i=0;i<step.v.m_output.size();i++) |
| 356 | step.v.m_output[i].data->flush(); |
| 357 | return true; |
| 358 | } |
| 359 | |
| 360 | void Engine::reset() { |
| 361 | m_graph->visitAll<Engine::resetStep>(); |
nothing calls this directly
no test coverage detected