XrdSysLogger.hh

Go to the documentation of this file.

#ifndef __SYS_LOGGER_H__
#define __SYS_LOGGER_H__
/******************************************************************************/
/*                                                                            */
/*                       X r d S y s L o g g e r . h h                        */
/*                                                                            */
/*(c) 2004 by the Board of Trustees of the Leland Stanford, Jr., University   */
/*Produced by Andrew Hanushevsky for Stanford University under contract       */
/*           DE-AC02-76-SFO0515 with the Deprtment of Energy                  */
/*                                                                            */
/* This file is part of the XRootD software suite.                            */
/*                                                                            */
/* XRootD is free software: you can redistribute it and/or modify it under    */
/* the terms of the GNU Lesser General Public License as published by the     */
/* Free Software Foundation, either version 3 of the License, or (at your     */
/* option) any later version.                                                 */
/*                                                                            */
/* XRootD is distributed in the hope that it will be useful, but WITHOUT      */
/* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or      */
/* FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Lesser General Public       */
/* License for more details.                                                  */
/*                                                                            */
/* You should have received a copy of the GNU Lesser General Public License   */
/* along with XRootD in a file called COPYING.LESSER (LGPL license) and file  */
/* COPYING (GPL license).  If not, see <http://www.gnu.org/licenses/>.        */
/*                                                                            */
/* The copyright holder's institutional names and contributor's names may not */
/* be used to endorse or promote products derived from this software without  */
/* specific prior written permission of the institution or contributor.       */
/******************************************************************************/
 
#include <cstdlib>
#ifndef WIN32
#include <unistd.h>
#include <cstring>
#include <strings.h>
#else
#include <cstring>
#include <io.h>
#include "XrdSys/XrdWin32.hh"
#endif
 
#include "XrdSys/XrdSysPthread.hh"
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
class XrdOucTListFIFO;
 
class XrdSysLogger
{
public:
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
         XrdSysLogger(int ErrFD=STDERR_FILENO, int xrotate=1);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
        ~XrdSysLogger()
        {
          RmLogRotateLock();
          if (ePath)
            free(ePath);
        }
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
void  AddMsg(const char *msg);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
class Task
{
public:
friend class XrdSysLogger;
 
virtual void  Ring() = 0; 
 
inline  Task *Next() {return next;}
 
              Task() : next(0) {}
virtual      ~Task() {}
 
private:
Task *next;
};
 
void  AtMidnight(Task *mnTask);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static const int onFifo = (int)0x80000000;
 
int Bind(const char *path, int lfh=0);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
void Capture(XrdOucTListFIFO *tFIFO);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
void Flush() {fsync(eFD);}
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
int  originalFD() {return baseFD;}
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
int  ParseKeep(const char *arg);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
void Put(int iovcnt, struct iovec *iov);
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
static
void setForwarding(bool onoff) {doForward = onoff;}
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
void setHiRes() {hiRes = true;}
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
void setKeep(long long knum) {eKeep = knum;}
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
void setRotate(int onoff) {doLFR = onoff;}
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
char *traceBeg() {Logger_Mutex.Lock(); Time(TBuff); return TBuff;}
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
char  traceEnd() {Logger_Mutex.UnLock(); return '\n';}
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
const char *xlogFN() {return (ePath ? ePath : "stderr");}
 
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
 
void        zHandler();
 
private:
int         FifoMake();
void        FifoWait();
int         Time(char *tbuff);
static int  TimeStamp(struct timeval &tVal, unsigned long tID,
                      char *tbuff, int tbsz, bool hires);
int         HandleLogRotateLock( bool dorotate );
void        RmLogRotateLock();
 
struct mmMsg
      {mmMsg *next;
       int    mlen;
       char  *msg;
      };
mmMsg     *msgList;
Task      *taskQ;
XrdSysMutex Logger_Mutex;
long long  eKeep;
char       TBuff[32];        // Trace header buffer
int        eFD;
int        baseFD;
char      *ePath;
char       Filesfx[8];
int        eInt;
int        reserved1;
char      *fifoFN;
bool       hiRes;
bool       doLFR;
pthread_t  lfhTID;
 
static bool doForward;
 
void   putEmsg(char *msg, int msz);
int    ReBind(int dorename=1);
void   Trim();
};
#endif