- created udp_flood_disc (same as udp_flood but uses unconnected sockets)

test/locking/locking_test.c

@@ -149,6 +149,7 @@ int main (int argc, char** argv)
 	address=0;
 
 
+
 	opterr=0;
 	while ((c=getopt(argc,argv, "c:vhV"))!=-1){
 		switch(c){
@@ -187,6 +188,7 @@ int main (int argc, char** argv)
 					abort();
 		}
 	}
+
 	
 	/* check if all the required params are present */
 	if(count==0){
@@ -197,6 +199,7 @@ int main (int argc, char** argv)
 		exit(-1);
 	}
 
+
 #ifdef SYSV_SEM
 	/*init*/
 	puts("Initializing SYS V semaphores\n");

test/stateless.cfg

@@ -8,19 +8,19 @@
 debug=3          # debug level (cmd line: -dddddddddd)
 #fork=yes          # (cmd. line: -D)
 fork=yes
-fork=no
+#fork=no
 log_stderror=yes # (cmd line: -E)
 #log_stderror=no	# (cmd line: -E)
 
 
-children=2
+children=1
 check_via=no     # (cmd. line: -v)
 dns=off           # (cmd. line: -r)
 rev_dns=off      # (cmd. line: -R)
 #port=5070
-#listen=10.0.0.179
+listen=10.0.0.179
 #listen=127.0.0.1
-listen=192.168.57.33
+#listen=192.168.57.33
 loop_checks=0
 # for more info: sip_router -h
 

test/th-uri-2.cfg

@@ -15,14 +15,14 @@ log_stderror=yes # (cmd line: -E)
 #log_stderror=no	# (cmd line: -E)
 
 
-children=2
+children=4
 check_via=no     # (cmd. line: -v)
 dns=on           # (cmd. line: -r)
 rev_dns=yes      # (cmd. line: -R)
 #port=5070
 #listen=127.0.0.1
-listen=192.168.57.33
-#listen=10.0.0.179
+#listen=192.168.57.33
+listen=10.0.0.179
 loop_checks=0
 # for more info: sip_router -h
 

test/udp_flood_disc.c

@@ -0,0 +1,192 @@
+/* $Id$ */
+
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <errno.h>
+#include <string.h>
+#include <ctype.h>
+#include <netdb.h>
+#include <unistd.h>
+#include <sys/types.h>
+#include <fcntl.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+
+
+static char *id="$Id$";
+static char *version="udp_flood_disc 0.1";
+static char* help_msg="\
+Usage: udp_flood -f file -d address -p port -c count [-v]\n\
+Options:\n\
+    -f file       file with the content of the udp packet (max 65k)\n\
+    -d address    destination address\n\
+    -p port       destination port\n\
+    -c count      number of packets to be sent\n\
+    -v            increase verbosity level\n\
+    -V            version number\n\
+    -h            this help message\n\
+";
+
+#define BUF_SIZE 65535
+
+
+int main (int argc, char** argv)
+{
+	int fd;
+	int sock;
+	char c;
+	int n,r;
+	char* tmp;
+	char* buf[BUF_SIZE];
+	struct hostent* he;
+	struct sockaddr_in addr;
+	
+	int count;
+	int verbose;
+	char *fname;
+	char *dst;
+	int port;
+	
+	/* init */
+	count=0;
+	verbose=0;
+	fname=0;
+	dst=0;
+	port=0;
+
+	opterr=0;
+	while ((c=getopt(argc,argv, "f:c:d:p:vhV"))!=-1){
+		switch(c){
+			case 'f':
+				fname=optarg;
+				break;
+			case 'v':
+				verbose++;
+				break;
+			case 'd':
+				dst=optarg;
+				break;
+			case 'p':
+				port=strtol(optarg, &tmp, 10);
+				if ((tmp==0)||(*tmp)){
+					fprintf(stderr, "bad port number: -p %s\n", optarg);
+					goto error;
+				}
+				break;
+			case 'c':
+				count=strtol(optarg, &tmp, 10);
+				if ((tmp==0)||(*tmp)){
+					fprintf(stderr, "bad count: -c %s\n", optarg);
+					goto error;
+				}
+				break;
+			case 'V':
+				printf("version: %s\n", version);
+				printf("%s\n",id);
+				exit(0);
+				break;
+			case 'h':
+				printf("version: %s\n", version);
+				printf("%s", help_msg);
+				exit(0);
+				break;
+			case '?':
+				if (isprint(optopt))
+					fprintf(stderr, "Unknown option `-%c´\n", optopt);
+				else
+					fprintf(stderr, "Unknown character `\\x%x´\n", optopt);
+				goto error;
+			case ':':
+				fprintf(stderr, "Option `-%c´ requires an argument.\n",
+						optopt);
+				goto error;
+				break;
+			default:
+					abort();
+		}
+	}
+	
+	/* check if all the required params are present */
+	if (fname==0){
+		fprintf(stderr, "Missing -f file\n");
+		exit(-1);
+	}
+	if (dst==0){
+		fprintf(stderr, "Missing destination (-d ...)\n");
+		exit(-1);
+	}
+	if(port==0){
+		fprintf(stderr, "Missing port number (-p port)\n");
+		exit(-1);
+	}else if(port<0){
+		fprintf(stderr, "Invalid port number (-p %d)\n", port);
+		exit(-1);
+	}
+	if(count==0){
+		fprintf(stderr, "Missing packet count (-c number)\n");
+		exit(-1);
+	}else if(count<0){
+		fprintf(stderr, "Invalid packet count (-c %d)\n", count);
+		exit(-1);
+	}
+	
+	/* open packet file */
+	fd=open(fname, O_RDONLY);
+	if (fd<0){
+		fprintf(stderr, "ERROR: loading packet-file(%s): %s\n", fname,
+				strerror(errno));
+		goto error;
+	}
+	n=read(fd, buf, BUF_SIZE);
+	if (n<0){
+		fprintf(stderr, "ERROR: reading file(%s): %s\n", fname,
+				strerror(errno));
+		goto error;
+	}
+	if (verbose) printf("read %d bytes from file %s\n", n, fname);
+	close(fd);
+
+	/* resolve destination */
+	he=gethostbyname(dst);
+	if (he==0){
+		fprintf(stderr, "ERROR: could not resolve %s\n", dst);
+		goto error;
+	}
+	/* open socket*/
+	addr.sin_family=he->h_addrtype;
+	addr.sin_port=htons(port);
+	memcpy(&addr.sin_addr.s_addr, he->h_addr_list[0], he->h_length);
+	
+	sock = socket(he->h_addrtype, SOCK_DGRAM, 0);
+	if (sock==-1){
+		fprintf(stderr, "ERROR: socket: %s\n", strerror(errno));
+		goto error;
+	}
+/*
+	if (connect(sock, (struct sockaddr*) &addr, sizeof(struct sockaddr))!=0){
+		fprintf(stderr, "ERROR: connect: %s\n", strerror(errno));
+		goto error;
+	}
+*/
+
+
+	/* flood loop */
+	for (r=0; r<count; r++){
+		if ((verbose>1)&&(r%1000))  putchar('.');
+		if (sendto(sock,buf, n, 0, (struct sockaddr*) &addr, sizeof(addr))==-1)
+		{
+			fprintf(stderr, "Error: send: %s\n",  strerror(errno));
+			exit(1);
+		}
+	}
+	printf("\n%d packets sent, %d bytes each => total %d bytes\n",
+			count, n, n*count);
+
+	close(sock);
+	exit(0);
+
+error:
+	exit(-1);
+}