Main Page | Alphabetical List | Data Structures | Directories | File List | Data Fields | Globals

test_udp.c

Go to the documentation of this file.
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 }
See file LICENSE for details about the license agreement for using, modifying, copying or deriving work from this software.