#include <ProxyMgr.h>

Inheritance diagram for ProxyCombinedResultMsg:

Static Public Member Functions
static ProxyCombinedResultRawMsg *	toRaw (ProxyCombinedResultMsg *msg)

static ProxyCombinedResultMsg *	fromRaw (ProxyCombinedResultRawMsg *msg)

Public Attributes
PatchID	patch

NodeIDList	nodes

ForceList *	forceList [Results::maxNumForces]

Detailed Description

Definition at line 239 of file ProxyMgr.h.

Member Function Documentation

◆ fromRaw()

ProxyCombinedResultMsg * ProxyCombinedResultMsg::fromRaw ( ProxyCombinedResultRawMsg * msg )

static

Definition at line 302 of file ProxyMgr.C.

References ResizeArray< Elem >::add(), ResizeArray< Elem >::begin(), ComputeGlobalResultsMsg::f, ProxyCombinedResultRawMsg::flLen, ProxyCombinedResultRawMsg::forceArr, forceList, ProxyCombinedResultRawMsg::isForceNonZero, Results::maxNumForces, ProxyCombinedResultRawMsg::nodes, nodes, ProxyCombinedResultRawMsg::nodeSize, ProxyCombinedResultRawMsg::patch, patch, ResizeArray< Elem >::resize(), Vector::x, Vector::y, and Vector::z.

Referenced by ProxyPatch::depositCombinedResultRawMsg().

                                                                                       {
 
   //CkPrintf("[%d]: unpacking: plainData=%p\n", CkMyPe(), ptr->plainData);      
 
   void *vmsg = CkAllocBuffer(ptr,sizeof(ProxyCombinedResultMsg));
   ProxyCombinedResultMsg *msg = new (vmsg) ProxyCombinedResultMsg;
 
   for (int i=0; i<ptr->nodeSize; i++) {
     msg->nodes.add(ptr->nodes[i]);
   }
   #if defined(NODEAWARE_PROXY_SPANNINGTREE) && defined(USE_NODEPATCHMGR)
   msg->destPe = ptr->destPe;
   #if CMK_SMP && defined(NAMDSRC_IMMQD_HACK)
   msg->isFromImmMsgCall = ptr->isFromImmMsgCall;
   #endif
   #endif
   msg->patch = ptr->patch;
 
   char *nonzero = ptr->isForceNonZero;
   Force* farr = ptr->forceArr;
 
   for ( int j = 0; j < Results::maxNumForces; ++j ) {
     int array_size = ptr->flLen[j];
     msg->forceList[j] = &(msg->forceListInternal[j]);
     msg->forceList[j]->resize(array_size);
     Force* f = msg->forceList[j]->begin();
 
     for ( int i = 0; i < array_size; ++i, nonzero++ ) {
       if ( *nonzero ) {
                 f[i].x = farr->x;
                 f[i].y = farr->y;
                 f[i].z = farr->z;
                 farr++;
       } else {
         f[i].x = 0.;  f[i].y = 0.;  f[i].z = 0.;
       }
     }
   }
 
   delete ptr;
   return msg;
 }

◆ toRaw()

ProxyCombinedResultRawMsg * ProxyCombinedResultMsg::toRaw ( ProxyCombinedResultMsg * msg )

static

Definition at line 247 of file ProxyMgr.C.

References ResizeArray< Elem >::begin(), ComputeGlobalResultsMsg::f, ProxyCombinedResultRawMsg::flLen, ProxyCombinedResultRawMsg::forceArr, forceList, ProxyCombinedResultRawMsg::isForceNonZero, Results::maxNumForces, ProxyCombinedResultRawMsg::nodes, nodes, ProxyCombinedResultRawMsg::nodeSize, ProxyCombinedResultRawMsg::patch, patch, PRIORITY_SIZE, ResizeArray< Elem >::size(), Vector::x, Vector::y, and Vector::z.

Referenced by ProxyMgr::recvImmediateResults(), NodeProxyMgr::recvImmediateResults(), and ProxyMgr::sendResults().

                                                                                     {
   int totalFLLen=0;
   int nonzero_count = 0;
   int nodeSize = msg->nodes.size();
   for (int j = 0; j < Results::maxNumForces; ++j ) {
         int array_size = msg->forceList[j]->size();
     totalFLLen +=  array_size;
     Force* f = msg->forceList[j]->begin();
     for ( int i = 0; i < array_size; ++i ) {
       if ( f[i].x != 0. || f[i].y != 0. || f[i].z != 0. ) { ++nonzero_count; }
     }
   }
 
   ProxyCombinedResultRawMsg *msg_buf = new(nodeSize, totalFLLen, nonzero_count, PRIORITY_SIZE)ProxyCombinedResultRawMsg;
   //Copy envelope stuff
   {
          envelope *oenv = UsrToEnv(msg);
          envelope *nenv = UsrToEnv(msg_buf);
          CmiMemcpy(nenv->getPrioPtr(), oenv->getPrioPtr(), nenv->getPrioBytes());
   }
 
   msg_buf->nodeSize = nodeSize;
   for (int i=0; i<nodeSize; i++) {
     msg_buf->nodes[i] = msg->nodes[i];
   }
   #if defined(NODEAWARE_PROXY_SPANNINGTREE) && defined(USE_NODEPATCHMGR)
   msg_buf->destPe = msg->destPe;
   #if CMK_SMP && defined(NAMDSRC_IMMQD_HACK)
   msg_buf->isFromImmMsgCall = msg->isFromImmMsgCall;
   #endif
   #endif
   msg_buf->patch = msg->patch;
 
   Force *farr = msg_buf->forceArr;
   char *isNonZeroPtr = msg_buf->isForceNonZero;
   for ( int j = 0; j < Results::maxNumForces; ++j ) {
         int array_size = msg->forceList[j]->size();
     msg_buf->flLen[j] = array_size;
     Force* f = msg->forceList[j]->begin();
     for ( int i = 0; i < array_size; ++i , isNonZeroPtr++) {
       if ( f[i].x != 0. || f[i].y != 0. || f[i].z != 0. ) {
         *isNonZeroPtr = 1;
                 farr->x  =  f[i].x;
         farr->y  =  f[i].y;
         farr->z  =  f[i].z;
         farr ++;
       } else {
         *isNonZeroPtr = 0;
       }
     }
   }
   delete msg;
   return msg_buf;
 }