#include <ProxyMgr.h>

Inheritance diagram for ProxyNodeAwareSpanningTreeMsg:

Public Member Functions
void	printOut (char *tag)

Static Public Member Functions
static ProxyNodeAwareSpanningTreeMsg *	getANewMsg (PatchID pid, NodeID nid, proxyTreeNode *tree, int size)

Public Attributes
PatchID	patch

NodeID	procID

int	numNodesWithProxies

int *	numPesOfNode

int *	allPes

Detailed Description

Definition at line 201 of file ProxyMgr.h.

Member Function Documentation

◆ getANewMsg()

ProxyNodeAwareSpanningTreeMsg * ProxyNodeAwareSpanningTreeMsg::getANewMsg	(	PatchID	pid,
		NodeID	nid,
		proxyTreeNode *	tree,
		int	size
	)

static

Definition at line 196 of file ProxyMgr.C.

References allPes, numNodesWithProxies, proxyTreeNode::numPes, numPesOfNode, patch, proxyTreeNode::peIDs, and procID.

Referenced by ProxyMgr::sendNodeAwareSpanningTreeToHomePatch().

                                                                                                                               {
     int numAllPes = 0;
     for(int i=0; i<size; i++) {
         numAllPes += tree[i].numPes;
     }
     ProxyNodeAwareSpanningTreeMsg *retmsg = new(size, numAllPes, 0) ProxyNodeAwareSpanningTreeMsg;
     retmsg->patch = pid;
     retmsg->procID = nid;
     retmsg->numNodesWithProxies = size;
     int *pAllPes = retmsg->allPes;
     for(int i=0; i<size; i++) {
         retmsg->numPesOfNode[i] = tree[i].numPes;
         for(int j=0; j<tree[i].numPes; j++) {
             *pAllPes = tree[i].peIDs[j];
             pAllPes++;
         }
     }
     return retmsg;
 }

◆ printOut()

void ProxyNodeAwareSpanningTreeMsg::printOut ( char * tag )

Definition at line 217 of file ProxyMgr.C.

References allPes, numNodesWithProxies, numPesOfNode, patch, and procID.

Referenced by ProxyMgr::recvNodeAwareSpanningTree().

                                                      {
 #ifdef PROCTRACE_DEBUG
     DebugFileTrace *dft = DebugFileTrace::Object();
     dft->openTrace();
     const char *patchname = "ProxyPatch";
     if(procID == CkMyPe()) patchname = "HomePatch";
     dft->writeTrace("%s: %s[%d] on proc %d node %d has ST (src %d) with %d nodes\n", 
                     tag, patchname, patch, CkMyPe(), CkMyNode(), procID, numNodesWithProxies);
     if(numNodesWithProxies==0) {
         dft->closeTrace();
         return;
     }
     dft->writeTrace("%s: ===%d===pes/node: ", tag, patch);
     for(int i=0; i<numNodesWithProxies; i++) {
         dft->writeTrace("%d ", numPesOfNode[i]);
     }
     dft->writeTrace("\n%s: ===%d===pe list: ", tag, patch);
     int *p = allPes;
     for(int i=0; i<numNodesWithProxies; i++) {
         for(int j=0; j<numPesOfNode[i]; j++) {
             dft->writeTrace("%d ", *p);
             p++;
         }
     }
     dft->writeTrace("\n");    
     dft->closeTrace();
 #endif
 }