BroadcastMgr Class Reference

#include <BroadcastMgr.h>

Inheritance diagram for BroadcastMgr:

Public Member Functions
	BroadcastMgr ()
	~BroadcastMgr (void)
int	getbuf (BroadcastClient &b, int tag, void *msg)
void	send (BroadcastClient &b, int tag, void *buf, size_t)
void	subscribe (BroadcastClient &bc)
void	unsubscribe (BroadcastClient &bc)
void	recvBroadcast (BroadcastMsg *msg)

Static Public Member Functions
static BroadcastMgr *	Object ()

Detailed Description

Definition at line 87 of file BroadcastMgr.h.

Constructor & Destructor Documentation

BroadcastMgr::BroadcastMgr ( )

inline

Definition at line 90 of file BroadcastMgr.h.

                 { 
    CkpvAccess(BroadcastMgr_instance) = this; 
  }

BroadcastMgr::~BroadcastMgr

(

void

)

Definition at line 18 of file BroadcastMgr.C.

References UniqueSetIter< Type >::begin(), and UniqueSetIter< Type >::end().

                                {
  UniqueSetIter<BOID> boidIter(boid);
  for (boidIter = boidIter.begin(); boidIter != boidIter.end(); boidIter++) {
    delete boidIter->broadcastSet;
    if (boidIter->taggedMsg) {
      delete boidIter->taggedMsg;
    }
  }
}

Member Function Documentation

int BroadcastMgr::getbuf	(	BroadcastClient &	b,
		int	tag,
		void *	msg
	)

Definition at line 30 of file BroadcastMgr.C.

References TaggedMsg::counter, UniqueSet< Elem >::find(), BroadcastClient::id, TaggedMsg::msg, TaggedMsg::msgSize, and BOID::taggedMsg.

                                                           {
  int rval = -1;
  TaggedMsg *tm;
  BOID* boidTmp = boid.find(BOID(b.id));
  if (!boidTmp) {
    return(-2);
  }
  if ( (tm = (boidTmp->taggedMsg->find(TaggedMsg(tag)))) ) {
    rval = tm->msgSize;
    memcpy(msg, tm->msg, tm->msgSize);
    if (!--(tm->counter)) {
      (boid.find(BOID(b.id)))->taggedMsg->del(TaggedMsg(tag));
    }
  }
  return(rval);
}

static BroadcastMgr* BroadcastMgr::Object ( )

inlinestatic

Definition at line 96 of file BroadcastMgr.h.

Referenced by BroadcastClient::BroadcastClient(), SimpleBroadcastObject< Tensor >::get(), SimpleBroadcastObject< Tensor >::publish(), and BroadcastClient::~BroadcastClient().

                                       {
    return CkpvAccess(BroadcastMgr_instance);
  }

void BroadcastMgr::recvBroadcast

(

BroadcastMsg *

msg

)

Definition at line 86 of file BroadcastMgr.C.

References UniqueSet< Elem >::add(), UniqueSetIter< Type >::begin(), BOID::broadcastSet, UniqueSetIter< Type >::end(), UniqueSet< Elem >::find(), NAMD_bug(), UniqueSet< Elem >::size(), and BOID::taggedMsg.

                                             {
  BOID *b;
  int counter;
  // Check if msg->id has any registrants
  if ( (b = boid.find(BOID(msg->id))) ) {
    // add message to taggedMsg container
    counter = b->broadcastSet->size();
    if (msg->node == CkMyPe()) counter--; // get rid of sender
    if ( counter < 0 ) NAMD_bug("BroadcastMgr::recvBroadcast counter < 0");
    else if ( counter > 0 ) {
      b->taggedMsg->add(TaggedMsg(msg->tag,msg->size,counter,msg->msg));

      // inform all registrants of mew message
      UniqueSetIter<BroadcastClientElem> bcIter(*(b->broadcastSet));
      for (bcIter = bcIter.begin(); bcIter != bcIter.end(); bcIter++) {
        bcIter->broadcastClient->awaken(msg->id, msg->tag);
      }
    }
  }
  delete msg;
}

void BroadcastMgr::send	(	BroadcastClient &	b,
		int	tag,
		void *	buf,
		size_t	size
	)

Definition at line 49 of file BroadcastMgr.C.

References BroadcastClient::id.

Referenced by SimpleBroadcastObject< Tensor >::publish().

                                                                      {
  BroadcastMsg* msg = new BroadcastMsg;
  memcpy((void*)(msg->msg),buf,size);
  msg->size = (int)size;
  msg->tag = tag;
  msg->id = b.id;
  msg->node = CkMyPe();
  CProxy_BroadcastMgr(thisgroup).recvBroadcast(msg);
}

void BroadcastMgr::subscribe

(

BroadcastClient &

bc

)

Definition at line 60 of file BroadcastMgr.C.

References UniqueSet< Elem >::add(), BOID::broadcastSet, UniqueSet< Elem >::find(), BroadcastClient::id, and BOID::taggedMsg.

Referenced by BroadcastClient::BroadcastClient().

                                           {
  BOID *b;
  if (!(b = boid.find(BOID(bc.id)))) {
    boid.add(BOID(bc.id));
    b = boid.find(BOID(bc.id));
    b->broadcastSet = new UniqueSet<BroadcastClientElem>;
    b->taggedMsg = new UniqueSet<TaggedMsg>;
  }
  b->broadcastSet->add(BroadcastClientElem(&bc));
}

void BroadcastMgr::unsubscribe

(

BroadcastClient &

bc

)

Definition at line 72 of file BroadcastMgr.C.

References BOID::broadcastSet, UniqueSet< Elem >::del(), UniqueSet< Elem >::find(), BroadcastClient::id, UniqueSet< Elem >::size(), and BOID::taggedMsg.

Referenced by BroadcastClient::~BroadcastClient().

                                             {
  BOID *b;
  if ( (b = boid.find(BOID(bc.id))) ) {
    b->broadcastSet->del(BroadcastClientElem(&bc));
    if (!b->broadcastSet->size()) {
      delete b->broadcastSet;
      b->broadcastSet = 0;
      delete b->taggedMsg;
      b->taggedMsg = 0;
    }
  }
}

---

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

• BroadcastMgr.h
• BroadcastMgr.C