pelican/core/test/src/TestPipeline.cpp
/**
 * @details
 * Pipeline run method (overridden virtual).
 * Defines a single iteration of the pipeline.
 */
@details
Pipeline run method (overridden virtual).
Defines a single iteration of the pipeline.
@details Pipeline run method ( overridden virtual ) . Defines a single iteration of the pipeline .
void TestPipeline::run(QHash<QString, DataBlob*>& dataHash)
{
    if (_requiredDataRemote == dataHash.keys())
        ++_matchedCounter;
    if (++_counter >= _iterations)
    {
        if( _deactivateStop ) {
            deactivate();
        }
        else {
            stop(); 
        }
    }
}
void TestPipeline :: run ( QHash < QString , DataBlob * > & dataHash ) { if ( _requiredDataRemote == dataHash . keys ( ) ) ++ _matchedCounter ; if ( ++ _counter >= _iterations ) { if ( _deactivateStop ) { deactivate ( ) ; } else { stop ( ) ; } } }
@details
 Pipeline run method (overridden virtual).
@details Pipeline run method ( overridden virtual ) .
// Print message. //cout << "Running TestPipeline, iteration " << _counter << endl; // Check the data is correct. // Increment counter and test for completion. // Stop the pipeline driver.