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()));
106 if (!res.has_exception())
109 if ((ostr=s.get_logstream(fulldebug))!=NULL)
111 (*ostr) << "decoded packet data: " << std::endl;
112 boost::archive::xml_oarchive xo(*ostr);
113 xo << BOOST_SERIALIZATION_NVP(ccont);
116 command* cmd=cast_command(ccont.get_command());
122 res.set_result((*cmd)());
124 catch (t2n_exception &e)
125 { res.set_exception(e.clone()); }
129 std::ostringstream msg;
130 if (ccont.get_command()!=NULL)
131 msg << "illegal command of type " << typeid(ccont.get_command()).name() << " called";
133 msg << "NULL command called";
134 res.set_exception(new t2n_command_error(msg.str()));
138 std::ostringstream ofs;
139 boost::archive::binary_oarchive oa(ofs);
145 catch(boost::archive::archive_exception &e)
147 std::ostringstream msg;
148 msg << "archive_exception while serializing on server-side, "
149 "code " << e.code << " (" << e.what() << ")";
150 res.set_exception(new t2n_serialization_error(msg.str()));
155 if ((ostr=s.get_logstream(fulldebug))!=NULL)
157 (*ostr) << "returning result, decoded data: " << std::endl;
158 boost::archive::xml_oarchive xo(*ostr);
159 xo << BOOST_SERIALIZATION_NVP(res);
162 conn->write(ofs.str());
165 /** @brief handle incoming commands
166 @param[in,out] usec_timeout wait until new data is found, max timeout usecs.
167 -1: wait endless, 0: instant return
168 @param[out] usec_timeout_remaining microseconds from the timeout that were not used
170 void command_server::handle(long long usec_timeout, long long* usec_timeout_remaining)
176 if (s.fill_buffer(usec_timeout,usec_timeout_remaining))
179 unsigned int conn_id = 0;
181 while (s.get_packet(packet,conn_id))
183 server_connection* conn=s.get_connection(conn_id);
185 EXCEPTIONSTREAM(error,logic_error,"illegal connection id " << conn_id << " received");
187 { handle_packet(packet,conn); }
188 catch (t2n_transfer_error &e)
190 // shut down a connection with transfer errors (usually write errors)
203 // don't call cleanup on re-entered handle-calls
204 if (guard_handle == 0)