00001 #ifndef FWCore_Framework_MessageReceiverForSource_h 00002 #define FWCore_Framework_MessageReceiverForSource_h 00003 // -*- C++ -*- 00004 // 00005 // Package: Framework 00006 // Class : MessageReceiverForSource 00007 // 00016 // 00017 // Original Author: Chris Jones 00018 // Created: Thu Dec 30 10:09:44 CST 2010 00019 // $Id: MessageReceiverForSource.h,v 1.2 2011/01/03 21:05:00 chrjones Exp $ 00020 // 00021 00022 // system include files 00023 00024 // user include files 00025 #include "FWCore/Framework/src/MessageForSource.h" 00026 00027 // forward declarations 00028 namespace edm { 00029 namespace multicore { 00030 class MessageReceiverForSource 00031 { 00032 00033 public: 00035 MessageReceiverForSource(int iQueueID); 00036 //MessageReceiverForSource(unsigned int iChildIndex, unsigned int iNumberOfChildren, unsigned int iNumberOfSequentialEvents); 00037 //virtual ~MessageReceiverForSource(); 00038 00039 // ---------- const member functions --------------------- 00040 00041 // ---------- static member functions -------------------- 00042 00043 // ---------- member functions --------------------------- 00044 00046 void receive(); 00047 00049 unsigned long startIndex() const { 00050 return m_startIndex; 00051 } 00055 unsigned long numberOfConsecutiveIndices() const { 00056 return m_numberOfConsecutiveIndices; 00057 } 00060 unsigned long numberToSkip() const { 00061 return m_numberToSkip; 00062 } 00063 00064 private: 00065 MessageReceiverForSource(const MessageReceiverForSource&); // stop default 00066 00067 const MessageReceiverForSource& operator=(const MessageReceiverForSource&); // stop default 00068 00069 // ---------- member data -------------------------------- 00070 int m_queueID; 00071 unsigned long m_startIndex; 00072 unsigned long m_numberOfConsecutiveIndices; 00073 unsigned long m_numberToSkip; 00074 00075 }; 00076 } 00077 } 00078 00079 00080 #endif