#include <AsyncSmacqModule.h>
Inheritance diagram for ThreadedSmacqModule:
Public Member Functions | |
smacq_result | produce (DtsObject, int &) |
smacq_result | consume (DtsObject, int &) |
The consume() method is called when there is new data for a module to process. It is passed a pointer to a data object and a reference to an output channel descriptor. The return code should be SMACQ_PASS if the object is not filtered out and SMACQ_FREE if it is. In addition, the return code can be OR'd with the following flags: SMACQ_ERROR specifies that there was a fatel error in the module. SMACQ_END signifies that the module wishes to never be called again. | |
ThreadedSmacqModule (smacq_init *) | |
smacq_result | produce (DtsObject, int &) |
smacq_result | consume (DtsObject, int &) |
The consume() method is called when there is new data for a module to process. It is passed a pointer to a data object and a reference to an output channel descriptor. The return code should be SMACQ_PASS if the object is not filtered out and SMACQ_FREE if it is. In addition, the return code can be OR'd with the following flags: SMACQ_ERROR specifies that there was a fatel error in the module. SMACQ_END signifies that the module wishes to never be called again. | |
ThreadedSmacqModule (smacq_init *) | |
Protected Member Functions | |
virtual smacq_result | thread (smacq_init *context)=0 |
This is the only method that subclasses should (and must) implement. It performs all of the work of the module and uses the following methods to produce and consume data. This function should not return until the module is completely finished. Return SMACQ_END or SMACQ_ERROR. | |
virtual smacq_result | thread (smacq_init *context)=0 |
This is the only method that subclasses should (and must) implement. It performs all of the work of the module and uses the following methods to produce and consume data. This function should not return until the module is completely finished. Return SMACQ_END or SMACQ_ERROR. | |
Methods used by the thread() implementation | |
DtsObject | smacq_read () |
Read a new data object to process. | |
int | smacq_flush () |
void | smacq_decision (DtsObject datum, smacq_result result) |
Register a decision regarding an input object. | |
void | smacq_write (DtsObject datum, int outchan) |
Produce a new object. | |
Methods used by the thread() implementation | |
DtsObject | smacq_read () |
Read a new data object to process. | |
int | smacq_flush () |
void | smacq_decision (DtsObject datum, smacq_result result) |
Register a decision regarding an input object. | |
void | smacq_write (DtsObject datum, int outchan) |
Produce a new object. | |
Friends | |
void | run_thread (int args, ThreadedSmacqModule *ths) |
void | run_thread (int args, ThreadedSmacqModule *ths) |