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);
236 CPPUNIT_TEST(ignore_server_disconnect);
237 CPPUNIT_TEST(ignore_handler_reconnects);
239 // TODO: missing tests:
240 // ignore: init, no server, ignore
241 // ignore: init, no server, ignore, server ok, connect?
243 CPPUNIT_TEST_SUITE_END();
254 switch(child_pid=fork())
258 CPPUNIT_FAIL("fork error");
265 while(i < 10 && !kill_server)
269 socket_server ss("./socket");
270 group_command_server<cmd_group_x> cs(ss);
271 ss.set_logging(&logstream,debug);
274 for (; !close_server && !kill_server && i < 10; i++)
278 // don't call atexit and stuff
285 // wait till server is up
294 // make sure the server-child is dead before the next test runs
295 kill(child_pid,SIGKILL);
299 void no_init_exception()
301 CPPUNIT_ASSERT_THROW(t2n_exec(&cmd_group_x_client::serverfunc)(1),std::logic_error);
306 wraptype::set_connection(auto_ptr<ConnectionWrapper>
307 (new BasicSocketWrapper("./socket")));
309 int i=t2n_exec(&cmd_group_x_client::serverfunc)(1);
311 CPPUNIT_ASSERT_EQUAL(2,i);
316 // only one connection used?
317 wraptype::set_connection(auto_ptr<ConnectionWrapper>
318 (new BasicSocketWrapper("./socket")));
320 t2n_exec(&cmd_group_x_client::serverfunc)(17);
321 string out=t2n_exec(&cmd_group_x_client::getserverlog)();
323 // count the number of times that "new connection accepted" appears in the server log
324 string::size_type p=0;
326 while ((p=out.find("new connection accepted",p))++ != string::npos)
329 CPPUNIT_ASSERT_EQUAL(1,cnt);
332 void double_use_with_close()
334 wraptype::set_connection(auto_ptr<ConnectionWrapper>
335 (new BasicSocketWrapper("./socket")));
337 t2n_exec(&cmd_group_x_client::serverfunc)(17);
339 // closes the connection from the client side
340 wraptype::set_connection(auto_ptr<ConnectionWrapper>
341 (new BasicSocketWrapper("./socket")));
343 string out=t2n_exec(&cmd_group_x_client::getserverlog)();
345 // count the number of times that "new connection accepted" appears in the server log
346 string::size_type p=0;
348 while ((p=out.find("new connection accepted",p))++ != string::npos)
351 CPPUNIT_ASSERT_EQUAL(2,cnt);
354 void reconnect_after_close()
356 wraptype::set_connection(auto_ptr<ConnectionWrapper>
357 (new ReconnectSocketWrapper("./socket")));
359 wraptype::get_connection_wrapper()->set_command_timeout_usec(3000000);
360 wraptype::get_connection_wrapper()->set_hello_timeout_usec(3000000);
362 // 42 closes connection on the server side
363 t2n_exec(&cmd_group_x_client::serverfunc)(42);
365 string out=t2n_exec(&cmd_group_x_client::getserverlog)();
367 // count the number of times that "new connection accepted" appears in the server log
368 string::size_type p=0;
370 while ((p=out.find("new connection accepted",p))++ != string::npos)
373 CPPUNIT_ASSERT_EQUAL(2,cnt);
376 void reconnect_not_possible()
378 wraptype::set_connection(auto_ptr<ConnectionWrapper>
379 (new ReconnectSocketWrapper("./socket")));
381 // the server doens't like the beast
382 t2n_exec(&cmd_group_x_client::serverfunc)(666);
384 CPPUNIT_ASSERT_THROW(t2n_exec(&cmd_group_x_client::serverfunc)(1),t2n_communication_error);
387 void ignore_server_disconnect()
389 wraptype::set_connection(auto_ptr<ConnectionWrapper>
390 (new ReconnectIgnoreFailureSocketWrapper("./socket")));
392 // the server doens't like the beast
393 t2n_exec(&cmd_group_x_client::serverfunc)(666);
395 int i=t2n_exec(&cmd_group_x_client::serverfunc)(1);
397 // result is constructed with default constructor on error-and-ignore -> i=0
399 CPPUNIT_ASSERT_EQUAL(0,i);
402 void ignore_handler_reconnects()
404 wraptype::set_connection(auto_ptr<ConnectionWrapper>
405 (new ReconnectIgnoreFailureSocketWrapper("./socket")));
407 wraptype::get_connection_wrapper()->set_command_timeout_usec(3000000);
408 wraptype::get_connection_wrapper()->set_hello_timeout_usec(3000000);
410 // 42 closes connection on the server side
411 t2n_exec(&cmd_group_x_client::serverfunc)(42);
413 string out=t2n_exec(&cmd_group_x_client::getserverlog)();
415 // count the number of times that "new connection accepted" appears in the server log
416 string::size_type p=0;
418 while ((p=out.find("new connection accepted",p))++ != string::npos)
421 CPPUNIT_ASSERT_EQUAL(2,cnt);
428 CPPUNIT_TEST_SUITE_REGISTRATION(test_wrapper);
431 class test_wrapper_noserver : public TestFixture
433 CPPUNIT_TEST_SUITE(test_wrapper_noserver);
435 CPPUNIT_TEST(ignore_noserver);
436 CPPUNIT_TEST(ignore_finds_lateserver);
438 CPPUNIT_TEST_SUITE_END();
450 void ignore_noserver()
452 wraptype::set_connection(auto_ptr<ConnectionWrapper>
453 (new ReconnectIgnoreFailureSocketWrapper("./socket")));
455 // wraptype::get_connection_wrapper()->set_logging(&cerr,debug);
457 // there is no server
459 int i=t2n_exec(&cmd_group_x_client::serverfunc)(1);
461 // result is constructed with default constructor on error-and-ignore -> i=0
463 CPPUNIT_ASSERT_EQUAL(0,i);
466 void ignore_finds_lateserver()
468 wraptype::set_connection(auto_ptr<ConnectionWrapper>
469 (new ReconnectIgnoreFailureSocketWrapper("./socket")));
471 // there is no server
472 t2n_exec(&cmd_group_x_client::serverfunc)(1);
479 switch(child_pid=fork())
483 CPPUNIT_FAIL("fork error");
490 while(i < 10 && !kill_server)
494 socket_server ss("./socket");
495 group_command_server<cmd_group_x> cs(ss);
496 ss.set_logging(&logstream,debug);
499 for (; !close_server && !kill_server && i < 10; i++)
503 // don't call atexit and stuff
510 // wait till server is up
515 // server should be active
516 int i=t2n_exec(&cmd_group_x_client::serverfunc)(1);
518 CPPUNIT_ASSERT_EQUAL(2,i);
520 // make sure the server-child is dead before the next test runs
521 kill(child_pid,SIGKILL);
528 CPPUNIT_TEST_SUITE_REGISTRATION(test_wrapper_noserver);