00001 /* ==================================================================== 00002 * The Kannel Software License, Version 1.0 00003 * 00004 * Copyright (c) 2001-2008 Kannel Group 00005 * Copyright (c) 1998-2001 WapIT Ltd. 00006 * All rights reserved. 00007 * 00008 * Redistribution and use in source and binary forms, with or without 00009 * modification, are permitted provided that the following conditions 00010 * are met: 00011 * 00012 * 1. Redistributions of source code must retain the above copyright 00013 * notice, this list of conditions and the following disclaimer. 00014 * 00015 * 2. Redistributions in binary form must reproduce the above copyright 00016 * notice, this list of conditions and the following disclaimer in 00017 * the documentation and/or other materials provided with the 00018 * distribution. 00019 * 00020 * 3. The end-user documentation included with the redistribution, 00021 * if any, must include the following acknowledgment: 00022 * "This product includes software developed by the 00023 * Kannel Group (http://www.kannel.org/)." 00024 * Alternately, this acknowledgment may appear in the software itself, 00025 * if and wherever such third-party acknowledgments normally appear. 00026 * 00027 * 4. The names "Kannel" and "Kannel Group" must not be used to 00028 * endorse or promote products derived from this software without 00029 * prior written permission. For written permission, please 00030 * contact org@kannel.org. 00031 * 00032 * 5. Products derived from this software may not be called "Kannel", 00033 * nor may "Kannel" appear in their name, without prior written 00034 * permission of the Kannel Group. 00035 * 00036 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED 00037 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES 00038 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 00039 * DISCLAIMED. IN NO EVENT SHALL THE KANNEL GROUP OR ITS CONTRIBUTORS 00040 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, 00041 * OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT 00042 * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR 00043 * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 00044 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE 00045 * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, 00046 * EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 00047 * ==================================================================== 00048 * 00049 * This software consists of voluntary contributions made by many 00050 * individuals on behalf of the Kannel Group. For more information on 00051 * the Kannel Group, please see <http://www.kannel.org/>. 00052 * 00053 * Portions of this software are based upon software originally written at 00054 * WapIT Ltd., Helsinki, Finland for the Kannel project. 00055 */ 00056 00057 /* 00058 * test_udp.c - program to test UDP packet functions 00059 * 00060 * This program implements a simple ping-pong server. 00061 * 00062 * Lars Wirzenius 00063 */ 00064 00065 #include "gwlib/gwlib.h" 00066 #include <string.h> 00067 00068 static char usage[] = "\ 00069 Usage: test_udp client server_port\n\ 00070 test_udp server server_port\n\ 00071 "; 00072 00073 #define PING "ping" 00074 #define PONG "pong" 00075 #define TIMES 10 00076 00077 static void client(int port) { 00078 int i, s; 00079 Octstr *ping, *pong, *addr, *from; 00080 00081 s = udp_client_socket(); 00082 ping = octstr_create(PING); 00083 addr = udp_create_address(octstr_create("localhost"), port); 00084 if (s == -1 || addr == NULL) 00085 panic(0, "Couldn't set up client socket."); 00086 00087 for (i = 0; i < TIMES; ++i) { 00088 if (udp_sendto(s, ping, addr) == -1) 00089 panic(0, "Couldn't send ping."); 00090 if (udp_recvfrom(s, &pong, &from) == -1) 00091 panic(0, "Couldn't receive pong"); 00092 info(0, "Got <%s> from <%s:%d>", octstr_get_cstr(pong), 00093 octstr_get_cstr(udp_get_ip(from)), 00094 udp_get_port(from)); 00095 } 00096 } 00097 00098 static void server(int port) { 00099 int i, s; 00100 Octstr *ping, *pong, *from; 00101 00102 s = udp_bind(port,"0.0.0.0"); 00103 pong = octstr_create(PONG); 00104 if (s == -1) 00105 panic(0, "Couldn't set up client socket."); 00106 00107 for (i = 0; i < TIMES; ++i) { 00108 if (udp_recvfrom(s, &ping, &from) == -1) 00109 panic(0, "Couldn't receive ping"); 00110 info(0, "Got <%s> from <%s:%d>", octstr_get_cstr(ping), 00111 octstr_get_cstr(udp_get_ip(from)), 00112 udp_get_port(from)); 00113 if (udp_sendto(s, pong, from) == -1) 00114 panic(0, "Couldn't send pong."); 00115 } 00116 } 00117 00118 int main(int argc, char **argv) { 00119 int port; 00120 00121 gwlib_init(); 00122 00123 if (argc != 3) 00124 panic(0, "Bad argument list\n%s", usage); 00125 00126 port = atoi(argv[2]); 00127 00128 if (strcmp(argv[1], "client") == 0) 00129 client(port); 00130 else 00131 server(port); 00132 return 0; 00133 }