DDSClient.h

Go to the documentation of this file.

#ifndef DDSCLIENT_H
#define DDSCLIENT_H

//                                                                          //
// DDSClient                                                                //
//                                                                          //
// Package: DDS (Data Dispatcher System).                                   //
//                                                                          //
// S. Kasahara 5/2001                                                       //
// This class is the interface to be used by the client to receive          //
// near-online data from the data dispatcher server.                        //
//                                                                          //
#include <iosfwd> // ostream forward decl
#include "TInetAddress.h"
#include "TMessage.h"
#include "Dispatcher/DDS.h"

class TSocket;
class MomNavigator;
class DDSClient;
class DDSSubscription;
class DDSClientId;
class DDSPSStatus;

std::ostream& operator << (std::ostream& ms, DDSClient* cs);

class DDSClient {

public:
  // Typedefs and enumerations.

  // Constructor and destructor.
  DDSClient (const char* serverhost, UInt_t serverport = 0, 
             DDS::EMessageType initmsg = DDS::kData,
             DDS::EClientType type = DDS::kUnknownClientType,
             std::string clientname = "");   
  virtual ~DDSClient ();       

  // State testing member functions.
  DDS::EMessageType GetStatus() const { return fStatus; }
  const DDSPSStatus* GetPSStatus() const { return fPSStatus; }
  const DDSClientId* GetClientId() const { return fClientId; }
  DDSSubscription* GetSubscription() const { return fSubscription; }
  bool IsValid () const { return (fTSocket != (TSocket*)0) ? true : false; }
  std::ostream& Print(std::ostream& ms) const;

  // State changing member functions
  DDS::EMessageType GoToFile(std::string filename, 
                             std::string& returnedfilename);
  DDS::EMessageType GoToNextFile(std::string& returnedfilename);
  DDS::EMessageType Next(MomNavigator*& mom,UInt_t waittime=120,UInt_t advanceby=1); // request next entry
  DDS::EMessageType Shutdown();     // shutdown the child server
  DDS::EMessageType Subscribe();    // submit subscription

private:

  // Private member functions.
  DDS::EMessageType SendMessage();  //  Send new request to server

  // Data members.
  DDS::EMessageType fStatus; // status of connection with server
  TSocket*  fTSocket;    // pointer to connected socket
  DDSSubscription* fSubscription; // client's subscription
  TMessage* fMessageIn;  // message buffer for received message objects
  TMessage  fMessageOut; // message buffer for outgoing message objects
  TInetAddress fClientAddress;  // internet address of client
  TInetAddress fServerAddress;  // internet address of server
  DDSClientId* fClientId; // client id
  DDSPSStatus* fPSStatus; // ps status received in response to kStatus request

  ClassDef(DDSClient,0)  // MINOS Data Dispatcher System Client
};

#endif                                    // DDSCLIENT_H

---