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)
int	boidSize ()
int	boidBroadcastSize ()
int	boidTaggedMsgSize ()

Static Public Member Functions
static BroadcastMgr *	Object ()

Detailed Description

Definition at line 86 of file BroadcastMgr.h.

Constructor & Destructor Documentation

BroadcastMgr()

BroadcastMgr::BroadcastMgr ( )

inline

Definition at line 89 of file BroadcastMgr.h.

                 { 
    CkpvAccess(BroadcastMgr_instance) = this; 
  }

~BroadcastMgr()

BroadcastMgr::~BroadcastMgr

(

void

)

Definition at line 18 of file BroadcastMgr.C.

References UniqueSetIter< T >::begin(), BOID::broadcastSet, UniqueSetIter< T >::end(), and BOID::taggedMsg.

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

Member Function Documentation

boidBroadcastSize()

int BroadcastMgr::boidBroadcastSize

(

)

Definition at line 28 of file BroadcastMgr.C.

References UniqueSetIter< T >::begin(), BOID::broadcastSet, UniqueSetIter< T >::end(), and UniqueSet< Elem >::size().

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

{
  int sum=0;
  UniqueSetIter<BOID> boidIter(boid);
  for (boidIter = boidIter.begin(); boidIter != boidIter.end(); boidIter++) {
    sum+=boidIter->broadcastSet->size();
  }
  return sum;
}

boidSize()

int BroadcastMgr::boidSize ( )

inline

Definition at line 104 of file BroadcastMgr.h.

References UniqueSet< Elem >::size().

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

{ return boid.size();}

boidTaggedMsgSize()

int BroadcastMgr::boidTaggedMsgSize

(

)

Definition at line 38 of file BroadcastMgr.C.

References UniqueSetIter< T >::begin(), UniqueSetIter< T >::end(), UniqueSet< Elem >::size(), and BOID::taggedMsg.

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

{
  int sum=0;
  UniqueSetIter<BOID> boidIter(boid);
  for (boidIter = boidIter.begin(); boidIter != boidIter.end(); boidIter++) {
    sum+=boidIter->taggedMsg->size();
  }
  return sum;
}

getbuf()

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

Definition at line 50 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);
}

Object()

static BroadcastMgr* BroadcastMgr::Object ( )

inlinestatic

Definition at line 95 of file BroadcastMgr.h.

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

                                       {
    return CkpvAccess(BroadcastMgr_instance);
  }

recvBroadcast()

void BroadcastMgr::recvBroadcast

(

BroadcastMsg *

msg

)

Definition at line 106 of file BroadcastMgr.C.

References UniqueSet< Elem >::add(), BroadcastClient::awaken(), UniqueSetIter< T >::begin(), BroadcastClientElem::broadcastClient, BOID::broadcastSet, UniqueSetIter< T >::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;
}

send()

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

Definition at line 69 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);
}

subscribe()

void BroadcastMgr::subscribe

(

BroadcastClient &

bc

)

Definition at line 80 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));
}

unsubscribe()

void BroadcastMgr::unsubscribe

(

BroadcastClient &

bc

)

Definition at line 92 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