diff options
Diffstat (limited to 'tests/CommonLibs/SocketsTest.cpp')
-rw-r--r-- | tests/CommonLibs/SocketsTest.cpp | 101 |
1 files changed, 0 insertions, 101 deletions
diff --git a/tests/CommonLibs/SocketsTest.cpp b/tests/CommonLibs/SocketsTest.cpp deleted file mode 100644 index e4eef54..0000000 --- a/tests/CommonLibs/SocketsTest.cpp +++ /dev/null @@ -1,101 +0,0 @@ -/* -* Copyright 2008 Free Software Foundation, Inc. -* -* -* This software is distributed under the terms of the GNU Affero Public License. -* See the COPYING file in the main directory for details. -* -* This use of this software may be subject to additional restrictions. -* See the LEGAL file in the main directory for details. - - This program is free software: you can redistribute it and/or modify - it under the terms of the GNU Affero General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - This program is distributed in the hope that it will be useful, - but WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - GNU Affero General Public License for more details. - - You should have received a copy of the GNU Affero General Public License - along with this program. If not, see <http://www.gnu.org/licenses/>. - -*/ - - - - -#include "Sockets.h" -#include "Threads.h" -#include <stdio.h> -#include <stdlib.h> -#include <unistd.h> -#include <signal.h> - -static const int gNumToSend = 10; - -static void sigalarm_handler(int foo) -{ - printf("FAIL: test did not run successfully\n"); - exit(EXIT_FAILURE); -} - -void *testReaderIP(void *param) -{ - UDPSocket *readSocket = (UDPSocket *)param; - readSocket->nonblocking(); - int rc = 0; - while (rc<gNumToSend) { - char buf[MAX_UDP_LENGTH+1] = { 0 }; - int count = readSocket->read(buf, MAX_UDP_LENGTH); - if (count>0) { - buf[count] = 0; - CERR("read: " << buf); - rc++; - } else { - sleep(2); - } - } - return NULL; -} - -int main(int argc, char * argv[] ) -{ - int count; - - if (signal(SIGALRM, sigalarm_handler) == SIG_ERR) { - perror("signal"); - exit(EXIT_FAILURE); - } - - /* If the test takes longer than 2*gNumToSend seconds, abort it */ - alarm(2* gNumToSend); - - UDPSocket readSocket("127.0.0.1", 0); - UDPSocket socket1("127.0.0.1", 0, "localhost", readSocket.port()); - - CERR("socket1: " << socket1.port() << ", readSocket: " << readSocket.port()); - - Thread readerThreadIP; - readerThreadIP.start(testReaderIP, &readSocket); - - // give the readers time to open - sleep(1); - - for (int i=0; i<gNumToSend; i++) { - CERR("write"); - count = socket1.write("Hello IP land"); - if (count < 0) { - COUT("FAIL: write"); - exit(EXIT_FAILURE); - } - sleep(1); - } - - readerThreadIP.join(); - - printf("Done\n"); -} - -// vim: ts=4 sw=4 |