File /code/linux-sctp/test/test-sctpc.c

#ident "@(#) $RCSfile: test-sctpc.c,v $ $Name:  $($Revision: 1.4 $) $Date: 2003/03/20 10:02:13 $"

static char const ident[] =
    "$RCSfile: test-sctpc.c,v $ $Name:  $($Revision: 1.4 $) $Date: 2003/03/20 10:02:13 $";

#include <stdio.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <asm/ioctls.h>
#include <linux/sockios.h>
#include <netinet/in.h>
#include <netinet/sctp.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/poll.h>
#include <sys/time.h>
#include <signal.h>
#include <getopt.h>
#include <stdlib.h>
#include <string.h>

#define MSG_LEN 64

void usage(void)
{
	fprintf(stderr, "Usage:  test-sctpc [options]\n");
	fprintf(stderr, "Options:\n");
	fprintf(stderr, "  -p, --port port           (default: 10000)\n");
	fprintf(stderr, "      port specifies the remote port number\n");
	fprintf(stderr, "  -l, --loc_host loc_host   (default: 0.0.0.0)\n");
	fprintf(stderr, "      loc_host specifies the local (bind) host for the SCTP socket\n");
	fprintf(stderr, "  -r, --rem_host rem_host   (default: 127.0.0.1)\n");
	fprintf(stderr, "      rem_host specifies the remote (sendto) address for the SCTP socket\n");
	fprintf(stderr, "  -t, --rep_time time       (default: 1 second)\n");
	fprintf(stderr, "      time give the time in seconds between reports\n");
	fprintf(stderr, "  -w, --length              (default: %d)\n", MSG_LEN);
	fprintf(stderr, "      packet length\n");
	fprintf(stderr, "  -n, --nagle               (default: nonagle)\n");
	fprintf(stderr, "      enable nagle algorithm\n");
}

#define HOST_BUF_LEN 256

int rep_time = 1;

static int timer_timeout = 0;

static void timer_handler(int signum)
{
	if (signum == SIGALRM)
		timer_timeout = 1;
	return;
}

static int timer_sethandler(void)
{
	sigset_t mask;
	struct sigaction act;
	act.sa_handler = timer_handler;
	act.sa_flags = SA_RESTART | SA_ONESHOT;
	act.sa_restorer = NULL;
	sigemptyset(&act.sa_mask);
	if (sigaction(SIGALRM, &act, NULL))
		return -1;
	sigemptyset(&mask);
	sigaddset(&mask, SIGALRM);
	sigprocmask(SIG_UNBLOCK, &mask, NULL);
	return 0;
}

static int start_timer(void)
{
	struct itimerval setting = { {0, 0}, {rep_time, 0} };
	if (timer_sethandler())
		return -1;
	if (setitimer(ITIMER_REAL, &setting, NULL))
		return -1;
	timer_timeout = 0;
	return 0;
}

static struct sockaddr_in loc_addr = { AF_INET, 0, {INADDR_ANY}, };
static struct sockaddr_in rem_addr = { AF_INET, 0, {INADDR_ANY}, };

int len = MSG_LEN;

int nodelay = 1;

unsigned char my_msg[8192] =
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.\0"
    "This is a good short test message that has some 64 bytes in it.";
unsigned char ur_msg[8192];

int test_sctpc(void)
{
	int fd;
	int i, out_offset = 0, inp_offset = 0, mode = 0;
	long rtt_delay = 0;
	long inp_count = 0, out_count = 0;
	long inp_bytes = 0, out_bytes = 0;
	struct pollfd pfd[1] = { {0, POLLIN | POLLOUT | POLLERR | POLLHUP, 0} };

	fprintf(stderr, "Opening socket\n");
	if ((fd = socket(PF_INET, SOCK_SEQPACKET, IPPROTO_SCTP)) < 0) {
		perror("socket");
		goto dead;
	}
	fprintf(stderr, "Binding socket to %s:%d\n", inet_ntoa(loc_addr.sin_addr),
		ntohs(loc_addr.sin_port));
	if (bind(fd, (struct sockaddr *) &loc_addr, sizeof(loc_addr)) < 0) {
		perror("bind");
		goto dead;
	}
	if (connect(fd, (struct sockaddr *) &rem_addr, sizeof(rem_addr)) < 0) {
		perror("connect");
		goto dead;
	}
	if (fcntl(fd, F_SETFL, O_NONBLOCK) < 0) {
		perror("fcntl");
		goto dead;
	}
	if (setsockopt(fd, SOL_SCTP, SCTP_NODELAY, &nodelay, sizeof(nodelay)) < 0) {
		perror("setsockopt");
		goto dead;
	}
	if (start_timer()) {
		perror("timer");
		goto dead;
	}
	for (;;) {
		pfd[0].fd = fd;
		pfd[0].events = POLLOUT | POLLIN | POLLERR | POLLHUP;
		pfd[0].revents = 0;
		if (timer_timeout) {
#if 0
			int inq = 0, outq = 0;
			if ((ioctl(fd, SIOCINQ, &inq)) < 0) {
				perror("ioctl");
				goto dead;
			}
			if ((ioctl(fd, SIOCOUTQ, &outq)) < 0) {
				perror("ioctl");
				goto dead;
			}
#endif
			printf
			    ("Bytes sent: %7ld, recv: %7ld, tot: %7ld, dif: %8ld dly: %6ld\n",
			     out_bytes, inp_bytes, out_bytes + inp_bytes, inp_bytes - out_bytes,
			     inp_count ? rtt_delay / inp_count : 0);
			inp_count = 0;
			out_count = 0;
			inp_bytes = 0;
			out_bytes = 0;
			rtt_delay = 0;
#if 0
			printf("In q: %d, Out q: %d\n", inq, outq);
#endif
			if (start_timer()) {
				perror("timer");
				goto dead;
			}
			continue;
		}
		if (poll(&pfd[0], 1, -1) < 0) {
			if (errno == EINTR || errno == EAGAIN)
				continue;
			perror("poll");
			goto dead;
		}
		if (pfd[0].revents & POLLIN) {
			int rtn;
			if ((rtn =
			     recv(fd, ur_msg + inp_offset, len - inp_offset, MSG_DONTWAIT)) < 0) {
				if (errno == EINTR || errno == EAGAIN)
					goto skip_pollin;
				perror("recv");
				goto dead;
			}
			if (rtn) {
				inp_bytes += rtn;
				inp_offset += rtn;
				if (inp_offset >= len) {
					struct timeval tnow;
					struct timeval *tv = (struct timeval *) ur_msg;
					if (gettimeofday(&tnow, NULL) < 0) {
						perror("gettimeofday");
						goto dead;
					}
					if (tnow.tv_sec < tv->tv_sec ||
					    (tnow.tv_sec == tv->tv_sec &&
					     tnow.tv_usec < tv->tv_usec))
						fprintf(stderr,
							"time: %ld.%06ld before %ld.%06ld\n",
							tnow.tv_sec, tnow.tv_usec, tv->tv_sec,
							tv->tv_usec);
					rtt_delay +=
					    (tnow.tv_sec - tv->tv_sec) * 1000000 + tnow.tv_usec -
					    tv->tv_usec;
					inp_count++;
					inp_offset = 0;
				}
			}
			continue;
		}
	      skip_pollin:
		if (pfd[0].revents & POLLOUT) {
			int rtn;
			if (!out_offset) {
				struct timeval *tv = (struct timeval *) my_msg;
				if (gettimeofday(tv, NULL) < 0) {
					perror("gettimeofday");
					goto dead;
				}
			}
			if ((rtn =
			     send(fd, my_msg + out_offset, len - out_offset, MSG_DONTWAIT)) < 0) {
				if (errno == EINTR || errno == EAGAIN)
					goto skip_pollout;
				perror("send");
				fprintf(stderr, "rtn = %d, ", rtn);
				fprintf(stderr, "fd = %d, ", fd);
				fprintf(stderr, "my_msg = %p, ", my_msg);
				fprintf(stderr, "out_offset = %d, ", out_offset);
				fprintf(stderr, "len = %d, ", len);
				fprintf(stderr, "flags = %d\n", MSG_DONTWAIT);
				goto dead;
			}
			if (rtn) {
				out_bytes += rtn;
				out_offset += rtn;
				if (out_offset >= len) {
					out_count++;
					out_offset = 0;
				}
			}
			continue;
		}
	      skip_pollout:
		if (pfd[0].revents & POLLERR) {
			perror("POLLERR");
			goto dead;
		}
		if (pfd[0].revents & POLLHUP) {
			perror("POLLHUP");
			goto dead;
		}
	}
      dead:
	fprintf(stderr, "Error number: %d\n", errno);
	close(fd);
	return (0);
}

int main(int argc, char **argv)
{
	int c;
	char *hostl = "0.0.0.0";
	char *hostr = "127.0.0.1";
	char hostbufl[HOST_BUF_LEN];
	char hostbufr[HOST_BUF_LEN];
	char **hostlp = &hostl;
	char **hostrp = &hostr;
	short port = 10000;
	struct hostent *haddr;
	while (1) {
		int option_index = 0;
		static struct option long_options[] = {
			{"loc_host", 1, 0, 'l'},
			{"rem_host", 1, 0, 'r'},
			{"rep_time", 1, 0, 't'},
			{"help", 0, 0, 'h'},
			{"port", 1, 0, 'p'},
			{"length", 1, 0, 'w'},
			{"nagle", 0, 0, 'n'}
		};
		c = getopt_long(argc, argv, "l:r:t:hp:w:n", long_options, &option_index);
		if (c == -1)
			break;
		switch (c) {
		case 0:
			switch (option_index) {
			case 0:	/* loc_host */
				strncpy(hostbufl, optarg, HOST_BUF_LEN);
				hostl = hostbufl;
				hostlp = &hostl;
				break;
			case 1:	/* rem_host */
				strncpy(hostbufr, optarg, HOST_BUF_LEN);
				hostr = hostbufr;
				hostrp = &hostr;
				break;
			case 2:	/* rep_time */
				rep_time = atoi(optarg);
				break;
			case 3:	/* help */
				usage();
				exit(0);
			case 4:	/* port */
				port = atoi(optarg);
				break;
			case 5:	/* length */
				len = atoi(optarg);
				if (len > 8192) {
					len = 8192;
				}
				break;
			case 6:	/* nagle */
				nodelay = 0;
				break;
			default:
				usage();
				exit(1);
			}
			break;
		case 'l':
			strncpy(hostbufl, optarg, HOST_BUF_LEN);
			hostl = hostbufl;
			hostlp = &hostl;
			break;
		case 'r':
			strncpy(hostbufr, optarg, HOST_BUF_LEN);
			hostr = hostbufr;
			hostrp = &hostr;
			break;
		case 't':
			rep_time = atoi(optarg);
			break;
		case 'h':
			usage();
			exit(0);
		case 'p':
			port = atoi(optarg);
			break;
		case 'w':
			len = atoi(optarg);
			if (len > 8192)
				len = 8192;
			break;
		case 'n':
			nodelay = 0;
			break;
		default:
			fprintf(stderr, "ERROR: Unrecognized option `%c'.\n", c);
			usage();
			exit(1);
		}
	}
	if (optind < argc) {
		fprintf(stderr, "ERROR: Option syntax: ");
		while (optind < argc)
			fprintf(stderr, "%s ", argv[optind++]);
		fprintf(stderr, "\n");
		usage();
		exit(1);
	}

	haddr = gethostbyname(*hostlp);
	loc_addr.sin_family = AF_INET;
	loc_addr.sin_port = 0;
	loc_addr.sin_addr.s_addr = *(uint32_t *) (haddr->h_addr);

	haddr = gethostbyname(*hostrp);
	rem_addr.sin_family = AF_INET;
	rem_addr.sin_port = htons(port);
	rem_addr.sin_addr.s_addr = *(uint32_t *) (haddr->h_addr);

	return test_sctpc();
}