2 Copyright (C) 2006 by Intra2net AG - Gerd v. Egidy
4 The software in this package is distributed under the GNU General
5 Public License version 2 (with a special exception described below).
7 A copy of GNU General Public License (GPL) is included in this distribution,
8 in the file COPYING.GPL.
10 As a special exception, if other files instantiate templates or use macros
11 or inline functions from this file, or you compile this file and link it
12 with other works to produce a work based on this file, this file
13 does not by itself cause the resulting work to be covered
14 by the GNU General Public License.
16 However the source code for this file must still be made available
17 in accordance with section (3) of the GNU General Public License.
19 This exception does not invalidate any other reasons why a work based
20 on this file might be covered by the GNU General Public License.
28 #include <boost/archive/binary_oarchive.hpp>
29 #include <boost/archive/binary_iarchive.hpp>
30 #include <boost/archive/xml_oarchive.hpp>
31 #include <boost/archive/xml_iarchive.hpp>
32 #include <boost/serialization/serialization.hpp>
34 #include <boost/bind.hpp>
36 #include "command_server.hxx"
37 #include "container.hxx"
49 command_server::command_server(server& _s)
50 : s(_s), guard_handle(0)
53 s.add_callback(new_connection,bind(&command_server::send_hello, boost::ref(*this), _1));
59 command_server::~command_server()
63 /// send a hello message to a new connection
64 void command_server::send_hello(unsigned int conn_id)
66 server_connection* sc=s.get_connection(conn_id);
69 return; // connection not existing, so no hello
71 std::ostringstream hello;
73 hello << "T2Nv" << PROTOCOL_VERSION << ';';
76 hello.write((char*)&byteordercheck,sizeof(byteordercheck));
80 sc->write(hello.str());
83 /// handle a command including deserialization and answering
84 void command_server::handle_packet(const std::string& packet, server_connection* conn)
86 OBJLOGSTREAM(s,debug,"handling packet from connection " << conn->get_id());
89 std::istringstream ifs(packet);
90 boost::archive::binary_iarchive ia(ifs);
91 command_container ccont;
98 catch(boost::archive::archive_exception &e)
100 std::ostringstream msg;
101 msg << "archive_exception while deserializing on server-side, "
102 "code " << e.code << " (" << e.what() << ")";
103 res.set_exception(new t2n_serialization_error(msg.str()));
108 if (!res.has_exception())
111 if ((ostr=s.get_logstream(fulldebug))!=NULL)
113 (*ostr) << "decoded packet data: " << std::endl;
114 boost::archive::xml_oarchive xo(*ostr);
115 xo << BOOST_SERIALIZATION_NVP(ccont);
118 command* cmd=cast_command(ccont.get_command());
124 res.set_result((*cmd)());
126 catch (t2n_exception &e)
127 { res.set_exception(e.clone()); }
133 std::ostringstream msg;
134 if (ccont.get_command()!=NULL)
135 msg << "illegal command of type " << typeid(ccont.get_command()).name() << " called";
137 msg << "NULL command called";
138 res.set_exception(new t2n_command_error(msg.str()));
142 std::ostringstream ofs;
143 boost::archive::binary_oarchive oa(ofs);
149 catch(boost::archive::archive_exception &e)
151 std::ostringstream msg;
152 msg << "archive_exception while serializing on server-side, "
153 "code " << e.code << " (" << e.what() << ")";
154 res.set_exception(new t2n_serialization_error(msg.str()));
161 if ((ostr=s.get_logstream(fulldebug))!=NULL)
163 (*ostr) << "returning result, decoded data: " << std::endl;
164 boost::archive::xml_oarchive xo(*ostr);
165 xo << BOOST_SERIALIZATION_NVP(res);
168 conn->write(ofs.str());
171 /** @brief handle incoming commands
172 @param[in,out] usec_timeout wait until new data is found, max timeout usecs.
173 -1: wait endless, 0: instant return
174 @param[out] usec_timeout_remaining microseconds from the timeout that were not used
176 void command_server::handle(long long usec_timeout, long long* usec_timeout_remaining)
182 if (s.fill_buffer(usec_timeout,usec_timeout_remaining))
185 unsigned int conn_id = 0;
187 while (s.get_packet(packet,conn_id))
189 server_connection* conn=s.get_connection(conn_id);
191 EXCEPTIONSTREAM(error,logic_error,"illegal connection id " << conn_id << " received");
193 { handle_packet(packet,conn); }
194 catch (t2n_transfer_error &e)
196 // shut down a connection with transfer errors (usually write errors)
211 // don't call cleanup on re-entered handle-calls
212 if (guard_handle == 0)