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; }