Nymph  v1.5.2
Flow-Based Data Processing Framework
KTDataQueueProcessor.cc
Go to the documentation of this file.
1 /*
2  * KTDataQueueProcessor.cc
3  *
4  * Created on: Feb 5, 2013
5  * Author: nsoblath
6  */
7 
9 
10 //using std::list;
11 
12 namespace Nymph
13 {
14  KT_REGISTER_PROCESSOR(KTDataQueueProcessor, "data-queue");
15 
16  KTDataQueueProcessor::KTDataQueueProcessor(const std::string& name) :
18  fDataSignal("data", this)
19  {
21  //RegisterSlot("data-list", this, &KTDataQueueProcessor::QueueDataList);
22  }
23 
25  {
26 
27  }
28 
29  bool KTDataQueueProcessor::ConfigureSubClass(const scarab::param_node&)
30  {
31  return true;
32  }
33 
35  {
36  fDataSignal(data);
37  return;
38  }
39 
41  {
43  }
44 /*
45  void KTDataQueueProcessor::QueueDataList(list< KTDataPtr >* dataList)
46  {
47  return DoQueueDataList(dataList, &KTDataQueueProcessor::EmitDataSignal);
48  }
49 */
50 }
bool ConfigureSubClass(const scarab::param_node &node)
void RegisterSlot(std::string name, XTarget *target, XReturn(XTarget::*funcPtr)())
Definition: KTProcessor.hh:96
Generic data queue for asynchronous processing.
KT_REGISTER_PROCESSOR(KTDataQueueProcessor, "data-queue")
void EmitDataSignal(KTDataPtr data)
void QueueData(KTDataPtr &data)
KTDataQueueProcessor(const std::string &name="data-queue")
boost::shared_ptr< KTData > KTDataPtr
Definition: KTData.hh:67
Template class for creating data queueing processors.
void DoQueueData(KTDataPtr &data, void(KTDataQueueProcessor ::*func)(KTDataPtr))