Main Page | Modules | Namespace List | Class Hierarchy | Alphabetical List | Class List | Directories | File List | Namespace Members | Class Members | File Members | Related Pages

RotoSocket Class Reference

#include <RotoSocket.h>

List of all members.

Public Member Functions

 RotoSocket (const char *fileName)
 ~RotoSocket ()
virtual void Close (Option_t *="")
virtual Int_t GetDescriptor () const
virtual TInetAddress GetLocalInetAddress ()
virtual Int_t GetLocalPort ()
virtual Int_t Send (const TMessage &)
virtual Int_t Send (Int_t)
virtual Int_t Send (Int_t, Int_t)
virtual Int_t Send (const char *, Int_t=kMESS_STRING)
virtual Int_t SendObject (const TObject *, Int_t=kMESS_OBJECT)
virtual Int_t SendRaw (const void *, Int_t, ESendRecvOptions=kDefault)
virtual Int_t Recv (TMessage *&)
virtual Int_t Recv (Int_t &, Int_t &)
virtual Int_t Recv (char *, Int_t)
virtual Int_t Recv (char *, Int_t, Int_t &)
virtual Int_t RecvRaw (void *buffer, Int_t length, ESendRecvOptions opt=kDefault)
virtual Bool_t IsValid () const
virtual Int_t SetOption (ESockOptions, Int_t)
virtual Int_t GetOption (ESockOptions, Int_t &)

Private Types

enum  RotoCommand {
  INITIALISE, OPEN_SOCKET, OPEN_FILE, SEND_DATA,
  SEND_SHUTDOWN
}
enum  RotoAction { PREPARE_NEXT_COMMAND, TRANSMIT_COMMAND, TRANSMIT_LENGTH, TRANSMIT_DATA }

Private Member Functions

 RotoSocket ()
 RotoSocket (const RotoSocket &)
void NotImp (const char *method) const
void PrepareCommand ()
Int_t Transmit (void *buffer, Int_t length)
Option_t * GetOption () const
Bool_t ReallocateBuffer (long minBytes)

Private Attributes

RotoCommand fCommand
RotoAction fAction
RotoRcCmd fTransCmd
long fTransLen
long fTransAlloc
long * fTransData
string fFileName
FILE * fFile

Member Enumeration Documentation

enum RotoSocket::RotoAction [private]
 

Enumeration values:
PREPARE_NEXT_COMMAND 
TRANSMIT_COMMAND 
TRANSMIT_LENGTH 
TRANSMIT_DATA 

Definition at line 82 of file RotoSocket.h.

00082                  {
00083     PREPARE_NEXT_COMMAND,
00084     TRANSMIT_COMMAND,
00085     TRANSMIT_LENGTH,
00086     TRANSMIT_DATA
00087 };

enum RotoSocket::RotoCommand [private]
 

Enumeration values:
INITIALISE 
OPEN_SOCKET 
OPEN_FILE 
SEND_DATA 
SEND_SHUTDOWN 

Definition at line 74 of file RotoSocket.h.

00074                  {
00075    INITIALISE,
00076    OPEN_SOCKET,
00077    OPEN_FILE,
00078    SEND_DATA,
00079    SEND_SHUTDOWN
00080 };

Constructor & Destructor Documentation

RotoSocket::RotoSocket (  const char *  fileName  ) 
 

Definition at line 30 of file RotoSocket.cxx.

References MsgService::GetStream(), MsgService::Instance(), MSG, and MsgStream::SetLogLevel().

00030                                            :
00031 fCommand(INITIALISE),
00032 fAction(PREPARE_NEXT_COMMAND),
00033 fTransCmd(0),
00034 fTransLen(0),
00035 fTransAlloc(MAXBUFFER),
00036 fTransData(new long[MAXBUFFER / sizeof(long)]),
00037 fFileName(fileName),
00038 fFile(0)
00039 {
00040 
00041   MsgService::Instance()->GetStream("Roto")->SetLogLevel(Msg::kInfo);
00042   
00043   MSG("Roto",Msg::kInfo) << "Opening: " << fileName << endl;
00044 
00045   fFile=fopen(fileName,"rb");
00046   if (fFile==NULL) {
00047     printf("Failed to open input file: '%s'\n",fileName);
00048     fCommand = SEND_SHUTDOWN;
00049   }
00050 
00051 }
//_____________________________________________________________________________

RotoSocket::~RotoSocket (   ) 
 

Definition at line 54 of file RotoSocket.cxx.

References fFile.

00054                          {
00055 
00056   delete [] fTransData;
00057   if ( fFile ) fclose(fFile);
00058   fFile = 0;
00059 
00060 }

RotoSocket::RotoSocket (   )  [private]
 

RotoSocket::RotoSocket (  const RotoSocket &   )  [private]
 

Member Function Documentation

virtual void RotoSocket::Close (  Option_t *  = ""  )  [inline, virtual]
 

Definition at line 36 of file RotoSocket.h.

References fFile.

00036                                                    {
00037                if (fFile); fclose(fFile); fFile=0; }

virtual Int_t RotoSocket::GetDescriptor (   )  const [inline, virtual]
 

Definition at line 38 of file RotoSocket.h.

References NotImp().

00038                                          {
00039                           NotImp("GetDescriptor"); return -1; }

virtual TInetAddress RotoSocket::GetLocalInetAddress (   )  [inline, virtual]
 

Definition at line 41 of file RotoSocket.h.

References NotImp().

00041                                          {
00042                           NotImp("GetLocalInetAddress"); return TInetAddress(); }

virtual Int_t RotoSocket::GetLocalPort (   )  [inline, virtual]
 

Definition at line 43 of file RotoSocket.h.

References NotImp().

00043                                   {
00044                           NotImp("GetLocalPort"); return -1; }

Option_t* RotoSocket::GetOption (   )  const [inline, private]
 

Definition at line 96 of file RotoSocket.h.

00096 { return TObject::GetOption(); } // same as TSocket

virtual Int_t RotoSocket::GetOption (  ESockOptions  ,
Int_t & 
)  [inline, virtual]
 

Definition at line 69 of file RotoSocket.h.

References NotImp().

00069                                                                         {
00070                           NotImp("GetOption"); return -1; }

virtual Bool_t RotoSocket::IsValid (   )  const [inline, virtual]
 

Definition at line 66 of file RotoSocket.h.

References fFile.

00066 { return fFile ? kTRUE : kFALSE; }

void RotoSocket::NotImp (  const char *  method  )  const [private]
 

Definition at line 64 of file RotoSocket.cxx.

References MSG.

Referenced by GetDescriptor(), GetLocalInetAddress(), GetLocalPort(), GetOption(), Recv(), Send(), SendObject(), and SetOption().

00064                                                 {
00065 
00066   MSG("Roto",Msg::kError) << "RotoSocket: Attempting to use un implimented"
00067                           << "  method: " << method << endl;
00068 }

void RotoSocket::PrepareCommand (   )  [private]
 

Definition at line 90 of file RotoSocket.cxx.

References bitDataToFollow, fAction, fCommand, fFile, fFileName, fTransAlloc, fTransCmd, fTransData, fTransLen, INITIALISE, MINOS_DCP, MINOS_DCS, MINOS_ROOTER, MINOS_ROOTER_COMMAND, OPEN_FILE, OPEN_SOCKET, ReallocateBuffer(), SEND_DATA, and SEND_SHUTDOWN.

Referenced by RecvRaw().

00090                                  {
00091 //
00092 //  Purpose:  
00093 //
00094 //  Argument: buffer        address of receiving buffer
00095 //            length        size of buffer
00096 //            
00097 //
00098 //  Return:    
00099 //
00100 //  Contact:  N. West
00101 
00102   static int  nRecords =0;
00103   const int bitDataToFollow = (1 << 15);
00104   Int_t   instr = 0;
00105 
00106   
00107 // Select next command.
00108 
00109   switch ( fCommand ) {
00110   case INITIALISE:   fCommand = OPEN_SOCKET; break;
00111   case OPEN_SOCKET:  fCommand = OPEN_FILE;   break;
00112   case OPEN_FILE:    fCommand = SEND_DATA;   break;
00113   case SEND_DATA:    break;  // do nothing
00114   default:
00115      cout << " fCommand was " << (int)fCommand << endl;
00116      assert(0);
00117   }
00118   
00119 // Prepare next command
00120 
00121   switch ( fCommand ) {
00122 
00123   case OPEN_SOCKET:
00124     instr     = MINOS_ROOTER_OPENSOCKET;
00125     fTransLen = 0;
00126     break;
00127 
00128   case OPEN_FILE:
00129     instr     = MINOS_ROOTER_OPENFILE;
00130     {
00131       int*  iptr = (int*) fTransData;
00132       char* cptr = (char*) fTransData + sizeof(int);
00133       
00134 // Signal that we are sending file name.
00135       *iptr      = MINOS_DCS | bitDataToFollow;
00136 // Remove directory path from file name and store
00137       const char* lastslash = strrchr(fFileName.c_str(),'/');
00138       if (lastslash) lastslash++;  // move past slash to next char
00139       else lastslash = fFileName.c_str();  // no slash, use whole thing
00140       sprintf(cptr,"%s",lastslash);
00141       int fnlen = strlen(cptr);
00142       cptr[fnlen] = 0;   
00143       fTransLen = sizeof(int) + fnlen + 1;
00144       
00145     }
00146     break;
00147 
00148   case SEND_DATA:
00149     instr     = MINOS_ROOTER_SHUTDOWN;  //The default if we cannot read record!
00150     fTransLen = 0;
00151     if ( feof(fFile) )  {
00152       printf("Seen EOF after record %d Quiting ...\n",nRecords);
00153       break;
00154     }
00155     if ( fread(&fTransLen,sizeof(long),1,fFile) !=1 ) {
00156       if ( feof(fFile) )  {
00157         printf("Seen EOF after record %d Quiting ...\n",nRecords);
00158       }
00159       else {
00160       printf("Read error on record %d Quiting ...\n",nRecords);
00161       }
00162       break;
00163     }
00164     nRecords++;
00165     fTransLen -= sizeof(long);  // byte count is inclusive 
00166     if ( fTransLen > fTransAlloc ) {
00167       if ( ! ReallocateBuffer(fTransLen) ) {
00168         printf("Record %d Size %ld bytes too large for buffer (%ld) Quiting ...\n",
00169                nRecords,fTransLen,fTransAlloc);
00170         fTransLen = 0;
00171       }
00172       else {
00173         printf("Record %d Size %ld bytes, buffer reallocated to %ld.\n",
00174                nRecords,fTransLen,fTransAlloc);
00175       }
00176     }
00177     if ( fread(fTransData,fTransLen,1,fFile) != 1 ) {
00178       printf("Read error on record %d Quiting ...\n",nRecords);
00179       fTransLen = 0;
00180       break;
00181     }
00182     instr     = MINOS_ROOTER_RECBUFFER;
00183     break;
00184 
00185   case SEND_SHUTDOWN:
00186     instr     = MINOS_ROOTER_SHUTDOWN;
00187     fTransLen = 0;
00188     break;
00189 
00190   default:
00191      assert(0);
00192 
00193   }
00194 
00195 
00196   fTransCmd = RotoRcCmd(MINOS_DCP,
00197                         MINOS_ROOTER,
00198                         MINOS_ROOTER_COMMAND,
00199                         instr, 
00200                         fTransLen > 0);
00201   
00202 
00203   fAction = TRANSMIT_COMMAND;
00204 
00205 }

Bool_t RotoSocket::ReallocateBuffer (  long  minBytes  )  [private]
 

Definition at line 250 of file RotoSocket.cxx.

References fTransAlloc, and fTransData.

Referenced by PrepareCommand().

00250                                                  {
00251 //
00252 //  Purpose:  Reallocate the fTransData buffer so it is at least minBytes
00253 //            in length.
00254 //
00255 //  Argument: minBytes       minimum size of buffer
00256 //
00257 //  Return:   true if successful
00258 //
00259 //  Contact:  R. Hatcher
00260 
00261   long oldsize  = fTransAlloc;
00262   long mrequest = minBytes;
00263   int  failures = 0;
00264 
00265   // release existing buffer
00266   if (fTransData) {
00267     delete [] fTransData;
00268     fTransData = 0;
00269   }
00270 
00271   // set absolute mimimum size
00272   if ( mrequest < MAXBUFFER ) mrequest = MAXBUFFER;
00273 
00274   // round up to even 1M bytes
00275   mrequest = ((mrequest >> 20) + 1 ) << 20;
00276 
00277   while ( ! fTransData ) {
00278     fTransData = new long[mrequest / sizeof(long)];
00279     if ( fTransData ) break; // success
00280     failures++;
00281     mrequest -= 1024*sizeof(char);  // failed, try smaller size
00282   }
00283   fTransAlloc = mrequest;
00284 
00285   if ( fTransAlloc >= minBytes ) return true;
00286   
00287   printf("RotoSocket::ReallocateBuffer was unable to allocate requested "
00288          "%ld bytes \n  from initial size %ld, only got final size %ld.",
00289          minBytes,oldsize,fTransAlloc);
00290   return false;
00291 }

virtual Int_t RotoSocket::Recv (  char *  ,
Int_t  ,
Int_t & 
)  [inline, virtual]
 

Definition at line 63 of file RotoSocket.h.

References NotImp().

00063                                                                                 {
00064                           NotImp("Recv"); return -1; }

virtual Int_t RotoSocket::Recv (  char *  ,
Int_t 
)  [inline, virtual]
 

Definition at line 61 of file RotoSocket.h.

References NotImp().

00061                                                             {
00062                           NotImp("Recv"); return -1; }

virtual Int_t RotoSocket::Recv (  Int_t &  ,
Int_t & 
)  [inline, virtual]
 

Definition at line 59 of file RotoSocket.h.

References NotImp().

00059                                                                   {
00060                           NotImp("Recv"); return -1; }

virtual Int_t RotoSocket::Recv (  TMessage *&   )  [inline, virtual]
 

Definition at line 57 of file RotoSocket.h.

References NotImp().

00057                                                 {
00058                           NotImp("Recv"); return -1; }

Int_t RotoSocket::RecvRaw (  void *  buffer,
Int_t  length,
ESendRecvOptions  opt = kDefault
)  [virtual]
 

Definition at line 71 of file RotoSocket.cxx.

References fAction, PrepareCommand(), and Transmit().

00072                                                       {
00073 //
00074 //  Purpose:  Construct and pass raw command.
00075 //
00076 //  Argument:  buffer        address of receivin
00077 //             length        size of buffer
00078 //             opt           ignored.
00079 //
00080 //  Return:    number of bytes transferred to buffer.
00081 //
00082 //  Contact:  N. West
00083 
00084   if ( fAction == PREPARE_NEXT_COMMAND ) PrepareCommand();
00085   return Transmit(buffer,length);
00086 
00087 }

virtual Int_t RotoSocket::Send (  const char *  ,
Int_t  = kMESS_STRING
)  [inline, virtual]
 

Definition at line 51 of file RotoSocket.h.

References NotImp().

00051                                                                                   {
00052                           NotImp("Send"); return -1; }

virtual Int_t RotoSocket::Send (  Int_t  ,
Int_t 
)  [inline, virtual]
 

Definition at line 49 of file RotoSocket.h.

References NotImp().

00049                                                               {
00050                           NotImp("Send"); return -1; }

virtual Int_t RotoSocket::Send (  Int_t   )  [inline, virtual]
 

Definition at line 47 of file RotoSocket.h.

References NotImp().

00047                                           {
00048                           NotImp("Send"); return -1; }

virtual Int_t RotoSocket::Send (  const TMessage &   )  [inline, virtual]
 

Definition at line 45 of file RotoSocket.h.

References NotImp().

00045                                                      {
00046                           NotImp("Send"); return -1; }

virtual Int_t RotoSocket::SendObject (  const TObject *  ,
Int_t  = kMESS_OBJECT
)  [inline, virtual]
 

Definition at line 53 of file RotoSocket.h.

References NotImp().

00053                                                                                           {
00054                           NotImp("SendObject"); return -1; }

virtual Int_t RotoSocket::SendRaw (  const void *  ,
Int_t  ,
ESendRecvOptions  = kDefault
)  [inline, virtual]
 

Definition at line 55 of file RotoSocket.h.

00056                                                                   { return -1; }

virtual Int_t RotoSocket::SetOption (  ESockOptions  ,
Int_t 
)  [inline, virtual]
 

Definition at line 67 of file RotoSocket.h.

References NotImp().

00067                                                                       {
00068                           NotImp("SetOption"); return -1; }

Int_t RotoSocket::Transmit (  void *  buffer,
Int_t  length
)  [private]
 

Definition at line 209 of file RotoSocket.cxx.

References fAction, RotoRcCmd::fEncoded, fTransCmd, fTransData, fTransLen, TRANSMIT_COMMAND, TRANSMIT_DATA, and TRANSMIT_LENGTH.

Referenced by RecvRaw().

00209                                                     {
00210 //
00211 //  Purpose:  
00212 //
00213 //  Argument: buffer        address of receiving buffer
00214 //             length        size of buffer
00215 //            
00216 //
00217 //  Return:    
00218 //
00219 //  Contact:  N. West
00220 
00221  switch ( fAction ) {
00222  int nbytes;
00223 
00224  case  TRANSMIT_COMMAND: 
00225    memcpy(buffer,&fTransCmd.fEncoded,sizeof(long));
00226    fAction = ( fTransLen > 0 ) ? TRANSMIT_LENGTH : PREPARE_NEXT_COMMAND;
00227    return sizeof(long);
00228 
00229  case  TRANSMIT_LENGTH: 
00230    nbytes = fTransLen + sizeof(int);// Compute total length with byte count
00231    memcpy(buffer,&nbytes,sizeof(long));
00232    fAction = TRANSMIT_DATA;
00233    return sizeof(long);
00234 
00235  case  TRANSMIT_DATA: 
00236    nbytes = ( fTransLen < length ) ? fTransLen : length;
00237    memcpy(buffer,fTransData,nbytes);
00238    fAction = PREPARE_NEXT_COMMAND;
00239    return nbytes;
00240 
00241  default:
00242     assert(0);
00243  }
00244 
00245  return -1;
00246 }

Member Data Documentation

RotoAction RotoSocket::fAction [private]
 

Definition at line 101 of file RotoSocket.h.

Referenced by PrepareCommand(), RecvRaw(), and Transmit().

RotoCommand RotoSocket::fCommand [private]
 

Definition at line 100 of file RotoSocket.h.

Referenced by PrepareCommand().

FILE* RotoSocket::fFile [private]
 

Definition at line 112 of file RotoSocket.h.

Referenced by Close(), IsValid(), PrepareCommand(), and ~RotoSocket().

string RotoSocket::fFileName [private]
 

Definition at line 111 of file RotoSocket.h.

Referenced by PrepareCommand().

long RotoSocket::fTransAlloc [private]
 

Definition at line 108 of file RotoSocket.h.

Referenced by PrepareCommand(), and ReallocateBuffer().

RotoRcCmd RotoSocket::fTransCmd [private]
 

Definition at line 106 of file RotoSocket.h.

Referenced by PrepareCommand(), and Transmit().

long* RotoSocket::fTransData [private]
 

Definition at line 109 of file RotoSocket.h.

Referenced by PrepareCommand(), ReallocateBuffer(), and Transmit().

long RotoSocket::fTransLen [private]
 

Definition at line 107 of file RotoSocket.h.

Referenced by PrepareCommand(), and Transmit().

The documentation for this class was generated from the following files:
Generated on Mon Feb 15 11:10:15 2010 for loon by  doxygen 1.3.9.1