libasynccpp-dev 15.11-2 / usr / include / svxlink / AsyncCppApplication.h

/**
 * @file    AsyncCppApplication.h
 * @brief   The core class for writing asyncronous cpp applications.
 * @author  Tobias Blomberg
 * @date    2003-03-16
 *
 * This file contains the AsyncCppApplication class which is the core of an
 * application that use the Async classes in a non-GUI application.
 *
 * \verbatim
 * Async - A library for programming event driven applications
 * Copyright (C) 2003  Tobias Blomberg
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 * \endverbatim
 */


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

/**
* @brief An application class for writing non GUI applications.
*/
class CppApplication : public Application
{
  public:
    /**
     * @brief Constructor
     */
    CppApplication(void);

    /**
     * @brief Destructor
     */
    ~CppApplication(void);
    
    /**
     * @brief   Catch the specified UNIX signal
     * @param   signum The signal number to catch
     */
    void catchUnixSignal(int signum);

    /**
     * @brief   Uncatch the specified UNIX signal
     * @param   signum The UNIX signal to uncatch
     */
    void uncatchUnixSignal(int signum);

    /**
     * @brief Execute the application main loop
     *
     * When this member function is called the application core will enter the
     * main loop. It will not exit from this loop until the
     * Async::Application::quit method is called.
     */
    void exec(void);
    
    /**
     * @brief Exit the application main loop
     *
     * This function should be called to exit the application core main loop.
     */
    void quit(void);

    /**
     * @brief   A signal that is emitted when a monitored UNIX signal is caught
     * @param   signum The signal number that was caught
     *
     * Use the catchUnixSignal and uncatchUnixSignal functions to add signals
     * to be monitored for activity. When the signal is triggered, this sigc
     * signal will be emitted.
     */
    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 std::string& label);
    void handleUnixSignal(void);
    
};  /* class CppApplication */


} /* namespace */

#endif /* ASYNC_CPP_APPLICATION_INCLUDED */



/*
 * This file has not been truncated
 */