home *** CD-ROM | disk | FTP | other *** search
- /*-
- * Copyright (c) 1988, 1990 The Regents of the University of California.
- * All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions
- * are met:
- * 1. Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * 2. Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * 3. All advertising materials mentioning features or use of this software
- * must display the following acknowledgement:
- * This product includes software developed by the University of
- * California, Berkeley and its contributors.
- * 4. Neither the name of the University nor the names of its contributors
- * may be used to endorse or promote products derived from this software
- * without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
- * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
- * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
- * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
- * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
- * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
- * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
- * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
- * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
- * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
- * SUCH DAMAGE.
- */
-
- #ifndef lint
- char copyright[] =
- "@(#) Copyright (c) 1988, 1990 The Regents of the University of California.\n\
- All rights reserved.\n";
- #endif /* not lint */
-
- #ifndef lint
- static char sccsid[] = "@(#)tisink.c 7.6 (Berkeley) 5/7/91";
- #endif /* not lint */
-
- /*
- * This is a test program to be a sink for ISO packets.
- */
- #include <sys/param.h>
- #include <sys/uio.h>
- #include <sys/socket.h>
- #include <sys/ioctl.h>
- #include <net/route.h>
- #include <net/if.h>
- #define TCPT_NTIMERS 4
- #include <netiso/iso.h>
- #include <netiso/tp_param.h>
- #include <netiso/tp_user.h>
-
- #include <stdio.h>
- #include <errno.h>
- #include <ctype.h>
- #include <netdb.h>
-
-
- #define dbprintf if(verbose)printf
- #define try(a,b,c) {x = (a b); dbprintf("%s%s returns %d\n",c,"a",x);\
- if(x<0) {perror("a"); myexit(0);}}
-
-
- struct ifreq ifr;
- short port = 3000;
- struct sockaddr_iso faddr, laddr = { sizeof(laddr), AF_ISO };
- struct sockaddr_iso *siso = &laddr;
- char **xenvp;
-
- long size, count = 10, forkp, confp, echop, mynamep, verbose = 1, playtag = 0;
- long records, intercept = 0, isode_mode = 0, dgramp = 0;
-
- char buf[2048];
- char your_it[] = "You're it!";
-
- char *Servername;
-
- main(argc, argv, envp)
- int argc;
- char *argv[];
- char *envp[];
- {
- register char **av = argv;
- register char *cp;
- struct iso_addr *iso_addr();
-
- xenvp = envp;
- while(--argc > 0) {
- av++;
- if(strcmp(*av,"Servername")==0) {
- av++;
- Servername = *av;
- argc--;
- } else if (strcmp(*av,"host")==0) {
- av++;
- laddr.siso_addr = *iso_addr(*av);
- argc--;
- } else if (strcmp(*av,"count")==0) {
- av++;
- sscanf(*av,"%ld",&count);
- argc--;
- } else if (strcmp(*av,"port")==0) {
- av++;
- sscanf(*av,"%hd",&port);
- argc--;
- } else if (strcmp(*av,"size")==0) {
- av++;
- sscanf(*av,"%ld",&size);
- argc--;
- } else if (strcmp(*av, "intercept")==0) {
- intercept++;
- }
- }
- if (Servername) {
- int tlen = laddr.siso_tlen = strlen(Servername);
- int len = TSEL(siso) + tlen - (caddr_t) &siso;
- if (len > sizeof(*siso)) {
- siso = (struct sockaddr_iso *)malloc(len);
- *siso = laddr;
- siso->siso_len = len;
- }
- bcopy(Servername, TSEL(siso), tlen);
- } else {
- port = htons(port);
- laddr.siso_tlen = sizeof(port);
- bcopy((char *)&port, TSEL(siso), sizeof(port));
- }
- tisink();
- }
- #define BIG 2048
- #define MIDLIN 512
- char readbuf[BIG];
- struct iovec iov[1] = {
- readbuf,
- sizeof readbuf,
- };
- char name[MIDLIN];
- union {
- struct {
- struct cmsghdr cmhdr;
- char cmdata[128 - sizeof(struct cmsghdr)];
- } cm;
- char data[128];
- } cbuf;
- #define control cbuf.data
- struct msghdr msghdr = {
- name, sizeof(name),
- iov, sizeof(iov)/sizeof(iov[1]),
- control, sizeof control,
- 0 /* flags */
- };
-
- tisink()
- {
- int x, s, pid, on = 1, loop = 0, n, ns;
- extern int errno;
- int socktype = (dgramp ? SOCK_DGRAM : SOCK_SEQPACKET);
- int addrlen = sizeof(faddr);
-
- try(socket, (AF_ISO, socktype, 0),"");
-
- s = x;
-
- try(bind, (s, (struct sockaddr *) siso, siso->siso_len), "");
-
- /*try(setsockopt, (s, SOL_SOCKET, SO_DEBUG, &on, sizeof (on)), ""); */
- if (dgramp) {
- ns = s;
- goto dgram1;
- }
-
- try(listen, (s, 5), "");
- if (intercept) {
- try(setsockopt,
- (s, SOL_TRANSPORT, TPOPT_INTERCEPT, &on, sizeof(on)), "");
- }
- for(;;) {
- int child;
- char childname[50];
-
- try (accept, (s, &faddr, &addrlen), "");
- ns = x;
- dumpit("connection from:", &faddr, sizeof faddr);
- if (mynamep || intercept) {
- addrlen = sizeof(faddr);
- try (getsockname, (ns, &faddr, &addrlen), "");
- dumpit("connected as:", &faddr, addrlen);
- }
- loop++;
- if(loop > 3) myexit(0);
- if (forkp) {
- try(fork, (), "");
- } else
- x = 0;
- if (x == 0) {
- long n, count = 0, cn, flags;
- records = 0;
- if (confp) {
- msghdr.msg_iovlen = 0;
- msghdr.msg_namelen = 0;
- msghdr.msg_controllen =
- cbuf.cm.cmhdr.cmsg_len = sizeof (cbuf.cm.cmhdr);
- cbuf.cm.cmhdr.cmsg_level = SOL_TRANSPORT;
- cbuf.cm.cmhdr.cmsg_type = TPOPT_CFRM_DATA;
- n = sendmsg(ns, &msghdr, 0);
- if (n < 0) {
- printf("confirm: errno is %d\n", errno);
- fflush(stdout);
- perror("Confirm error");
- } else {
- dbprintf("confim ok\n");
- }
- sleep(10);
- }
- #ifdef ISODE_MODE
- if (isode_mode) {
- static char fdbuf[10];
- static char *nargv[4] =
- {"/usr/sbin/isod.tsap", fdbuf, "", 0};
- sprintf(fdbuf, "Z%d", ns);
- old_isod_main(3, nargv, xenvp);
- } else
- #endif
- for (;;) {
- dgram1:
- msghdr.msg_iovlen = 1;
- msghdr.msg_controllen = sizeof(control);
- msghdr.msg_namelen = (dgramp ? (sizeof name) : 0);
- iov->iov_len = sizeof(readbuf);
- n = recvmsg(ns, &msghdr, 0);
- flags = msghdr.msg_flags;
- count++;
- dbprintf("recvmsg from child %d got %d ctl %d flags %x\n",
- getpid(), n, (cn = msghdr.msg_controllen), flags);
- fflush(stdout);
- if (dgramp && msghdr.msg_namelen && verbose)
- dumpit("from:\n", name, msghdr.msg_namelen);
- if (cn && verbose)
- dumpit("control data:\n", control, cn);
- if (n < 0) {
- fprintf(stderr, "errno is %d\n", errno);
- perror("recvmsg");
- /*sleep (10);*/
- break;
- } else {
- if (verbose)
- dumpit("data:\n", readbuf, n);
- }
- if (echop) {
- n = answerback(flags, n, ns);
- }
- if (flags & MSG_EOR)
- records++;
- if (playtag && n == sizeof(your_it) && (flags & MSG_EOR)
- && bcmp(readbuf, your_it, n) == 0) {
- printf("Answering back!!!!\n");
- answerback(flags, n, ns);
- answerback(flags, n, ns);
- }
- errno = 0;
- }
- }
- myexit(0);
- }
- }
- answerback(flags, n, ns)
- {
- msghdr.msg_controllen = 0;
- msghdr.msg_iovlen = 1;
- iov->iov_len = n;
- n = sendmsg(ns, &msghdr, flags);
- dbprintf("echoed %d\n", n);
- return n;
- }
-
- dumpit(what, where, n)
- char *what; unsigned short *where; int n;
- {
- unsigned short *s = where;
- unsigned short *z = where + (n+1)/2;
- int count = 0;
- printf(what);
- while(s < z) {
- count++;
- printf("%x ",*s++);
- if ((count & 15) == 0)
- putchar('\n');
- }
- if (count & 15)
- putchar('\n');
- fflush(stdout);
- }
- myexit(n)
- {
- fflush(stderr);
- printf("got %d records\n", records);
- fflush(stdout);
- exit(n);
- }
-