ProxyCombinedResultMsg Class Reference

#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

ProxyCombinedResultMsg * ProxyCombinedResultMsg::fromRaw ( ProxyCombinedResultRawMsg *  msg )

static

Definition at line 303 of file ProxyMgr.C.

References ResizeArray< T >::add(), ResizeArray< T >::begin(), ProxyCombinedResultRawMsg::flLen, ProxyCombinedResultRawMsg::forceArr, forceList, ProxyCombinedResultRawMsg::isForceNonZero, Results::maxNumForces, ProxyCombinedResultRawMsg::nodes, nodes, ProxyCombinedResultRawMsg::nodeSize, ProxyCombinedResultRawMsg::patch, patch, ResizeArray< T >::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;
}

ProxyCombinedResultRawMsg * ProxyCombinedResultMsg::toRaw ( ProxyCombinedResultMsg *  msg )

static

Definition at line 248 of file ProxyMgr.C.

References ResizeArray< T >::begin(), ProxyCombinedResultRawMsg::flLen, ProxyCombinedResultRawMsg::forceArr, forceList, ProxyCombinedResultRawMsg::isForceNonZero, Results::maxNumForces, ProxyCombinedResultRawMsg::nodes, nodes, ProxyCombinedResultRawMsg::nodeSize, ProxyCombinedResultRawMsg::patch, patch, PRIORITY_SIZE, ResizeArray< T >::size(), Vector::x, x, Vector::y, y, Vector::z, and 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;
}

Member Data Documentation

ForceList* ProxyCombinedResultMsg::forceList[Results::maxNumForces]

Definition at line 254 of file ProxyMgr.h.

Referenced by ProxyPatch::depositCombinedResultMsg(), ProxyPatch::depositCombinedResultRawMsg(), fromRaw(), and toRaw().

NodeIDList ProxyCombinedResultMsg::nodes

Definition at line 253 of file ProxyMgr.h.

Referenced by ProxyPatch::depositCombinedResultMsg(), ProxyPatch::depositCombinedResultRawMsg(), fromRaw(), and toRaw().

PatchID ProxyCombinedResultMsg::patch

Definition at line 252 of file ProxyMgr.h.

Referenced by fromRaw(), ProxyMgr::sendResults(), and toRaw().

---

The documentation for this class was generated from the following files:

• ProxyMgr.h
• ProxyMgr.C