[libt2n] / src / server.hxx

/***************************************************************************
 *   Copyright (C) 2006 by Gerd v. Egidy                                   *
 *   gve@intra2net.com                                                     *
 *                                                                         *
 *   This library is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU Lesser General Public License version   *
 *   2.1 as published by the Free Software Foundation.                     *
 *                                                                         *
 *   This library 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 Lesser General Public License for more details.                   *
 *                                                                         *
 *   You should have received a copy of the GNU Lesser 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.             *
 ***************************************************************************/
#ifndef __LIBT2N_SERVER
#define __LIBT2N_SERVER

#include <iostream>
#include <string>
#include <map>

#include "connection.hxx"
#include "types.hxx"

namespace libt2n
{

class server;

/**
    Basic connection class
*/
class server_connection : public connection
{
    private:
        int timeout;
        int last_action_time;
        unsigned int connection_id;

    protected:
        server_connection(int _timeout)
            : connection()
        {
            set_timeout(_timeout);
            reset_timeout();
            connection_id=0;
            my_server=0;
        }

        server *my_server;

    public:
        void check_timeout();
        void reset_timeout();
        void set_timeout(int _timeout)
            { timeout=_timeout; }

        void set_server(server* _my_server)
            { my_server=_my_server; }

        void set_id(unsigned int _connection_id)
            { connection_id=_connection_id; }
        unsigned int get_id()
            { return connection_id; }
};

/**
    Basic server class
*/
class server
{
    private:
        int default_timeout;
        log_level_values log_level;
        std::ostream *logstream;

        unsigned int next_id;

    protected:
        std::map<unsigned int, server_connection*> connections;

        server()
        {
            set_default_timeout(30);
            set_logging(NULL,none);
            next_id=1;
        }

        int add_connection(server_connection* newconn);

    public:
        virtual ~server();

        void set_default_timeout(int _default_timeout)
            { default_timeout=_default_timeout; }
        int get_default_timeout(void)
            { return default_timeout; }

        void set_logging(std::ostream *_logstream, log_level_values _log_level)
        {
            log_level=_log_level;
            logstream=_logstream;
        }

        server_connection* get_connection(unsigned int conn_id);

        virtual void fill_buffer(long long usec_timeout=-1)=0;
        void cleanup();

        bool get_packet(std::string& data)
            { unsigned int x; return get_packet(data,x); }
        bool get_packet(std::string& data, unsigned int& conn_id);

        virtual void fill_connection_buffers(void)=0;

        void log(log_level_values level, const std::string& message)
            { log(level,message.c_str()); }
        void log(log_level_values level, const char* message);
};

}

#endif
Commit	Line	Data
	1	/***************************************************************************
	2	* Copyright (C) 2006 by Gerd v. Egidy *
	3	* gve@intra2net.com *
	4	* *
	5	* This library is free software; you can redistribute it and/or modify *
	6	* it under the terms of the GNU Lesser General Public License version *
	7	* 2.1 as published by the Free Software Foundation. *
	8	* *
	9	* This library is distributed in the hope that it will be useful, *
	10	* but WITHOUT ANY WARRANTY; without even the implied warranty of *
	11	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
	12	* GNU Lesser General Public License for more details. *
	13	* *
	14	* You should have received a copy of the GNU Lesser General Public *
	15	* License along with this program; if not, write to the *
	16	* Free Software Foundation, Inc., *
	17	* 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. *
	18	***************************************************************************/
	19	#ifndef __LIBT2N_SERVER
	20	#define __LIBT2N_SERVER
	21
	22	#include <iostream>
	23	#include <string>
	24	#include <map>
	25
	26	#include "connection.hxx"
	27	#include "types.hxx"
	28
	29	namespace libt2n
	30	{
	31
	32	class server;
	33
	34	/**
	35	Basic connection class
	36	*/
	37	class server_connection : public connection
	38	{
	39	private:
	40	int timeout;
	41	int last_action_time;
	42	unsigned int connection_id;
	43
	44	protected:
	45	server_connection(int _timeout)
	46	: connection()
	47	{
	48	set_timeout(_timeout);
	49	reset_timeout();
	50	connection_id=0;
	51	my_server=0;
	52	}
	53
	54	server *my_server;
	55
	56	public:
	57	void check_timeout();
	58	void reset_timeout();
	59	void set_timeout(int _timeout)
	60	{ timeout=_timeout; }
	61
	62	void set_server(server* _my_server)
	63	{ my_server=_my_server; }
	64
	65	void set_id(unsigned int _connection_id)
	66	{ connection_id=_connection_id; }
	67	unsigned int get_id()
	68	{ return connection_id; }
	69	};
	70
	71	/**
	72	Basic server class
	73	*/
	74	class server
	75	{
	76	private:
	77	int default_timeout;
	78	log_level_values log_level;
	79	std::ostream *logstream;
	80
	81	unsigned int next_id;
	82
	83	protected:
	84	std::map<unsigned int, server_connection*> connections;
	85
	86	server()
	87	{
	88	set_default_timeout(30);
	89	set_logging(NULL,none);
	90	next_id=1;
	91	}
	92
	93	int add_connection(server_connection* newconn);
	94
	95	public:
	96	virtual ~server();
	97
	98	void set_default_timeout(int _default_timeout)
	99	{ default_timeout=_default_timeout; }
	100	int get_default_timeout(void)
	101	{ return default_timeout; }
	102
	103	void set_logging(std::ostream *_logstream, log_level_values _log_level)
	104	{
	105	log_level=_log_level;
	106	logstream=_logstream;
	107	}
	108
	109	server_connection* get_connection(unsigned int conn_id);
	110
	111	virtual void fill_buffer(long long usec_timeout=-1)=0;
	112	void cleanup();
	113
	114	bool get_packet(std::string& data)
	115	{ unsigned int x; return get_packet(data,x); }
	116	bool get_packet(std::string& data, unsigned int& conn_id);
	117
	118	virtual void fill_connection_buffers(void)=0;
	119
	120	void log(log_level_values level, const std::string& message)
	121	{ log(level,message.c_str()); }
	122	void log(log_level_values level, const char* message);
	123	};
	124
	125	}
	126
	127	#endif