doc: Add serial to list of ci file reserved words
[charm.git] / src / ck-com / ComlibManager.h
index 9a153d39ca865df8dec7efc271fa025a9e191c77..2edfac29e0344501750dc5d7d9639c196801b0ff 100644 (file)
@@ -190,15 +190,16 @@ inline int indexCountCompare(const void *a, const void *b) {
   return 0;
 }
 
   return 0;
 }
 
-/** Used to setup a multicast tree in SectionInfo and MulticastStrategies */
-// TO BE MOVED TO MULTICAST SPECIFIC
+
+/** A class for multicast messages that contains the user message 
+    as well as a list of all destination indices and corresponding PEs 
+*/
 class ComlibMulticastMsg : public CkMcastBaseMsg, 
                public CMessage_ComlibMulticastMsg {
 class ComlibMulticastMsg : public CkMcastBaseMsg, 
                public CMessage_ComlibMulticastMsg {
-    
   public:
     int nPes;
     ComlibMulticastIndexCount *indicesCount;
   public:
     int nPes;
     ComlibMulticastIndexCount *indicesCount;
-    CkArrayIndexMax *indices;
+    CkArrayIndex *indices;
     char *usrMsg;        
 };
 
     char *usrMsg;        
 };
 
@@ -217,7 +218,7 @@ void ComlibEnd(CProxy &proxy, int iteration);
     now it is used to reset a proxy before it is reassociated with another strategy. 
  */
 inline void ComlibResetSectionProxy(CProxySection_ArrayBase &sproxy) {
     now it is used to reset a proxy before it is reassociated with another strategy. 
  */
 inline void ComlibResetSectionProxy(CProxySection_ArrayBase &sproxy) {
-  sproxy.ckGetSectionInfo().sInfo.cInfo.id = 0;
+  sproxy.ckGetSectionInfo().info.sInfo.cInfo.id = 0;
 }
 
 
 }
 
 
@@ -239,7 +240,7 @@ class ComlibManager: public CkDelegateMgr {
     /// Used to register and record events into projection
     int section_send_event;
 
     /// Used to register and record events into projection
     int section_send_event;
 
-    CkArrayIndexMax dummyArrayIndex;
+    CkArrayIndex dummyArrayIndex;
 
     /// Pointer to the converse comlib object, for efficiency over calling CkpvAccess
     ConvComlibManager *converseManager;
 
     /// Pointer to the converse comlib object, for efficiency over calling CkpvAccess
     ConvComlibManager *converseManager;
@@ -283,11 +284,11 @@ class ComlibManager: public CkDelegateMgr {
     ///bracket.
     void endIteration(int instid, int iteration);
     
     ///bracket.
     void endIteration(int instid, int iteration);
     
-    void printPeList(char* note, int *peList);
+    void printPeList(const char* note, int *peList);
 
     
     bool shouldBufferMessagesNow(int instid);
 
     
     bool shouldBufferMessagesNow(int instid);
-    void sendBufferedMessages(int instid);
+    void sendBufferedMessages(int instid, int step=-1);
     void sendBufferedMessagesAllStrategies();
 
  public:
     void sendBufferedMessagesAllStrategies();
 
  public:
@@ -309,13 +310,13 @@ class ComlibManager: public CkDelegateMgr {
     /* The delegation framework reimplemented functions */
 
     void ArraySend(CkDelegateData *pd,int ep, void *msg, 
     /* The delegation framework reimplemented functions */
 
     void ArraySend(CkDelegateData *pd,int ep, void *msg, 
-                   const CkArrayIndexMax &idx, CkArrayID a);
+                   const CkArrayIndex &idx, CkArrayID a);
     void GroupSend(CkDelegateData *pd, int ep, void *msg, int onpe, 
                    CkGroupID gid);
     void ArrayBroadcast(CkDelegateData *pd,int ep,void *m,CkArrayID a);
     void GroupBroadcast(CkDelegateData *pd,int ep,void *m,CkGroupID g);
     void ArraySectionSend(CkDelegateData *pd, int ep ,void *m, 
     void GroupSend(CkDelegateData *pd, int ep, void *msg, int onpe, 
                    CkGroupID gid);
     void ArrayBroadcast(CkDelegateData *pd,int ep,void *m,CkArrayID a);
     void GroupBroadcast(CkDelegateData *pd,int ep,void *m,CkGroupID g);
     void ArraySectionSend(CkDelegateData *pd, int ep ,void *m, 
-                                  CkArrayID a, CkSectionID &s, int opts);
+                                  int nsid, CkSectionID *s, int opts);
     CkDelegateData* ckCopyDelegateData(CkDelegateData *data); 
     CkDelegateData *DelegatePointerPup(PUP::er &p,CkDelegateData *pd);
 
     CkDelegateData* ckCopyDelegateData(CkDelegateData *data); 
     CkDelegateData *DelegatePointerPup(PUP::er &p,CkDelegateData *pd);
 
@@ -337,17 +338,17 @@ class ComlibManager: public CkDelegateMgr {
     void bracketedReceiveCount(int instid, int pe, int count, int isFirst, int step);
     void bracketedStartErrorRecoveryProcess(int instid, int step);
     void bracketedErrorDetected(int instid, int step);
     void bracketedReceiveCount(int instid, int pe, int count, int isFirst, int step);
     void bracketedStartErrorRecoveryProcess(int instid, int step);
     void bracketedErrorDetected(int instid, int step);
-    void bracketedConfirmCount(int instid);
+    void bracketedConfirmCount(int instid, int step);
     void bracketedCountConfirmed(int instid, int count, int step);
     void bracketedCountConfirmed(int instid, int count, int step);
-    void bracketedReceiveNewCount(int instid);
-    void bracketedReceiveNewPeList(int instid, int *count);
+    void bracketedReceiveNewCount(int instid, int step);
+    void bracketedReceiveNewPeList(int instid, int step, int *count);
 
 
-    void bracketedFinalBarrier(int instid);
-    void bracketedReleaseCount(int instid);
-    void bracketedReleaseBufferedMessages(int instid);
+    void bracketedFinalBarrier(int instid, int step);
+    void bracketedReleaseCount(int instid, int step);
+    void bracketedReleaseBufferedMessages(int instid, int step);
 
     void bracketedStartDiscovery(int instid);
 
     void bracketedStartDiscovery(int instid);
-    void bracketedDiscover(int instid, CkArrayID aid, CkArrayIndexMax &idx, int isSrc);
+    void bracketedDiscover(int instid, CkArrayID aid, CkArrayIndex &idx, int isSrc);
     void bracketedContributeDiscovery(int instid, int pe, int nsrc, int ndest, int step);
 
 
     void bracketedContributeDiscovery(int instid, int pe, int nsrc, int ndest, int step);