WriterGzip Class Reference

Inheritance diagram for WriterGzip:

Collaboration diagram for WriterGzip:

Public Member Functions
	WriterGzip (LOG_CHN *log_chn, int compress)
	~WriterGzip ()
int	wr_open (LOG_CHN *log_chn, int run_number)
int	wr_write (LOG_CHN *log_chn, const void *data, const int size)
int	wr_close (LOG_CHN *log_chn, int run_number)
std::string	wr_get_file_ext ()
std::string	wr_get_chain ()
Public Member Functions inherited from WriterInterface
	WriterInterface ()
virtual	~WriterInterface ()

Private Attributes
std::string	fFilename
gzFile	fGzfp
int	fCompress
time_t	fLastCheckTime

Additional Inherited Members
Public Attributes inherited from WriterInterface
bool	fTrace
double	fBytesIn
double	fBytesOut

Detailed Description

Definition at line 608 of file mlogger.cxx.

Constructor & Destructor Documentation

WriterGzip()

WriterGzip::WriterGzip ( LOG_CHN *  log_chn, int  compress  )

inline

Definition at line 611 of file mlogger.cxx.

   {
      if (fTrace)
         printf("WriterGzip: path [%s]\n", log_chn->path.c_str());
      fGzfp = 0;
      if (log_chn->settings.gzip_compression) {
         fCompress = log_chn->settings.gzip_compression;
      } else {
         fCompress = compress;
      }
      fLastCheckTime = time(NULL);
   }

Here is the call graph for this function:

~WriterGzip()

WriterGzip::~WriterGzip ( )

inline

Definition at line 624 of file mlogger.cxx.

   {
      if (fTrace)
         printf("WriterGzip: destructor\n");
      assert(fGzfp == 0);
   }

Here is the call graph for this function:

Member Function Documentation

wr_close()

int WriterGzip::wr_close ( LOG_CHN *  log_chn, int  run_number  )

inlinevirtual

Implements WriterInterface.

Definition at line 715 of file mlogger.cxx.

   {
      int zerror;
 
      if (fTrace)
         printf("WriterGzip: close path [%s]\n", log_chn->path.c_str());
 
      assert(fGzfp);
 
      log_chn->handle = 0;
 
      zerror = gzflush(fGzfp, Z_FINISH);
 
      if (zerror != Z_OK) {
         cm_msg(MERROR, "WriterGzip::wr_close", "Cannot write to file \'%s\', gzflush(Z_FINISH) zerror %d, errno: %d (%s)", log_chn->path.c_str(), zerror, errno, strerror(errno));
         return SS_FILE_ERROR;
      }
 
      zerror = gzclose(fGzfp);
      fGzfp = 0;
 
      if (zerror != Z_OK) {
         cm_msg(MERROR, "WriterGzip::wr_close", "Cannot write to file \'%s\', gzclose() zerror %d, errno: %d (%s)", log_chn->path.c_str(), zerror, errno, strerror(errno));
         return SS_FILE_ERROR;
      }
 
      fBytesOut = ss_file_size(log_chn->path.c_str());
 
      return SUCCESS;
   }

Here is the call graph for this function:

wr_get_chain()

std::string WriterGzip::wr_get_chain ( )

inlinevirtual

Implements WriterInterface.

Definition at line 751 of file mlogger.cxx.

   {
      return "gzip > " + fFilename;
   }

wr_get_file_ext()

std::string WriterGzip::wr_get_file_ext ( )

inlinevirtual

Reimplemented from WriterInterface.

Definition at line 746 of file mlogger.cxx.

   {
      return ".gz";
   }

wr_open()

int WriterGzip::wr_open ( LOG_CHN *  log_chn, int  run_number  )

inlinevirtual

Implements WriterInterface.

Definition at line 631 of file mlogger.cxx.

   {
      int zerror;
 
      fBytesIn = 0;
      fBytesOut = 0;
 
      if (fTrace)
         printf("WriterGzip: open path [%s]\n", log_chn->path.c_str());
 
      assert(fGzfp == 0);
 
      if (check_file_exists(log_chn->path.c_str()))
         return SS_FILE_EXISTS;
 
      fGzfp = gzopen(log_chn->path.c_str(), "wb");
      if (fGzfp == 0) {
         cm_msg(MERROR, "WriterGzip::wr_open", "Cannot write to file \'%s\', gzopen() errno %d (%s)", log_chn->path.c_str(), errno, strerror(errno));
         return SS_FILE_ERROR;
      }
 
      chmod(log_chn->path.c_str(), 0444);
 
      //printf("WriterGzip::wr_open: compress %d\n", fCompress);
 
      if (fCompress) {
         zerror = gzsetparams(fGzfp, fCompress, Z_DEFAULT_STRATEGY);
         if (zerror != Z_OK) {
            cm_msg(MERROR, "WriterGzip::wr_open", "gzsetparams() zerror %d", zerror);
            return SS_FILE_ERROR;
         }
      }
 
#if ZLIB_VERNUM > 0x1235
      // gzbuffer() added in zlib 1.2.3.5 (8 Jan 2010)
      zerror = gzbuffer(fGzfp, 128*1024);
      if (zerror != Z_OK) {
         cm_msg(MERROR, "WriterGzip::wr_open", "gzbuffer() zerror %d", zerror);
         return SS_FILE_ERROR;
      }
#else
#warning Very old zlib, no gzbuffer()!
#endif
         
      log_chn->handle = 8888;
 
      fFilename = log_chn->path;
      return SUCCESS;
   }

Here is the call graph for this function:

wr_write()

int WriterGzip::wr_write ( LOG_CHN *  log_chn, const void *  data, const int  size  )

inlinevirtual

Implements WriterInterface.

Definition at line 681 of file mlogger.cxx.

   {
      if (fTrace)
         printf("WriterGzip: write path [%s], size %d\n", log_chn->path.c_str(), size);
 
      if (size == 0)
         return SUCCESS;
 
      assert(fGzfp);
 
      fBytesIn += size;
 
      int wr = gzwrite(fGzfp, data, size);
 
      if (wr != size) {
         cm_msg(MERROR, "WriterGzip::wr_write", "Cannot write to file \'%s\', gzwrite(%d) returned %d, errno: %d (%s)", log_chn->path.c_str(), size, wr, errno, strerror(errno));
         return SS_FILE_ERROR;
      }
 
#if ZLIB_VERNUM > 0x1235
      // gzoffset() added in zlib 1.2.3.5 (8 Jan 2010)
      fBytesOut = gzoffset(fGzfp);
#else
#warning Very old zlib, no gzoffset()!
      time_t now = time(NULL);
      if (now - fLastCheckTime > 2) {
         fLastCheckTime = now;
         fBytesOut = ss_file_size(log_chn->path.c_str());
      }
#endif
 
      return SUCCESS;
   }

Here is the call graph for this function:

Member Data Documentation

fCompress

int WriterGzip::fCompress

private

Definition at line 759 of file mlogger.cxx.

fFilename

std::string WriterGzip::fFilename

private

Definition at line 757 of file mlogger.cxx.

fGzfp

gzFile WriterGzip::fGzfp

private

Definition at line 758 of file mlogger.cxx.

fLastCheckTime

time_t WriterGzip::fLastCheckTime

private

Definition at line 760 of file mlogger.cxx.

---

The documentation for this class was generated from the following file:

• progs/mlogger.cxx