#include <ProxyMgr.h>

Inheritance diagram for PatchProxyListMsg:

Public Member Functions
	PatchProxyListMsg (int num)

Static Public Member Functions
static PatchProxyListMsg *	createPatchProxyListMsg (PatchProxyListMsg *bufs, int bufSize, ProxyListInfo info, int size)

Public Attributes
int	numPatches

int *	patchIDs

int *	proxyListLen

int *	proxyPEs

Detailed Description

Definition at line 414 of file ProxyMgr.h.

Constructor & Destructor Documentation

◆ PatchProxyListMsg()

PatchProxyListMsg::PatchProxyListMsg ( int num )

inline

Definition at line 422 of file ProxyMgr.h.

Referenced by createPatchProxyListMsg().

422 { numPatches = num; }

PatchProxyListMsg::numPatches

int numPatches

Definition: ProxyMgr.h:416

Member Function Documentation

◆ createPatchProxyListMsg()

PatchProxyListMsg * PatchProxyListMsg::createPatchProxyListMsg	(	PatchProxyListMsg **	bufs,
		int	bufSize,
		ProxyListInfo *	info,
		int	size
	)

static

Definition at line 1881 of file ProxyMgr.C.

References numPatches, ProxyListInfo::numProxies, ProxyListInfo::patchID, patchIDs, PatchProxyListMsg(), ProxyListInfo::proxyList, proxyListLen, and proxyPEs.

Referenced by NodeProxyMgr::contributeToParent().

                                                                                                                                  {
         //1. compute the total patches this node manages, and the total length of all proxy lists
         int totalPatches = 0;
         int totalProxies = 0;
         for(int i=0; i<bufSize; i++) {
                 PatchProxyListMsg *one = bufs[i];
                 totalPatches += one->numPatches;
                 for(int j=0; j<one->numPatches; j++) totalProxies += one->proxyListLen[j];
         }
         totalPatches += size;
         for(int i=0; i<size; i++) {
                 totalProxies += info[i].numProxies;
         }
 
         PatchProxyListMsg *msg = new(totalPatches, totalPatches, totalProxies, 0)PatchProxyListMsg(totalPatches);
         int msgPatchIdx = 0;
         int msgProxyPeIdx = 0;
         for(int i=0; i<bufSize; i++) {
                 PatchProxyListMsg *one = bufs[i];
                 int curPeIdx = 0;
                 for(int j=0; j<one->numPatches; j++) {
                         msg->patchIDs[msgPatchIdx] = one->patchIDs[j];
                         int curListLen = one->proxyListLen[j];
                         msg->proxyListLen[msgPatchIdx++] = curListLen;
                         memcpy(msg->proxyPEs+msgProxyPeIdx, one->proxyPEs+curPeIdx, sizeof(int)*curListLen);
                         curPeIdx += curListLen;
                         msgProxyPeIdx += curListLen;
                 }
         }
         for(int i=0; i<size; i++) {
                 msg->patchIDs[msgPatchIdx] = info[i].patchID;
                 int curListLen = info[i].numProxies;
                 msg->proxyListLen[msgPatchIdx++] = curListLen;
                 memcpy(msg->proxyPEs+msgProxyPeIdx, info[i].proxyList, sizeof(int)*curListLen);
                 msgProxyPeIdx += curListLen;
         }
         return msg;
 }