1 /***************************************************************************
2 * Copyright (C) 2004 by Intra2net AG *
5 ***************************************************************************/
18 #include <cppunit/extensions/TestFactoryRegistry.h>
19 #include <cppunit/ui/text/TestRunner.h>
20 #include <cppunit/extensions/HelperMacros.h>
22 #include <boost/archive/binary_oarchive.hpp>
23 #include <boost/archive/binary_iarchive.hpp>
24 #include <boost/archive/xml_oarchive.hpp>
25 #include <boost/archive/xml_iarchive.hpp>
26 #include <boost/serialization/serialization.hpp>
27 #include <boost/serialization/export.hpp>
29 #include <container.hxx>
30 #include <socket_client.hxx>
31 #include <socket_server.hxx>
32 #include <command_client.hxx>
33 #include <command_server.hxx>
34 #include <client_wrapper.hxx>
35 #include <socket_wrapper.hxx>
42 using namespace libt2n;
43 using namespace CppUnit;
47 stringstream logstream;
48 bool close_server=false;
49 bool kill_server=false;
62 std::string getserverlog(void)
64 return logstream.str();
67 class serverfunc_res : public libt2n::result
72 friend class boost::serialization::access;
73 template<class Archive>
74 void serialize(Archive & ar, const unsigned int version)
76 ar & BOOST_SERIALIZATION_BASE_OBJECT_NVP(libt2n::result);
77 ar & BOOST_SERIALIZATION_NVP(res);
95 class getserverlog_res : public libt2n::result
100 friend class boost::serialization::access;
101 template<class Archive>
102 void serialize(Archive & ar, const unsigned int version)
104 ar & BOOST_SERIALIZATION_BASE_OBJECT_NVP(libt2n::result);
105 ar & BOOST_SERIALIZATION_NVP(res);
112 getserverlog_res(std::string s)
117 std::string get_data()
123 class cmd_group_x : public command
126 friend class boost::serialization::access;
127 template<class Archive>
128 void serialize(Archive & ar, const unsigned int version)
130 ar & BOOST_SERIALIZATION_BASE_OBJECT_NVP(libt2n::command);
134 class serverfunc_cmd : public cmd_group_x
139 friend class boost::serialization::access;
140 template<class Archive>
141 void serialize(Archive & ar, const unsigned int version)
143 ar & BOOST_SERIALIZATION_BASE_OBJECT_NVP(cmd_group_x);
144 ar & BOOST_SERIALIZATION_NVP(param);
151 serverfunc_cmd(int i)
156 libt2n::result* operator()()
158 return new serverfunc_res(serverfunc(param));
162 class getserverlog_cmd : public cmd_group_x
165 friend class boost::serialization::access;
166 template<class Archive>
167 void serialize(Archive & ar, const unsigned int version)
169 ar & BOOST_SERIALIZATION_BASE_OBJECT_NVP(cmd_group_x);
176 libt2n::result* operator()()
178 return new getserverlog_res(getserverlog());
182 BOOST_CLASS_EXPORT(serverfunc_res)
183 BOOST_CLASS_EXPORT(getserverlog_res)
184 BOOST_CLASS_EXPORT(cmd_group_x)
185 BOOST_CLASS_EXPORT(serverfunc_cmd)
186 BOOST_CLASS_EXPORT(getserverlog_cmd)
188 class cmd_group_x_client : public command_client
191 cmd_group_x_client(libt2n::client_connection &_c,
192 long long _command_timeout_usec=command_timeout_usec_default,
193 long long _hello_timeout_usec=hello_timeout_usec_default)
194 : libt2n::command_client(_c,_command_timeout_usec,_hello_timeout_usec)
197 int serverfunc(int i)
199 libt2n::result_container rc;
201 send_command(new serverfunc_cmd(i), rc);
202 serverfunc_res* res=dynamic_cast<serverfunc_res*>(rc.get_result());
203 if (!res) throw libt2n::t2n_communication_error("result object of wrong type");
204 return res->get_data();
207 std::string getserverlog(void)
209 libt2n::result_container rc;
211 send_command(new getserverlog_cmd(), rc);
212 getserverlog_res* res=dynamic_cast<getserverlog_res*>(rc.get_result());
213 if (!res) throw libt2n::t2n_communication_error("result object of wrong type");
214 return res->get_data();
218 typedef T2nSingletonWrapper<cmd_group_x_client> wraptype;
221 std::auto_ptr<wraptype> wraptype::SingletonObject = std::auto_ptr<wraptype>();
224 std::auto_ptr<ConnectionWrapper> wraptype::WrappedConnection = std::auto_ptr<ConnectionWrapper>();
226 class test_wrapper : public TestFixture
228 CPPUNIT_TEST_SUITE(test_wrapper);
230 CPPUNIT_TEST(no_init_exception); // must be called first!!!
231 CPPUNIT_TEST(simple_wrap);
232 CPPUNIT_TEST(double_use);
233 CPPUNIT_TEST(double_use_with_close);
234 CPPUNIT_TEST(reconnect_after_close);
235 CPPUNIT_TEST(reconnect_not_possible);
237 // TODO: missing tests:
238 // ignore: init, use, server die, ignore
239 // ignore: init, no server, ignore
240 // ignore: init, no server, ignore, server ok, connect?
242 CPPUNIT_TEST_SUITE_END();
254 CPPUNIT_FAIL("fork error");
261 while(i < 15 && !kill_server)
265 socket_server ss("./socket");
266 group_command_server<cmd_group_x> cs(ss);
267 ss.set_logging(&logstream,debug);
270 for (; !close_server && !kill_server && i < 15; i++)
274 // don't call atexit and stuff
281 // wait till server is up
293 wraptype::set_connection(auto_ptr<ConnectionWrapper>
294 (new BasicSocketWrapper("./socket")));
296 int i=t2n_exec(&cmd_group_x_client::serverfunc)(1);
298 CPPUNIT_ASSERT_EQUAL(2,i);
301 void no_init_exception()
303 CPPUNIT_ASSERT_THROW(t2n_exec(&cmd_group_x_client::serverfunc)(1),std::logic_error);
308 // only one connection used?
309 wraptype::set_connection(auto_ptr<ConnectionWrapper>
310 (new BasicSocketWrapper("./socket")));
312 t2n_exec(&cmd_group_x_client::serverfunc)(17);
313 string out=t2n_exec(&cmd_group_x_client::getserverlog)();
315 // count the number of times that "new connection accepted" appears in the server log
316 string::size_type p=0;
318 while ((p=out.find("new connection accepted",p))++ != string::npos)
321 CPPUNIT_ASSERT_EQUAL(1,cnt);
324 void double_use_with_close()
326 wraptype::set_connection(auto_ptr<ConnectionWrapper>
327 (new BasicSocketWrapper("./socket")));
329 t2n_exec(&cmd_group_x_client::serverfunc)(17);
331 // closes the connection from the client side
332 wraptype::set_connection(auto_ptr<ConnectionWrapper>
333 (new BasicSocketWrapper("./socket")));
335 string out=t2n_exec(&cmd_group_x_client::getserverlog)();
337 // count the number of times that "new connection accepted" appears in the server log
338 string::size_type p=0;
340 while ((p=out.find("new connection accepted",p))++ != string::npos)
343 CPPUNIT_ASSERT_EQUAL(2,cnt);
346 void reconnect_after_close()
348 wraptype::set_connection(auto_ptr<ConnectionWrapper>
349 (new ReconnectSocketWrapper("./socket")));
351 wraptype::get_connection_wrapper()->set_command_timeout_usec(3000000);
352 wraptype::get_connection_wrapper()->set_hello_timeout_usec(3000000);
354 // 42 closes connection on the server side
355 t2n_exec(&cmd_group_x_client::serverfunc)(42);
357 string out=t2n_exec(&cmd_group_x_client::getserverlog)();
359 // count the number of times that "new connection accepted" appears in the server log
360 string::size_type p=0;
362 while ((p=out.find("new connection accepted",p))++ != string::npos)
365 CPPUNIT_ASSERT_EQUAL(2,cnt);
368 void reconnect_not_possible()
370 wraptype::set_connection(auto_ptr<ConnectionWrapper>
371 (new ReconnectSocketWrapper("./socket")));
373 // the server doens't like the beast
374 t2n_exec(&cmd_group_x_client::serverfunc)(666);
376 CPPUNIT_ASSERT_THROW(t2n_exec(&cmd_group_x_client::serverfunc)(1),t2n_communication_error);
382 CPPUNIT_TEST_SUITE_REGISTRATION(test_wrapper);