RotoClientBinaryFile.cxx

Go to the documentation of this file.

// $Id: RotoClientBinaryFile.cxx,v 1.8 2005/08/26 19:09:35 rhatcher Exp $
//
// A JobControl  for sending raw blocks to the Roto-Rooter
//
// rhatcher@fnal.gov 
#include "Rotorooter/RotoClientBinaryFile.h"

#include <iostream>
#include <fstream>

// for function: char* Form(const char *fmt, ...)
#include "TString.h"

#include "MessageService/MsgService.h"
#include "Conventions/Detector.h"

ClassImp(RotoClientBinaryFile)
CVSID("$Id: RotoClientBinaryFile.cxx,v 1.8 2005/08/26 19:09:35 rhatcher Exp $");

//_____________________________________________________________________________
RotoClientBinaryFile::RotoClientBinaryFile(const Char_t* ipaddress, Int_t port,
                                           MinosRooterEntity whom)
   : RotoClient(ipaddress,port,whom), fFileName(""),
#ifdef BINARYVIAOSTREAM
     fStream(0)
#else
     fFile(0)
#endif
{
   // use ipaddress (host) as filename
}

//_____________________________________________________________________________
RotoClientBinaryFile::~RotoClientBinaryFile() 
{
#ifdef BINARYVIAOSTREAM
   if (fStream) {
      fStream->close();
      delete fStream;
      fStream = 0;
   }
#else
   if (fFile) {
      fclose(fFile);
      delete fFile;
      fFile = 0;
   }
#endif

}

//_____________________________________________________________________________
Bool_t RotoClientBinaryFile::Connected()
{
   return true;
}

//_____________________________________________________________________________
Bool_t RotoClientBinaryFile::OpenDAQFile(Int_t detector,
                                         Int_t run, Int_t subrun)
{
   return OpenFile(BuildDAQFileName(detector,run,subrun));
}
//_____________________________________________________________________________
Bool_t RotoClientBinaryFile::CloseDAQFile(Int_t detector,
                                          Int_t run, Int_t subrun)
{
   return CloseFile(BuildDAQFileName(detector,run,subrun));
}
//_____________________________________________________________________________
Bool_t RotoClientBinaryFile::OpenDCSFile(Int_t detector,
                                         Int_t sec, Int_t nanosec)
{
   return OpenFile(BuildDCSFileName(detector,sec,nanosec));
}
//_____________________________________________________________________________
Bool_t RotoClientBinaryFile::CloseDCSFile(Int_t detector,
                                          Int_t sec, Int_t nanosec)
{
   return CloseFile(BuildDCSFileName(detector,sec,nanosec));
}
//_____________________________________________________________________________
Bool_t RotoClientBinaryFile::OpenBeamMonFile(Int_t detector,
                                             Int_t sec, Int_t nanosec)
{
   return OpenFile(BuildBeamMonFileName(detector,sec,nanosec));
}
//_____________________________________________________________________________
Bool_t RotoClientBinaryFile::CloseBeamMonFile(Int_t detector,
                                              Int_t sec, Int_t nanosec)
{
   return CloseFile(BuildBeamMonFileName(detector,sec,nanosec));
}

//_____________________________________________________________________________
string RotoClientBinaryFile::BuildDAQFileName(Int_t detector, 
                                              Int_t run, Int_t subrun)
{
   // don't build the filename

   // MSG("Roto",Msg::kInfo)
   //   << "RotoClientBinaryFile::BuildDAQFileName \""
   //     << fIPAddress << "\"" << endl;
   return fIPAddress;

   Detector::Detector_t det = (Detector::Detector_t)(detector);
   Char_t detchar = Detector::AsString(det)[0];
//   MSG("Roto",Msg::kInfo)
//      << "DAQfile detector(" << detector 
//      << ") run(" << run << ") subrun (" << subrun << ") -> " << endl
//      << Form("%c%8.8d_%4.4d.mdaq.dat",detchar,run,subrun) << endl;
   return string(Form("%c%8.8d_%4.4d.mdaq.dat",detchar,run,subrun));
}

//_____________________________________________________________________________
string RotoClientBinaryFile::BuildDCSFileName(Int_t detector, 
                                              Int_t sec, Int_t nanosec)
{
   Detector::Detector_t det = (Detector::Detector_t)(detector);
   Char_t detchar = Detector::AsString(det)[0];
   return string(Form("%c%8.8x_%8.8x.mdcs.dat",detchar,sec,nanosec));
}

//_____________________________________________________________________________
string RotoClientBinaryFile::BuildBeamMonFileName(Int_t detector, 
                                                  Int_t sec, Int_t nanosec)
{
   Detector::Detector_t det = (Detector::Detector_t)(detector);
   Char_t detchar = Detector::AsString(det)[0];
   return string(Form("%c%8.8x_%8.8x.mbeam.dat",detchar,sec,nanosec));
}

//_____________________________________________________________________________
Bool_t RotoClientBinaryFile::OpenFile(const string& fname)
{
   if (fFileName != "") {
      MSG("Roto",Msg::kWarning) 
         << "RotoClientBinaryFile::OpenFile called while "
         << fFileName << " was still open" << endl;
      CloseFile(fFileName);
   }

   fFileName = fname;
#ifdef BINARYVIAOSTREAM
   fStream = new ofstream(fname.c_str(),ios::out|ios::binary|ios::trunc);
#else
   fFile = fopen(fname.c_str(),"wb");
#endif

   MSG("Roto",Msg::kInfo) << "OpenFile \"" <<  fFileName << "\"" << endl;

   return true;
}

//_____________________________________________________________________________
Bool_t RotoClientBinaryFile::CloseFile(const string& fname)
{

   if (fname == fFileName) {
      if (fFileName != "") {
#ifdef BINARYVIAOSTREAM
         if (fStream) {
            MSG("Roto",Msg::kInfo) << "CloseFile \"" <<  fFileName <<"\""<< endl;
            fStream->close();
            delete fStream;
            fStream = 0;
         }
#else
         if (fFile) {
            MSG("Roto",Msg::kInfo) << "CloseFile \"" <<  fFileName <<"\""<< endl;
            fclose(fFile);
            fFile = 0;
         }
#endif
         fFileName = "";
      }
      return true;
   } else {
      MSG("Roto",Msg::kWarning) 
         << "RotoClientBinaryFile::CloseFile name mismatch" << endl
         << fFileName << " is open" << endl
         << fname << " was requested to be closed " << endl;
      return false;
   }
}

//_____________________________________________________________________________
Bool_t RotoClientBinaryFile::GetRotoStatus(Char_t* statusBuffer, Int_t maxBytes)
{
   snprintf(statusBuffer,maxBytes,"RotoClientBinaryFile:: status");
   return true;
}

//_____________________________________________________________________________
Bool_t RotoClientBinaryFile::SendRecordBuffer(const void* buffer, Int_t nbytes)
{
   MSG("Roto",Msg::kVerbose) 
      << "RotoClientBinaryFile::SendRecordBuffer" << endl;

#ifdef BINARYVIAOSTREAM
   if (!fStream) {
#else
   if (!fFile) {
#endif
      MSG("Roto",Msg::kWarning) 
         << "RotoClientBinaryFile::SendRecordBuffer - no open file" << endl;
      return false;
   }

   // in binary mode one can NOT use operator<<

   // output the number of bytes inclusive of the byte count
   Int_t nrecbytes = nbytes + sizeof(Int_t);
   Int_t* nrb_addr = &nrecbytes;
#ifdef BINARYVIAOSTREAM
   fStream->write((const char*)nrb_addr,sizeof(Int_t));

   // output the buffer
   fStream->write((const char*)buffer,nbytes);

   fStream->flush();
#else
   fwrite(nrb_addr,sizeof(Int_t),1,fFile);
   fwrite(buffer,1,nbytes,fFile);
   fflush(fFile);
#endif

   return true;
}

//_____________________________________________________________________________
Bool_t RotoClientBinaryFile::SendShutdownMessage()
{

   MSG("Roto",Msg::kInfo) 
      << "RotoClientBinaryFile::SendShutdownMessage" << endl;

   CloseFile(fFileName);
   return true;
}

//_____________________________________________________________________________

---