TMonitor Class Reference

#include <TMonitor.h>

Inheritance diagram for TMonitor:

TObject TQObject TObject TQObject List of all members.

Public Types

enum  EInterest
enum  EInterest

Public Member Functions

 TMonitor (Bool_t mainloop=kTRUE)
 TMonitor (const TMonitor &m)
virtual ~TMonitor ()
virtual void Add (TSocket *sock, Int_t interest=kRead)
virtual void SetInterest (TSocket *sock, Int_t interest=kRead)
virtual void Remove (TSocket *sock)
virtual void RemoveAll ()
virtual void Activate (TSocket *sock)
virtual void ActivateAll ()
virtual void DeActivate (TSocket *sock)
virtual void DeActivateAll ()
virtual void Ready (TSocket *sock)
void Interrupt ()
void ResetInterrupt ()
TSocket * Select ()
TSocket * Select (Long_t timeout)
Int_t Select (TList *rdready, TList *wrready, Long_t timeout)
Int_t GetActive (Long_t timeout=-1) const
Int_t GetDeActive () const
TList * GetListOfActives () const
TList * GetListOfDeActives () const
Bool_t IsActive (TSocket *s) const
 TMonitor (Bool_t mainloop=kTRUE)
 TMonitor (const TMonitor &m)
virtual ~TMonitor ()
virtual void Add (TSocket *sock, Int_t interest=kRead)
virtual void SetInterest (TSocket *sock, Int_t interest=kRead)
virtual void Remove (TSocket *sock)
virtual void RemoveAll ()
virtual void Activate (TSocket *sock)
virtual void ActivateAll ()
virtual void DeActivate (TSocket *sock)
virtual void DeActivateAll ()
virtual void Ready (TSocket *sock)
void Interrupt ()
void ResetInterrupt ()
TSocket * Select ()
TSocket * Select (Long_t timeout)
Int_t Select (TList *rdready, TList *wrready, Long_t timeout)
Int_t GetActive (Long_t timeout=-1) const
Int_t GetDeActive () const
TList * GetListOfActives () const
TList * GetListOfDeActives () const
Bool_t IsActive (TSocket *s) const

Private Member Functions

void SetReady (TSocket *sock)
void * GetSender ()
void SetReady (TSocket *sock)
void * GetSender ()

Private Attributes

TList * fActive
TList * fDeActive
TSocket * fReady
Bool_t fMainLoop
Bool_t fInterrupt
TList * fActive
TList * fDeActive
TSocket * fReady

Friends

class TSocketHandler
class TTimeOutTimer
class TXSlave
class TXSocket

Detailed Description

Definition at line 40 of file TMonitor.h.

Member Enumeration Documentation

enum TMonitor::EInterest

Definition at line 58 of file TMonitor.h.

enum TMonitor::EInterest

Definition at line 58 of file TMonitor.h.

Constructor & Destructor Documentation

TMonitor::TMonitor ( Bool_t  mainloop = kTRUE  ) 

TMonitor::TMonitor ( const TMonitor &  m  ) 

Definition at line 120 of file TMonitor.cxx.

References TList::Add(), fActive, fDeActive, fInterrupt, fMainLoop, fReady, TSocketHandler::GetSocket(), TFileHandler::HasReadInterest(), TFileHandler::HasWriteInterest(), m, mask, TSocketHandler, x1, and x2.

TMonitor::~TMonitor (  )  [virtual]

Definition at line 150 of file TMonitor.cxx.

References TList::Delete(), fActive, fDeActive, and SafeDelete.

TMonitor::TMonitor ( Bool_t  mainloop = kTRUE  ) 

TMonitor::TMonitor ( const TMonitor &  m  ) 

virtual TMonitor::~TMonitor (  )  [virtual]

Member Function Documentation

void TMonitor::SetReady ( TSocket *  sock  )  [private]

Definition at line 417 of file TMonitor.cxx.

References fReady, and Ready().

Referenced by TXSlave::HandleInput(), TTimeOutTimer::Notify(), and TSocketHandler::Notify().

void* TMonitor::GetSender (  )  [inline, private, virtual]

Reimplemented from TQObject.

Definition at line 55 of file TMonitor.h.

void TMonitor::Add ( TSocket *  sock,
Int_t  interest = kRead 
) [virtual]

Definition at line 162 of file TMonitor.cxx.

References TList::Add(), fActive, fMainLoop, and TSocketHandler.

Referenced by TProofServ::AcceptResults(), TProof::AddWorkers(), TProof::FindUniqueSlaves(), TProofLite::FindUniqueSlaves(), TProof::GoParallel(), SpyServ::HandleSocket(), hserv(), TPSocket::Init(), TProof::ModifyWorkerLists(), TProofLite::SetupWorkers(), SpyServ::SpyServ(), TProofSuperMaster::StartSlaves(), TProofPEAC::StartSlaves(), TProof::StartSlaves(), TProofCondor::StartSlaves(), TApplicationRemote::TApplicationRemote(), TPSocket::TPSocket(), TPacketizer::ValidateFiles(), and TPacketizerAdaptive::ValidateFiles().

void TMonitor::SetInterest ( TSocket *  sock,
Int_t  interest = kRead 
) [virtual]

Definition at line 173 of file TMonitor.cxx.

References TList::Add(), fActive, fDeActive, fMainLoop, kRead, TList::Remove(), s, and TSocketHandler.

void TMonitor::Remove ( TSocket *  sock  )  [virtual]

Definition at line 211 of file TMonitor.cxx.

References fActive, fDeActive, TList::Remove(), and s.

Referenced by TProofServ::AcceptResults(), TProof::CollectInputFrom(), TProof::FindUniqueSlaves(), SpyServ::HandleSocket(), hserv(), TProof::MarkBad(), TProof::ModifyWorkerLists(), and TProof::StartSlaves().

void TMonitor::RemoveAll (  )  [virtual]

Definition at line 238 of file TMonitor.cxx.

References TList::Delete(), fActive, and fDeActive.

Referenced by TProofServ::AcceptResults(), TProof::FindUniqueSlaves(), TProofLite::FindUniqueSlaves(), and TProof::GoParallel().

void TMonitor::Activate ( TSocket *  sock  )  [virtual]

Definition at line 247 of file TMonitor.cxx.

References TList::Add(), fActive, fDeActive, TList::Remove(), and s.

Referenced by TProof::Activate(), TProof::Collect(), TPSocket::RecvRaw(), TPSocket::SendRaw(), TPacketizer::ValidateFiles(), and TPacketizerAdaptive::ValidateFiles().

void TMonitor::ActivateAll (  )  [virtual]

Definition at line 265 of file TMonitor.cxx.

References TList::Add(), TList::Clear(), fActive, fDeActive, fInterrupt, kFALSE, and s.

Referenced by TProof::Collect(), TApplicationRemote::Collect(), and TProof::SetMonitor().

void TMonitor::DeActivate ( TSocket *  sock  )  [virtual]

Definition at line 281 of file TMonitor.cxx.

References TList::Add(), fActive, fDeActive, TList::Remove(), and s.

Referenced by TProof::Collect(), TApplicationRemote::Collect(), TXSlave::Interrupt(), TProof::MarkBad(), TPacketizer::ValidateFiles(), and TPacketizerAdaptive::ValidateFiles().

void TMonitor::DeActivateAll (  )  [virtual]

Definition at line 299 of file TMonitor.cxx.

References TList::Add(), TList::Clear(), fActive, fDeActive, fInterrupt, kFALSE, and s.

Referenced by TProofServ::AcceptResults(), TProof::Activate(), TProof::Collect(), TApplicationRemote::Collect(), TProof::FindUniqueSlaves(), TProofLite::FindUniqueSlaves(), TProof::Init(), TProofLite::Init(), TPSocket::Init(), TPSocket::RecvRaw(), TPSocket::SendRaw(), TProofLite::SetupWorkers(), TApplicationRemote::TApplicationRemote(), TPSocket::TPSocket(), TPacketizer::ValidateFiles(), and TPacketizerAdaptive::ValidateFiles().

void TMonitor::Ready ( TSocket *  sock  )  [virtual]

Definition at line 527 of file TMonitor.cxx.

References TQObject::Emit().

Referenced by SetReady().

void TMonitor::Interrupt (  )  [inline]

Definition at line 75 of file TMonitor.h.

References fInterrupt, and kTRUE.

Referenced by TProofServ::HandleSubmerger(), and TProof::InterruptCurrentMonitor().

void TMonitor::ResetInterrupt (  )  [inline]

Definition at line 76 of file TMonitor.h.

References fInterrupt, and kFALSE.

Referenced by TProof::Collect().

TSocket * TMonitor::Select (  ) 

Definition at line 315 of file TMonitor.cxx.

References fInterrupt, fReady, gSystem, TObject::Info(), TSystem::InnerLoop(), and kFALSE.

Referenced by TProofServ::AcceptResults(), TProof::Collect(), TApplicationRemote::Collect(), hserv(), TPSocket::RecvRaw(), Select(), TPSocket::SendRaw(), TProofLite::SetupWorkers(), SpyServ::SpyServ(), TApplicationRemote::TApplicationRemote(), TPacketizer::ValidateFiles(), and TPacketizerAdaptive::ValidateFiles().

TSocket * TMonitor::Select ( Long_t  timeout  ) 

Definition at line 339 of file TMonitor.cxx.

References fInterrupt, fReady, gSystem, TObject::Info(), TSystem::InnerLoop(), kFALSE, Select(), and t.

Int_t TMonitor::Select ( TList *  rdready,
TList *  wrready,
Long_t  timeout 
)

Definition at line 370 of file TMonitor.cxx.

References TList::Add(), TList::Clear(), fActive, TList::First(), TCollection::GetSize(), gSystem, h, and TSystem::Select().

Int_t TMonitor::GetActive ( Long_t  timeout = -1  )  const

Definition at line 429 of file TMonitor.cxx.

References TList::Add(), fActive, fDeActive, TInetAddress::GetHostName(), TSocket::GetInetAddress(), TSocket::GetLastUsage(), TTimeStamp::GetNanoSec(), TInetAddress::GetPort(), TTimeStamp::GetSec(), TCollection::GetSize(), TObject::Info(), TList::Remove(), s, and ts.

Referenced by TProofServ::AcceptResults(), TProof::Collect(), TApplicationRemote::Collect(), TProof::HandleSubmerger(), hserv(), TProof::MarkBad(), TPacketizer::ValidateFiles(), and TPacketizerAdaptive::ValidateFiles().

Int_t TMonitor::GetDeActive (  )  const

Definition at line 470 of file TMonitor.cxx.

References fDeActive, and TCollection::GetSize().

TList * TMonitor::GetListOfActives (  )  const

Definition at line 493 of file TMonitor.cxx.

References fActive, h, and list.

Referenced by TProof::Collect(), TXSlave::Interrupt(), TPacketizer::ValidateFiles(), and TPacketizerAdaptive::ValidateFiles().

TList * TMonitor::GetListOfDeActives (  )  const

Definition at line 510 of file TMonitor.cxx.

References fDeActive, h, and list.

Referenced by TProofServ::AcceptResults().

Bool_t TMonitor::IsActive ( TSocket *  s  )  const

Definition at line 478 of file TMonitor.cxx.

References fActive, h, kFALSE, and kTRUE.

Referenced by TXSlave::HandleInput().

void TMonitor::SetReady ( TSocket *  sock  )  [private]

void* TMonitor::GetSender (  )  [inline, private, virtual]

Reimplemented from TQObject.

Definition at line 55 of file TMonitor.h.

virtual void TMonitor::Add ( TSocket *  sock,
Int_t  interest = kRead 
) [virtual]

virtual void TMonitor::SetInterest ( TSocket *  sock,
Int_t  interest = kRead 
) [virtual]

virtual void TMonitor::Remove ( TSocket *  sock  )  [virtual]

virtual void TMonitor::RemoveAll (  )  [virtual]

virtual void TMonitor::Activate ( TSocket *  sock  )  [virtual]

virtual void TMonitor::ActivateAll (  )  [virtual]

virtual void TMonitor::DeActivate ( TSocket *  sock  )  [virtual]

virtual void TMonitor::DeActivateAll (  )  [virtual]

virtual void TMonitor::Ready ( TSocket *  sock  )  [virtual]

void TMonitor::Interrupt (  )  [inline]

Definition at line 75 of file TMonitor.h.

References fInterrupt, and kTRUE.

void TMonitor::ResetInterrupt (  )  [inline]

Definition at line 76 of file TMonitor.h.

References fInterrupt, and kFALSE.

TSocket* TMonitor::Select (  ) 

TSocket* TMonitor::Select ( Long_t  timeout  ) 

Int_t TMonitor::Select ( TList *  rdready,
TList *  wrready,
Long_t  timeout 
)

Int_t TMonitor::GetActive ( Long_t  timeout = -1  )  const

Int_t TMonitor::GetDeActive (  )  const

TList* TMonitor::GetListOfActives (  )  const

TList* TMonitor::GetListOfDeActives (  )  const

Bool_t TMonitor::IsActive ( TSocket *  s  )  const

Friends And Related Function Documentation

TSocketHandler [friend]

Definition at line 42 of file TMonitor.h.

Referenced by Add(), SetInterest(), and TMonitor().

TTimeOutTimer [friend]

Definition at line 43 of file TMonitor.h.

TXSlave [friend]

Definition at line 44 of file TMonitor.h.

TXSocket [friend]

Definition at line 45 of file TMonitor.h.

Member Data Documentation

TList* TMonitor::fActive [private]

Definition at line 48 of file TMonitor.h.

Referenced by Activate(), ActivateAll(), Add(), DeActivate(), DeActivateAll(), GetActive(), GetListOfActives(), IsActive(), Remove(), RemoveAll(), Select(), SetInterest(), TMonitor(), and ~TMonitor().

TList* TMonitor::fDeActive [private]

Definition at line 49 of file TMonitor.h.

Referenced by Activate(), ActivateAll(), DeActivate(), DeActivateAll(), GetActive(), GetDeActive(), GetListOfDeActives(), Remove(), RemoveAll(), SetInterest(), TMonitor(), and ~TMonitor().

TSocket* TMonitor::fReady [private]

Definition at line 50 of file TMonitor.h.

Referenced by Select(), SetReady(), and TMonitor().

Bool_t TMonitor::fMainLoop [private]

Definition at line 51 of file TMonitor.h.

Referenced by Add(), SetInterest(), and TMonitor().

Bool_t TMonitor::fInterrupt [private]

Definition at line 52 of file TMonitor.h.

Referenced by ActivateAll(), DeActivateAll(), Interrupt(), ResetInterrupt(), Select(), and TMonitor().

TList* TMonitor::fActive [private]

Definition at line 48 of file TMonitor.h.

TList* TMonitor::fDeActive [private]

Definition at line 49 of file TMonitor.h.

TSocket* TMonitor::fReady [private]

Definition at line 50 of file TMonitor.h.

The documentation for this class was generated from the following files:
Generated on Tue Jul 5 16:43:01 2011 for ROOT_528-00b_version by  doxygen 1.5.1