CVS: linux-atm/src/test svc_recv.c,NONE,1.1.2.1 svc_send.c,NONE,1.1.2.1 Makefile.am,1.2.2.2,1.2.2.3

SourceForge Headquarters 225 Broadway Suite 1600 San Diego, CA 92101 +1 (858) 422-6466

Update of /cvsroot/linux-atm/linux-atm/src/test
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv28846

Modified Files:
      Tag: V2_5_0
	Makefile.am 
Added Files:
      Tag: V2_5_0
	svc_recv.c svc_send.c 
Log Message:
svc examples program from ek...@cm...


--- NEW FILE: svc_recv.c ---
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <sys/ioctl.h>
#include <atm.h>
#include <linux/atmdev.h>

#define BHLI_MAGIC	"FORE_ATM"
#define	NUMPDUS		50000

static void usage(const char *name)
{
	fprintf(stderr, "usage: %s [<nsap> [<selector> [<qos>]]]\n", name);
	exit(1);
}

int main(int argc, char **argv)
{
	struct sockaddr_atmsvc addr;
	struct sockaddr_atmsvc *my_addr;
	struct atm_qos qos;
	struct atm_sap sap;
	int s, i, errcount = 0, fd, rv;
	int selector = 0;
	int one = 1;
	socklen_t len;

	char *outbuf = (char *) malloc(65535);
	if (outbuf == NULL)
		return 1;

	if ((s = socket(PF_ATMSVC, SOCK_DGRAM, 0)) < 0) {
		perror("socket");
		return 1;
	}

	memset(&addr, 0, sizeof(addr));
	memset(&qos, 0, sizeof(qos));
	memset(&my_addr, 0, sizeof(my_addr));

	qos.aal = ATM_AAL5;
	qos.txtp.traffic_class = ATM_NONE;
	qos.rxtp.traffic_class = ATM_UBR;
	qos.rxtp.max_sdu = 65535;

	/* Usage: svc_recv [local_host_name [selector [qos]]] */
	if (argc > 1) {
		int answer;
		my_addr =
		    (struct sockaddr_atmsvc *)
		    malloc(sizeof(struct sockaddr_atmsvc));

		answer =
		    text2atm(argv[1], (struct sockaddr *) my_addr,
			     sizeof(struct sockaddr_atmsvc),
			     T2A_SVC | T2A_NAME);

		if (-1 == answer) {
			fprintf(stderr, "Bad host name: %s\n", argv[1]);
			usage(argv[0]);
		}

		if (argc > 2) {

			selector = atoi(argv[2]);
			my_addr->sas_addr.prv[ATM_ESA_LEN - 1] =
			    (char) selector;

			if (argc > 3) {
				if (text2qos(argv[3], &qos, 0) < 0) {
					fprintf(stderr, "Invalid qos.\n");
					usage(argv[0]);
				}
			}
		}
	}

	memset(&sap, 0, sizeof(sap));
	sap.bhli.hl_type = ATM_HL_USER;
	sap.bhli.hl_length = 8;
	memcpy(&sap.bhli.hl_info, BHLI_MAGIC, 8);

	if (setsockopt(s, SOL_ATM, SO_ATMQOS, &qos, sizeof(qos)) < 0) {
		perror("setsockopt SO_ATMQOS (1)");
		return 1;
	}

	if (setsockopt(s, SOL_ATM, SO_ATMSAP, &sap, sizeof(sap)) < 0) {
		perror("setsockopt SO_ATMSAP");
		return 1;
	}

	if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one)) < 0) {
		perror("setsockopt SO_REUSEADDR");
		return 1;
	}

	if (NULL != my_addr) {
		int ret;
		char atm2textbuf[MAX_ATM_ADDR_LEN + 1];

		ret =
		    atm2text(atm2textbuf, sizeof(atm2textbuf),
			     (struct sockaddr *) my_addr,
			     A2T_NAME | A2T_PRETTY | A2T_LOCAL);

		if (-1 == ret) {
			fprintf(stderr, "Bad host name: %s\n", argv[1]);
			return 1;
		}

		fprintf(stderr, "binding to addr %s\n", atm2textbuf);

		ret =
		    bind(s, (struct sockaddr *) my_addr,
			 sizeof(struct sockaddr_atmsvc));

		if (ret < 0) {
			perror("bind() said");
			return 1;
		}
	}

	if (listen(s, 1) < 0) {
		perror("listen");
		return 1;
	}

	len = sizeof(addr);
	if ((fd = accept(s, (struct sockaddr *) &addr, &len)) < 0) {
		perror("accept");
		return 1;
	}

	fprintf(stderr, "receiving %d PDUs\n", NUMPDUS);
	for (i = 0, errcount = 0, rv = -1; i < NUMPDUS && rv != 0; i++)
		if ((rv = read(fd, outbuf, 65535)) < 0)
			errcount++;

	if (errcount > 0)
		fprintf(stderr, "read() failed %d out of %d times\n",
			errcount, NUMPDUS);
	fprintf(stderr, "received %d PDUs\n", i - 1);

	if (close(s) < 0)
		perror("close s");
	if (close(fd) < 0)
		perror("close fd");
	exit(0);
}

--- NEW FILE: svc_send.c ---
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <sys/ioctl.h>
#include <atm.h>
#include <linux/atmdev.h>

#define BHLI_MAGIC	"FORE_ATM"
#define	NUMPDUS		50000

static void usage(const char *name)
{
	fprintf(stderr, "usage: %s <nsap> [<qos>]\n", name);
	exit(1);
}

int main(int argc, char **argv)
{
	struct sockaddr_atmsvc addr;
	struct atm_qos qos;
	struct atm_sap sap;
	int s, i, errcount = 0;
	unsigned long one = 1;

	char *outbuf = (char *) malloc(8192);
	if (outbuf == NULL)
		return 1;

	if (argc < 2) {
		fprintf(stderr, "not enough arguments\n");
		usage(argv[0]);
	}
	if ((s = socket(PF_ATMSVC, SOCK_DGRAM, 0)) < 0) {
		perror("socket");
		return 1;
	}

	memset(&addr, 0, sizeof(addr));
	if (text2atm(argv[1], (struct sockaddr *) &addr, sizeof(addr),
		     T2A_SVC) < 0)
		usage(argv[0]);
	memset(&qos, 0, sizeof(qos));
	memset(&sap, 0, sizeof(sap));
	sap.bhli.hl_type = ATM_HL_USER;
	sap.bhli.hl_length = 8;
	memcpy(&sap.bhli.hl_info, BHLI_MAGIC, 8);

	if (argc > 2) {
		if (text2qos(argv[2], &qos, 0) < 0) {
			fprintf(stderr, "Invalid qos.\n");
			return 1;
		}
	} else {
		qos.aal = ATM_AAL5;
		qos.txtp.traffic_class = ATM_UBR;
		qos.rxtp.traffic_class = ATM_NONE;
		qos.txtp.max_sdu = 8192;
	}

	if (setsockopt(s, SOL_ATM, SO_ATMQOS, &qos, sizeof(qos)) < 0) {
		perror("setsockopt SO_ATMQOS (1)");
		return 1;
	}

	if (setsockopt(s, SOL_ATM, SO_ATMSAP, &sap, sizeof(sap)) < 0) {
		perror("setsockopt SO_ATMSAP");
		return 1;
	}

	if (connect(s, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
		perror("connect");
		return 1;
	}

	fprintf(stderr, "sending %d PDUs of length %d\n",
		NUMPDUS, qos.txtp.max_sdu);
	for (i = 0, errcount = 0; i < NUMPDUS; i++)
		if (write(s, outbuf, qos.txtp.max_sdu) < 0)
			errcount++;
	write(s, NULL, 0);

	if (errcount > 0)
		fprintf(stderr, "write() failed %d out of %d times\n",
			errcount, NUMPDUS);

	if (close(s) < 0)
		perror("close s");
	exit(0);
}

Index: Makefile.am
===================================================================
RCS file: /cvsroot/linux-atm/linux-atm/src/test/Makefile.am,v
retrieving revision 1.2.2.2
retrieving revision 1.2.2.3
diff -C2 -d -r1.2.2.2 -r1.2.2.3
*** Makefile.am	24 Feb 2004 23:37:24 -0000	1.2.2.2
--- Makefile.am	26 Sep 2004 12:07:06 -0000	1.2.2.3
***************
*** 1,3 ****
! USRPGMS = aread awrite ttcp_atm atmswitch
  PGMS = align aping br bw isp window
  bin_PROGRAMS = $(USRPGMS)
--- 1,3 ----
! USRPGMS = aread awrite ttcp_atm atmswitch svc_recv svc_send
  PGMS = align aping br bw isp window
  bin_PROGRAMS = $(USRPGMS)
***************
*** 9,12 ****
--- 9,14 ----
  aread_SOURCES = aread.c
  awrite_SOURCES = awrite.c
+ svc_recv_SOURCES = svc_recv.c
+ svc_send_SOURCES = svc_send.c
  ttcp_atm_SOURCES = ttcp.c