9 #include "BroadcastMgr.decl.h"
14 #define MIN_DEBUG_LEVEL 3
20 for (boidIter = boidIter.
begin(); boidIter != boidIter.
end(); boidIter++) {
21 delete boidIter->broadcastSet;
22 if (boidIter->taggedMsg) {
23 delete boidIter->taggedMsg;
51 memcpy((
void*)(msg->msg),buf,size);
52 msg->size = (int)size;
56 CProxy_BroadcastMgr(thisgroup).recvBroadcast(msg);
90 if ( (b = boid.
find(
BOID(msg->id))) ) {
93 if (msg->node == CkMyPe()) counter--;
94 if ( counter < 0 )
NAMD_bug(
"BroadcastMgr::recvBroadcast counter < 0");
95 else if ( counter > 0 ) {
100 for (bcIter = bcIter.
begin(); bcIter != bcIter.
end(); bcIter++) {
101 bcIter->broadcastClient->awaken(msg->id, msg->tag);
108 #include "BroadcastMgr.def.h"
Elem * find(const Elem &elem)
void recvBroadcast(BroadcastMsg *msg)
int add(const Elem &elem)
UniqueSet< TaggedMsg > * taggedMsg
int getbuf(BroadcastClient &b, int tag, void *msg)
void unsubscribe(BroadcastClient &bc)
UniqueSetIter< T > begin(void) const
void send(BroadcastClient &b, int tag, void *buf, size_t)
void NAMD_bug(const char *err_msg)
void subscribe(BroadcastClient &bc)
UniqueSetIter< T > end(void) const
UniqueSet< BroadcastClientElem > * broadcastSet
int del(const Elem &elem)