CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
MessageReceiverForSource.h
Go to the documentation of this file.
1 #ifndef FWCore_Framework_MessageReceiverForSource_h
2 #define FWCore_Framework_MessageReceiverForSource_h
3 // -*- C++ -*-
4 //
5 // Package: Framework
6 // Class : MessageReceiverForSource
7 //
16 //
17 // Original Author: Chris Jones
18 // Created: Thu Dec 30 10:09:44 CST 2010
19 // $Id: MessageReceiverForSource.h,v 1.1 2011/01/02 19:50:59 chrjones Exp $
20 //
21 
22 // system include files
23 
24 // user include files
26 
27 // forward declarations
28 namespace edm {
29  namespace multicore {
31  {
32 
33  public:
35  MessageReceiverForSource(int iQueueID);
36  //MessageReceiverForSource(unsigned int iChildIndex, unsigned int iNumberOfChildren, unsigned int iNumberOfSequentialEvents);
37  //virtual ~MessageReceiverForSource();
38 
39  // ---------- const member functions ---------------------
40 
41  // ---------- static member functions --------------------
42 
43  // ---------- member functions ---------------------------
44 
46  void receive();
47 
49  unsigned long startIndex() const {
50  return m_startIndex;
51  }
55  unsigned long numberOfConsecutiveIndices() const {
57  }
60  unsigned long numberToSkip() const {
61  return m_numberToSkip;
62  }
63 
64  private:
65  MessageReceiverForSource(const MessageReceiverForSource&); // stop default
66 
67  const MessageReceiverForSource& operator=(const MessageReceiverForSource&); // stop default
68 
69  // ---------- member data --------------------------------
70  int m_queueID;
71  unsigned long m_startIndex;
73  unsigned long m_numberToSkip;
74 
75  };
76  }
77 }
78 
79 
80 #endif
MessageReceiverForSource(int iQueueID)
Takes the ID of the posix message queue used for the messages.
unsigned long startIndex() const
After calling receive this holds the index to the first event to process.
const MessageReceiverForSource & operator=(const MessageReceiverForSource &)