remote_msg_buffer.h

Go to the documentation of this file. Or view the newest version in sPHENIX GitHub for file remote_msg_buffer.h

#ifndef __REMOTE_MSG_BUFFER_H__
#define __REMOTE_MSG_BUFFER_H__



#include "msg_buffer.h"

#ifndef __CINT__

#include <sys/types.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/times.h>

#include <netdb.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#endif



class remote_msg_buffer : public   msg_buffer {

protected:

#ifndef __CINT__
  STREAMBUF * original_streambuf;
  int ThePort;
  char *TheHost;

  int sockfd;
  struct sockaddr_in server_addr;
  struct hostent *p_host;

  void send_string(const char *x, const int len);
  int writen (int fd, const char *ptr, int nbytes);
#endif


public:


  remote_msg_buffer (const char *host = "va010.phenix.bnl.gov",
                     const int port = 8400, const int msglen=256);

  virtual ~remote_msg_buffer();


  // mlp -- the pubsync is what's needed for the new
  // iostream libraries - sync will no longer be a public method. 
  // for now we leave it as it was.

#ifdef STREAMBUF_NEW_IOSTREAM
  virtual int pubsync ();
#else
  virtual int sync ();
#endif


};


#endif /* __REMOTE_MSG_BUFFER_H__ */