DDSSubscription.h

Go to the documentation of this file.

#ifndef DDSSUBSCRIPTION_H
#define DDSSUBSCRIPTION_H

//                                                                          //
// DDSSubscription                                                          //
//                                                                          //
// Package: DDS (Data Dispatcher System).                                   //
//                                                                          //
// S. Kasahara 5/2001                                                       //
// Subscription class used to specify client's subscription needs to server //

#include <map>
#include "TObject.h"
#include "TString.h"

#include "Persistency/Per.h"
#include "Dispatcher/DDS.h"

using std::string;

class DDSSubscription;

std::ostream& operator << (std::ostream& ms, DDSSubscription* sub);

class DDSSubscription : public TObject {

public:
  // Typedefs and enumerations.
  typedef  std::map<TString, TString> StreamMap; 
  // std::map<string, string> doesn't work with ROOT I/O yet
  typedef  StreamMap::iterator StreamMapItr;
  typedef  StreamMap::const_iterator StreamMapConstItr;

  // Constructor and destructor.
  DDSSubscription(DDS::EDataSource datasource = DDS::kDaq, 
                  DDS::EKeepUpMode = DDS::kFileKeepUp);   
  virtual ~DDSSubscription (); // destructor       

  // State testing member functions.
  DDS::EDataSource GetDataSource() const { return fDataSource; }
  DDS::EKeepUpMode GetKeepUpMode() const { return fKeepUpMode; }
  const StreamMap& GetStreamMap() const { return fStreamMap; }  
  Int_t GetKeepUpWindow() const { return fKeepUpWindow; }
  UInt_t GetNumStream() const { return fStreamMap.size(); }
  UInt_t GetMaxSyncDelay() const { return fMaxSyncDelay; }
  Bool_t IsOffLine() const { return fOffLine; }
  std::ostream& Print(std::ostream& ms) const;
  void Print(Option_t* option = "") const;

  // State changing member functions
  void SetDataSource(DDS::EDataSource datasource) {fDataSource = datasource;}
  void SetKeepUpMode(DDS::EKeepUpMode keepupmode) {fKeepUpMode = keepupmode;}
  void SetOffLine(Bool_t offLine = true) { fOffLine = offLine; }
  void AddStream(Per::EStreamType streamtype, string selection="");
  void RemoveStream(Per::EStreamType streamtype);
  void Reset();
  void SetSelection(Per::EStreamType streamtype,std::string selection="");
  void SetSelection(std::string stream,std::string selection=""); 
  void SetMaxSyncDelay(UInt_t maxSyncDelay) { fMaxSyncDelay = maxSyncDelay; }
  int  SetStreams(std::string streamlist); //delimiter separated stream list
  void SetKeepUpWindow(Int_t keepUpWindow) { fKeepUpWindow = keepUpWindow; }

private:

  // Data members.
  DDS::EDataSource fDataSource;  // data source
  DDS::EKeepUpMode fKeepUpMode;  // keepup mode
  Bool_t fOffLine;           // use offlinefile softlink instead of currentfile
  StreamMap fStreamMap;      // map of <stream,selection> pairs
  UInt_t    fMaxSyncDelay;  // max time (sec) to wait for synchronized data set
  Int_t     fKeepUpWindow; // keep up w/in this time window (sec) to end 
  ClassDef(DDSSubscription,3)  // MINOS Data Dispatcher System Subscription
};

#endif              // DDSSUBSCRIPTION_H

---