/home/vlg/develop/libASSA/libassa/assa/TimerQueue.h

Go to the documentation of this file.

// -*- c++ -*-
//------------------------------------------------------------------------------
//                          TimerQueue.h
//------------------------------------------------------------------------------
//  Copyright (c) 1999,2005 by Vladislav Grinchenko
//
//  This library is free software; you can redistribute it and/or
//  modify it under the terms of the GNU Library General Public
//  License as published by the Free Software Foundation; either
//  version 2 of the License, or (at your option) any later version.
//------------------------------------------------------------------------------
//  Created: 07/28/1999
//------------------------------------------------------------------------------
#ifndef TIMER_QUEUE_H
#define TIMER_QUEUE_H

#include <time.h>
#include <sys/time.h>
#include <unistd.h>

#include "assa/Logger.h"
#include "assa/EventHandler.h"
#include "assa/Timer.h"
#include "assa/PriorityQueue.h"

namespace ASSA {

typedef unsigned long TimerId;

class TimerQueue
{
public:
    TimerQueue ();

    ~TimerQueue ();

    bool isEmpty ();

    TimerId insert (EventHandler* eh_, 
                    const TimeVal& tv_, 
                    const TimeVal& delta_,
                    const std::string& name_);

    int remove (EventHandler* eh_);

    bool remove (TimerId tid_);

    int expire (const TimeVal& tv_);

    TimeVal& top (void);

    void dump (void);

private:
    PriorityQueue <Timer*, TimerCompare> m_queue;
};

//------------------------------------------------------------------------------
// Inline functions
//------------------------------------------------------------------------------

inline
TimerQueue::
TimerQueue () 
{
    trace("TimerQueue::TimerQueue");
}

inline bool
TimerQueue::
isEmpty ()
{ 
    return m_queue.size () == 0;
}

inline TimeVal&
TimerQueue::
top (void)
{
    return (TimeVal&) m_queue.top ()->getExpirationTime ();
}

} // end namespace ASSA

#endif /* TIMER_QUEUE_H */  

---