|

GlibMultiplexer.hpp

Go to the documentation of this file.

#ifndef IONFLUX_TOOLS_GLIBMULTIPLEXER
#define IONFLUX_TOOLS_GLIBMULTIPLEXER
/* ==========================================================================
 * Ionflux Tools
 * Copyright (c) 2004 Joern P. Meier
 * mail@ionflux.org
 * --------------------------------------------------------------------------
 * GlibMultiplexer.hpp                 Glib based IO event multiplexer.
 * ==========================================================================
 * 
 * This file is part of Ionflux Tools.
 * 
 * Ionflux Tools 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.
 * 
 * Ionflux Tools 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 Ionflux Tools; if not, write to the Free Software Foundation, 
 * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 * 
 * ========================================================================== */

#include <string>
#include <iostream>
#include <sstream>
#include <vector>
#include <signal.h>
#include <gtkmm/main.h>
#include "ionflux/IOHandler.hpp"
#include "ionflux/Reporter.hpp"
#include "ionflux/IOMultiplexer.hpp"

namespace Ionflux
{

namespace Tools
{

class GlibMultiplexer;

class GlibIOEventInfo
: public sigc::trackable
{
    public:
        IOEvent event;
        IOHandler *handler;
        sigc::connection signalCon;
#ifdef HAVE_WINSOCK

        WSAEVENT socketEvent;
#endif

        GlibMultiplexer *target;
        
        // Constructor.
        GlibIOEventInfo() : target(0) { }
        bool ioHandler(Glib::IOCondition ioCond);
};

class GlibMultiplexer
: public sigc::trackable, public IOMultiplexer
{
    protected:
        static sig_atomic_t shutdown;
        Ionflux::Tools::Reporter log;
        std::vector<GlibIOEventInfo *> events;
        std::vector<GlibIOEventInfo *> trash;
        std::vector<GlibIOEventInfo *> newEvents;
        bool running;
        Gtk::Main* kit;
        int argc;
        char** argv;
        Gtk::Window* mainWindow;
        
        virtual void clearEvent(GlibIOEventInfo* eventInfo);
        
        virtual void clearEvents();
        
        virtual void addEvent(GlibIOEventInfo* eventInfo);
        
        virtual void addEvents();
        
    public:
        GlibMultiplexer();
        
        GlibMultiplexer(int initArgc, char** initArgv);
        
        GlibMultiplexer(int initArgc, char** initArgv, 
            Gtk::Window* initMainWin);
        
        virtual ~GlibMultiplexer();
        
        virtual void registerEvent(IOHandler* handler, IOEvent event);
        
        virtual void removeEvent(IOHandler* handler, IOEvent event);
        
        virtual bool processEvent(GlibIOEventInfo* eventInfo, 
            Glib::IOCondition ioCond);
        
        virtual void run();
        
        virtual void quit();
        
        virtual bool isRunning();
        
        virtual void runHandler();
        
        virtual bool quitHandler();
        
        static void shutdownHandler(int signum);
        
        virtual Reporter& getLog();
        
        virtual void setMainWindow(Gtk::Window* newMainWindow);
        
        virtual Gtk::Window* getMainWindow();
};

}

}

#endif

---