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 CPPUNIT_TEST_SUITE_END();
250 switch(child_pid=fork())
254 CPPUNIT_FAIL("fork error");
261 while(i < 10 && !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 < 10; i++)
274 // don't call atexit and stuff
281 // wait till server is up
290 // make sure the server-child is dead before the next test runs
291 kill(child_pid,SIGKILL);
295 void no_init_exception()
297 CPPUNIT_ASSERT_THROW(t2n_exec(&cmd_group_x_client::serverfunc)(1),std::logic_error);
302 wraptype::set_connection(auto_ptr<ConnectionWrapper>
303 (new BasicSocketWrapper("./socket")));
305 int i=t2n_exec(&cmd_group_x_client::serverfunc)(1);
307 CPPUNIT_ASSERT_EQUAL(2,i);
312 // only one connection used?
313 wraptype::set_connection(auto_ptr<ConnectionWrapper>
314 (new BasicSocketWrapper("./socket")));
316 t2n_exec(&cmd_group_x_client::serverfunc)(17);
317 string out=t2n_exec(&cmd_group_x_client::getserverlog)();
319 // count the number of times that "new connection accepted" appears in the server log
320 string::size_type p=0;
322 while ((p=out.find("new connection accepted",p))++ != string::npos)
325 CPPUNIT_ASSERT_EQUAL(1,cnt);
328 void double_use_with_close()
330 wraptype::set_connection(auto_ptr<ConnectionWrapper>
331 (new BasicSocketWrapper("./socket")));
333 t2n_exec(&cmd_group_x_client::serverfunc)(17);
335 // closes the connection from the client side
336 wraptype::set_connection(auto_ptr<ConnectionWrapper>
337 (new BasicSocketWrapper("./socket")));
339 string out=t2n_exec(&cmd_group_x_client::getserverlog)();
341 // count the number of times that "new connection accepted" appears in the server log
342 string::size_type p=0;
344 while ((p=out.find("new connection accepted",p))++ != string::npos)
347 CPPUNIT_ASSERT_EQUAL(2,cnt);
350 void reconnect_after_close()
352 wraptype::set_connection(auto_ptr<ConnectionWrapper>
353 (new ReconnectSocketWrapper("./socket")));
355 wraptype::get_connection_wrapper()->set_command_timeout_usec(3000000);
356 wraptype::get_connection_wrapper()->set_hello_timeout_usec(3000000);
358 // 42 closes connection on the server side
359 t2n_exec(&cmd_group_x_client::serverfunc)(42);
361 string out=t2n_exec(&cmd_group_x_client::getserverlog)();
363 // count the number of times that "new connection accepted" appears in the server log
364 string::size_type p=0;
366 while ((p=out.find("new connection accepted",p))++ != string::npos)
369 CPPUNIT_ASSERT_EQUAL(2,cnt);
372 void reconnect_not_possible()
374 wraptype::set_connection(auto_ptr<ConnectionWrapper>
375 (new ReconnectSocketWrapper("./socket")));
377 // the server doens't like the beast
378 t2n_exec(&cmd_group_x_client::serverfunc)(666);
380 CPPUNIT_ASSERT_THROW(t2n_exec(&cmd_group_x_client::serverfunc)(1),t2n_communication_error);
383 void ignore_server_disconnect()
385 wraptype::set_connection(auto_ptr<ConnectionWrapper>
386 (new ReconnectIgnoreFailureSocketWrapper("./socket")));
388 // the server doens't like the beast
389 t2n_exec(&cmd_group_x_client::serverfunc)(666);
391 int i=t2n_exec(&cmd_group_x_client::serverfunc)(1);
393 // result is constructed with default constructor on error-and-ignore -> i=0
395 CPPUNIT_ASSERT_EQUAL(0,i);
398 void ignore_handler_reconnects()
400 wraptype::set_connection(auto_ptr<ConnectionWrapper>
401 (new ReconnectIgnoreFailureSocketWrapper("./socket")));
403 wraptype::get_connection_wrapper()->set_command_timeout_usec(3000000);
404 wraptype::get_connection_wrapper()->set_hello_timeout_usec(3000000);
406 // 42 closes connection on the server side
407 t2n_exec(&cmd_group_x_client::serverfunc)(42);
409 string out=t2n_exec(&cmd_group_x_client::getserverlog)();
411 // count the number of times that "new connection accepted" appears in the server log
412 string::size_type p=0;
414 while ((p=out.find("new connection accepted",p))++ != string::npos)
417 CPPUNIT_ASSERT_EQUAL(2,cnt);
422 CPPUNIT_TEST_SUITE_REGISTRATION(test_wrapper);
425 class test_wrapper_noserver : public TestFixture
427 CPPUNIT_TEST_SUITE(test_wrapper_noserver);
429 CPPUNIT_TEST(ignore_noserver);
430 CPPUNIT_TEST(ignore_finds_lateserver);
431 CPPUNIT_TEST(ignore_wrongserver);
433 CPPUNIT_TEST_SUITE_END();
446 // make sure the server-child is dead before the next test runs
449 kill(child_pid,SIGKILL);
454 void ignore_noserver()
456 wraptype::set_connection(auto_ptr<ConnectionWrapper>
457 (new ReconnectIgnoreFailureSocketWrapper("./socket")));
459 // wraptype::get_connection_wrapper()->set_logging(&cerr,debug);
461 // there is no server
463 int i=t2n_exec(&cmd_group_x_client::serverfunc)(1);
465 // result is constructed with default constructor on error-and-ignore -> i=0
467 CPPUNIT_ASSERT_EQUAL(0,i);
470 void ignore_finds_lateserver()
472 wraptype::set_connection(auto_ptr<ConnectionWrapper>
473 (new ReconnectIgnoreFailureSocketWrapper("./socket")));
475 // there is no server
476 t2n_exec(&cmd_group_x_client::serverfunc)(1);
482 switch(child_pid=fork())
486 CPPUNIT_FAIL("fork error");
493 while(i < 10 && !kill_server)
497 socket_server ss("./socket");
498 group_command_server<cmd_group_x> cs(ss);
499 ss.set_logging(&logstream,debug);
502 for (; !close_server && !kill_server && i < 10; i++)
506 // don't call atexit and stuff
513 // wait till server is up
518 // server should be active
519 int i=t2n_exec(&cmd_group_x_client::serverfunc)(1);
521 CPPUNIT_ASSERT_EQUAL(2,i);
524 void send_hello(string hello_string, socket_server* ss, int conn_id)
526 server_connection *sc=ss->get_connection(conn_id);
527 sc->write(hello_string);
530 void ignore_wrongserver()
532 wraptype::set_connection(auto_ptr<ConnectionWrapper>
533 (new ReconnectIgnoreFailureSocketWrapper("./socket")));
537 switch(child_pid=fork())
541 CPPUNIT_FAIL("fork error");
547 socket_server ss("./socket");
549 // server sends garbage
554 ss.add_callback(new_connection,bind(&test_wrapper_noserver::send_hello, boost::ref(*this), hello.str(),&ss, _1));
557 for (int i=0; i < 10; i++)
558 ss.fill_buffer(1000000);
559 // don't call atexit and stuff
566 // wait till server is up
571 // there is no valid server
573 int i=t2n_exec(&cmd_group_x_client::serverfunc)(1);
575 // result is constructed with default constructor on error-and-ignore -> i=0
577 CPPUNIT_ASSERT_EQUAL(0,i);
583 CPPUNIT_TEST_SUITE_REGISTRATION(test_wrapper_noserver);