Iniziate le opzioni dei socket.
[gapil.git] / sources / TCP_echo.c
1 /* TCP_echo.c
2  * 
3  * Copyright (C) 2001-2003 Simone Piccardi
4  * 
5  * This program is free software; you can redistribute it and/or modify
6  * it under the terms of the GNU General Public License as published by
7  * the Free Software Foundation; either version 2 of the License, or (at
8  * your option) any later version.
9  * 
10  * This program is distributed in the hope that it will be useful, but
11  * WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
13  * General Public License for more details.
14  * 
15  * You should have received a copy of the GNU General Public License
16  * along with this program; if not, write to the Free Software
17  * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
18  */
19 /****************************************************************
20  *
21  * Program TCP_echo.c
22  * Simple TCP client for echo service (port 7)
23  *
24  * Author: Simone Piccardi
25  * Jun. 2001
26  *
27  * Usage: echo -h give all info's
28  *
29  * $Id: TCP_echo.c,v 1.11 2003/10/20 22:44:16 piccardi Exp $
30  *
31  ****************************************************************/
32 /* 
33  * Include needed headers
34  */
35 #include <sys/types.h>   /* predefined types */
36 #include <unistd.h>      /* include unix standard library */
37 #include <arpa/inet.h>   /* IP addresses conversion utiliites */
38 #include <sys/socket.h>  /* socket library */
39 #include <stdio.h>       /* include standard I/O library */
40 #include <errno.h>       /* include error codes */
41 #include <string.h>      /* include erroro strings definitions */
42
43 #include "Gapil.h"
44 #include "macros.h"
45
46 #define MAXLINE 256
47 void usage(void);
48 void ClientEcho(FILE * filein, int socket);
49 void SigTERM_hand(int sig);
50
51 /* Program begin */
52 int main(int argc, char *argv[])
53 {
54 /* 
55  * Variables definition  
56  */
57     int sock, i;
58     int reset = 0;
59     struct linger ling;
60     /*
61      * Input section: decode parameters passed in the calling 
62      * Use getopt function
63      */
64     opterr = 0;  /* don't want writing to stderr */
65     while ( (i = getopt(argc, argv, "hr")) != -1) {
66         switch (i) {
67         /* 
68          * Handling options 
69          */ 
70         case 'h':  
71             printf("Wrong -h option use\n");
72             usage();
73             return(1);
74             break;
75         case 'r':
76             reset = 1;
77             break;
78         case '?':   /* unrecognized options */
79             printf("Unrecognized options -%c\n",optopt);
80             usage();
81         default:    /* should not reached */
82             usage();
83         }
84     }
85     /* ***********************************************************
86      * 
87      *           Options processing completed
88      *
89      *                Main code beginning
90      * 
91      * ***********************************************************/
92     /* call sockaddr to get a connected socket */
93     if ( (sock = sockconn(argv[optind], "echo", 6, SOCK_STREAM)) < 0) {
94         if (errno) perror("Socket creation error");
95         return 1;
96     }
97     /* check if resetting on close is required */
98     if (reset) {
99         printf("Setting reset on close \n");
100         ling.l_onoff = 1;
101         ling.l_linger = 0;      
102         if (setsockopt(sock, SOL_SOCKET, SO_LINGER, &ling, sizeof(ling))) {
103             perror("Cannot set linger");
104             exit(1);
105         }
106     }
107     /* do read/write operations */
108     ClientEcho(stdin, sock);
109     /* normal exit */
110     return 0;
111 }
112 /*
113  * routine to print usage info and exit 
114  */
115 void usage(void) {
116     printf("Take daytime from a remote host \n");
117     printf("Usage:\n");
118     printf("  daytime [-h] [-v] [host in dotted decimal form] \n");
119 //    printf("  -v         set verbosity on\n");
120     printf("  -r           require reset on closing\n");
121     printf("  -h           print this help\n");
122     exit(1);
123 }
124
125 void ClientEcho(FILE * filein, int socket) 
126 {
127     char sendbuff[MAXLINE+1], recvbuff[MAXLINE+1];
128     int nread, nwrite; 
129     int maxfd;
130     fd_set fset;
131     int eof = 0;
132     /* initialize file descriptor set */
133     FD_ZERO(&fset);
134     maxfd = max(fileno(filein), socket) + 1;
135     while (1) {
136         FD_SET(socket, &fset);         /* set for the socket */
137         if (eof == 0) {
138             FD_SET(fileno(filein), &fset); /* set for the standard input */
139         }
140         select(maxfd, &fset, NULL, NULL, NULL); /* wait for read ready */
141         if (FD_ISSET(fileno(filein), &fset)) {  /* if ready on stdin */
142             if (fgets(sendbuff, MAXLINE, filein) == NULL) { /* if no input */
143                 eof = 1;               /* EOF on input */
144                 shutdown(socket, SHUT_WR);      /* close write half */
145                 FD_CLR(fileno(filein), &fset);  /* no more interest on stdin */
146             } else {                   /* else we have to write to socket */
147                 nwrite = FullWrite(socket, sendbuff, strlen(sendbuff)); 
148                 if (nwrite < 0) {      /* on error stop */
149                     printf("Errore in scrittura: %s", strerror(errno));
150                     return;
151                 }
152             }
153         }
154         if (FD_ISSET(socket, &fset)) { /* if ready on socket */ 
155             nread = read(socket, recvbuff, strlen(sendbuff)); /* do read */
156             if (nread < 0) {  /* error condition, stop client */
157                 printf("Errore in lettura: %s\n", strerror(errno));
158                 return;
159             }
160             if (nread == 0) { /* server closed connection, stop */
161                 if (eof == 1) {
162                     return;
163                 } else {
164                     printf("EOF prematuro sul socket\n");
165                     return;
166                 }
167             }
168             recvbuff[nread] = 0;   /* else read is ok, write on stdout */
169             if (fputs(recvbuff, stdout) == EOF) {
170                 perror("Errore in scrittura su terminale");
171                 return;
172             }
173         }
174     }
175 }