|
| KTDataQueueProcessorTemplate (const std::string &name="default-data-queue-proc-template-name") |
|
virtual | ~KTDataQueueProcessorTemplate () |
|
bool | Configure (const scarab::param_node &node) |
| Should perform parameter store and command-line configurations. More...
|
|
virtual bool | ConfigureSubClass (const scarab::param_node &node)=0 |
|
Status | GetStatus () const |
|
void | SetStatus (KTDataQueueProcessorTemplate< XProcessorType >::Status) |
|
void | SetFuncPtr (void(XProcessorType::*ptr)(KTDataPtr)) |
|
bool | Run () |
| Begins processing of queue (switches status from kStopped to kRunning) More...
|
|
void | Stop () |
| Stops processing of queue (switches status to kStopped) More...
|
|
bool | ProcessQueue () |
| Begins processing of queue if status is already kRunning; otherwise does nothing. More...
|
|
void | ClearQueue () |
|
void | SwitchToTimedPop () |
|
void | SwitchToUntimedPop () |
|
void | SwitchToSinglePop () |
|
| KTPrimaryProcessor (const std::string &name="default-primary-processor-name") |
|
virtual | ~KTPrimaryProcessor () |
|
virtual void | operator() () |
| Callable function used by boost::thread. More...
|
|
| KTProcessor (const std::string &name="default-proc-name") |
|
virtual | ~KTProcessor () |
|
void | ConnectASlot (const std::string &signalName, KTProcessor *processor, const std::string &slotName, int groupNum=-1) |
|
void | ConnectASignal (KTProcessor *processor, const std::string &signalName, const std::string &slotName, int groupNum=-1) |
|
void | ConnectSignalToSlot (KTSignalWrapper *signal, KTSlotWrapper *slot, int groupNum=-1) |
|
template<class XProcessor > |
void | RegisterSignal (std::string name, XProcessor *signalPtr) |
|
template<class XTarget , typename XReturn > |
void | RegisterSlot (std::string name, XTarget *target, XReturn(XTarget::*funcPtr)()) |
|
template<class XTarget , typename XReturn , typename XArg1 > |
void | RegisterSlot (std::string name, XTarget *target, XReturn(XTarget::*funcPtr)(XArg1)) |
|
template<class XTarget , typename XReturn , typename XArg1 , typename XArg2 > |
void | RegisterSlot (std::string name, XTarget *target, XReturn(XTarget::*funcPtr)(XArg1, XArg2)) |
|
KTSignalWrapper * | GetSignal (const std::string &name) |
|
KTSlotWrapper * | GetSlot (const std::string &name) |
|
template<typename XSignalSig > |
void | RegisterSignal (std::string name, XSignalSig *signalPtr) |
|
| KTConfigurable (const std::string &name="default-name") |
|
virtual | ~KTConfigurable () |
|
bool | Configure (const std::string &config) |
| Implement the option for calling Configure without passing a parameter store node. More...
|
|
const std::string & | GetConfigName () const |
|
void | SetConfigName (const std::string &name) |
|
template<class XProcessorType>
class Nymph::KTDataQueueProcessorTemplate< XProcessorType >
Template class for creating data queueing processors.
- Author
- N. S. Oblath
Available configuration values:
- "timeout": unsigned – maximum time to wait for new data (integer number of milliseconds)
Slots:
- "use-timed-pop": void () – Switch the queue-popping function to the TIMED version
- "use-untimed-pop": void () – Switch the queue-popping function to the UNTIMED version
- "use-single-pop": void () – Switch to the single-pop queue-popping function
Signals:
- "queue-done": void () – Emitted when queue is emptied
Definition at line 46 of file KTDataQueueProcessor.hh.