Communicate Class Reference

#include <Communicate.h>

Public Member Functions
	Communicate (void)
	~Communicate ()
MIStream *	newInputStream (int pe, int tag)
MOStream *	newOutputStream (int pe, int tag, unsigned int bufsize)
void *	getMessage (int PE, int tag)
void	sendMessage (int PE, void *msg, int size)

Detailed Description

Definition at line 18 of file Communicate.h.

Constructor & Destructor Documentation

Communicate()

Communicate::Communicate

(

void

)

Definition at line 32 of file Communicate.C.

References CsmAckHandler(), CsmHandler(), and split().

{
  CkpvInitialize(CmmTable, CsmMessages);
  CsmHandlerIndex = CmiRegisterHandler((CmiHandler) CsmHandler);
  CsmAckHandlerIndex = CmiRegisterHandler((CmiHandler) CsmAckHandler);
  CkpvAccess(CsmMessages) = CmmNew();

  int parent_node = 0;
  int self = CkMyNode();
  int range_begin = 0;
  int range_end = CkNumNodes();
  while ( self != range_begin ) {
    parent_node = range_begin;
    ++range_begin;
    int split = range_begin + ( range_end - range_begin ) / 2;
    if ( self < split ) { range_end = split; }
    else { range_begin = split; }
  }
  int send_near = self + 1;
  int send_far = send_near + ( range_end - send_near ) / 2;

  parent = CkNodeFirst(parent_node);
  nchildren = 0;
  if ( send_far < range_end ) children[nchildren++] = CkNodeFirst(send_far);
  if ( send_near < send_far ) children[nchildren++] = CkNodeFirst(send_near);

  CkpvInitialize(int, CsmAcks);
  CkpvAccess(CsmAcks) = nchildren;

  ackmsg = (char *) CmiAlloc(CmiMsgHeaderSizeBytes);
  CmiSetHandler(ackmsg, CsmAckHandlerIndex);
}

~Communicate()

Communicate::~Communicate

(

void

)

Definition at line 66 of file Communicate.C.

{
  CmiFree(ackmsg);
}

Member Function Documentation

getMessage()

void * Communicate::getMessage	(	int	PE,
		int	tag
	)

Definition at line 83 of file Communicate.C.

References NAMD_bug().

{
  if ( CmiMyRank() ) NAMD_bug("Communicate::getMessage called on non-rank-zero Pe\n");

  int itag[2], rtag[2];
  void *msg;

  itag[0] = (PE==(-1)) ? (CmmWildCard) : PE;
  itag[1] = (tag==(-1)) ? (CmmWildCard) : tag;
  while((msg=CmmGet(CkpvAccess(CsmMessages),2,itag,rtag))==0) {
    CmiDeliverMsgs(0);
    // CmiDeliverSpecificMsg(CsmHandlerIndex);
  }

  CmiSyncSend(parent, CmiMsgHeaderSizeBytes, ackmsg);

  while ( CkpvAccess(CsmAcks) < nchildren ) {
    CmiDeliverMsgs(0);
    // CmiDeliverSpecificMsg(CsmAckHandlerIndex);
  }
  CkpvAccess(CsmAcks) = 0;

  int size = SIZEFIELD(msg);
  for ( int i = 0; i < nchildren; ++i ) {
    CmiSyncSend(children[i],size,(char*)msg);
  }

  return msg;
}

newInputStream()

MIStream * Communicate::newInputStream	(	int	pe,
		int	tag
	)

Definition at line 71 of file Communicate.C.

{
  MIStream *st = new MIStream(this, PE, tag);
  return st;
}

newOutputStream()

MOStream * Communicate::newOutputStream	(	int	pe,
		int	tag,
		unsigned int	bufsize
	)

Definition at line 77 of file Communicate.C.

{
  MOStream *st = new MOStream(this, PE, tag, bufSize);
  return st;
}

sendMessage()

void Communicate::sendMessage	(	int	PE,
		void *	msg,
		int	size
	)

Definition at line 113 of file Communicate.C.

References ALL, ALLBUTME, and NAMD_bug().

Referenced by MOStream::end().

{
  if ( CmiMyPe() ) NAMD_bug("Communicate::sendMessage not from Pe 0");

  while ( CkpvAccess(CsmAcks) < nchildren ) {
    CmiDeliverMsgs(0);
    // CmiDeliverSpecificMsg(CsmAckHandlerIndex);
  }
  CkpvAccess(CsmAcks) = 0;

  CmiSetHandler(msg, CsmHandlerIndex);
  switch(PE) {
    case ALL:
      NAMD_bug("Unexpected Communicate::sendMessage(ALL,...)");
      //CmiSyncBroadcastAll(size, (char *)msg);
      break;
    case ALLBUTME:
      //CmiSyncBroadcast(size, (char *)msg);
      for ( int i = 0; i < nchildren; ++i ) {
        CmiSyncSend(children[i],size,(char*)msg);
      }
      break;
    default:
      NAMD_bug("Unexpected Communicate::sendMessage(PEL,...)");
      //CmiSyncSend(PE, size, (char *)msg);
      break;
  }
}

---

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

• Communicate.h
• Communicate.C