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 <socket_client.hxx>
23 #include <socket_server.hxx>
26 using namespace libt2n;
27 using namespace CppUnit;
29 class test_comm : public TestFixture
31 CPPUNIT_TEST_SUITE(test_comm);
33 CPPUNIT_TEST(UnixCommToServer);
34 CPPUNIT_TEST(UnixCommToServerAndBack);
35 CPPUNIT_TEST(IPCommToServer);
36 CPPUNIT_TEST(IPCommToServerAndBack);
38 CPPUNIT_TEST_SUITE_END();
48 void UnixCommToServer()
57 CPPUNIT_FAIL("fork error");
63 // wait till server is up
65 socket_client_connection sc("./socket");
67 // don't call atexit and stuff
74 socket_server ss("./socket");
77 for (int i=0; i < 10; i++)
79 ss.fill_buffer(1000000);
81 if(ss.get_packet(data))
86 CPPUNIT_ASSERT_EQUAL(string("hello"),data);
89 void UnixCommToServerAndBack()
97 CPPUNIT_FAIL("fork error");
103 socket_server ss("./socket");
104 ss.set_logging(&cerr,debug);
107 for (int i=0; i < 10; i++)
109 ss.fill_buffer(1000000);
114 if(ss.get_packet(data,cid))
116 server_connection* con=ss.get_connection(cid);
127 // don't call atexit and stuff
136 // wait till server is up
138 socket_client_connection sc("./socket");
142 sc.fill_buffer(1000000);
145 CPPUNIT_ASSERT_EQUAL(string("DEF"),data);
149 sc.fill_buffer(1000000);
152 CPPUNIT_ASSERT_EQUAL(string("xyz"),data);
159 void IPCommToServer()
168 CPPUNIT_FAIL("fork error");
174 // wait till server is up
176 socket_client_connection sc(6666);
178 // don't call atexit and stuff
185 socket_server ss(6666);
188 for (int i=0; i < 10; i++)
190 ss.fill_buffer(1000000);
192 if(ss.get_packet(data))
197 CPPUNIT_ASSERT_EQUAL(string("hello"),data);
200 void IPCommToServerAndBack()
208 CPPUNIT_FAIL("fork error");
214 socket_server ss(6666);
215 ss.set_logging(&cerr,debug);
218 for (int i=0; i < 10; i++)
220 ss.fill_buffer(1000000);
225 if(ss.get_packet(data,cid))
227 server_connection* con=ss.get_connection(cid);
238 // don't call atexit and stuff
247 // wait till server is up
249 socket_client_connection sc(6666);
252 sc.fill_buffer(1000000);
255 CPPUNIT_ASSERT_EQUAL(string("DEF"),data);
259 sc.fill_buffer(1000000);
262 CPPUNIT_ASSERT_EQUAL(string("xyz"),data);
271 CPPUNIT_TEST_SUITE_REGISTRATION(test_comm);