Reactor.h

Go to the documentation of this file.

// -*- c++ -*-
//------------------------------------------------------------------------------
//                             Reactor.h
//------------------------------------------------------------------------------
//  Copyright (C) 1997-2002,2005  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: 05/25/1999
//------------------------------------------------------------------------------
#ifndef REACTOR_H
#define REACTOR_H
 
#include <sys/time.h>           // select(2)
#include <map>
 
#if !defined(WIN32)
#    include <sys/resource.h>       // getrlimit(2)
#endif
 
#include "assa/EventHandler.h"
#include "assa/Singleton.h"
#include "assa/MaskSet.h"
#include "assa/TimerQueue.h"
#include "assa/TimerCountdown.h"
 
namespace ASSA {

 
class Reactor 
{
public:
    Reactor ();

    ~Reactor();

    TimerId registerTimerHandler (EventHandler*      eh_, 
                                  const TimeVal&     tv_,
                                  const std::string& name_ = "<unknown>");

    bool registerIOHandler (EventHandler* eh_, 
                            handler_t     fd_, 
                            EventType     et_ = RWE_EVENTS);

    bool removeHandler (EventHandler* eh_, EventType et_ = ALL_EVENTS);

    bool removeTimerHandler (TimerId id_);

    bool removeIOHandler (handler_t fd_);

    void waitForEvents (void);

    void waitForEvents (TimeVal* tv_);

    void stopReactor (void);

    void deactivate (void);
 
private:
    Reactor (const Reactor&);            
    Reactor& operator= (const Reactor&); 
 
private:
    typedef std::map<u_int, EventHandler*> Fd2Eh_Map_Type;
    typedef Fd2Eh_Map_Type::iterator Fd2Eh_Map_Iter;
 
private:
    void adjust_maxfdp1 (handler_t fd_);

    bool handleError (void);

    bool dispatch (int minimum_);

    int isAnyReady (void);

    bool checkFDs (void);

    void dispatchHandler ( FdSet&          mask_, 
                           Fd2Eh_Map_Type& fdSet_,
                           EH_IO_Callback  callback_);
    
    void calculateTimeout (TimeVal*& howlong_, TimeVal* maxwait_);
 
private:
    int m_fd_setsize;

    handler_t m_maxfd_plus1;

    bool m_active;

    Fd2Eh_Map_Type m_readSet;

    Fd2Eh_Map_Type m_writeSet;

    Fd2Eh_Map_Type m_exceptSet;

    MaskSet m_waitSet;

    MaskSet m_readySet;

    TimerQueue m_tqueue;
};
 
//-----------------------------------------------------------------------------
// Inline functions
//-----------------------------------------------------------------------------
 
inline void Reactor::deactivate (void) {  m_active = false; }
 
} // end namespace ASSA
 
 
 
#endif /* REACTOR_H */