X-Git-Url: http://developer.intra2net.com/git/?p=libt2n;a=blobdiff_plain;f=src%2Fserver.hxx;h=cc3c5ddb6faba7762efc2dbc8fc8ebbf50a71355;hp=8d2db8e7f7c496768937c7a1454e1de14b123174;hb=19facd8558fe2e32ce843860b40631ebe03ff3cf;hpb=59adb9e24e4ac66b2623742c3b9c81a1c20ff9f0 diff --git a/src/server.hxx b/src/server.hxx index 8d2db8e..cc3c5dd 100644 --- a/src/server.hxx +++ b/src/server.hxx @@ -1,120 +1,156 @@ -/*************************************************************************** - * 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. * - ***************************************************************************/ +/* +Copyright (C) 2006 by Intra2net AG - Gerd v. Egidy + +The software in this package is distributed under the GNU General +Public License version 2 (with a special exception described below). + +A copy of GNU General Public License (GPL) is included in this distribution, +in the file COPYING.GPL. + +As a special exception, if other files instantiate templates or use macros +or inline functions from this file, or you compile this file and link it +with other works to produce a work based on this file, this file +does not by itself cause the resulting work to be covered +by the GNU General Public License. + +However the source code for this file must still be made available +in accordance with section (3) of the GNU General Public License. + +This exception does not invalidate any other reasons why a work based +on this file might be covered by the GNU General Public License. +*/ #ifndef __LIBT2N_SERVER #define __LIBT2N_SERVER #include #include #include +#include +#include + +#include + +#include "connection.hxx" +#include "types.hxx" namespace libt2n { +class server; + /** - Basic connection class + @brief connection on a server + + on a server every connection to a client is represented as server_connection. + a server_connection is abstract, derived classes like socket_server_connection are used. */ -class connection +class server_connection : public connection { + friend class server; + private: int timeout; int last_action_time; - bool closed; - std::string buffer; + unsigned int connection_id; + + void set_server(server* _my_server) + { my_server=_my_server; } + + void set_id(unsigned int _connection_id) + { connection_id=_connection_id; } protected: - connection(int _timeout) - { - set_timeout(_timeout); - reset_timeout(); - closed=false; - } + server *my_server; - public: - ~connection() - { this->close(); } + server_connection(int _timeout); + virtual ~server_connection(); + std::ostream* get_logstream(log_level_values level); + + public: void check_timeout(); void reset_timeout(); void set_timeout(int _timeout) { timeout=_timeout; } - bool is_closed() - { return closed; } - - virtual void close() - { closed=true; } - - virtual void fill_buffer(void)=0; + /// get the id of this connection within the server object + unsigned int get_id() + { return connection_id; } - bool get_packet(std::string& data, unsigned int& conn_id); - virtual void write(const std::string& data)=0; + void add_callback(callback_event_type event, const boost::function& func); }; /** - Basic server class + @brief server base class + + constitutes a server. is abstract, use derived classes like socket_server. */ class server { - public: - enum log_level_values { none=0, error=1, debug=2 }; - private: int default_timeout; log_level_values log_level; std::ostream *logstream; + /// vector initialized for all callback-types, all elements in each list will be called + std::vector > > callbacks; + unsigned int next_id; - std::map connections; protected: - server() - { - set_default_timeout(30); - set_logging(NULL,none); - next_id=0; - } + std::map connections; + + server(); + + virtual bool fill_connection_buffers(void)=0; + + unsigned int add_connection(server_connection* newconn); + + void do_callbacks(callback_event_type event, unsigned int conn_id); public: virtual ~server(); + /// set the default timeout for new client connections void set_default_timeout(int _default_timeout) { default_timeout=_default_timeout; } - void set_logging(std::ostream *_logstream, log_level_values _log_level) - { - log_level=_log_level; - logstream=_logstream; - } + /// get the current default timeout for client connections + int get_default_timeout(void) + { return default_timeout; } - connection* get_connection(unsigned int conn_id); + void set_logging(std::ostream *_logstream, log_level_values _log_level); - virtual void fill_buffer(long long usec_timeout=-1)=0; - void check_timeout(); + server_connection* get_connection(unsigned int conn_id); - bool get_packet(std::string& data, unsigned int& conn_id); + void add_callback(callback_event_type event, const boost::function& func); - void fill_connection_buffers(void); + /** @brief look for new data and store it in the local buffer + @param usec_timeout wait until new data is found, max timeout usecs. + -1: wait endless + 0: return instantly + @param usec_timeout_remaining if non-NULL the function will write the + not used time to the given target + @retval true if new data was found (does not mean that the received data + is a complete packet though) + */ + virtual bool fill_buffer(long long usec_timeout=-1, long long* usec_timeout_remaining=NULL)=0; - protected: - void log(log_level_values level, const std::string& message) - { log(level,message.c_str()); } - void log(log_level_values level, const char* message); + void close(); + + void cleanup(); + + /** @brief get a complete data packet from any client. The packet is removed from the + connection buffer. + @param[out] data the data package + @retval true if packet found + */ + bool get_packet(std::string& data) + { unsigned int x; return get_packet(data,x); } + + bool get_packet(std::string& data, unsigned int& conn_id); + + std::ostream* get_logstream(log_level_values level); }; }