X-Git-Url: http://developer.intra2net.com/git/?p=libt2n;a=blobdiff_plain;f=src%2Fserver.cpp;fp=src%2Fserver.cpp;h=32dda77bd908907ee7776ee650f8200178c0aee8;hp=a49bc7a31fa890f9b91bcf1afa0b26b2f017ce01;hb=a64066eb0e456c92c4c06959616443e531d4b39d;hpb=0ea6d528901a0eeb0fce1c2a71ae69c277798142 diff --git a/src/server.cpp b/src/server.cpp index a49bc7a..32dda77 100644 --- a/src/server.cpp +++ b/src/server.cpp @@ -29,7 +29,7 @@ namespace libt2n { server_connection::server_connection(int _timeout) - : connection(), callbacks(__events_end) + : connection() { set_timeout(_timeout); reset_timeout(); @@ -37,23 +37,6 @@ server_connection::server_connection(int _timeout) my_server=0; } -server_connection::~server_connection() -{ - // we want the connection_closed callbacks to be called before - close(); - - do_callbacks(connection_deleted); -} - -void server_connection::close() -{ - if (!is_closed()) - { - connection::close(); - do_callbacks(connection_closed); - } -} - /// get pointer to logging stream, returns NULL if no logging needed std::ostream* server_connection::get_logstream(log_level_values level) { @@ -84,28 +67,12 @@ void server_connection::reset_timeout() last_action_time=time(NULL); } -/** @brief add a callback - - @param event event the function will be called at - @param func functor (see boost function) that will be called - - @note use boost::bind to bind to member functions and parameters like this: - 17 is a fixed parameter that is always added to the call - c.add_callback(connection_closed,bind(&my_class::func_to_call_back, boost::ref(*this), 17)); -*/ void server_connection::add_callback(callback_event_type event, const boost::function& func) { if (event == new_connection) throw std::logic_error("new_connection callback not allowed for server_connections"); - callbacks[event].push_back(func); -} - -void server_connection::do_callbacks(callback_event_type event) -{ - std::list >::iterator i,ie=callbacks[event].end(); - for (i=callbacks[event].begin(); i != ie; i++) - (*i)(); + connection::add_callback(event,func); } server::server()