DDSSubscription.cxx

Go to the documentation of this file.

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


#include "Dispatcher/DDSSubscription.h"
#include "MessageService/MsgService.h"
#include "Util/UtilString.h"

std::ostream& operator << (std::ostream& ms, DDSSubscription* sub)
                             { return sub->Print(ms); } 

ClassImp(DDSSubscription)

// Definition of static data members
// *********************************

//CVSID("$Id: DDSSubscription.cxx,v 1.15 2005/02/16 05:07:46 schubert Exp $");
 
// Definition of methods (alphabetical order)
// ******************************************


void DDSSubscription::AddStream(Per::EStreamType streamtype, string selection){
  //
  // Purpose: Add new stream to subscription list.
  //
  // Argument: streamtype  stream of type Per::EStreamType to be added.
  //           selection   selection cut to be applied to entries in this
  //                       stream (default="" => no selection cuts applied).
  // 
  // Return: none.
  //
  // Contact: S. Kasahara
  //
  // Notes: If the requested stream is already in subscription list, the 
  //        requested selection string is applied to the existing stream.
  //

  // If streamtype is not already in map, this will add it
  fStreamMap[Per::AsString(streamtype)] = selection.c_str();

}

DDSSubscription::DDSSubscription(DDS::EDataSource datasource,
                                 DDS::EKeepUpMode keepupmode):
                 fDataSource(datasource),fKeepUpMode(keepupmode),
                 fOffLine(false),fMaxSyncDelay(15),fKeepUpWindow(30) {
  // 
  // Purpose: Default constructor for DDSSubscription class.  
  //  
  // Arguments: datasource  defines source of data
  //                        (default = DDS::kDaq)
  //            keepupmode  enumerated keepup mode (default = DDS::kFileKeepUp)
  //
  // Return: n/a.
  //
  // Contact: S. Kasahara
  //

}

DDSSubscription::~DDSSubscription() {
  // Purpose: Destructor.
  //
  // Argument: n/a.
  //
  // Return: n/a.
  //
  // Contact: S. Kasahara
  //

}


std::ostream& DDSSubscription::Print(std::ostream& ms) const {
  //
  // Purpose: Print DDSSubscription status on std::ostream.
  //
  // Argument: ms  std::ostream to print on.
  //
  // Return: std::ostream reference.
  //
  // Contact: S. Kasahara
  //

  ms << "    DataSource " << DDS::AsString(fDataSource) << "." << endl;
  ms << "    KeepUpMode " << DDS::AsString(fKeepUpMode) << "." << endl;
  ms << "    MaxSyncDelay " << fMaxSyncDelay << "." << endl;
  ms << "    KeepUpWindow " << fKeepUpWindow << "." << endl;
  if (this -> IsOffLine()) ms << "    OffLine true." << endl; 
  else                     ms << "    OffLine false." << endl;

  ms << "    Number of streams = " << GetNumStream() << endl;
  Int_t istream = 0;
  for (StreamMapConstItr citr = fStreamMap.begin(); citr != fStreamMap.end();
       ++citr) {
    ms << "    " << ++istream << ")" << "Stream: " << citr->first << ".";
    if ( (citr -> second).IsNull() ) {
      ms << " No selection cut specified." << endl;
    }
    else {
      ms << " Selection cut: " << citr->second << "." << endl;
    }
  }  

  return ms;

}

void DDSSubscription::Print(Option_t* /* option */) const { 
  Print(std::cout); 
}

void DDSSubscription::RemoveStream(Per::EStreamType streamtype) {
  //
  // Purpose: Remove stream from subscription list.
  //
  // Argument: streamtype  requested stream
  // 
  // Return: none.
  //
  // Contact: S. Kasahara
  //

  StreamMapItr itr = fStreamMap.find(Per::AsString(streamtype));
  if (itr != fStreamMap.end()) {
    fStreamMap.erase(itr);
  }   

}

void DDSSubscription::Reset() {
  //
  // Purpose: Remove all streams from subscription list.
  //
  // Argument: none.
  // 
  // Return: none.
  //
  // Contact: S. Kasahara
  //

  fStreamMap.clear();

}

void DDSSubscription::SetSelection(Per::EStreamType streamtype, string selection) {
  //
  // Purpose: Modify selection string for requested stream.
  //
  // Argument: streamtype  stream of type Per::EStreamType.
  //           selection   selection cut to be applied to entries in this
  //                       stream (default ="" => no selection cuts applied).
  // 
  // Return: none.
  //
  // Contact: S. Kasahara
  //
  // Notes: If the requested stream does not already exist in subscription 
  //        list, the stream is added to the list. (Hence this method
  //        performs the same function as AddStream.)
  //

  // If streamtype is not already in map, this will add it
  fStreamMap[Per::AsString(streamtype)] = selection.c_str();

}

void DDSSubscription::SetSelection(std::string stream, std::string selection) {
   //
   // Purpose: Modify selection string for requested stream.
   //
   // Argument: stream      streamname
   //           selection   selection cut to be applied to entries in this
   //                       stream (default ="" => no selection cuts applied).
   // 
   // Return: none.
   //
   // Contact: S. Kasahara
   //
   // Notes: If the requested stream does not already exist in subscription 
   //        list, the stream is added to the list. 
   //
 
   // If streamtype is not already in map, this will add it
   fStreamMap[stream.c_str()] = selection.c_str();
 
}

int DDSSubscription::SetStreams(std::string streamList){
  //
  // Purpose: Set active streams in subscription to correspond to those
  //          in delimiter separated (,;: ) streamList.
  //
  // Argument: streamList  delimiter (,;: ) separated list of streams.
  // 
  // Return: Number of streams set.
  //
  // Contact: S. Kasahara
  //


  fStreamMap.clear();
  std::vector<std::string> ls;
  UtilString::StringTok(ls,streamList,",:; ");

  std::vector<std::string>::iterator vitr;
  for ( vitr = ls.begin(); vitr != ls.end(); vitr++ ) {
    fStreamMap[(*vitr).c_str()] = "";
  }
  return fStreamMap.size();

}

---