xrootd
Loading...
Searching...
No Matches
Public Types | Public Member Functions | Static Public Member Functions | Static Public Attributes | Private Member Functions | Private Attributes | Static Private Attributes | List of all members
XrdOfsEvs Class Reference

#include <XrdOfsEvs.hh>

Collaboration diagram for XrdOfsEvs:
Collaboration graph
[legend]

Public Types

enum  Event {
  All = 0x7fffff00 , None = 0x00000000 , Chmod = 0x00000100 , Closer = 0x00000201 ,
  Closew = 0x00000402 , Close = 0x00000600 , Create = 0x00000803 , Fwrite = 0x00001004 ,
  Mkdir = 0x00002005 , Mv = 0x00004006 , Openr = 0x00008007 , Openw = 0x00010008 ,
  Open = 0x00018000 , Rm = 0x00020009 , Rmdir = 0x0004000a , Trunc = 0x0008000b ,
  nCount = 12 , Mask = 0X000000ff , enMask = 0x7fffff00
}
 

Public Member Functions

int Enabled (Event theEvents)
 
int maxSmsg ()
 
int maxLmsg ()
 
void Notify (Event eNum, XrdOfsEvsInfo &Info)
 
const char * Prog ()
 
void sendEvents (void)
 
int Start (XrdSysError *eobj)
 
 XrdOfsEvs (Event theEvents, const char *Target, int minq=90, int maxq=10)
 
 ~XrdOfsEvs ()
 

Static Public Member Functions

static int Parse (XrdSysError &Eroute, Event eNum, char *mText)
 

Static Public Attributes

static const int minMsgSize = 1360
 
static const int maxMsgSize = 2384
 

Private Member Functions

const char * eName (int eNum)
 
int Feed (const char *data, int dlen)
 
XrdOfsEvsMsg * getMsg (int bigmsg)
 
void retMsg (XrdOfsEvsMsg *tp)
 

Private Attributes

pthread_t tid
 
char * theTarget
 
Event enEvents
 
XrdSysErroreDest
 
XrdOucProgtheProg
 
XrdSysMutex qMut
 
XrdSysSemaphore qSem
 
XrdOfsEvsMsg * msgFirst
 
XrdOfsEvsMsg * msgLast
 
XrdSysMutex fMut
 
XrdOfsEvsMsg * msgFreeMax
 
XrdOfsEvsMsg * msgFreeMin
 
int endIT
 
int msgFD
 
int numMax
 
int maxMax
 
int numMin
 
int maxMin
 

Static Private Attributes

static XrdOfsEvsFormat MsgFmt [XrdOfsEvs::nCount]
 

Member Enumeration Documentation

◆ Event

Enumerator
All 
None 
Chmod 
Closer 
Closew 
Close 
Create 
Fwrite 
Mkdir 
Mv 
Openr 
Openw 
Open 
Rm 
Rmdir 
Trunc 
nCount 
Mask 
enMask 

Constructor & Destructor Documentation

◆ XrdOfsEvs()

XrdOfsEvs::XrdOfsEvs ( Event  theEvents,
const char *  Target,
int  minq = 90,
int  maxq = 10 
)

◆ ~XrdOfsEvs()

XrdOfsEvs::~XrdOfsEvs ( )

Member Function Documentation

◆ Enabled()

int XrdOfsEvs::Enabled ( Event  theEvents)
inline

References enEvents.

◆ eName()

const char * XrdOfsEvs::eName ( int  eNum)
private

◆ Feed()

int XrdOfsEvs::Feed ( const char *  data,
int  dlen 
)
private

◆ getMsg()

XrdOfsEvsMsg * XrdOfsEvs::getMsg ( int  bigmsg)
private

◆ maxLmsg()

int XrdOfsEvs::maxLmsg ( )
inline

References maxMax.

◆ maxSmsg()

int XrdOfsEvs::maxSmsg ( )
inline

References maxMin.

◆ Notify()

void XrdOfsEvs::Notify ( Event  eNum,
XrdOfsEvsInfo Info 
)

◆ Parse()

static int XrdOfsEvs::Parse ( XrdSysError Eroute,
Event  eNum,
char *  mText 
)
static

◆ Prog()

const char * XrdOfsEvs::Prog ( )
inline

References theTarget.

◆ retMsg()

void XrdOfsEvs::retMsg ( XrdOfsEvsMsg *  tp)
private

◆ sendEvents()

void XrdOfsEvs::sendEvents ( void  )

◆ Start()

int XrdOfsEvs::Start ( XrdSysError eobj)

Member Data Documentation

◆ eDest

XrdSysError* XrdOfsEvs::eDest
private

◆ endIT

int XrdOfsEvs::endIT
private

◆ enEvents

Event XrdOfsEvs::enEvents
private

Referenced by Enabled().

◆ fMut

XrdSysMutex XrdOfsEvs::fMut
private

◆ maxMax

int XrdOfsEvs::maxMax
private

Referenced by maxLmsg().

◆ maxMin

int XrdOfsEvs::maxMin
private

Referenced by maxSmsg().

◆ maxMsgSize

const int XrdOfsEvs::maxMsgSize = 2384
static

◆ minMsgSize

const int XrdOfsEvs::minMsgSize = 1360
static

◆ msgFD

int XrdOfsEvs::msgFD
private

◆ msgFirst

XrdOfsEvsMsg* XrdOfsEvs::msgFirst
private

◆ MsgFmt

XrdOfsEvsFormat XrdOfsEvs::MsgFmt[XrdOfsEvs::nCount]
staticprivate

◆ msgFreeMax

XrdOfsEvsMsg* XrdOfsEvs::msgFreeMax
private

◆ msgFreeMin

XrdOfsEvsMsg* XrdOfsEvs::msgFreeMin
private

◆ msgLast

XrdOfsEvsMsg* XrdOfsEvs::msgLast
private

◆ numMax

int XrdOfsEvs::numMax
private

◆ numMin

int XrdOfsEvs::numMin
private

◆ qMut

XrdSysMutex XrdOfsEvs::qMut
private

◆ qSem

XrdSysSemaphore XrdOfsEvs::qSem
private

◆ theProg

XrdOucProg* XrdOfsEvs::theProg
private

◆ theTarget

char* XrdOfsEvs::theTarget
private

Referenced by Prog().

◆ tid

pthread_t XrdOfsEvs::tid
private

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