class TProofMonSenderML: public TProofMonSender


TProofMonSenderML

TProofMonSender implementation for the ML writer.

Function Members (Methods)

public:

virtual	~TProofMonSenderML()
void	TObject::AbstractMethod(const char* method) const
virtual void	TObject::AppendPad(Option_t* option = "")
virtual void	TObject::Browse(TBrowser* b)
static TClass*	Class()
virtual const char*	TObject::ClassName() const
virtual void	TNamed::Clear(Option_t* option = "")
virtual TObject*	TNamed::Clone(const char* newname = "") const
virtual Int_t	TNamed::Compare(const TObject* obj) const
virtual void	TNamed::Copy(TObject& named) const
virtual void	TObject::Delete(Option_t* option = "")MENU
virtual Int_t	TObject::DistancetoPrimitive(Int_t px, Int_t py)
virtual void	TObject::Draw(Option_t* option = "")
virtual void	TObject::DrawClass() constMENU
virtual TObject*	TObject::DrawClone(Option_t* option = "") constMENU
virtual void	TObject::Dump() constMENU
virtual void	TObject::Error(const char* method, const char* msgfmt) const
virtual void	TObject::Execute(const char* method, const char* params, Int_t* error = 0)
virtual void	TObject::Execute(TMethod* method, TObjArray* params, Int_t* error = 0)
virtual void	TObject::ExecuteEvent(Int_t event, Int_t px, Int_t py)
virtual void	TObject::Fatal(const char* method, const char* msgfmt) const
virtual void	TNamed::FillBuffer(char*& buffer)
virtual TObject*	TObject::FindObject(const char* name) const
virtual TObject*	TObject::FindObject(const TObject* obj) const
virtual Option_t*	TObject::GetDrawOption() const
static Long_t	TObject::GetDtorOnly()
virtual const char*	TObject::GetIconName() const
virtual const char*	TNamed::GetName() const
virtual char*	TObject::GetObjectInfo(Int_t px, Int_t py) const
static Bool_t	TObject::GetObjectStat()
virtual Option_t*	TObject::GetOption() const
virtual const char*	TNamed::GetTitle() const
virtual UInt_t	TObject::GetUniqueID() const
virtual Bool_t	TObject::HandleTimer(TTimer* timer)
virtual ULong_t	TNamed::Hash() const
virtual void	TObject::Info(const char* method, const char* msgfmt) const
virtual Bool_t	TObject::InheritsFrom(const char* classname) const
virtual Bool_t	TObject::InheritsFrom(const TClass* cl) const
virtual void	TObject::Inspect() constMENU
void	TObject::InvertBit(UInt_t f)
virtual TClass*	IsA() const
virtual Bool_t	TObject::IsEqual(const TObject* obj) const
virtual Bool_t	TObject::IsFolder() const
Bool_t	TObject::IsOnHeap() const
virtual Bool_t	TNamed::IsSortable() const
Bool_t	TProofMonSender::IsValid() const
Bool_t	TObject::IsZombie() const
virtual void	TNamed::ls(Option_t* option = "") const
void	TObject::MayNotUse(const char* method) const
virtual Bool_t	TObject::Notify()
void	TObject::Obsolete(const char* method, const char* asOfVers, const char* removedFromVers) const
void	TObject::operator delete(void* ptr)
void	TObject::operator delete(void* ptr, void* vp)
void	TObject::operator delete[](void* ptr)
void	TObject::operator delete[](void* ptr, void* vp)
void*	TObject::operator new(size_t sz)
void*	TObject::operator new(size_t sz, void* vp)
void*	TObject::operator new[](size_t sz)
void*	TObject::operator new[](size_t sz, void* vp)
TProofMonSenderML&	operator=(const TProofMonSenderML&)
virtual void	TObject::Paint(Option_t* option = "")
virtual void	TObject::Pop()
virtual void	TNamed::Print(Option_t* option = "") const
virtual Int_t	TObject::Read(const char* name)
virtual void	TObject::RecursiveRemove(TObject* obj)
void	TObject::ResetBit(UInt_t f)
virtual void	TObject::SaveAs(const char* filename = "", Option_t* option = "") constMENU
virtual void	TObject::SavePrimitive(ostream& out, Option_t* option = "")
virtual Int_t	SendDataSetInfo(TDSet, TList, const char, const char)
virtual Int_t	SendFileInfo(TDSet, TList, const char, const char)
virtual Int_t	SendSummary(TList, const char)
void	TObject::SetBit(UInt_t f)
void	TObject::SetBit(UInt_t f, Bool_t set)
virtual void	TObject::SetDrawOption(Option_t* option = "")MENU
static void	TObject::SetDtorOnly(void* obj)
virtual void	TNamed::SetName(const char* name)MENU
virtual void	TNamed::SetNameTitle(const char* name, const char* title)
static void	TObject::SetObjectStat(Bool_t stat)
Int_t	TProofMonSender::SetSendOptions(const char*)
virtual void	TNamed::SetTitle(const char* title = "")MENU
virtual void	TObject::SetUniqueID(UInt_t uid)
virtual void	ShowMembers(TMemberInspector& insp) const
virtual Int_t	TNamed::Sizeof() const
virtual void	Streamer(TBuffer&)
void	StreamerNVirtual(TBuffer& ClassDef_StreamerNVirtual_b)
virtual void	TObject::SysError(const char* method, const char* msgfmt) const
Bool_t	TObject::TestBit(UInt_t f) const
Int_t	TObject::TestBits(UInt_t f) const
	TProofMonSenderML(const TProofMonSenderML&)
	TProofMonSenderML(const char* serv, const char* tag, const char* id = 0, const char* subid = 0, const char* opt = "")
virtual void	TObject::UseCurrentStyle()
virtual void	TObject::Warning(const char* method, const char* msgfmt) const
virtual Int_t	TObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0)
virtual Int_t	TObject::Write(const char* name = 0, Int_t option = 0, Int_t bufsize = 0) const

protected:

virtual void	TObject::DoError(int level, const char* location, const char* fmt, va_list va) const
void	TObject::MakeZombie()

Data Members

public:

static TObject::<anonymous>	TObject::kBitMask
static TObject::EStatusBits	TObject::kCanDelete
static TObject::EStatusBits	TObject::kCannotPick
static TObject::EStatusBits	TObject::kHasUUID
static TObject::EStatusBits	TObject::kInvalidObject
static TObject::<anonymous>	TObject::kIsOnHeap
static TObject::EStatusBits	TObject::kIsReferenced
static TObject::EStatusBits	TObject::kMustCleanup
static TObject::EStatusBits	TObject::kNoContextMenu
static TObject::<anonymous>	TObject::kNotDeleted
static TObject::EStatusBits	TObject::kObjInCanvas
static TObject::<anonymous>	TObject::kOverwrite
static TObject::<anonymous>	TObject::kSingleKey
static TObject::<anonymous>	TObject::kWriteDelete
static TObject::<anonymous>	TObject::kZombie

protected:

Int_t	TProofMonSender::fDataSetInfoVrs	Version of the dataset info 'table'
Int_t	TProofMonSender::fFileInfoVrs	Version of the file info 'table'
TString	TNamed::fName	object identifier
Int_t	TProofMonSender::fSummaryVrs	Version of the summary 'table'
TString	TNamed::fTitle	object title
static TProofMonSender::EConfigBits	TProofMonSender::kSendDataSetInfo
static TProofMonSender::EConfigBits	TProofMonSender::kSendFileInfo
static TProofMonSender::EConfigBits	TProofMonSender::kSendSummary

private:

TVirtualMonitoringWriter*	fWriter	Writer instance connect to backend

Class Charts

Inheritance Inherited Members Includes Libraries

Function documentation

TProofMonSenderML(const char* serv, const char* tag, const char* id = 0, const char* subid = 0, const char* opt = "")

 Main constructor

~TProofMonSenderML()

 Destructor

Int_t SendSummary(TList* , const char* )

 Send summary record

 There are three versions of this record, corresponding the evolution
 in time of the monitoring requirements.

 The default version 2 contains the following information

    user                  XRD_STRING
    proofgroup            XRD_STRING
    begin                 XRD_STRING
    end                   XRD_STRING
    walltime              XRD_REAL64
    cputime               XRD_REAL64
    bytesread             XRD_REAL64
    events                XRD_REAL64
    totevents             XRD_REAL64
    workers               XRD_REAL64
    vmemmxw               XRD_REAL64
    rmemmxw               XRD_REAL64
    vmemmxm               XRD_REAL64
    rmemmxm               XRD_REAL64
    numfiles              XRD_REAL64
    missfiles             XRD_REAL64
    status                XRD_REAL64
    rootver               XRD_STRING

 Version 1 contains the following information
    (no 'status', 'missfiles', 'rootver'; 'dataset' field with name(s) of
     processed dataset(s))

    user                  XRD_STRING
    proofgroup            XRD_STRING
    begin                 XRD_STRING
    end                   XRD_STRING
    walltime              XRD_REAL64
    cputime               XRD_REAL64
    bytesread             XRD_REAL64
    events                XRD_REAL64
    totevents             XRD_REAL64
    workers               XRD_REAL64
    vmemmxw               XRD_REAL64
    rmemmxw               XRD_REAL64
    vmemmxm               XRD_REAL64
    rmemmxm               XRD_REAL64
    numfiles              XRD_REAL64
    dataset               XRD_STRING

 Version 0 contains the following information
    ('group' instead of 'proofgroup'; no 'vmemmxw',
     'rmemmxw', 'vmemmxm', 'rmemmxm', 'numfiles', 'dataset')

    user                  XRD_STRING
    group                 XRD_STRING
    begin                 XRD_STRING
    end                   XRD_STRING
    walltime              XRD_REAL64
    cputime               XRD_REAL64
    bytesread             XRD_REAL64
    events                XRD_REAL64
    totevents             XRD_REAL64
    workers               XRD_REAL64

  Return 0 on success, -1 on any failure.

Int_t SendDataSetInfo(TDSet* , TList* , const char* , const char* )

 Post information about the processed dataset(s). The information is taken
 from the TDSet object 'dset' and integrated with the missing files
 information in the list 'missing'. The string 'qid' is the uninque
 ID of the query; 'begin' the starting time.

 The records sent by this call will appear with ids 'dataset_<dataset_name_hash>'

 There are two versions of this record, with or without the starting time.
 The starting time could be looked up from the summary record, if available.

 The default version 1 contains the following information:

    dsn              XRD_STRING
    querytag         XRD_STRING
    querybegin       XRD_STRING
    numfiles         XRD_REAL64
    missfiles        XRD_REAL64

 Version 0 contains the following information:
    (no 'querybegin')

    dsn              XRD_STRING
    querytag         XRD_STRING
    numfiles         XRD_REAL64
    missfiles        XRD_REAL64

 The information is posted with a bulk insert.

 Returns 0 on success, -1 on failure.

Int_t SendFileInfo(TDSet* , TList* , const char* , const char* )

 Post information about the requested files. The information is taken
 from the TDSet object 'dset' and integrated with the missing files
 information in the list 'missing'. The string 'qid' is the unique
 ID of the query; 'begin' the starting time.

 The records sent by this call will appear with ids 'file_<file_name_hash>'

 There are two versions of this record, with or without the starting time.
 The starting time could be looked up from the summary record, if available.

 The default version 1 contains the following information:

    lfn              XRD_STRING
    path             XRD_STRING
    querytag         XRD_STRING
    querybegin       XRD_STRING
    status           XRD_REAL64

 Version 0 contains the following information:
    (no 'querybegin')

    lfn              XRD_STRING
    path             XRD_STRING
    querytag         XRD_STRING
    status           XRD_REAL64

 The information is posted with a bulk insert.

 Returns 0 on success, -1 on failure.

TProofMonSenderML(const char* serv, const char* tag, const char* id = 0, const char* subid = 0, const char* opt = "")