AsyncCppApplication.h

Go to the documentation of this file.

 
#ifndef ASYNC_CPP_APPLICATION_INCLUDED
#define ASYNC_CPP_APPLICATION_INCLUDED
 
 
/****************************************************************************
 *
 * System Includes
 *
 ****************************************************************************/
 
#include <sys/types.h>
#include <sys/select.h>
#include <sys/time.h>
#include <signal.h>
#include <sigc++/sigc++.h>
 
#include <map>
#include <utility>
 
 
/****************************************************************************
 *
 * Project Includes
 *
 ****************************************************************************/
 
#include <AsyncApplication.h>
 
 
/****************************************************************************
 *
 * Local Includes
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Forward declarations
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Namespace
 *
 ****************************************************************************/
 
namespace Async
{
 
/****************************************************************************
 *
 * Defines & typedefs
 *
 ****************************************************************************/
 
/*
 *----------------------------------------------------------------------------
 * Macro:   
 * Purpose: 
 * Input:   
 * Output:  
 * Author:  
 * Created: 
 * Remarks: 
 * Bugs:    
 *----------------------------------------------------------------------------
 */
 
 
/*
 *----------------------------------------------------------------------------
 * Type:    
 * Purpose: 
 * Members: 
 * Input:   
 * Output:  
 * Author:  
 * Created: 
 * Remarks: 
 *----------------------------------------------------------------------------
 */
 
 
/****************************************************************************
 *
 * Exported Global Variables
 *
 ****************************************************************************/
 
 
 
/****************************************************************************
 *
 * Class definitions
 *
 ****************************************************************************/
 
class CppApplication : public Application
{
  public:
    CppApplication(void);
 
    ~CppApplication(void);
    
    void catchUnixSignal(int signum);
 
    void uncatchUnixSignal(int signum);
 
    void exec(void);
    
    void quit(void);
 
    sigc::signal<void, int> unixSignalCaught;
    
  protected:
    
  private:
    struct lttimespec
    {
      bool operator()(const struct timespec& t1, const struct timespec& t2) const
      {
        return ((t1.tv_sec == t2.tv_sec)
                ? (t1.tv_nsec < t2.tv_nsec)
                : (t1.tv_sec < t2.tv_sec));
      }
    };
    typedef std::map<int, FdWatch*>                             WatchMap;
    typedef std::multimap<struct timespec, Timer *, lttimespec> TimerMap;
    typedef std::map<int, struct sigaction>                     UnixSignalMap;
    
    static int          sighandler_pipe[2];
 
    bool                do_quit;
    int                 max_desc;
    fd_set              rd_set;
    fd_set              wr_set;
    WatchMap            rd_watch_map;
    WatchMap            wr_watch_map;
    TimerMap            timer_map;
    UnixSignalMap       unix_signals;
    int                 unix_signal_recv;
    size_t              unix_signal_recv_cnt;
    
    static void unixSignalHandler(int signum);
 
    void addFdWatch(FdWatch *fd_watch);
    void delFdWatch(FdWatch *fd_watch);
    void addTimer(Timer *timer);
    void addTimerP(Timer *timer, const struct timespec& current);
    void delTimer(Timer *timer);    
    DnsLookupWorker *newDnsLookupWorker(const DnsLookup& lookup);
    void handleUnixSignal(void);
    
};  /* class CppApplication */
 
 
} /* namespace */
 
#endif /* ASYNC_CPP_APPLICATION_INCLUDED */
 
 
 
/*
 * This file has not been truncated
 */