BroadcastObject.h

Go to the documentation of this file.

/*
   Coordinates broadcast of a data type from a Controller/Seq
   to all other Controller/Sequencer type objects (they must
   run in a thread!)
*/

#ifndef _BCASTOBJ_H
#define _BCASTOBJ_H

#include "BroadcastMgr.h"
#include "BroadcastClient.h"
#include "LdbCoordinator.h"
#include "common.h"

template <class T> class SimpleBroadcastObject : public BroadcastClient {

  public:

    const LDObjHandle *ldObjPtr;

    SimpleBroadcastObject(int id, const LDObjHandle *h = 0) : BroadcastClient(id), ldObjPtr(h) {
      if ( sizeof(T) > BCASTMSGSIZE ) {
        NAMD_bug("SimpleBroadcastObject instantiated on class larger than BCASTMSGSIZE");
      }
    }
    ~SimpleBroadcastObject() { }

    T get(int tag) {
      T tmp;
      if ( ldObjPtr ) LdbCoordinator::Object()->pauseWork(*ldObjPtr);
      while ( BroadcastMgr::Object()->getbuf(*this, tag, (void*)(&tmp)) < 0 ) {
        suspendFor(tag);
      }
      if ( ldObjPtr ) LdbCoordinator::Object()->startWork(*ldObjPtr);
      return tmp;
    }
  int getSize() {
    return BroadcastMgr::Object()->boidSize();
  }
    int getBcastSize() {
    return BroadcastMgr::Object()->boidBroadcastSize();
  }
      int getTaggedSize() {
    return BroadcastMgr::Object()->boidTaggedMsgSize();
  }
    void publish(int tag,const T &t ) {
      BroadcastMgr::Object()->send(*this, tag, (void*)(&t), sizeof(T));
    }

};

#endif