WriterPopen Class Reference

Inheritance diagram for WriterPopen:

Collaboration diagram for WriterPopen:

Public Member Functions
	WriterPopen (LOG_CHN *log_chn, const char *pipe_command, const char *file_ext)
	~WriterPopen ()
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
FILE *	fFp
std::string	fPipeCommand
std::string	fCommand
std::string	fFileExt
time_t	fLastCheckTime

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

Detailed Description

Definition at line 739 of file mlogger.cxx.

Constructor & Destructor Documentation

WriterPopen()

WriterPopen::WriterPopen ( LOG_CHN *  log_chn, const char *  pipe_command, const char *  file_ext  )

inline

Definition at line 742 of file mlogger.cxx.

   {
      if (fTrace)
         printf("WriterPopen: path [%s]\n", log_chn->path.c_str());
      fFp = NULL;
      fPipeCommand = pipe_command;
      fFileExt = file_ext;
      fLastCheckTime = time(NULL);
   }

~WriterPopen()

WriterPopen::~WriterPopen ( )

inline

Definition at line 752 of file mlogger.cxx.

   {
      if (fTrace)
         printf("WriterPopen: destructor\n");
      if (fFp)
         pclose(fFp);
      fFp = NULL;
   }

Member Function Documentation

wr_close()

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

inlinevirtual

Implements WriterInterface.

Definition at line 831 of file mlogger.cxx.

   {
      int err;
 
      if (fTrace)
         printf("WriterPopen: close path [%s]\n", log_chn->path.c_str());
 
      assert(fFp != NULL);
 
      log_chn->handle = 0;
 
#ifdef OS_WINNT
      // sorry no popen?!?
      return SS_FILE_ERROR;
#else
      err = pclose(fFp);
      fFp = NULL;
 
      if (err != 0) {
         cm_msg(MERROR, "WriterPopen::wr_close", "Cannot write to pipe \'%s\', pclose() returned %d, errno %d (%s)", fCommand.c_str(), err, errno, strerror(errno));
         return SS_FILE_ERROR;
      }
 
      chmod(log_chn->path.c_str(), 0444);
 
      fBytesOut = ss_file_size(log_chn->path.c_str());
 
      return SUCCESS;
#endif
   }

Here is the call graph for this function:

Here is the caller graph for this function:

wr_get_chain()

std::string WriterPopen::wr_get_chain ( )

inlinevirtual

Implements WriterInterface.

Definition at line 867 of file mlogger.cxx.

   {
      return fPipeCommand;
   }

wr_get_file_ext()

std::string WriterPopen::wr_get_file_ext ( )

inlinevirtual

Reimplemented from WriterInterface.

Definition at line 862 of file mlogger.cxx.

   {
      return fFileExt;
   }

wr_open()

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

inlinevirtual

Implements WriterInterface.

Definition at line 761 of file mlogger.cxx.

   {
      fBytesIn = 0;
      fBytesOut = 0;
 
      if (fTrace)
         printf("WriterPopen: open path [%s] pipe [%s] ext [%s]\n", log_chn->path.c_str(), fPipeCommand.c_str(), fFileExt.c_str());
 
      assert(fFp == NULL);
 
      if (check_file_exists(log_chn->path.c_str()))
         return SS_FILE_EXISTS;
 
#ifdef OS_WINNT
      // sorry no popen?!?
      return SS_FILE_ERROR;
#else
      fCommand = fPipeCommand + log_chn->path;
 
      fFp = popen(fCommand.c_str(), "w");
      if (fFp == NULL) {
         cm_msg(MERROR, "WriterPopen::wr_open", "Cannot write to pipe \'%s\', popen() errno %d (%s)", fCommand.c_str(), errno, strerror(errno));
         return SS_FILE_ERROR;
      }
 
      log_chn->handle = 9999;
 
      return SUCCESS;
#endif
   }

Here is the call graph for this function:

wr_write()

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

inlinevirtual

Implements WriterInterface.

Definition at line 792 of file mlogger.cxx.

   {
      if (fTrace)
         printf("WriterPopen: write path [%s], size %d\n", log_chn->path.c_str(), size);
 
      if (size == 0)
         return SUCCESS;
 
      if (fFp == NULL) {
         return SS_FILE_ERROR;
      }
 
      fBytesIn += size;
 
      int wr = fwrite(data, 1, size, fFp);
 
      //if (wr > 0)
      //fBytesOut += wr;
 
      if (wr != size) {
         cm_msg(MERROR, "WriterPopen::wr_write", "Cannot write to pipe \'%s\', fwrite(%d) returned %d, errno %d (%s)", fCommand.c_str(), size, wr, errno, strerror(errno));
 
         if (errno == EPIPE) {
            cm_msg(MERROR, "WriterPopen::wr_write", "Cannot write to pipe \'%s\': broken pipe, closing the pipe", fCommand.c_str());
            wr_close(log_chn, 0);
         }
 
         return SS_FILE_ERROR;
      }
 
      time_t now = time(NULL);
      if (now - fLastCheckTime > 2) {
         fLastCheckTime = now;
         fBytesOut = ss_file_size(log_chn->path.c_str());
      }
 
      return SUCCESS;
   }

Here is the call graph for this function:

Member Data Documentation

fCommand

std::string WriterPopen::fCommand

private

Definition at line 875 of file mlogger.cxx.

fFileExt

std::string WriterPopen::fFileExt

private

Definition at line 876 of file mlogger.cxx.

fFp

FILE* WriterPopen::fFp

private

Definition at line 873 of file mlogger.cxx.

fLastCheckTime

time_t WriterPopen::fLastCheckTime

private

Definition at line 877 of file mlogger.cxx.

fPipeCommand

std::string WriterPopen::fPipeCommand

private

Definition at line 874 of file mlogger.cxx.

---

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

• progs/mlogger.cxx