---

Scheduler.cxx

Go to the documentation of this file.

// $Heading: Scheduler.cxx$

#include "facilities/Scheduler.h"
#include "facilities/ScheduledEvent.h"

#include <cassert>

Scheduler* Scheduler::s_instance = 0;
Scheduler* Scheduler::instance(){return (s_instance) ? s_instance : new Scheduler();}

Scheduler::Scheduler()
: m_time(GPStime(0))
, m_running(false)
, m_log(0)
{
    assert( s_instance==0);  // require only one
    s_instance = this;
}

Scheduler::~Scheduler()
{
    clear();
}
void Scheduler::clear()
{
    while( ! empty() ) {
        iterator f = begin();
        delete (*f).second;
        erase(f);
    }
    m_time = 0;
}


void Scheduler::schedule(double deltaT, ScheduledEvent* event)
{
    insert(std::make_pair(m_time+deltaT, event));
}

void Scheduler::start()
{
    m_running = true;

    while( !empty() && m_running ) {

        // get the entry at the head of the queue
        std::pair<double, ScheduledEvent*> entry = *begin();

        // set current time, remove the entry
        m_time = entry.first;
        erase(begin());

        // run, then delete it
        if( m_log ) {
            (*m_log) << "\t" << entry.first << '\t' << entry.second->name() << std::endl ;
        }
        entry.second->execute();
        delete entry.second;
    }
}

void Scheduler::stop()
{
    m_running = false;
}
void Scheduler::printOn(std::ostream& out)const
{
    out << "\nScheduler stack: current time = " << elapsed_time() << std::endl;
    out << "\ttime\tclass name\n";
    for( const_iterator it= begin(); it !=end(); ++it){
        std::pair<double, ScheduledEvent*> entry = *it;
        out << "\t" << entry.first << '\t' << entry.second->name() << std::endl ;
    }
    out << std::endl;

}

void Scheduler::setLog(std::ostream& out)
{
    m_log = &out;
    out << "\nSchedule event: current time = " << elapsed_time() << std::endl;
    out << "\ttime\tEvent\n";

}

void Scheduler::endLogging()
{
    m_log = 0;
}

---