xref: /netbsd-src/share/doc/psd/20.ipctut/strchkread.c (revision 075022b349321510ad14036d70908681ed02f117)
1*075022b3Sagc .\"	$NetBSD: strchkread.c,v 1.3 2003/08/07 10:30:50 agc Exp $
26d400d56Sperry .\"
3d9158b13Scgd .\" Copyright (c) 1986, 1993
4d9158b13Scgd .\"	The Regents of the University of California.  All rights reserved.
5d9158b13Scgd .\"
6d9158b13Scgd .\" Redistribution and use in source and binary forms, with or without
7d9158b13Scgd .\" modification, are permitted provided that the following conditions
8d9158b13Scgd .\" are met:
9d9158b13Scgd .\" 1. Redistributions of source code must retain the above copyright
10d9158b13Scgd .\"    notice, this list of conditions and the following disclaimer.
11d9158b13Scgd .\" 2. Redistributions in binary form must reproduce the above copyright
12d9158b13Scgd .\"    notice, this list of conditions and the following disclaimer in the
13d9158b13Scgd .\"    documentation and/or other materials provided with the distribution.
14*075022b3Sagc .\" 3. Neither the name of the University nor the names of its contributors
15d9158b13Scgd .\"    may be used to endorse or promote products derived from this software
16d9158b13Scgd .\"    without specific prior written permission.
17d9158b13Scgd .\"
18d9158b13Scgd .\" THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
19d9158b13Scgd .\" ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
20d9158b13Scgd .\" IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
21d9158b13Scgd .\" ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
22d9158b13Scgd .\" FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
23d9158b13Scgd .\" DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
24d9158b13Scgd .\" OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
25d9158b13Scgd .\" HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26d9158b13Scgd .\" LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27d9158b13Scgd .\" OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
28d9158b13Scgd .\" SUCH DAMAGE.
29d9158b13Scgd .\"
30d9158b13Scgd .\"	@(#)strchkread.c	8.1 (Berkeley) 6/8/93
31d9158b13Scgd .\"
32d9158b13Scgd #include <sys/types.h>
33d9158b13Scgd #include <sys/socket.h>
34d9158b13Scgd #include <sys/time.h>
35d9158b13Scgd #include <netinet/in.h>
36d9158b13Scgd #include <netdb.h>
37d9158b13Scgd #include <stdio.h>
38d9158b13Scgd #define TRUE 1
39d9158b13Scgd 
40d9158b13Scgd /*
41d9158b13Scgd  * This program uses select() to check that someone is trying to connect
42d9158b13Scgd  * before calling accept().
43d9158b13Scgd  */
44d9158b13Scgd 
45d9158b13Scgd main()
46d9158b13Scgd {
47d9158b13Scgd 	int sock, length;
48d9158b13Scgd 	struct sockaddr_in server;
49d9158b13Scgd 	int msgsock;
50d9158b13Scgd 	char buf[1024];
51d9158b13Scgd 	int rval;
52d9158b13Scgd 	fd_set ready;
53d9158b13Scgd 	struct timeval to;
54d9158b13Scgd 
55d9158b13Scgd 	/* Create socket */
56d9158b13Scgd 	sock = socket(AF_INET, SOCK_STREAM, 0);
57d9158b13Scgd 	if (sock < 0) {
58d9158b13Scgd 		perror("opening stream socket");
59d9158b13Scgd 		exit(1);
60d9158b13Scgd 	}
61d9158b13Scgd 	/* Name socket using wildcards */
62d9158b13Scgd 	server.sin_family = AF_INET;
63d9158b13Scgd 	server.sin_addr.s_addr = INADDR_ANY;
64d9158b13Scgd 	server.sin_port = 0;
65d9158b13Scgd 	if (bind(sock, &server, sizeof(server))) {
66d9158b13Scgd 		perror("binding stream socket");
67d9158b13Scgd 		exit(1);
68d9158b13Scgd 	}
69d9158b13Scgd 	/* Find out assigned port number and print it out */
70d9158b13Scgd 	length = sizeof(server);
71d9158b13Scgd 	if (getsockname(sock, &server, &length)) {
72d9158b13Scgd 		perror("getting socket name");
73d9158b13Scgd 		exit(1);
74d9158b13Scgd 	}
75d9158b13Scgd 	printf("Socket has port #%d\en", ntohs(server.sin_port));
76d9158b13Scgd 
77d9158b13Scgd 	/* Start accepting connections */
78d9158b13Scgd 	listen(sock, 5);
79d9158b13Scgd 	do {
80d9158b13Scgd 		FD_ZERO(&ready);
81d9158b13Scgd 		FD_SET(sock, &ready);
82d9158b13Scgd 		to.tv_sec = 5;
83d9158b13Scgd 		if (select(sock + 1, &ready, 0, 0, &to) < 0) {
84d9158b13Scgd 			perror("select");
85d9158b13Scgd 			continue;
86d9158b13Scgd 		}
87d9158b13Scgd 		if (FD_ISSET(sock, &ready)) {
88d9158b13Scgd 			msgsock = accept(sock, (struct sockaddr *)0, (int *)0);
89d9158b13Scgd 			if (msgsock == -1)
90d9158b13Scgd 				perror("accept");
91d9158b13Scgd 			else do {
92d9158b13Scgd 				bzero(buf, sizeof(buf));
93d9158b13Scgd 				if ((rval = read(msgsock, buf, 1024)) < 0)
94d9158b13Scgd 					perror("reading stream message");
95d9158b13Scgd 				else if (rval == 0)
96d9158b13Scgd 					printf("Ending connection\en");
97d9158b13Scgd 				else
98d9158b13Scgd 					printf("-->%s\en", buf);
99d9158b13Scgd 			} while (rval > 0);
100d9158b13Scgd 			close(msgsock);
101d9158b13Scgd 		} else
102d9158b13Scgd 			printf("Do something else\en");
103d9158b13Scgd 	} while (TRUE);
104d9158b13Scgd }
105