online_distribution/newbasic/oamlBuffer.h

0001 #ifndef __OAMLBUFFER_H__
0002 #define __OAMLBUFFER_H__
0003
0004 #include "olzoBuffer.h"
0005
0006 #define CTRL_BEGINRUN 1
0007 #define CTRL_ENDRUN   2
0008 #define CTRL_DATA     3
0009 #define CTRL_CLOSE    4
0010
0011
0012 #ifndef __CINT__
0013 class WINDOWSEXPORT oamlBuffer : public olzoBuffer{
0014 #else
0015 class  oamlBuffer : public oBuffer{
0016 #endif
0017
0018 public:
0019
0020   //** Constructors
0021
0022   oamlBuffer (const char *host, const int port, PHDWORD * where,
0023          const int length,
0024          const int irun=0,
0025          const int iseq=0 );
0026
0027   // this one takes the form hostname:port
0028
0029   oamlBuffer (const char *hostport,  PHDWORD * where,
0030          const int length,
0031          const int irun=0,
0032          const int iseq=0 );
0033
0034
0035   virtual  ~oamlBuffer();
0036
0037
0038   virtual int writeout ();
0039
0040
0041 protected:
0042
0043   int connect_aml();
0044   int begin_run();
0045
0046   int has_begun;
0047   int RunNumber;
0048   int DontOverrideRunNumber;
0049
0050   static int readn(int , char *, int);
0051   static int writen(int , char *, int);
0052
0053
0054   char HostName[256];
0055   int ThePort;
0056
0057   int sockfd;
0058
0059
0060 };
0061
0062
0063
0064 #endif /* __OAMLBUFFER_H__ */
0065