pelican/examples/tutorial/src/SignalProcessingPipeline.cpp
// Defines a single iteration of the pipeline.
Defines a single iteration of the pipeline.
Defines a single iteration of the pipeline .
void SignalProcessingPipeline::run(QHash<QString, DataBlob*>& remoteData)
{
    SignalData* inputData = (SignalData*) remoteData["SignalData"];
    dataOutput(inputData, "pre");
    amplifier->run(inputData, outputData);
    dataOutput(outputData, "post");
    if (counter%10 == 0)
        std::cout << counter << " Chunks processed." << std::endl;
    counter++;
}
void SignalProcessingPipeline :: run ( QHash < QString , DataBlob * > & remoteData ) { SignalData * inputData = ( SignalData * ) remoteData [ " " ] ; dataOutput ( inputData , " " ) ; amplifier -> run ( inputData , outputData ) ; dataOutput ( outputData , " " ) ; if ( counter % 10 == 0 ) std :: cout << counter << " " << std :: endl ; counter ++ ; }
Defines a single iteration of the pipeline.
Defines a single iteration of the pipeline .
// Get pointers to the remote data blob(s) from the supplied hash. // Output the input data. // Run each module as required. // Output the processed data.