- added test udp flood program & config

- prototype plugin interface

main.c

@@ -310,7 +310,7 @@ int main(int argc, char** argv)
 					break;
 			case '?':
 					if (isprint(optopt))
-						fprintf(stderr, "Unknown option `-%c'.\n", optopt);
+						fprintf(stderr, "Unknown option `-%c´.\n", optopt);
 					else
 						fprintf(stderr, 
 								"Unknown option character `\\x%x´.\n",

mod_iface.h

@@ -0,0 +1,50 @@
+/*
+ * $Id$
+ *
+ * interface for modules
+ */
+
+#ifndef mod_iface_h
+#define mod_iface_h
+
+
+struct hdr_lst{
+	int type; /* VIA, OTHER, UNSPEC(=0), ... */
+	int op;   /* DEL, ADD, NOP, UNSPEC(=0) */
+	
+	union{
+		int offset; /* used for DEL, MODIFY */
+		char * value; /* used for ADD */
+	}u;
+	int len; /* length of this header field */
+	
+	
+	struct hdr_lst* before; /* list of headers to be inserted in front of the
+								current one */
+	struct hdr_lst* after; /* list of headers to be inserted immediately after
+							  the current one */
+	
+	struct hdr_lst* next;
+};
+
+/*
+ * hdrs must be kept sorted after their offset (DEL, NOP, UNSPEC)
+ * and/or their position (ADD). E.g.:
+ *  - to delete header Z insert it in to the list according to its offset 
+ *   and with op=DELETE
+ * - if you want to add a new header X after a  header Y, insert Y in the list
+ *   with op NOP and after it X (op ADD).
+ * - if you want X before Y, insert X in Y's before list.
+ * - if you want X to be the first header just put it first in hdr_lst.
+ *  -if you want to replace Y with X, insert Y with op=DELETE and then X with
+ *  op=ADD.
+ * before and after must contain only ADD ops!
+ * 
+ * Difference between "after" & "next" when ADDing:
+ * "after" forces the new header immediately after the current one while
+ * "next" means another header can be inserted between them.
+ * 
+ */
+
+
+#endif

test/test-throughput.cfg

@@ -0,0 +1,17 @@
+debug=1			# for speed
+check_via=0
+dns=off
+rev_dns=off
+fork=yes
+log_stderror=no
+children=64
+
+route{
+
+	if ( method=~'^INV' && uri=~'iptel\.org' ){
+		forward(127.0.0.1, 5060);
+		drop;
+	};
+	log("no rule for this packet => dropping\n");
+}
+

test/udp_flood.c

@@ -0,0 +1,186 @@
+/* $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 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('.');
+		send(sock, buf, n, 0);
+	}
+	printf("\n%d packets sent, %d bytes each => total %d bytes\n",
+			count, n, n*count);
+
+	close(sock);
+	exit(0);
+
+error:
+	exit(-1);
+}