ProxyPatch.h

Go to the documentation of this file.

#ifndef PROXYPATCH_H
#define PROXYPATCH_H

#include "Patch.h"

class ProxyDataMsg;
class ProxyAtomsMsg;
//class ProxyAllMsg;

#define PROXYMSGNOTBUFFERED 0
#define PROXYDATAMSGBUFFERED 1
#define PROXYALLMSGBUFFERED 2

class ProxyPatch : public Patch
{
  public:

     ProxyPatch(PatchID pd);
     virtual ~ProxyPatch(void);

     void receiveAtoms(ProxyAtomsMsg*);
     void receiveData(ProxyDataMsg*);
     void receiveAll(ProxyDataMsg*);

     void setSpanningTree(int, int*, int);
     int  getSpanningTreeParent() { return parent; }
     int  getSpanningTreeChild(int *);
     inline int getSpanningTreeNChild(void) {
        #ifdef NODEAWARE_PROXY_SPANNINGTREE
            return numChild;
        #else
            return nChild; 
        #endif
     }

    #if defined(NODEAWARE_PROXY_SPANNINGTREE) && defined(USE_NODEPATCHMGR)
     void setSTNodeChildren(int numNids, int *nids);
     int getSTNodeChild(int *nodeChildren_) {
         for(int i=0; i<numNodeChild; i++) nodeChildren_[i] = nodeChildren[i];         
         return numNodeChild; 
     }
     int getSTNNodeChild() { return numNodeChild; }
     #endif


     ProxyCombinedResultMsg *depositCombinedResultMsg(ProxyCombinedResultMsg *);

#if CMK_PERSISTENT_COMM
  private:
     PersistentHandle localphs;
#endif
  protected:

     virtual void boxClosed(int);

  private:

     void sendResults(void);

     //"proxyMsgBufferStatus" indicates whether there's a ProxyDataMsg buffered
     // and waiting to be processed, while "curProxyMsg" points to 
     // the actual msg. This msg will be freed at the next step. --Chao Mei  
     int proxyMsgBufferStatus;
     ProxyDataMsg* curProxyMsg;
     ProxyDataMsg* prevProxyMsg;

     // for spanning tree
     ProxyCombinedResultMsg *msgCBuffer;
     int parent;
#ifdef NODEAWARE_PROXY_SPANNINGTREE
     /* Moved to Patch.h */
     //int *children;
     //int numChild;
#else
     int *child; // spanning tree for recvResults()
     int nChild;
#endif
     int nWait;
     
#if defined(NODEAWARE_PROXY_SPANNINGTREE) && defined(USE_NODEPATCHMGR)
    CmiNodeLock depositLock;
#endif     
};


#endif

---