PUBLIC

TimedTriggerQueueBodyC::TimedTriggerQueueBodyC(void) TimedTriggerQueueBodyC::~TimedTriggerQueueBodyC(void) TimedTriggerQueueBodyC::Schedule(RealT,const TriggerC &) TimedTriggerQueueBodyC::Schedule(DateC &,const TriggerC &) TimedTriggerQueueBodyC::Cancel(UIntT) TimedTriggerQueueBodyC::Shutdown(void) TimedTriggerQueueBodyC::Process(void) RCBodyC::References(void) const RCBodyC::Copy(void) const RCBodyC::DeepCopy(UIntT) const RCBodyC::IncRefCounter(void) RCBodyC::DecRefCounter(void)

public RCBodyC

MutexC access;

UIntT eventCount;

PriQueueC schedule;

HashC events;

bool done;

ThreadEventC hasShutdown;

Queue fd's

SemaphoreC semaSched;

int rfd;

int wfd;

TimedTriggerQueueBodyC()

Default constuctor

~TimedTriggerQueueBodyC()

Destructor.
This will not return until shutdown is complete.

UIntT Schedule(RealT t,const TriggerC & se)

Schedule event for running after time 't' (in seconds).
Thread safe. Returns an ID for the event, which can be used for canceling it.

UIntT Schedule(DateC & at,const TriggerC & se)

Schedule event for running.
Thread safe. Returns an ID for the event, which can be used for canceling it.

bool Cancel(UIntT eventID)

Cancel pending event.
Will return TRUE if event in canceled before it was run.

void Shutdown()

Shutdown even queue.

bool Process()

Process event queue.

UIntT References() const

Access count of handles open to this object.

RCBodyC & Copy() const

Make copy of body.
This should be provided in derived classes. this funtion will issue an assertion failure if called.

RCBodyC & DeepCopy(UIntT levels = ((UIntT))) const

Make a deep copy of body.
This should be provided in derived classes. this funtion will issue an assertion failure if called.

void IncRefCounter()

Increment reference counter.

bool DecRefCounter()

Decrement reference counter.