DDS.h

Go to the documentation of this file.

#ifndef DDS_H
#define DDS_H

//                                                                    //
// DDS                                                                //
//                                                                    //
// Package: DDS (Data Dispatcher System).                             //
//                                                                    //
// Concept:  Define data types and static utility methods used by     //
//           DDS package.                                             //
//                                                                    //
// S. Kasahara  05/2001                                               //
//                                                                    //

#include <string>
#ifndef ROOT_Rtypes
#if !defined(__CINT__) || defined(__MAKECINT__)
#include "Rtypes.h"
#endif
#endif

namespace DDS {

  // Define DDS Message Types. ROOT reserved message ids between 0-10000 in
  // $ROOTSYS/include/MessageTypes.h
  enum EMessageType {

    // DDS parent server service request messages 
    kData = 10001,            // Request for online data
  
    // DDS child server service request messages
    kGoToFile,                // Advance to specified file
    kNext,                    // Request for next event
    kSubscribe,               // Notify server of new subscription

    // DDS parent or child server service request messages
    kShutdown,                // Request to shutdown (parent or child) server

    // DDS parent server service return status messages 
    kPermissionDenied,        // Unauthorized client access denied
    kSaturated,               // Maximum number of concurrent clients reached

    // DDS child server service return status messages
    kFileError,         // Error in opening/reading online file
    kTimeoutNewFile,    // Timeout reached while waiting for new file
    kTimeoutNewRecord,  // Timeout reached while waiting for new record
                        // from current file

    // DDS parent or child server service return status messages
    kMessageUnknown,  // Unrecognized message from client
    kOk,              // Service provided successfully
    kSocketError,     // Error in socket performance
    kSystemError,     // Error in system call
    kError,            // Generic error return

    // DDS child server service return status message
    kInvalidSelection,  // Invalid subscription selection string expression

    // DDS parent server status request message
    kStatus,            // Request for status

    // DDS child server service return status message
    kInactive          // Client connection shutdown due to inactivity
  };
  
  // Define supported data sources, these are used to determine location
  // of file to receive data from. 
  enum EDataSource {
    kDaq,           // Daq file 
    kDcs            // Dcs file
  };

  // Define subscription modes.
  enum EKeepUpMode {
    kAll,          // Request all records from all files
    kFileKeepUp,   // Request to keep up with most recent file
    kRecordKeepUp  // Request most recent record set from file
  };

  // Define client types
  enum EClientType {
    kOnlineMonitor,             // Online Monitor
    kDatabaseUpdater,           // DBU
    kEventDisplay,              // Event Display
    kOther,                     // Other
    kUnknownClientType          // Not specified by client
  };

  const Int_t kPort = 9090;  // Default port # for listening socket

  const char* AsString(EDataSource datasource);
  const char* AsString(EKeepUpMode keepupmode);
  const char* AsString(EMessageType messagetype);
  const char* AsString(EClientType clienttype);
  
  int GetKeepUpCode(const char* keepupmode);
  int GetDataSourceCode(const char* datasource);
  DDS::EClientType GetClientType(const char* clienttype);

}

#endif  // DDS_H

---