---

dsched.cpp

Go to the documentation of this file.

#include "dsched.h"

namespace punnets_common {

class tsentinel : public taction
{
    bool processed;

public:
    tsentinel() : taction(), processed(false) { }

    bool isProcessed() { return processed; }
    
    virtual void activate(tscheduler &, ntime_t) 
        { 
            processed = true;
        }
    tqueue *queue() const{ return NULL; }

    virtual const char *getClassName() const { return "tsentinel"; };
};


tsched_double::tsched_double() 
{
}

void tsched_double::scheduleEvent(const tevent &event)
{
    tqueue *q = event.getAction().queue();
    bool need_insert = false;
    if( q != processing_queue )
    {
        if( q->empty() )
            need_insert = true;
        else {
            ntime_t prev_top = q->top().getTime();
            if( prev_top > event.getTime() )
            {
                global_queue.erase(make_pair(prev_top, q));
                need_insert = true;
            }
        }
    }
    q->push(event);
    if( need_insert )
        global_queue.insert(make_pair(event.getTime(), q));
}


ntime_t tsched_double::run(ntime_t until /* = HUGE_VAL */ )
{
    ntime_t ret = 0.0, retp = 0.0;
    tsentinel sentinel;
    
    global_queue.insert( sched_entry( until, NULL ) );

//  unsigned int c = 0;

    std::set< sched_entry, less_sched_entry >::iterator i = global_queue.begin();

    while( i->second != NULL )
    {
        tqueue *q = i->second;
        processing_queue = q;
        tevent event = q->top();
        q->pop();
        global_queue.erase(i);
        event.activate( *this );
        if( ! q->empty() )
            global_queue.insert( make_pair( q->top().getTime(), q ) );
//      if( ((++c) & 65535) == 0 )
//          cout << ret << "      \r";
        i = global_queue.begin();
    }

    global_queue.erase(i);
    return retp;
}

} // namespace punnets_common

---