/home/vlg/develop/libASSA/libassa/assa/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_,
                         handler_t rmax_, 
                         handler_t wmax_, 
                         handler_t emax_);

    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 */  

---