Inserita una nota esplicativa sulla struttura dirent, su segnalazione di
[gapil.git] / tcpsock.tex
1 %% tcpsock.tex
2 %%
3 %% Copyright (C) 2000-2003 Simone Piccardi.  Permission is granted to
4 %% copy, distribute and/or modify this document under the terms of the GNU Free
5 %% Documentation License, Version 1.1 or any later version published by the
6 %% Free Software Foundation; with the Invariant Sections being "Prefazione",
7 %% with no Front-Cover Texts, and with no Back-Cover Texts.  A copy of the
8 %% license is included in the section entitled "GNU Free Documentation
9 %% License".
10 %%
11 \chapter{I socket TCP}
12 \label{cha:TCP_socket}
13
14 In questo capitolo tratteremo le basi dei socket TCP, iniziando con una
15 descrizione delle principali caratteristiche del funzionamento di una
16 connessione TCP; vedremo poi le varie funzioni che servono alla creazione di
17 una connessione fra client e server, fornendo alcuni esempi elementari, e
18 finiremo prendendo in esame l'uso dell'I/O multiplexing.
19
20
21 \section{Il funzionamento di una connessione TCP}
22 \label{sec:TCP_connession}
23
24 Prima di entrare nei dettagli delle singole funzioni usate nelle applicazioni
25 che utilizzano i socket TCP, è fondamentale spiegare alcune delle basi del
26 funzionamento del protocollo, poiché questa conoscenza è essenziale per
27 comprendere il comportamento di dette funzioni per questo tipo di socket, ed
28 il relativo modello di programmazione.
29
30 Si ricordi che il protocollo TCP serve a creare degli \textit{stream socket},
31 cioè una forma di canale di comunicazione che stabilisce una connessione
32 stabile fra due stazioni, in modo che queste possano scambiarsi dei dati. In
33 questa sezione ci concentreremo sulle modalità con le quali il protocollo dà
34 inizio e conclude una connessione e faremo inoltre un breve accenno al
35 significato di alcuni dei vari \textsl{stati} ad essa associati.
36
37 \subsection{La creazione della connessione: il \textit{three way handshake}}
38 \label{sec:TCP_conn_cre}
39
40 Il processo che porta a creare una connessione TCP è chiamato \textit{three
41   way handshake}; la successione tipica degli eventi (e dei
42 \textsl{segmenti}\footnote{Si ricordi che il segmento è l'unità elementare di
43   dati trasmessa dal protocollo TCP al livello successivo; tutti i segmenti
44   hanno un header che contiene le informazioni che servono allo \textit{stack
45     TCP} (così viene di solito chiamata la parte del kernel che implementa il
46   protocollo) per realizzare la comunicazione, fra questi dati ci sono una
47   serie di flag usati per gestire la connessione, come SYN, ACK, URG, FIN,
48   alcuni di essi, come SYN (che sta per \textit{syncronize}) corrispondono a
49   funzioni particolari del protocollo e danno il nome al segmento, (per
50   maggiori dettagli vedere \secref{sec:tcp_protocol}).}  di dati che vengono
51 scambiati) che porta alla creazione di una connessione è la seguente:
52  
53 \begin{enumerate}
54 \item Il server deve essere preparato per accettare le connessioni in arrivo;
55   il procedimento si chiama \textsl{apertura passiva} del socket (in inglese
56   \textit{passive open}). Questo viene fatto chiamando la sequenza di funzioni
57   \func{socket}, \func{bind} e \func{listen}. Completata l'apertura passiva il
58   server chiama la funzione \func{accept} e il processo si blocca in attesa di
59   connessioni.
60   
61 \item Il client richiede l'inizio della connessione usando la funzione
62   \func{connect}, attraverso un procedimento che viene chiamato
63   \textsl{apertura attiva}, dall'inglese \textit{active open}. La chiamata di
64   \func{connect} blocca il processo e causa l'invio da parte del client di un
65   segmento SYN, in sostanza viene inviato al server un pacchetto IP che
66   contiene solo gli header IP e TCP (con il numero di sequenza iniziale e il
67   flag SYN) e le opzioni di TCP.
68   
69 \item il server deve dare ricevuto (l'\textit{acknowledge}) del SYN del
70   client, inoltre anche il server deve inviare il suo SYN al client (e
71   trasmettere il suo numero di sequenza iniziale) questo viene fatto
72   ritrasmettendo un singolo segmento in cui sono impostati entrambi i flag SYN
73   e ACK.
74   
75 \item una volta che il client ha ricevuto l'acknowledge dal server la funzione
76   \func{connect} ritorna, l'ultimo passo è dare dare il ricevuto del SYN del
77   server inviando un ACK. Alla ricezione di quest'ultimo la funzione
78   \func{accept} del server ritorna e la connessione è stabilita.
79 \end{enumerate} 
80
81 Il procedimento viene chiamato \textit{three way handshake} dato che per
82 realizzarlo devono essere scambiati tre segmenti.  In \figref{fig:TCP_TWH}
83 si è rappresentata graficamente la sequenza di scambio dei segmenti che
84 stabilisce la connessione.
85
86 % Una analogia citata da R. Stevens per la connessione TCP è quella con il
87 % sistema del telefono. La funzione \texttt{socket} può essere considerata
88 % l'equivalente di avere un telefono. La funzione \texttt{bind} è analoga al
89 % dire alle altre persone qual'è il proprio numero di telefono perché possano
90 % chiamare. La funzione \texttt{listen} è accendere il campanello del telefono
91 % per sentire le chiamate in arrivo.  La funzione \texttt{connect} richiede di
92 % conoscere il numero di chi si vuole chiamare. La funzione \texttt{accept} è
93 % quando si risponde al telefono.
94
95 \begin{figure}[htb]
96   \centering
97   \includegraphics[width=10cm]{img/three_way_handshake}  
98   \caption{Il \textit{three way handshake} del TCP.}
99   \label{fig:TCP_TWH}
100 \end{figure}
101
102 Si è accennato in precedenza ai \textsl{numeri di sequenza} (che sono anche
103 riportati in \figref{fig:TCP_TWH}): per gestire una connessione affidabile
104 infatti il protocollo TCP prevede nell'header la presenza di un numero a 32
105 bit (chiamato appunto \textit{sequence number}) che identifica a quale byte
106 nella sequenza del flusso corrisponde il primo byte della sezione dati
107 contenuta nel segmento.
108
109 Il numero di sequenza di ciascun segmento viene calcolato a partire da un
110 \textsl{numero di sequenza iniziale} generato in maniera casuale del kernel
111 all'inizio della connessione e trasmesso con il SYN; l'acknowledgement di
112 ciascun segmento viene effettuato dall'altro capo della connessione impostando
113 il flag ACK e restituendo nell'apposito campo dell'header un
114 \textit{acknowledge number}) pari al numero di sequenza che il ricevente si
115 aspetta di ricevere con il pacchetto successivo; dato che il primo pacchetto
116 SYN consuma un byte, nel \textit{three way handshake} il numero di acknowledge
117 è sempre pari al numero di sequenza iniziale incrementato di uno; lo stesso
118 varrà anche (vedi \figref{fig:TCP_close}) per l'acknowledgement di un FIN.
119
120 \subsection{Le opzioni TCP.}
121 \label{sec:TCP_TCP_opt}
122
123 Ciascun segmento SYN contiene in genere delle opzioni per il protocollo TCP
124 (le cosiddette \textit{TCP options}, che vengono inserite fra l'header e i
125 dati) che servono a comunicare all'altro capo una serie di parametri utili a
126 regolare la connessione. Normalmente vengono usate le seguenti opzioni:
127
128 \begin{itemize}
129 \item \textit{MSS option}, dove MMS sta per \textit{maximum segment size}, con
130   questa opzione ciascun capo della connessione annuncia all'altro il massimo
131   ammontare di dati che vorrebbe accettare per ciascun segmento nella
132   connessione corrente. È possibile leggere e scrivere questo valore
133   attraverso l'opzione del socket \const{TCP\_MAXSEG}.
134   
135 \item \textit{window scale option}, %come spiegato in \secref{sec:tcp_protocol}
136   il protocollo TCP implementa il controllo di flusso attraverso una
137   \textsl{finestra annunciata} (\textit{advertized window}) con la quale
138   ciascun capo della comunicazione dichiara quanto spazio disponibile ha in
139   memoria per i dati. Questo è un numero a 16 bit dell'header, che così può
140   indicare un massimo di 65535 byte;\footnote{ Linux usa come massimo 32767
141     per evitare problemi con alcune implementazioni che usano l'aritmetica con
142     segno per implementare lo stack TCP.} ma alcuni tipi di connessione come
143   quelle ad alta velocità (sopra i 45Mbit/sec) e quelle che hanno grandi
144   ritardi nel cammino dei pacchetti (come i satelliti) richiedono una finestra
145   più grande per poter ottenere il massimo dalla trasmissione, per questo
146   esiste questa opzione che indica un fattore di scala da applicare al valore
147   della finestra annunciata\footnote{essendo una nuova opzione per garantire
148     la compatibilità con delle vecchie implementazioni del protocollo la
149     procedura che la attiva prevede come negoziazione che l'altro capo della
150     connessione riconosca esplicitamente l'opzione inserendola anche lui nel
151     suo SYN di risposta dell'apertura della connessione.} per la connessione
152   corrente (espresso come numero di bit cui spostare a sinistra il valore
153   della finestra annunciata inserito nel pacchetto).
154
155 \item \textit{timestamp option}, è anche questa una nuova opzione necessaria
156   per le connessioni ad alta velocità per evitare possibili corruzioni di dati
157   dovute a pacchetti perduti che riappaiono; anche questa viene negoziata come
158   la precedente.
159
160 \end{itemize}
161
162 La MSS è generalmente supportata da quasi tutte le implementazioni del
163 protocollo, le ultime due opzioni (trattate
164 nell'\href{http://www.ietf.org/rfc/rfc1323.txt}{RFC~1323}) sono meno comuni;
165 vengono anche dette \textit{long fat pipe options} dato che questo è il nome
166 che viene dato alle connessioni caratterizzate da alta velocità o da ritardi
167 elevati. In ogni caso Linux supporta pienamente entrambe le opzioni.
168
169 \subsection{La terminazione della connessione}
170 \label{sec:TCP_conn_term}
171
172 Mentre per la creazione di una connessione occorre un interscambio di tre
173 segmenti, la procedura di chiusura ne richiede normalmente quattro. In questo
174 caso la successione degli eventi è la seguente:
175
176 \begin{enumerate}
177 \item Un processo ad uno dei due capi chiama la funzione \func{close}, dando
178   l'avvio a quella che viene chiamata \textsl{chiusura attiva} (o
179   \textit{active close}). Questo comporta l'emissione di un segmento FIN, che
180   serve ad indicare che si è finito con l'invio dei dati sulla connessione.
181   
182 \item L'altro capo della connessione riceve il FIN e dovrà eseguire la
183   \textsl{chiusura passiva} (o \textit{passive close}). Al FIN, come ad ogni
184   altro pacchetto, viene risposto con un ACK, inoltre il ricevimento del FIN
185   viene segnalato al processo che ha aperto il socket (dopo che ogni altro
186   eventuale dato rimasto in coda è stato ricevuto) come un end-of-file sulla
187   lettura: questo perché il ricevimento di un FIN significa che non si
188   riceveranno altri dati sulla connessione.
189   
190 \item Una volta rilevata l'end-of-file anche il secondo processo chiamerà la
191   funzione \func{close} sul proprio socket, causando l'emissione di un altro
192   segmento FIN.
193
194 \item L'altro capo della connessione riceverà il FIN conclusivo e risponderà
195   con un ACK.
196 \end{enumerate}
197
198 Dato che in questo caso sono richiesti un FIN ed un ACK per ciascuna direzione
199 normalmente i segmenti scambiati sono quattro.  Questo non è vero sempre
200 giacché in alcune situazioni il FIN del passo 1) è inviato insieme a dei dati.
201 Inoltre è possibile che i segmenti inviati nei passi 2 e 3 dal capo che
202 effettua la chiusura passiva, siano accorpati in un singolo segmento. In
203 \figref{fig:TCP_close} si è rappresentato graficamente lo sequenza di
204 scambio dei segmenti che conclude la connessione.
205
206 \begin{figure}[htb]
207   \centering  
208   \includegraphics[width=10cm]{img/tcp_close}  
209   \caption{La chiusura di una connessione TCP.}
210   \label{fig:TCP_close}
211 \end{figure}
212
213 Come per il SYN anche il FIN occupa un byte nel numero di sequenza, per cui
214 l'ACK riporterà un \textit{acknowledge number} incrementato di uno. 
215
216 Si noti che, nella sequenza di chiusura, fra i passi 2 e 3, è in teoria
217 possibile che si mantenga un flusso di dati dal capo della connessione che
218 deve ancora eseguire la chiusura passiva a quello che sta eseguendo la
219 chiusura attiva.  Nella sequenza indicata i dati verrebbero persi, dato che si
220 è chiuso il socket dal lato che esegue la chiusura attiva; esistono tuttavia
221 situazioni in cui si vuole poter sfruttare questa possibilità, usando una
222 procedura che è chiamata \textit{half-close}; torneremo su questo aspetto e su
223 come utilizzarlo in \secref{sec:TCP_shutdown}, quando parleremo della funzione
224 \func{shutdown}.
225
226 La emissione del FIN avviene quando il socket viene chiuso, questo però non
227 avviene solo per la chiamata esplicita della funzione \func{close}, ma anche
228 alla terminazione di un processo, quando tutti i file vengono chiusi.  Questo
229 comporta ad esempio che se un processo viene terminato da un segnale tutte le
230 connessioni aperte verranno chiuse.
231
232 Infine occorre sottolineare che, benché nella figura (e nell'esempio che
233 vedremo più avanti in \secref{sec:TCP_echo}) sia stato il client ad eseguire
234 la chiusura attiva, nella realtà questa può essere eseguita da uno qualunque
235 dei due capi della comunicazione (come nell'esempio di
236 \figref{fig:TCP_daytime_iter_server_code}), e anche se il caso più comune
237 resta quello del client, ci sono alcuni servizi, il principale dei quali è
238 l'HTTP, per i quali è il server ad effettuare la chiusura attiva.
239
240
241 \subsection{Un esempio di connessione}
242 \label{sec:TCP_conn_dia}
243
244 Come abbiamo visto le operazioni del TCP nella creazione e conclusione di una
245 connessione sono piuttosto complesse, ed abbiamo esaminato soltanto quelle
246 relative ad un andamento normale.  In \secref{sec:TCP_states} vedremo con
247 maggiori dettagli che una connessione può assumere vari stati, che ne
248 caratterizzano il funzionamento, e che sono quelli che vengono riportati dal
249 comando \cmd{netstat}, per ciascun socket TCP aperto, nel campo
250 \textit{State}.
251
252 Non possiamo affrontare qui una descrizione completa del funzionamento del
253 protocollo; un approfondimento sugli aspetti principali si trova in
254 \secref{sec:tcp_protocol}, ma per una trattazione completa il miglior
255 riferimento resta \cite{TCPIll1}. Qui ci limiteremo a descrivere brevemente un
256 semplice esempio di connessione e le transizioni che avvengono nei due casi
257 appena citati (creazione e terminazione della connessione).
258
259 In assenza di connessione lo stato del TCP è \texttt{CLOSED}; quando una
260 applicazione esegue una apertura attiva il TCP emette un SYN e lo stato
261 diventa \texttt{SYN\_SENT}; quando il TCP riceve la risposta del SYN$+$ACK
262 emette un ACK e passa allo stato \texttt{ESTABLISHED}; questo è lo stato
263 finale in cui avviene la gran parte del trasferimento dei dati.
264
265 Dal lato server in genere invece il passaggio che si opera con l'apertura
266 passiva è quello di portare il socket dallo stato \texttt{CLOSED} allo
267 stato \texttt{LISTEN} in cui vengono accettate le connessioni.
268
269 Dallo stato \texttt{ESTABLISHED} si può uscire in due modi; se un'applicazione
270 chiama la funzione \texttt{close} prima di aver ricevuto un
271 \textit{end-of-file} (chiusura attiva) la transizione è verso lo stato
272 \texttt{FIN\_WAIT\_1}; se invece l'applicazione riceve un FIN nello stato
273 \texttt{ESTABLISHED} (chiusura passiva) la transizione è verso lo stato
274 \texttt{CLOSE\_WAIT}.
275
276 In \figref{fig:TCP_conn_example} è riportato lo schema dello scambio dei
277 pacchetti che avviene per una un esempio di connessione, insieme ai vari stati
278 che il protocollo viene ad assumere per i due lati, server e client.
279
280 \begin{figure}[htb]
281   \centering
282   \includegraphics[width=9cm]{img/tcp_connection}  
283   \caption{Schema dello scambio di pacchetti per un esempio di connessione.}
284   \label{fig:TCP_conn_example}
285 \end{figure}
286
287 La connessione viene iniziata dal client che annuncia un MSS di 1460, un
288 valore tipico con Linux per IPv4 su Ethernet, il server risponde con lo stesso
289 valore (ma potrebbe essere anche un valore diverso).
290
291 Una volta che la connessione è stabilita il client scrive al server una
292 richiesta (che assumiamo stare in un singolo segmento, cioè essere minore dei
293 1460 byte annunciati dal server), quest'ultimo riceve la richiesta e
294 restituisce una risposta (che di nuovo supponiamo stare in un singolo
295 segmento). Si noti che l'acknowledge della richiesta è mandato insieme alla
296 risposta: questo viene chiamato \textit{piggybacking} ed avviene tutte le
297 volte che che il server è sufficientemente veloce a costruire la risposta; in
298 caso contrario si avrebbe prima l'emissione di un ACK e poi l'invio della
299 risposta.
300
301 Infine si ha lo scambio dei quattro segmenti che terminano la connessione
302 secondo quanto visto in \secref{sec:TCP_conn_term}; si noti che il capo della
303 connessione che esegue la chiusura attiva entra nello stato
304 \texttt{TIME\_WAIT}, sul cui significato torneremo fra poco.
305
306 È da notare come per effettuare uno scambio di due pacchetti (uno di richiesta
307 e uno di risposta) il TCP necessiti di ulteriori otto segmenti, se invece si
308 fosse usato UDP sarebbero stati sufficienti due soli pacchetti. Questo è il
309 costo che occorre pagare per avere l'affidabilità garantita dal TCP, se si
310 fosse usato UDP si sarebbe dovuto trasferire la gestione di tutta una serie di
311 dettagli (come la verifica della ricezione dei pacchetti) dal livello del
312 trasporto all'interno dell'applicazione.
313
314 Quello che è bene sempre tenere presente è allora quali sono le esigenze che
315 si hanno in una applicazione di rete, perché non è detto che TCP sia la
316 miglior scelta in tutti i casi (ad esempio se si devono solo scambiare dati
317 già organizzati in piccoli pacchetti l'overhead aggiunto può essere eccessivo)
318 per questo esistono applicazioni che usano UDP e lo fanno perché nel caso
319 specifico le sue caratteristiche di velocità e compattezza nello scambio dei
320 dati rispondono meglio alle esigenze che devono essere affrontate.
321
322 \subsection{Lo stato \texttt{TIME\_WAIT}}
323 \label{sec:TCP_time_wait}
324
325 Come riportato da Stevens in \cite{UNP1} lo stato \texttt{TIME\_WAIT} è
326 probabilmente uno degli aspetti meno compresi del protocollo TCP, è infatti
327 comune trovare domande su come sia possibile evitare che un'applicazione resti
328 in questo stato lasciando attiva una connessione ormai conclusa; la risposta è
329 che non deve essere fatto, ed il motivo cercheremo di spiegarlo adesso.
330
331 Come si è visto nell'esempio precedente (vedi \figref{fig:TCP_conn_example})
332 \texttt{TIME\_WAIT} è lo stato finale in cui il capo di una connessione che
333 esegue la chiusura attiva resta prima di passare alla chiusura definitiva
334 della connessione. Il tempo in cui l'applicazione resta in questo stato deve
335 essere due volte la MSL (\textit{Maximum Segment Lifetime}).
336
337 La MSL è la stima del massimo periodo di tempo che un pacchetto IP può vivere
338 sulla rete; questo tempo è limitato perché ogni pacchetto IP può essere
339 ritrasmesso dai router un numero massimo di volte (detto \textit{hop limit}).
340 Il numero di ritrasmissioni consentito è indicato dal campo TTL dell'header di
341 IP (per maggiori dettagli vedi \secref{sec:ip_protocol}), e viene decrementato
342 ad ogni passaggio da un router; quando si annulla il pacchetto viene scartato.
343 Siccome il numero è ad 8 bit il numero massimo di ``\textsl{salti}'' è di 255,
344 pertanto anche se il TTL (da \textit{time to live}) non è propriamente un
345 limite sul tempo di vita, si stima che un pacchetto IP non possa restare nella
346 rete per più di MSL secondi.
347
348 Ogni implementazione del TCP deve scegliere un valore per la MSL
349 (l'\href{http://www.ietf.org/rfc/rfc1122.txt}{RFC~1122} raccomanda 2 minuti,
350 Linux usa 30 secondi), questo comporta una durata dello stato
351 \texttt{TIME\_WAIT} che a seconda delle implementazioni può variare fra 1 a 4
352 minuti.  Lo stato \texttt{TIME\_WAIT} viene utilizzato dal protocollo per due
353 motivi principali:
354 \begin{enumerate}
355 \item implementare in maniera affidabile la terminazione della connessione
356   in entrambe le direzioni.
357 \item consentire l'eliminazione dei segmenti duplicati dalla rete. 
358 \end{enumerate}
359
360 Il punto è che entrambe le ragioni sono importanti, anche se spesso si fa
361 riferimento solo alla prima; ma è solo se si tiene conto della seconda che si
362 capisce il perché della scelta di un tempo pari al doppio della MSL come
363 durata di questo stato.
364
365 Il primo dei due motivi precedenti si può capire tornando a
366 \figref{fig:TCP_conn_example}: assumendo che l'ultimo ACK della sequenza
367 (quello del capo che ha eseguito la chiusura attiva) venga perso, chi esegue
368 la chiusura passiva non ricevendo risposta rimanderà un ulteriore FIN, per
369 questo motivo chi esegue la chiusura attiva deve mantenere lo stato della
370 connessione per essere in grado di reinviare l'ACK e chiuderla correttamente.
371 Se non fosse così la risposta sarebbe un RST (un altro tipo si segmento) che
372 verrebbe interpretato come un errore.
373
374 Se il TCP deve poter chiudere in maniera pulita entrambe le direzioni della
375 connessione allora deve essere in grado di affrontare la perdita di uno
376 qualunque dei quattro segmenti che costituiscono la chiusura. Per questo
377 motivo un socket deve rimanere attivo nello stato \texttt{TIME\_WAIT} anche
378 dopo l'invio dell'ultimo ACK, per potere essere in grado di gestirne
379 l'eventuale ritrasmissione, in caso esso venga perduto.
380
381 Il secondo motivo è più complesso da capire, e necessita di una spiegazione
382 degli scenari in cui può accadere che i pacchetti TCP si possano perdere nella
383 rete o restare intrappolati, per poi riemergere in un secondo tempo.
384
385 Il caso più comune in cui questo avviene è quello di anomalie
386 nell'instradamento; può accadere cioè che un router smetta di funzionare o che
387 una connessione fra due router si interrompa. In questo caso i protocolli di
388 instradamento dei pacchetti possono impiegare diverso tempo (anche dell'ordine
389 dei minuti) prima di trovare e stabilire un percorso alternativo per i
390 pacchetti. Nel frattempo possono accadere casi in cui un router manda i
391 pacchetti verso un'altro e quest'ultimo li rispedisce indietro, o li manda ad
392 un terzo router che li rispedisce al primo, si creano cioè dei circoli (i
393 cosiddetti \textit{routing loop}) in cui restano intrappolati i pacchetti.
394
395 Se uno di questi pacchetti intrappolati è un segmento TCP, chi l'ha inviato,
396 non ricevendo un ACK in risposta, provvederà alla ritrasmissione e se nel
397 frattempo sarà stata stabilita una strada alternativa il pacchetto ritrasmesso
398 giungerà a destinazione.
399
400 Ma se dopo un po' di tempo (che non supera il limite dell'MSL, dato che
401 altrimenti verrebbe ecceduto il TTL) l'anomalia viene a cessare, il circolo di
402 instradamento viene spezzato i pacchetti intrappolati potranno essere inviati
403 alla destinazione finale, con la conseguenza di avere dei pacchetti duplicati;
404 questo è un caso che il TCP deve essere in grado di gestire.
405
406 Allora per capire la seconda ragione per l'esistenza dello stato
407 \texttt{TIME\_WAIT} si consideri il caso seguente: si supponga di avere una
408 connessione fra l'IP \texttt{195.110.112.236} porta 1550 e l'IP
409 \texttt{192.84.145.100} porta 22 (affronteremo il significato delle porte
410 nella prossima sezione), che questa venga chiusa e che poco dopo si
411 ristabilisca la stessa connessione fra gli stessi IP sulle stesse porte
412 (quella che viene detta, essendo gli stessi porte e numeri IP, una nuova
413 \textsl{incarnazione} della connessione precedente); in questo caso ci si
414 potrebbe trovare con dei pacchetti duplicati relativi alla precedente
415 connessione che riappaiono nella nuova.
416
417 Ma fintanto che il socket non è chiuso una nuova incarnazione non può essere
418 creata: per questo un socket TCP resta sempre nello stato \texttt{TIME\_WAIT}
419 per un periodo di 2MSL, in modo da attendere MSL secondi per essere sicuri che
420 tutti i pacchetti duplicati in arrivo siano stati ricevuti (e scartati) o che
421 nel frattempo siano stati eliminati dalla rete, e altri MSL secondi per essere
422 sicuri che lo stesso avvenga per le risposte nella direzione opposta.
423
424 In questo modo, prima che venga creata una nuova connessione, il protocollo
425 TCP si assicura che tutti gli eventuali segmenti residui di una precedente
426 connessione, che potrebbero causare disturbi, siano stati eliminati dalla
427 rete.
428
429
430 \subsection{I numeri di porta}
431 \label{sec:TCP_port_num}
432
433 In un ambiente multitasking in un dato momento più processi devono poter usare
434 sia UDP che TCP, e ci devono poter essere più connessioni in contemporanea.
435 Per poter tenere distinte le diverse connessioni entrambi i protocolli usano i
436 \textsl{numeri di porta}, che fanno parte, come si può vedere in
437 \secref{sec:sock_sa_ipv4} e \secref{sec:sock_sa_ipv6} pure delle strutture
438 degli indirizzi del socket.
439
440 Quando un client contatta un server deve poter identificare con quale dei vari
441 possibili server attivi intende parlare. Sia TCP che UDP definiscono un gruppo
442 di \textsl{porte conosciute} (le cosiddette \textit{well-known port}) che
443 identificano una serie di servizi noti (ad esempio la porta 22 identifica il
444 servizio SSH) effettuati da appositi server che rispondono alle connessioni
445 verso tali porte.
446
447 D'altra parte un client non ha necessità di usare un numero di porta
448 specifico, per cui in genere vengono usate le cosiddette \textsl{porte
449   effimere} (o \textit{ephemeral ports}) cioè porte a cui non è assegnato
450 nessun servizio noto e che vengono assegnate automaticamente dal kernel alla
451 creazione della connessione. Queste sono dette effimere in quanto vengono
452 usate solo per la durata della connessione, e l'unico requisito che deve
453 essere soddisfatto è che ognuna di esse sia assegnata in maniera univoca.
454
455 La lista delle porte conosciute è definita
456 dall'\href{http://www.ietf.org/rfc/rfc1700.txt}{RFC~1700} che contiene
457 l'elenco delle porte assegnate dalla IANA (la \textit{Internet Assigned Number
458   Authority}) ma l'elenco viene costantemente aggiornato e pubblicato su
459 internet (una versione aggiornata si può trovare all'indirizzo
460 \texttt{ftp://ftp.isi.edu/in-notes/iana/assignements/port-numbers}); inoltre
461 in un sistema unix-like un analogo elenco viene mantenuto nel file
462 \file{/etc/services}, con la corrispondenza fra i vari numeri di porta ed il
463 nome simbolico del servizio.  I numeri sono divisi in tre intervalli:
464
465 \begin{enumerate}
466 \item \textsl{le porte conosciute}. I numeri da 0 a 1023. Queste sono
467   controllate e assegnate dalla IANA. Se è possibile la stessa porta è
468   assegnata allo stesso servizio sia su UDP che su TCP (ad esempio la porta 22
469   è assegnata a SSH su entrambi i protocolli, anche se viene usata solo dal
470   TCP).
471   
472 \item \textsl{le porte registrate}. I numeri da 1024 a 49151. Queste porte non
473   sono controllate dalla IANA, che però registra ed elenca chi usa queste
474   porte come servizio agli utenti. Come per le precedenti si assegna una porta
475   ad un servizio sia per TCP che UDP anche se poi il servizio è implementato
476   solo su TCP. Ad esempio X Window usa le porte TCP e UDP dal 6000 al 6063
477   anche se il protocollo è implementato solo tramite TCP.
478   
479 \item \textsl{le porte private} o \textsl{dinamiche}. I numeri da 49152 a
480   65535. La IANA non dice nulla riguardo a queste porte che pertanto
481   sono i candidati naturali ad essere usate come porte effimere.
482 \end{enumerate}
483
484 In realtà rispetto a quanto indicato
485 nell'\href{http://www.ietf.org/rfc/rfc1700.txt}{RFC~1700} i vari sistemi hanno
486 fatto scelte diverse per le porte effimere, in particolare in
487 \figref{fig:TCP_port_alloc} sono riportate quelle di BSD e Linux.  Nel caso di
488 Linux poi la scelta fra i due intervalli possibili viene fatta dinamicamente a
489 seconda della memoria a disposizione del kernel per gestire le relative
490 tabelle.
491
492 \begin{figure}[!htb]
493   \centering
494   \includegraphics[width=15cm]{img/port_alloc}  
495   \caption{Allocazione dei numeri di porta.}
496   \label{fig:TCP_port_alloc}
497 \end{figure}
498
499 I sistemi Unix hanno inoltre il concetto di \textsl{porte riservate} (che
500 corrispondono alle porte con numero minore di 1024 e coincidono quindi con le
501 porte conosciute). La loro caratteristica è che possono essere assegnate a un
502 socket solo da un processo con i privilegi di amministratore, per far si che
503 solo l'amministratore possa allocare queste porte per far partire i relativi
504 servizi.
505
506 Si tenga conto poi che ci sono alcuni client, in particolare \cmd{rsh} e
507 \cmd{rlogin}, che richiedono una connessione su una porta riservata anche dal
508 lato client come parte dell'autenticazione, contando appunto sul fatto che
509 solo l'amministratore può usare queste porte. Data l'assoluta inconsistenza in
510 termini di sicurezza di un tale metodo, al giorno d'oggi esso è in completo
511 disuso.
512
513 Data una connessione TCP si suole chiamare \textit{socket pair}\footnote{da
514   non confondere con la coppia di socket della omonima funzione
515   \func{socketpair} che fanno riferimento ad una coppia di socket sulla stessa
516   macchina, non ai capi di una connessione TCP.} la combinazione dei quattro
517 numeri che definiscono i due capi della connessione e cioè l'indirizzo IP
518 locale e la porta TCP locale, e l'indirizzo IP remoto e la porta TCP remota.
519 Questa combinazione, che scriveremo usando una notazione del tipo
520 (\texttt{195.110.112.152:22}, \texttt{192.84.146.100:20100}), identifica
521 univocamente una connessione su internet.  Questo concetto viene di solito
522 esteso anche a UDP, benché in questo caso non abbia senso parlare di
523 connessione. L'utilizzo del programma \cmd{netstat} permette di visualizzare
524 queste informazioni nei campi \textit{Local Address} e \textit{Foreing
525   Address}.
526
527
528 \subsection{Le porte ed il modello client/server}
529 \label{sec:TCP_port_cliserv}
530
531 Per capire meglio l'uso delle porte e come vengono utilizzate quando si ha a
532 che fare con un'applicazione client/server (come quelle che descriveremo in
533 \secref{sec:TCP_daytime_application} e \secref{sec:TCP_echo_application})
534 esamineremo cosa accade con le connessioni nel caso di un server TCP che deve
535 gestire connessioni multiple.
536
537 Se eseguiamo un \cmd{netstat} su una macchina di prova (il cui indirizzo sia
538 \texttt{195.110.112.152}) potremo avere un risultato del tipo:
539 \begin{verbatim}
540 Active Internet connections (servers and established)
541 Proto Recv-Q Send-Q Local Address           Foreign Address         State      
542 tcp        0      0 0.0.0.0:22              0.0.0.0:*               LISTEN
543 tcp        0      0 0.0.0.0:25              0.0.0.0:*               LISTEN
544 tcp        0      0 127.0.0.1:53            0.0.0.0:*               LISTEN
545 \end{verbatim}
546 essendo presenti e attivi un server SSH, un server di posta e un DNS per il
547 caching locale.
548
549 Questo ci mostra ad esempio che il server SSH ha compiuto un'apertura passiva,
550 mettendosi in ascolto sulla porta 22 riservata a questo servizio, e che si è
551 posto in ascolto per connessioni provenienti da uno qualunque degli indirizzi
552 associati alle interfacce locali. La notazione \texttt{0.0.0.0} usata da
553 \cmd{netstat} è equivalente all'asterisco utilizzato per il numero di porta,
554 indica il valore generico, e corrisponde al valore \const{INADDR\_ANY}
555 definito in \file{arpa/inet.h} (vedi \ref{tab:TCP_ipv4_addr}).
556
557 Inoltre si noti come la porta e l'indirizzo di ogni eventuale connessione
558 esterna non sono specificati; in questo caso la \textit{socket pair} associata
559 al socket potrebbe essere indicata come (\texttt{*:22}, \texttt{*:*}), usando
560 anche per gli indirizzi l'asterisco come carattere che indica il valore
561 generico.
562
563 Dato che in genere una macchina è associata ad un solo indirizzo IP, ci si può
564 chiedere che senso abbia l'utilizzo dell'indirizzo generico per specificare
565 l'indirizzo locale; ma a parte il caso di macchine che hanno più di un
566 indirizzo IP (il cosiddetto \textit{multihoming}) esiste sempre anche
567 l'indirizzo di loopback, per cui con l'uso dell'indirizzo generico si possono
568 accettare connessioni indirizzate verso uno qualunque degli indirizzi IP
569 presenti. Ma, come si può vedere nell'esempio con il DNS che è in ascolto
570 sulla porta 53, è possibile anche restringere l'accesso ad uno specifico
571 indirizzo, cosa che nel caso è fatta accettando solo connessioni che arrivino
572 sull'interfaccia di loopback.
573
574 Una volta che ci si vorrà collegare a questa macchina da un'altra, per esempio
575 quella con l'indirizzo \texttt{192.84.146.100}, si dovrà lanciare su
576 quest'ultima un client \cmd{ssh} per creare una connessione, e il kernel gli
577 assocerà una porta effimera (ad esempio la 21100), per cui la connessione sarà
578 espressa dalla socket pair (\texttt{192.84.146.100:21100},
579 \texttt{195.110.112.152:22}).
580
581 Alla ricezione della richiesta dal client il server creerà un processo figlio
582 per gestire la connessione, se a questo punto eseguiamo nuovamente il
583 programma \cmd{netstat} otteniamo come risultato:
584 \begin{verbatim}
585 Active Internet connections (servers and established)
586 Proto Recv-Q Send-Q Local Address           Foreign Address         State      
587 tcp        0      0 0.0.0.0:22              0.0.0.0:*               LISTEN
588 tcp        0      0 0.0.0.0:25              0.0.0.0:*               LISTEN
589 tcp        0      0 127.0.0.1:53            0.0.0.0:*               LISTEN
590 tcp        0      0 195.110.112.152:22      192.84.146.100:21100    ESTABLISHED
591 \end{verbatim}
592
593 Come si può notare il server è ancora in ascolto sulla porta 22, però adesso
594 c'è un nuovo socket (con lo stato \texttt{ESTABLISHED}) che utilizza anch'esso
595 la porta 22, ed ha specificato l'indirizzo locale, questo è il socket con cui
596 il processo figlio gestisce la connessione mentre il padre resta in ascolto
597 sul socket originale.
598
599 Se a questo punto lanciamo un'altra volta il client \cmd{ssh} per una seconda
600 connessione quello che otterremo usando \cmd{netstat} sarà qualcosa del
601 genere:
602 \begin{verbatim}
603 Active Internet connections (servers and established)
604 Proto Recv-Q Send-Q Local Address           Foreign Address         State      
605 tcp        0      0 0.0.0.0:22              0.0.0.0:*               LISTEN
606 tcp        0      0 0.0.0.0:25              0.0.0.0:*               LISTEN
607 tcp        0      0 127.0.0.1:53            0.0.0.0:*               LISTEN
608 tcp        0      0 195.110.112.152:22      192.84.146.100:21100    ESTABLISHED
609 tcp        0      0 195.110.112.152:22      192.84.146.100:21101    ESTABLISHED
610 \end{verbatim}
611 cioè il client effettuerà la connessione usando un'altra porta effimera: con
612 questa sarà aperta la connessione, ed il server creerà un'altro processo
613 figlio per gestirla.
614
615 Tutto ciò mostra come il TCP, per poter gestire le connessioni con un server
616 concorrente, non può suddividere i pacchetti solo sulla base della porta di
617 destinazione, ma deve usare tutta l'informazione contenuta nella socket pair,
618 compresa la porta dell'indirizzo remoto.  E se andassimo a vedere quali sono i
619 processi\footnote{ad esempio con il comando \cmd{fuser}, o con \cmd{lsof}.} a
620 cui fanno riferimento i vari socket vedremmo che i pacchetti che arrivano
621 dalla porta remota 21100 vanno al primo figlio e quelli che arrivano alla
622 porta 21101 al secondo.
623
624
625 \section{Le funzioni di base per la gestione dei socket}
626 \label{sec:TCP_functions}
627
628 In questa sezione descriveremo in maggior dettaglio le varie funzioni che
629 vengono usate per la gestione di base dei socket TCP, non torneremo però sulla
630 funzione \func{socket}, che è già stata esaminata accuratamente nel capitolo
631 precedente in \secref{sec:sock_socket}.
632
633
634 \subsection{La funzione \func{bind}}
635 \label{sec:TCP_func_bind}
636
637 La funzione \funcd{bind} assegna un indirizzo locale ad un
638 socket.\footnote{nel nostro caso la utilizzeremo per socket TCP, ma la
639   funzione è generica e deve essere usata per qualunque tipo di socket
640   \texttt{SOCK\_STREAM} prima che questo possa accettare connessioni.} È usata
641 cioè per specificare la prima parte dalla socket pair.  Viene usata sul lato
642 server per specificare la porta (e gli eventuali indirizzi locali) su cui poi
643 ci si porrà in ascolto. Il prototipo della funzione è il seguente:
644 \begin{prototype}{sys/socket.h}
645 {int bind(int sockfd, const struct sockaddr *serv\_addr, socklen\_t addrlen)}
646   
647   Assegna un indirizzo ad un socket.
648   
649   \bodydesc{La funzione restituisce 0 in caso di successo e -1 per un errore;
650     in caso di errore la variabile \var{errno} viene impostata secondo i
651     seguenti codici di errore:
652   \begin{errlist}
653   \item[\errcode{EBADF}] il file descriptor non è valido.
654   \item[\errcode{EINVAL}] il socket ha già un indirizzo assegnato.
655   \item[\errcode{ENOTSOCK}] il file descriptor non è associato ad un socket.
656   \item[\errcode{EACCES}] si è cercato di usare una porta riservata senza
657     sufficienti privilegi.
658   \item[\errcode{EADDRNOTAVAIL}] Il tipo di indirizzo specificato non è
659     disponibile.
660   \item[\errcode{EADDRINUSE}] qualche altro socket sta già usando l'indirizzo.
661   \end{errlist}
662   ed anche \errval{EFAULT} e per i socket di tipo \const{AF\_UNIX},
663   \errval{ENOTDIR}, \errval{ENOENT}, \errval{ENOMEM}, \errval{ELOOP},
664   \errval{ENOSR} e \errval{EROFS}.}
665 \end{prototype}
666
667 Il primo argomento è un file descriptor ottenuto da una precedente chiamata a
668 \func{socket}, mentre il secondo e terzo argomento sono rispettivamente
669 l'indirizzo (locale) del socket e la dimensione della struttura che lo
670 contiene, secondo quanto già trattato in \secref{sec:sock_sockaddr}. 
671
672 Con i socket TCP la chiamata \func{bind} permette di specificare l'indirizzo,
673 la porta, entrambi o nessuno dei due. In genere i server utilizzano una porta
674 nota che assegnano all'avvio, se questo non viene fatto è il kernel a
675 scegliere una porta effimera quando vengono eseguite la funzioni
676 \func{connect} o \func{listen}, ma se questo è normale per il client non lo è
677 per il server\footnote{un'eccezione a tutto ciò sono i server che usano RPC.
678   In questo caso viene fatta assegnare dal kernel una porta effimera che poi
679   viene registrata presso il \textit{portmapper}; quest'ultimo è un altro
680   demone che deve essere contattato dai client per ottenere la porta effimera
681   su cui si trova il server.} che in genere viene identificato dalla porta su
682 cui risponde (l'elenco di queste porte, e dei relativi servizi, è in
683 \file{/etc/services}).
684
685 Con \func{bind} si può assegnare un indirizzo IP specifico ad un socket,
686 purché questo appartenga ad una interfaccia della macchina.  Per un client TCP
687 questo diventerà l'indirizzo sorgente usato per i tutti i pacchetti inviati
688 sul socket, mentre per un server TCP questo restringerà l'accesso al socket
689 solo alle connessioni che arrivano verso tale indirizzo.
690
691 Normalmente un client non specifica mai l'indirizzo di un socket, ed il kernel
692 sceglie l'indirizzo di origine quando viene effettuata la connessione, sulla
693 base dell'interfaccia usata per trasmettere i pacchetti, (che dipenderà dalle
694 regole di instradamento usate per raggiungere il server).  Se un server non
695 specifica il suo indirizzo locale il kernel userà come indirizzo di origine
696 l'indirizzo di destinazione specificato dal SYN del client.
697
698 Per specificare un indirizzo generico, con IPv4 si usa il valore
699 \const{INADDR\_ANY}, il cui valore, come accennato in
700 \secref{sec:sock_sa_ipv4}, è pari a zero; nell'esempio
701 \figref{fig:TCP_daytime_iter_server_code} si è usata un'assegnazione immediata
702 del tipo: \includecodesnip{listati/serv_addr_sin_addr.c}
703
704 Si noti che si è usato \func{htonl} per assegnare il valore
705 \const{INADDR\_ANY}, anche se, essendo questo nullo, il riordinamento è
706 inutile.  Si tenga presente comunque che tutte le costanti \val{INADDR\_}
707 (riportate in \tabref{tab:TCP_ipv4_addr}) sono definite secondo
708 l'\textit{endianess} della macchina, ed anche se esse possono essere
709 invarianti rispetto all'ordinamento dei bit, è comunque buona norma usare
710 sempre la funzione \func{htonl}.
711
712 \begin{table}[htb]
713   \centering
714   \footnotesize
715   \begin{tabular}[c]{|l|l|}
716     \hline
717     \textbf{Costante} & \textbf{Significato} \\
718     \hline
719     \hline
720     \const{INADDR\_ANY}      & Indirizzo generico (\texttt{0.0.0.0})\\
721     \const{INADDR\_BROADCAST}& Indirizzo di \textit{broadcast}.\\
722     \const{INADDR\_LOOPBACK} & Indirizzo di \textit{loopback}
723                                (\texttt{127.0.0.1}).\\ 
724     \const{INADDR\_NONE}     & Indirizzo errato.\\
725     \hline    
726   \end{tabular}
727   \caption{Costanti di definizione di alcuni indirizzi generici per IPv4.}
728   \label{tab:TCP_ipv4_addr}
729 \end{table}
730
731 L'esempio precedente funziona correttamente con IPv4 poiché che l'indirizzo è
732 rappresentabile anche con un intero a 32 bit; non si può usare lo stesso
733 metodo con IPv6, in cui l'indirizzo deve necessariamente essere specificato
734 con una struttura, perché il linguaggio C non consente l'uso di una struttura
735 costante come operando a destra in una assegnazione.
736
737 Per questo motivo nell'header \file{netinet/in.h} è definita una variabile
738 \const{in6addr\_any} (dichiarata come \direct{extern}, ed inizializzata dal
739 sistema al valore \const{IN6ADRR\_ANY\_INIT}) che permette di effettuare una
740 assegnazione del tipo: \includecodesnip{listati/serv_addr_sin6_addr.c} in
741 maniera analoga si può utilizzare la variabile \const{in6addr\_loopback} per
742 indicare l'indirizzo di \textit{loopback}, che a sua volta viene inizializzata
743 staticamente a \const{IN6ADRR\_LOOPBACK\_INIT}.
744
745
746
747 \subsection{La funzione \func{connect}}
748 \label{sec:TCP_func_connect}
749
750 La funzione \funcd{connect} è usata da un client TCP per stabilire la
751 connessione con un server TCP,\footnote{di nuovo la funzione è generica e
752   supporta vari tipi di socket, la differenza è che per socket senza
753   connessione come quelli di tipo \texttt{SOCK\_DGRAM} la sua chiamata si
754   limiterà ad impostare l'indirizzo dal quale e verso il quale saranno inviati
755   e ricevuti i pacchetti, mentre per socket di tipo \texttt{SOCK\_STREAM} o
756   \texttt{SOCK\_SEQPACKET}, essa attiverà la procedura di avvio (nel caso del
757   TCP il \textit{three-way-handsjake}) della connessione.}  il prototipo della
758 funzione è il seguente:
759 \begin{prototype}{sys/socket.h}
760   {int connect(int sockfd, const struct sockaddr *servaddr, socklen\_t
761     addrlen)}
762   
763   Stabilisce una connessione fra due socket.
764   
765   \bodydesc{La funzione restituisce zero in caso di successo e -1 per un
766     errore, nel qual caso \var{errno} assumerà i valori:
767   \begin{errlist}
768   \item[\errcode{ECONNREFUSED}] non c'è nessuno in ascolto sull'indirizzo
769     remoto.
770   \item[\errcode{ETIMEDOUT}] si è avuto timeout durante il tentativo di
771     connessione.
772   \item[\errcode{ENETUNREACH}] la rete non è raggiungibile.
773   \item[\errcode{EINPROGRESS}] il socket è non bloccante (vedi
774     \secref{sec:file_noblocking}) e la connessione non può essere conclusa
775     immediatamente.
776   \item[\errcode{EALREADY}] il socket è non bloccante (vedi
777     \secref{sec:file_noblocking}) e un tentativo precedente di connessione non
778     si è ancora concluso.
779   \item[\errcode{EAGAIN}] non ci sono più porte locali libere. 
780   \item[\errcode{EAFNOSUPPORT}] l'indirizzo non ha una famiglia di indirizzi
781     corretta nel relativo campo.
782   \item[\errcode{EACCES}, \errcode{EPERM}] si è tentato di eseguire una
783     connessione ad un indirizzo broadcast senza che il socket fosse stato
784     abilitato per il broadcast.
785   \end{errlist}
786   altri errori possibili sono: \errval{EFAULT}, \errval{EBADF},
787   \errval{ENOTSOCK}, \errval{EISCONN} e \errval{EADDRINUSE}.}
788 \end{prototype}
789
790 Il primo argomento è un file descriptor ottenuto da una precedente chiamata a
791 \func{socket}, mentre il secondo e terzo argomento sono rispettivamente
792 l'indirizzo e la dimensione della struttura che contiene l'indirizzo del
793 socket, già descritta in \secref{sec:sock_sockaddr}.
794
795 La struttura dell'indirizzo deve essere inizializzata con l'indirizzo IP e il
796 numero di porta del server a cui ci si vuole connettere, come mostrato
797 nell'esempio \secref{sec:TCP_daytime_client}, usando le funzioni illustrate in
798 \secref{sec:sock_addr_func}.
799
800 Nel caso di socket TCP la funzione \func{connect} avvia il \textit{three way
801   handshake}, e ritorna solo quando la connessione è stabilita o si è
802 verificato un errore. Le possibili cause di errore sono molteplici (ed i
803 relativi codici riportati sopra), quelle che però dipendono dalla situazione
804 della rete e non da errori o problemi nella chiamata della funzione sono le
805 seguenti:
806 \begin{enumerate}
807 \item Il client non riceve risposta al SYN: l'errore restituito è
808   \errcode{ETIMEDOUT}. Stevens riporta che BSD invia un primo SYN alla chiamata
809   di \func{connect}, un'altro dopo 6 secondi, un terzo dopo 24 secondi, se
810   dopo 75 secondi non ha ricevuto risposta viene ritornato l'errore. Linux
811   invece ripete l'emissione del SYN ad intervalli di 30 secondi per un numero
812   di volte che può essere stabilito dall'utente sia con una opportuna
813   \func{sysctl} che attraverso il filesystem \file{/proc} scrivendo il valore
814   voluto in \file{/proc/sys/net/ipv4/tcp\_syn\_retries}. Il valore predefinito
815   per la ripetizione dell'invio è di 5 volte, che comporta un timeout dopo
816   circa 180 secondi.
817 %
818 % Le informazioni su tutte le opzioni impostabili via /proc stanno in
819 % Linux/Documentation/networking/ip-sysctl.txt
820 %
821 \item Il client riceve come risposta al SYN un RST significa che non c'è
822   nessun programma in ascolto per la connessione sulla porta specificata (il
823   che vuol dire probabilmente che o si è sbagliato il numero della porta o che
824   non è stato avviato il server), questo è un errore fatale e la funzione
825   ritorna non appena il RST viene ricevuto riportando un errore
826   \errcode{ECONNREFUSED}.
827   
828   Il flag RST sta per \textit{reset} ed è un segmento inviato direttamente
829   dal TCP quando qualcosa non va. Tre condizioni che generano un RST sono:
830   quando arriva un SYN per una porta che non ha nessun server in ascolto,
831   quando il TCP abortisce una connessione in corso, quando TCP riceve un
832   segmento per una connessione che non esiste.
833   
834 \item Il SYN del client provoca l'emissione di un messaggio ICMP di
835   destinazione non raggiungibile. In questo caso dato che il messaggio può
836   essere dovuto ad una condizione transitoria si ripete l'emissione dei SYN
837   come nel caso precedente, fino al timeout, e solo allora si restituisce il
838   codice di errore dovuto al messaggio ICMP, che da luogo ad un
839   \errcode{ENETUNREACH}.
840    
841 \end{enumerate}
842
843 Se si fa riferimento al diagramma degli stati del TCP riportato in
844 \figref{fig:TCP_state_diag} la funzione \func{connect} porta un socket
845 dallo stato \texttt{CLOSED} (lo stato iniziale in cui si trova un socket
846 appena creato) prima allo stato \texttt{SYN\_SENT} e poi, al ricevimento del
847 ACK, nello stato \texttt{ESTABLISHED}. Se invece la connessione fallisce il
848 socket non è più utilizzabile e deve essere chiuso.
849
850 Si noti infine che con la funzione \func{connect} si è specificato solo
851 indirizzo e porta del server, quindi solo una metà della socket pair; essendo
852 questa funzione usata nei client l'altra metà contenente indirizzo e porta
853 locale viene lasciata all'assegnazione automatica del kernel, e non è
854 necessario effettuare una \func{bind}.
855
856
857 \subsection{La funzione \func{listen}}
858 \label{sec:TCP_func_listen}
859
860 La funzione \funcd{listen} serve ad usare un socket in modalità passiva, cioè,
861 come dice il nome, per metterlo in ascolto di eventuali
862 connessioni;\footnote{questa funzione può essere usata con socket che
863   supportino le connessioni, cioè di tipo \texttt{SOCK\_STREAM} o
864   \texttt{SOCK\_SEQPACKET}.} in sostanza l'effetto della funzione è di portare
865 il socket dallo stato \texttt{CLOSED} a quello \texttt{LISTEN}. In genere si
866 chiama la funzione in un server dopo le chiamate a \func{socket} e \func{bind}
867 e prima della chiamata ad \func{accept}. Il prototipo della funzione, come
868 definito dalla pagina di manuale, è:
869 \begin{prototype}{sys/socket.h}{int listen(int sockfd, int backlog)}
870   Pone un socket in attesa di una connessione.
871   
872   \bodydesc{La funzione restituisce 0 in caso di successo e -1 in caso di
873     errore. I codici di errore restituiti in \var{errno} sono i seguenti:
874   \begin{errlist}
875   \item[\errcode{EBADF}] l'argomento \param{sockfd} non è un file descriptor
876     valido.
877   \item[\errcode{ENOTSOCK}] l'argomento \param{sockfd} non è un socket.
878   \item[\errcode{EOPNOTSUPP}] il socket è di un tipo che non supporta questa
879     operazione.
880   \end{errlist}}
881 \end{prototype}
882
883 La funzione pone il socket specificato da \param{sockfd} in modalità passiva e
884 predispone una coda per le connessioni in arrivo di lunghezza pari a
885 \param{backlog}. La funzione si può applicare solo a socket di tipo
886 \const{SOCK\_STREAM} o \const{SOCK\_SEQPACKET}.
887
888 L'argomento \param{backlog} indica il numero massimo di connessioni pendenti
889 accettate; se esso viene ecceduto il client al momento della richiesta della
890 connessione riceverà un errore di tipo \errcode{ECONNREFUSED}, o se il
891 protocollo, come accade nel caso del TCP, supporta la ritrasmissione, la
892 richiesta sarà ignorata in modo che la connessione possa venire ritentata.
893
894 Per capire meglio il significato di tutto ciò occorre approfondire la modalità
895 con cui il kernel tratta le connessioni in arrivo. Per ogni socket in ascolto
896 infatti vengono mantenute due code:
897 \begin{enumerate}
898 \item La coda delle connessioni incomplete (\textit{incomplete connection
899     queue} che contiene un riferimento per ciascun socket per il quale è
900   arrivato un SYN ma il \textit{three way handshake} non si è ancora concluso.
901   Questi socket sono tutti nello stato \texttt{SYN\_RECV}.
902 \item La coda delle connessioni complete (\textit{complete connection queue}
903   che contiene un ingresso per ciascun socket per il quale il three way
904   handshake è stato completato ma ancora \func{accept} non è ritornata.
905   Questi socket sono tutti nello stato \texttt{ESTABLISHED}.
906 \end{enumerate}
907
908 Lo schema di funzionamento è descritto in \figref{fig:TCP_listen_backlog}:
909 quando arriva un SYN da un client il server crea una nuova voce nella coda
910 delle connessioni incomplete, e poi risponde con il SYN$+$ACK. La voce resterà
911 nella coda delle connessioni incomplete fino al ricevimento dell'ACK dal
912 client o fino ad un timeout. Nel caso di completamento del three way handshake
913 la voce viene spostata nella coda delle connessioni complete.  Quando il
914 processo chiama la funzione \func{accept} (vedi \secref{sec:TCP_func_accept})
915 la prima voce nella coda delle connessioni complete è passata al programma, o,
916 se la coda è vuota, il processo viene posto in attesa e risvegliato all'arrivo
917 della prima connessione completa.
918
919 \begin{figure}[htb]
920   \centering
921   \includegraphics[width=11cm]{img/tcp_listen_backlog}  
922   \caption{Schema di funzionamento delle code delle connessioni complete ed
923     incomplete.}
924   \label{fig:TCP_listen_backlog}
925 \end{figure}
926
927 Storicamente il valore del parametro \param{backlog} era corrispondente al
928 massimo valore della somma del numero di voci possibili per ciascuna delle due
929 code. Stevens in \cite{UNP1} riporta che BSD ha sempre applicato un fattore di
930 1.5 a detto valore, e fornisce una tabella con i risultati ottenuti con vari
931 kernel, compreso Linux 2.0, che mostrano le differenze fra diverse
932 implementazioni.
933
934 In Linux il significato di questo valore è cambiato a partire dal kernel 2.2
935 per prevenire l'attacco chiamato \textit{syn flood}. Questo si basa
936 sull'emissione da parte dell'attaccante di un grande numero di pacchetti SYN
937 indirizzati verso una porta, forgiati con indirizzo IP fasullo\footnote{con la
938   tecnica che viene detta \textit{ip spoofing}.} così che i SYN$+$ACK vanno
939 perduti e la coda delle connessioni incomplete viene saturata, impedendo di
940 fatto ulteriori connessioni.
941
942 Per ovviare a questo il significato del \param{backlog} è stato cambiato a
943 indicare la lunghezza della coda delle connessioni complete. La lunghezza
944 della coda delle connessioni incomplete può essere ancora controllata usando
945 la funzione \func{sysctl} con il parametro \const{NET\_TCP\_MAX\_SYN\_BACKLOG}
946 o scrivendola direttamente in
947 \file{/proc/sys/net/ipv4/tcp\_max\_syn\_backlog}.  Quando si attiva la
948 protezione dei syncookies però (con l'opzione da compilare nel kernel e da
949 attivare usando \file{/proc/sys/net/ipv4/tcp\_syncookies}) questo valore viene
950 ignorato e non esiste più un valore massimo.  In ogni caso in Linux il valore
951 di \param{backlog} viene troncato ad un massimo di \const{SOMAXCONN} se è
952 superiore a detta costante (che di default vale 128).
953
954 La scelta storica per il valore di questo parametro era di 5, e alcuni vecchi
955 kernel non supportavano neanche valori superiori, ma la situazione corrente è
956 molto cambiata per via della presenza di server web che devono gestire un gran
957 numero di connessioni per cui un tale valore non è più adeguato. Non esiste
958 comunque una risposta univoca per la scelta del valore, per questo non
959 conviene specificarlo con una costante (il cui cambiamento richiederebbe la
960 ricompilazione del server) ma usare piuttosto una variabile di ambiente (vedi
961 \secref{sec:proc_environ}).
962
963 Stevens tratta accuratamente questo argomento in \cite{UNP1}, con esempi presi
964 da casi reali su web server, ed in particolare evidenzia come non sia più vero
965 che il compito principale della coda sia quello di gestire il caso in cui il
966 server è occupato fra chiamate successive alla \func{accept} (per cui la coda
967 più occupata sarebbe quella delle connessioni completate), ma piuttosto quello
968 di gestire la presenza di un gran numero di SYN in attesa di concludere il
969 three way handshake.
970
971 Infine va messo in evidenza che, nel caso di socket TCP, quando un SYN arriva
972 con tutte le code piene, il pacchetto deve essere ignorato. Questo perché la
973 condizione in cui le code sono piene è ovviamente transitoria, per cui se il
974 client ritrasmette il SYN è probabile che passato un po' di tempo possa
975 trovare nella coda lo spazio per una nuova connessione. Se invece si
976 rispondesse con un RST, per indicare l'impossibilità di effettuare la
977 connessione, la chiamata a \func{connect} nel client ritornerebbe con una
978 condizione di errore, costringendo a inserire nell'applicazione la gestione
979 dei tentativi di riconnessione, che invece può essere effettuata in maniera
980 trasparente dal protocollo TCP.
981
982
983 \subsection{La funzione \func{accept}}
984 \label{sec:TCP_func_accept}
985
986 La funzione \funcd{accept} è chiamata da un server per gestire la connessione
987 una volta che sia stato completato il \textit{three way
988   handshake},\footnote{la funzione è comunque generica ed è utilizzabile su
989   socket di tipo \texttt{SOCK\_STREAM}, \texttt{SOCK\_SEQPACKET} e
990   \texttt{SOCK\_RDM}.} la funzione restituisce un nuovo socket descriptor su
991 cui si potrà operare per effettuare la comunicazione. Se non ci sono
992 connessioni completate il processo viene messo in attesa. Il prototipo della
993 funzione è il seguente:
994 \begin{prototype}{sys/socket.h}
995 {int accept(int sockfd, struct sockaddr *addr, socklen\_t *addrlen)} 
996  
997   Accetta una connessione sul socket specificato.
998   
999   \bodydesc{La funzione restituisce un numero di socket descriptor positivo in
1000     caso di successo e -1 in caso di errore, nel qual caso \var{errno} viene
1001     impostata ai seguenti valori:
1002
1003   \begin{errlist}
1004   \item[\errcode{EBADF}] l'argomento \param{sockfd} non è un file descriptor
1005     valido.
1006   \item[\errcode{ENOTSOCK}] l'argomento \param{sockfd} non è un socket.
1007   \item[\errcode{EOPNOTSUPP}] il socket è di un tipo che non supporta questa
1008     operazione.
1009   \item[\errcode{EAGAIN} o \errcode{EWOULDBLOCK}] il socket è stato impostato
1010     come non bloccante (vedi \secref{sec:file_noblocking}), e non ci sono
1011     connessioni in attesa di essere accettate.
1012   \item[\errcode{EPERM}] Le regole del firewall non consentono la connessione.
1013   \item[\errcode{ENOBUFS}, \errcode{ENOMEM}] questo spesso significa che
1014     l'allocazione della memoria è limitata dai limiti sui buffer dei socket,
1015     non dalla memoria di sistema.
1016   \item[\errcode{EINTR}] La funzione è stata interrotta da un segnale.
1017   \end{errlist}
1018   Inoltre possono essere restituiti gli errori di rete relativi al nuovo
1019   socket, diversi a secondo del protocollo, come: \errval{EMFILE},
1020   \errval{EINVAL}, \errval{ENOSR}, \errval{ENOBUFS}, \errval{EFAULT},
1021   \errval{EPERM}, \errval{ECONNABORTED}, \errval{ESOCKTNOSUPPORT},
1022   \errval{EPROTONOSUPPORT}, \errval{ETIMEDOUT}, \errval{ERESTARTSYS}.}
1023 \end{prototype}
1024
1025 La funzione estrae la prima connessione relativa al socket \param{sockfd} in
1026 attesa sulla coda delle connessioni complete, che associa ad nuovo socket con
1027 le stesse caratteristiche di \param{sockfd}.  Il socket originale non viene
1028 toccato e resta nello stato di \texttt{LISTEN}, mentre il nuovo socket viene
1029 posto nello stato \texttt{ESTABLISHED}. Nella struttura \param{addr} e nella
1030 variabile \param{addrlen} vengono restituiti indirizzo e relativa lunghezza
1031 del client che si è connesso.
1032
1033 I due argomenti \param{addr} e \param{addrlen} (si noti che quest'ultimo è
1034 passato per indirizzo per avere indietro il valore) sono usati per ottenere
1035 l'indirizzo del client da cui proviene la connessione. Prima della chiamata
1036 \param{addrlen} deve essere inizializzato alle dimensioni della struttura il
1037 cui indirizzo è passato come argomento in \param{addr}; al ritorno della
1038 funzione \param{addrlen} conterrà il numero di byte scritti dentro
1039 \param{addr}. Se questa informazione non interessa basterà inizializzare a
1040 \val{NULL} detti puntatori.
1041
1042 Se la funzione ha successo restituisce il descrittore di un nuovo socket
1043 creato dal kernel (detto \textit{connected socket}) a cui viene associata la
1044 prima connessione completa (estratta dalla relativa coda, vedi
1045 \secref{sec:TCP_func_listen}) che il client ha effettuato verso il socket
1046 \param{sockfd}. Quest'ultimo (detto \textit{listening socket}) è quello creato
1047 all'inizio e messo in ascolto con \func{listen}, e non viene toccato dalla
1048 funzione.  Se non ci sono connessioni pendenti da accettare la funzione mette
1049 in attesa il processo\footnote{a meno che non si sia impostato il socket per
1050   essere non bloccante (vedi \secref{sec:file_noblocking}), nel qual caso
1051   ritorna con l'errore \errcode{EAGAIN}.  Torneremo su questa modalità di
1052   operazione in \secref{sec:TCP_sock_multiplexing}.}  fintanto che non ne
1053 arriva una.
1054
1055 La funzione può essere usata solo con socket che supportino la connessione
1056 (cioè di tipo \const{SOCK\_STREAM}, \const{SOCK\_SEQPACKET} o
1057 \const{SOCK\_RDM}). Per alcuni protocolli che richiedono una conferma
1058 esplicita della connessione,\footnote{attualmente in Linux solo DECnet ha
1059   questo comportamento.} la funzione opera solo l'estrazione dalla coda delle
1060 connessioni, la conferma della connessione viene eseguita implicitamente dalla
1061 prima chiamata ad una \func{read} o una \func{write}, mentre il rifiuto della
1062 connessione viene eseguito con la funzione \func{close}.
1063
1064 È da chiarire che Linux presenta un comportamento diverso nella gestione degli
1065 errori rispetto ad altre implementazioni dei socket BSD, infatti la funzione
1066 \func{accept} passa gli errori di rete pendenti sul nuovo socket come codici
1067 di errore per \func{accept}, per cui l'applicazione deve tenerne conto ed
1068 eventualmente ripetere la chiamata alla funzione come per l'errore di
1069 \errcode{EAGAIN} (torneremo su questo in \secref{sec:TCP_echo_critical}).
1070 Un'altra differenza con BSD è che la funzione non fa ereditare al nuovo socket
1071 i flag del socket originale, come \const{O\_NONBLOCK},\footnote{ed in generale
1072   tutti quelli che si possono impostare con \func{fcntl}, vedi
1073   \secref{sec:file_fcntl}.} che devono essere rispecificati ogni volta. Tutto
1074 questo deve essere tenuto in conto se si devono scrivere programmi portabili.
1075
1076 Il meccanismo di funzionamento di \func{accept} è essenziale per capire il
1077 funzionamento di un server: in generale infatti c'è sempre un solo socket in
1078 ascolto, detto per questo \textit{listening socket}, che resta per tutto il
1079 tempo nello stato \texttt{LISTEN}, mentre le connessioni vengono gestite dai
1080 nuovi socket, detti \textit{connected socket}, ritornati da \func{accept}, che
1081 si trovano automaticamente nello stato \texttt{ESTABLISHED}, e vengono
1082 utilizzati per lo scambio dei dati, che avviene su di essi, fino alla chiusura
1083 della connessione.  Si può riconoscere questo schema anche nell'esempio
1084 elementare di \figref{fig:TCP_daytime_iter_server_code}, dove per ogni
1085 connessione il socket creato da \func{accept} viene chiuso dopo l'invio dei
1086 dati.
1087
1088
1089 \subsection{Le funzioni \func{getsockname} e \func{getpeername}}
1090 \label{sec:TCP_get_names}
1091
1092 Oltre a tutte quelle viste finora, dedicate all'utilizzo dei socket, esistono
1093 alcune funzioni ausiliarie che possono essere usate per recuperare alcune
1094 informazioni relative ai socket ed alle connessioni ad essi associate. Le due
1095 funzioni più elementari sono queste, che vengono usate per ottenere i dati
1096 relativi alla socket pair associata ad un certo socket.
1097
1098 La prima funzione è \funcd{getsockname} e serve ad ottenere l'indirizzo locale
1099 associato ad un socket; il suo prototipo è:
1100 \begin{prototype}{sys/socket.h}
1101   {int getsockname(int sockfd, struct sockaddr *name, socklen\_t *namelen)}
1102   Legge l'indirizzo locale di un socket.
1103
1104 \bodydesc{La funzione restituisce 0 in caso di successo e -1 in caso di
1105   errore. I codici di errore restituiti in \var{errno} sono i seguenti:
1106   \begin{errlist}
1107   \item[\errcode{EBADF}] l'argomento \param{sockfd} non è un file descriptor
1108     valido.
1109   \item[\errcode{ENOTSOCK}] l'argomento \param{sockfd} non è un socket.
1110   \item[\errcode{ENOBUFS}] non ci sono risorse sufficienti nel sistema per
1111     eseguire l'operazione.
1112   \item[\errcode{EFAULT}] l'indirizzo \param{name} non è valido.
1113   \end{errlist}}
1114 \end{prototype}
1115
1116 La funzione restituisce la struttura degli indirizzi del socket \param{sockfd}
1117 nella struttura indicata dal puntatore \param{name} la cui lunghezza è
1118 specificata tramite l'argomento \param{namlen}. Quest'ultimo viene passato
1119 come indirizzo per avere indietro anche il numero di byte effettivamente
1120 scritti nella struttura puntata da \param{name}. Si tenga presente che se si è
1121 utilizzato un buffer troppo piccolo per \param{name} l'indirizzo risulterà
1122 troncato.
1123
1124 La funzione si usa tutte le volte che si vuole avere l'indirizzo locale di un
1125 socket; ad esempio può essere usata da un client (che usualmente non chiama
1126 \func{bind}) per ottenere numero IP e porta locale associati al socket
1127 restituito da una \func{connect}, o da un server che ha chiamato \func{bind}
1128 su un socket usando 0 come porta locale per ottenere il numero di porta
1129 effimera assegnato dal kernel.
1130
1131 Inoltre quando un server esegue una \func{bind} su un indirizzo generico, se
1132 chiamata dopo il completamento di una connessione sul socket restituito da
1133 \func{accept}, restituisce l'indirizzo locale che il kernel ha assegnato a
1134 quella connessione.
1135
1136 Tutte le volte che si vuole avere l'indirizzo remoto di un socket si usa la
1137 funzione \funcd{getpeername}, il cui prototipo è:
1138 \begin{prototype}{sys/socket.h}
1139   {int getpeername(int sockfd, struct sockaddr * name, socklen\_t * namelen)}
1140   Legge l'indirizzo remoto di un socket.
1141   
1142   \bodydesc{La funzione restituisce 0 in caso di successo e -1 in caso di
1143     errore. I codici di errore restituiti in \var{errno} sono i seguenti:
1144   \begin{errlist}
1145   \item[\errcode{EBADF}] l'argomento \param{sockfd} non è un file descriptor
1146     valido.
1147   \item[\errcode{ENOTSOCK}] l'argomento \param{sockfd} non è un socket.
1148   \item[\errcode{ENOTCONN}] il socket non è connesso.
1149   \item[\errcode{ENOBUFS}] non ci sono risorse sufficienti nel sistema per
1150     eseguire l'operazione.
1151   \item[\errcode{EFAULT}] l'argomento \param{name} punta al di fuori dello
1152     spazio di indirizzi del processo.
1153   \end{errlist}}
1154 \end{prototype}
1155
1156 La funzione è identica a \func{getsockname}, ed usa la stessa sintassi, ma
1157 restituisce l'indirizzo remoto del socket, cioè quello associato all'altro
1158 capo della connessione.  Ci si può chiedere a cosa serva questa funzione dato
1159 che dal lato client l'indirizzo remoto è sempre noto quando si esegue la
1160 \func{connect} mentre dal lato server si possono usare, come vedremo in
1161 \figref{fig:TCP_daytime_cunc_server_code}, i valori di ritorno di
1162 \func{accept}.
1163
1164 Il fatto è che in generale quest'ultimo caso non è sempre possibile.  In
1165 particolare questo avviene quando il server, invece di gestire la connessione
1166 direttamente in un processo figlio, come vedremo nell'esempio di server
1167 concorrente di \secref{sec:TCP_daytime_cunc_server}, lancia per ciascuna
1168 connessione un altro programma, usando \func{exec}.\footnote{questa ad esempio
1169   è la modalità con cui opera il \textsl{super-server} \cmd{inetd}, che può
1170   gestire tutta una serie di servizi diversi, eseguendo su ogni connessione
1171   ricevuta sulle porte tenute sotto controllo, il relativo server.}
1172
1173 In questo caso benché il processo figlio abbia una immagine della memoria che
1174 è copia di quella del processo padre (e contiene quindi anche la struttura
1175 ritornata da \func{accept}), all'esecuzione di \func{exec} verrà caricata in
1176 memoria l'immagine del programma eseguito, che a questo punto perde ogni
1177 riferimento ai valori tornati da \func{accept}.  Il socket descriptor però
1178 resta aperto, e se si è seguita una opportuna convenzione per rendere noto al
1179 programma eseguito qual'è il socket connesso, \footnote{ad esempio il solito
1180   \cmd{inetd} fa sempre in modo che i file descriptor 0, 1 e 2 corrispondano
1181   al socket connesso.} quest'ultimo potrà usare la funzione \func{getpeername}
1182 per determinare l'indirizzo remoto del client.
1183
1184 Infine è da chiarire (si legga la pagina di manuale) che, come per
1185 \func{accept}, il terzo parametro, che è specificato dallo standard POSIX.1g
1186 come di tipo \code{socklen\_t *} in realtà deve sempre corrispondere ad un
1187 \ctyp{int *} come prima dello standard perché tutte le implementazioni dei
1188 socket BSD fanno questa assunzione.
1189
1190
1191 \subsection{La funzione \func{close}}
1192 \label{sec:TCP_func_close}
1193
1194 La funzione standard Unix \func{close} (vedi \secref{sec:file_close}) che si
1195 usa sui file può essere usata con lo stesso effetto anche sui file descriptor
1196 associati ad un socket.
1197
1198 L'azione di questa funzione quando applicata a socket è di marcarlo come
1199 chiuso e ritornare immediatamente al processo. Una volta chiamata il socket
1200 descriptor non è più utilizzabile dal processo e non può essere usato come
1201 argomento per una \func{write} o una \func{read} (anche se l'altro capo della
1202 connessione non avesse chiuso la sua parte).  Il kernel invierà comunque tutti
1203 i dati che ha in coda prima di iniziare la sequenza di chiusura.
1204
1205 Vedremo più avanti in \secref{sec:TCP_so_linger} come è possibile cambiare
1206 questo comportamento, e cosa deve essere fatto perché il processo possa
1207 assicurarsi che l'altro capo abbia ricevuto tutti i dati.
1208
1209 Come per tutti i file descriptor anche per i socket viene mantenuto un numero
1210 di riferimenti, per cui se più di un processo ha lo stesso socket aperto
1211 l'emissione del FIN e la sequenza di chiusura di TCP non viene innescata
1212 fintanto che il numero di riferimenti non si annulla, questo si applica, come
1213 visto in \secref{sec:file_sharing}, sia ai file descriptor duplicati che a
1214 quelli ereditati dagli eventuali processi figli, ed è il comportamento che ci
1215 si aspetta in una qualunque applicazione client/server.
1216
1217 Per attivare immediatamente l'emissione del FIN e la sequenza di chiusura
1218 descritta in \secref{sec:TCP_conn_term}, si può invece usare la funzione
1219 \func{shutdown} su cui torneremo in seguito (vedi
1220 \secref{sec:TCP_shutdown}).
1221
1222
1223
1224 \section{Un esempio elementare: il servizio \textit{daytime}}
1225 \label{sec:TCP_daytime_application}
1226
1227 Avendo introdotto le funzioni di base per la gestione dei socket, potremo
1228 vedere in questa sezione un primo esempio di applicazione elementare che
1229 implementa il servizio \textit{daytime} su TCP, secondo quanto specificato
1230 dall'\href{http://www.ietf.org/rfc/rfc0867.txt}{RFC~867}.  Prima di passare
1231 agli esempi del client e del server, inizieremo riesaminando con maggiori
1232 dettagli una peculiarità delle funzioni di I/O, già accennata in
1233 \secref{sec:file_read} e \secref{sec:file_write}, che nel caso dei socket è
1234 particolarmente rilevante.  Passeremo poi ad illustrare gli esempi
1235 dell'implementazione, sia dal lato client, che dal lato server, che si è
1236 realizzato sia in forma iterativa che concorrente.
1237
1238
1239 \subsection{Il comportamento delle funzioni di I/O}
1240 \label{sec:sock_io_behav}
1241
1242 Una cosa che si tende a dimenticare quando si ha a che fare con i socket è che
1243 le funzioni di input/output non sempre hanno lo stesso comportamento che
1244 avrebbero con i normali file di dati (in particolare questo accade per i
1245 socket di tipo stream).
1246
1247 Infatti con i socket è comune che funzioni come \func{read} o \func{write}
1248 possano restituire in input o scrivere in output un numero di byte minore di
1249 quello richiesto. Come già accennato in \secref{sec:file_read} questo è un
1250 comportamento normale per le funzioni di I/O, ma con i normali file di dati il
1251 problema si avverte solo in lettura, quando si incontra la fine del file. In
1252 generale non è così, e con i socket questo è particolarmente evidente.
1253
1254
1255 \begin{figure}[htb]
1256   \footnotesize \centering
1257   \begin{minipage}[c]{15cm}
1258     \includecodesample{listati/FullRead.c}
1259   \end{minipage} 
1260   \normalsize
1261   \caption{La funzione \func{FullRead}, che legge esattamente \var{count} byte
1262     da un file descriptor, iterando opportunamente le letture.}
1263   \label{fig:sock_FullRead_code}
1264 \end{figure}
1265
1266 Quando ci si trova ad affrontare questo comportamento tutto quello che si deve
1267 fare è semplicemente ripetere la lettura (o la scrittura) per la quantità di
1268 byte restanti, tenendo conto che le funzioni si possono bloccare se i dati non
1269 sono disponibili: è lo stesso comportamento che si può avere scrivendo più di
1270 \const{PIPE\_BUF} byte in una pipe (si riveda quanto detto in
1271 \secref{sec:ipc_pipes}).
1272
1273 Per questo motivo, seguendo l'esempio di R. W. Stevens in \cite{UNP1}, si sono
1274 definite due funzioni, \func{FullRead} e \func{FullWrite}, che eseguono
1275 lettura e scrittura tenendo conto di questa caratteristica, ed in grado di
1276 ritornare solo dopo avere letto o scritto esattamente il numero di byte
1277 specificato; il sorgente è riportato rispettivamente in
1278 \figref{fig:sock_FullRead_code} e \figref{fig:sock_FullWrite_code} ed è
1279 disponibile fra i sorgenti allegati alla guida nei file \file{FullRead.c} e
1280 \file{FullWrite.c}.
1281
1282 \begin{figure}[htb]
1283   \centering
1284   \footnotesize \centering
1285   \begin{minipage}[c]{15cm}
1286     \includecodesample{listati/FullWrite.c}
1287   \end{minipage} 
1288   \normalsize
1289   \caption{La funzione \func{FullWrite}, che scrive esattamente \var{count}
1290     byte su un file descriptor, iterando opportunamente le scritture.}
1291   \label{fig:sock_FullWrite_code}
1292 \end{figure}
1293
1294 Come si può notare le due funzioni ripetono la lettura/scrittura in un ciclo
1295 fino all'esaurimento del numero di byte richiesti, in caso di errore viene
1296 controllato se questo è \errcode{EINTR} (cioè un'interruzione della system
1297 call dovuta ad un segnale), nel qual caso l'accesso viene ripetuto, altrimenti
1298 l'errore viene ritornato al programma chiamante, interrompendo il ciclo.
1299
1300 Nel caso della lettura, se il numero di byte letti è zero, significa che si è
1301 arrivati alla fine del file (per i socket questo significa in genere che
1302 l'altro capo è stato chiuso, e quindi non sarà più possibile leggere niente) e
1303 pertanto si ritorna senza aver concluso la lettura di tutti i byte
1304 richiesti. Entrambe le funzioni restituiscono 0 in caso di successo, ed un
1305 valore negativo in caso di errore, \texttt{FullRead} restituisce il numero di
1306 byte non letti in caso di end-of-file prematuro.
1307
1308
1309 \subsection{Il client \textit{daytime}}
1310 \label{sec:TCP_daytime_client}
1311
1312 Il primo esempio di applicazione delle funzioni di base illustrate in
1313 \secref{sec:TCP_functions} è relativo alla creazione di un client elementare
1314 per il servizio \textit{daytime}, un servizio elementare, definito
1315 nell'\href{http://www.ietf.org/rfc/rfc0867.txt}{RFC~867}, che restituisce
1316 l'ora locale della macchina a cui si effettua la richiesta, e che è assegnato
1317 alla porta 13.
1318
1319 In \figref{fig:TCP_daytime_client_code} è riportata la sezione principale del
1320 codice del nostro client. Il sorgente completo del programma
1321 (\file{TCP\_daytime.c}, che comprende il trattamento delle opzioni ed una
1322 funzione per stampare un messaggio di aiuto) è allegato alla guida nella
1323 sezione dei codici sorgente e può essere compilato su una qualunque macchina
1324 GNU/Linux.
1325
1326 \begin{figure}[!htb]
1327   \footnotesize \centering
1328   \begin{minipage}[c]{15cm}
1329     \includecodesample{listati/TCP_daytime.c}
1330   \end{minipage} 
1331   \normalsize
1332   \caption{Esempio di codice di un client elementare per il servizio
1333     \textit{daytime}.} 
1334   \label{fig:TCP_daytime_client_code}
1335 \end{figure}
1336
1337 Il programma anzitutto (\texttt{\small 1--5}) include gli header necessari;
1338 dopo la dichiarazione delle variabili (\texttt{\small 9--12}) si è omessa
1339 tutta la parte relativa al trattamento degli argomenti passati dalla linea di
1340 comando (effettuata con le apposite funzioni illustrate in
1341 \secref{sec:proc_opt_handling}).
1342
1343 Il primo passo (\texttt{\small 14--18}) è creare un socket TCP (quindi di tipo
1344 \const{SOCK\_STREAM} e di famiglia \const{AF\_INET}). La funzione
1345 \func{socket} ritorna il descrittore che viene usato per identificare il
1346 socket in tutte le chiamate successive. Nel caso la chiamata fallisca si
1347 stampa un errore (\texttt{\small 16}) con la funzione \func{perror} e si esce
1348 (\texttt{\small 17}) con un codice di errore.
1349
1350 Il passo seguente (\texttt{\small 19--27}) è quello di costruire un'apposita
1351 struttura \struct{sockaddr\_in} in cui sarà inserito l'indirizzo del server ed
1352 il numero della porta del servizio. Il primo passo (\texttt{\small 20}) è
1353 inizializzare tutto a zero, per poi inserire il tipo di indirizzo
1354 (\texttt{\small 21}) e la porta (\texttt{\small 22}), usando per quest'ultima
1355 la funzione \func{htons} per convertire il formato dell'intero usato dal
1356 computer a quello usato nella rete, infine \texttt{\small 23--27} si può
1357 utilizzare la funzione \func{inet\_pton} per convertire l'indirizzo numerico
1358 passato dalla linea di comando.
1359
1360 A questo punto (\texttt{\small 28--32}) usando la funzione \func{connect} sul
1361 socket creato in precedenza (\texttt{\small 29}) si può stabilire la
1362 connessione con il server. Per questo si deve utilizzare come secondo
1363 argomento la struttura preparata in precedenza con il relativo indirizzo; si
1364 noti come, esistendo diversi tipi di socket, si sia dovuto effettuare un cast.
1365 Un valore di ritorno della funzione negativo implica il fallimento della
1366 connessione, nel qual caso si stampa un errore (\texttt{\small 30}) e si
1367 ritorna (\texttt{\small 31}).
1368
1369 Completata con successo la connessione il passo successivo (\texttt{\small
1370   34--40}) è leggere la data dal socket; il protocollo prevede che il server
1371 invii sempre una stringa alfanumerica, il formato della stringa non è
1372 specificato dallo standard, per cui noi useremo il formato usato dalla
1373 funzione \func{ctime}, seguito dai caratteri di terminazione \verb|\r\n|, cioè
1374 qualcosa del tipo:
1375 \begin{verbatim}
1376 Wed Apr 4 00:53:00 2001\r\n
1377 \end{verbatim}
1378 questa viene letta dal socket (\texttt{\small 34}) con la funzione \func{read}
1379 in un buffer temporaneo; la stringa poi deve essere terminata (\texttt{\small
1380   35}) con il solito carattere nullo per poter essere stampata (\texttt{\small
1381   36}) sullo standard output con l'uso di \func{fputs}.
1382
1383 Come si è già spiegato in \secref{sec:sock_io_behav} la risposta dal socket
1384 potrà arrivare in un unico pacchetto di 26 byte (come avverrà senz'altro nel
1385 caso in questione) ma potrebbe anche arrivare in 26 pacchetti di un byte.  Per
1386 questo nel caso generale non si può mai assumere che tutti i dati arrivino con
1387 una singola lettura, pertanto quest'ultima deve essere effettuata in un ciclo
1388 in cui si continui a leggere fintanto che la funzione \func{read} non ritorni
1389 uno zero (che significa che l'altro capo ha chiuso la connessione) o un numero
1390 minore di zero (che significa un errore nella connessione).
1391
1392 Si noti come in questo caso la fine dei dati sia specificata dal server che
1393 chiude la connessione (anche questo è quanto richiesto dal protocollo); questa
1394 è una delle tecniche possibili (è quella usata pure dal protocollo HTTP), ma
1395 ce ne possono essere altre, ad esempio FTP marca la conclusione di un blocco
1396 di dati con la sequenza ASCII \verb|\r\n| (carriage return e line feed),
1397 mentre il DNS mette la lunghezza in testa ad ogni blocco che trasmette. Il
1398 punto essenziale è che TCP non provvede nessuna indicazione che permetta di
1399 marcare dei blocchi di dati, per cui se questo è necessario deve provvedere il
1400 programma stesso.
1401
1402 Se abilitiamo il servizio \textit{daytime}\footnote{in genere questo viene
1403   fornito direttamente dal \textsl{superdemone} \texttt{inetd}, pertanto basta
1404   assicurarsi che esso sia abilitato nel relativo file di configurazione.}
1405 possiamo verificare il funzionamento del nostro client, avremo allora:
1406 \begin{verbatim}
1407 [piccardi@gont sources]$ ./daytime 127.0.0.1
1408 Mon Apr 21 20:46:11 2003
1409 \end{verbatim}%$
1410 e come si vede tutto funziona regolarmente.
1411
1412
1413 \subsection{Un server \textit{daytime} iterativo}
1414 \label{sec:TCP_daytime_iter_server}
1415
1416 Dopo aver illustrato il client daremo anche un esempio di un server
1417 elementare, che sia anche in grado di rispondere al precedente client. Come
1418 primo esempio realizzeremo un server iterativo, in grado di fornire una sola
1419 risposta alla volta. Il codice del programma è nuovamente mostrato in
1420 \figref{fig:TCP_daytime_iter_server_code}, il sorgente completo
1421 (\file{TCP\_iter\_daytimed.c}) è allegato insieme agli altri file degli esempi.
1422
1423 \begin{figure}[!htbp]
1424   \footnotesize \centering
1425   \begin{minipage}[c]{15cm}
1426     \includecodesample{listati/TCP_iter_daytimed.c}
1427   \end{minipage} 
1428   \normalsize
1429   \caption{Esempio di codice di un semplice server per il servizio daytime.}
1430   \label{fig:TCP_daytime_iter_server_code}
1431 \end{figure}
1432
1433 Come per il client si includono (\texttt{\small 1--9}) gli header necessari a
1434 cui è aggiunto quello per trattare i tempi, e si definiscono (\texttt{\small
1435   14--18}) alcune costanti e le variabili necessarie in seguito. Come nel caso
1436 precedente si sono omesse le parti relative al trattamento delle opzioni da
1437 riga di comando.
1438
1439 La creazione del socket (\texttt{\small 20--24}) è analoga al caso precedente,
1440 come pure l'inizializzazione (\texttt{\small 25--29}) della struttura
1441 \struct{sockaddr\_in}.  Anche in questo caso (\texttt{\small 28}) si usa la
1442 porta standard del servizio daytime, ma come indirizzo IP si usa
1443 (\texttt{\small 27}) il valore predefinito \const{INET\_ANY}, che corrisponde
1444 all'indirizzo generico.
1445
1446 Si effettua poi (\texttt{\small 30--34}) la chiamata alla funzione \func{bind}
1447 che permette di associare la precedente struttura al socket, in modo che
1448 quest'ultimo possa essere usato per accettare connessioni su una qualunque
1449 delle interfacce di rete locali. In caso di errore si stampa (\texttt{\small
1450   31}) un messaggio, e si termina (\texttt{\small 32}) immediatamente il
1451 programma.
1452
1453 Il passo successivo (\texttt{\small 35--39}) è quello di mettere ``in
1454 ascolto'' il socket; questo viene fatto (\texttt{\small 36}) con la funzione
1455 \func{listen} che dice al kernel di accettare connessioni per il socket che
1456 abbiamo creato; la funzione indica inoltre, con il secondo parametro, il
1457 numero massimo di connessioni che il kernel accetterà di mettere in coda per
1458 il suddetto socket. Di nuovo in caso di errore si stampa (\texttt{\small 37})
1459 un messaggio, e si esce (\texttt{\small 38}) immediatamente.
1460
1461 La chiamata a \func{listen} completa la preparazione del socket per l'ascolto
1462 (che viene chiamato anche \textit{listening descriptor}) a questo punto si può
1463 procedere con il ciclo principale (\texttt{\small 40--53}) che viene eseguito
1464 indefinitamente. Il primo passo (\texttt{\small 42}) è porsi in attesa di
1465 connessioni con la chiamata alla funzione \func{accept}, come in precedenza in
1466 caso di errore si stampa (\texttt{\small 43}) un messaggio, e si esce
1467 (\texttt{\small 44}).
1468
1469 Il processo resterà in stato di \textit{sleep} fin quando non arriva e viene
1470 accettata una connessione da un client; quando questo avviene \func{accept}
1471 ritorna, restituendo un secondo descrittore, che viene chiamato
1472 \textit{connected descriptor}, e che è quello che verrà usato dalla successiva
1473 chiamata alla \func{write} per scrivere la risposta al client.
1474
1475 Il ciclo quindi proseguirà determinando (\texttt{\small 46}) il tempo corrente
1476 con una chiamata a \texttt{time}, con il quale si potrà opportunamente
1477 costruire (\texttt{\small 47}) la stringa con la data da trasmettere
1478 (\texttt{\small 48}) con la chiamata a \func{write}. Completata la
1479 trasmissione il nuovo socket viene chiuso (\texttt{\small 52}).  A questo
1480 punto il ciclo si chiude ricominciando da capo in modo da poter ripetere
1481 l'invio della data in risposta ad una successiva connessione.
1482
1483 È importante notare che questo server è estremamente elementare, infatti, a
1484 parte il fatto di poter essere usato solo con indirizzi IPv4, esso è in grado
1485 di rispondere ad un solo un client alla volta: è cioè, come dicevamo, un
1486 \textsl{server iterativo}. Inoltre è scritto per essere lanciato da linea di
1487 comando, se lo si volesse utilizzare come demone occorrerebbero le opportune
1488 modifiche\footnote{come una chiamata a \func{daemon} prima dell'inizio del
1489   ciclo principale.} per tener conto di quanto illustrato in
1490 \secref{sec:sess_daemon}. Si noti anche che non si è inserita nessuna forma di
1491 gestione della terminazione del processo, dato che tutti i file descriptor
1492 vengono chiusi automaticamente alla sua uscita, e che, non generando figli,
1493 non è necessario preoccuparsi di gestire la loro terminazione.
1494
1495
1496 \subsection{Un server \textit{daytime} concorrente}
1497 \label{sec:TCP_daytime_cunc_server}
1498
1499 Il server \texttt{daytime} dell'esempio in
1500 \secref{sec:TCP_daytime_iter_server} è un tipico esempio di server iterativo,
1501 in cui viene servita una richiesta alla volta; in generale però, specie se il
1502 servizio è più complesso e comporta uno scambio di dati più sostanzioso di
1503 quello in questione, non è opportuno bloccare un server nel servizio di un
1504 client per volta; per questo si ricorre alle capacità di multitasking del
1505 sistema.
1506
1507 Come accennato anche in \secref{sec:proc_gen} una delle modalità più comuni di
1508 funzionamento da parte dei server è quella di usare la funzione \func{fork}
1509 per creare, ad ogni richiesta da parte di un client, un processo figlio che si
1510 incarichi della gestione della comunicazione.  Si è allora riscritto il server
1511 \textit{daytime} dell'esempio precedente in forma concorrente, inserendo anche
1512 una opzione per la stampa degli indirizzi delle connessioni ricevute.
1513
1514 In \figref{fig:TCP_daytime_cunc_server_code} è mostrato un estratto del
1515 codice, in cui si sono tralasciati il trattamento delle opzioni e le parti
1516 rimaste invariate rispetto al precedente esempio (cioè tutta la parte
1517 riguardante l'apertura passiva del socket). Al solito il sorgente completo del
1518 server, nel file \file{TCP\_cunc\_daytimed.c}, è allegato insieme ai sorgenti
1519 degli altri esempi.
1520
1521 \begin{figure}[!htb]
1522   \footnotesize \centering
1523   \begin{minipage}[c]{15cm}
1524     \includecodesample{listati/TCP_cunc_daytimed.c}
1525   \end{minipage} 
1526   \normalsize
1527   \caption{Esempio di codice di un server concorrente elementare per il 
1528     servizio daytime.}
1529   \label{fig:TCP_daytime_cunc_server_code}
1530 \end{figure}
1531
1532 Stavolta (\texttt{\small 21--26}) la funzione \func{accept} è chiamata
1533 fornendo una struttura di indirizzi in cui saranno ritornati l'indirizzo IP e
1534 la porta da cui il client effettua la connessione, che in un secondo tempo,
1535 (\texttt{\small 40--44}), se il logging è abilitato, stamperemo sullo standard
1536 output.
1537
1538 Quando \func{accept} ritorna il server chiama la funzione \func{fork}
1539 (\texttt{\small 27--31}) per creare il processo figlio che effettuerà
1540 (\texttt{\small 32--46}) tutte le operazioni relative a quella connessione,
1541 mentre il padre proseguirà l'esecuzione del ciclo principale in attesa di
1542 ulteriori connessioni.
1543
1544 Si noti come il figlio operi solo sul socket connesso, chiudendo
1545 immediatamente (\texttt{\small 33}) il socket \var{list\_fd}; mentre il padre
1546 continua ad operare solo sul socket in ascolto chiudendo (\texttt{\small 48})
1547 \var{conn\_fd} al ritorno dalla \func{fork}. Per quanto abbiamo detto in
1548 \secref{sec:TCP_func_close} nessuna delle due chiamate a \func{close} causa
1549 l'innesco della sequenza di chiusura perché il numero di riferimenti al file
1550 descriptor non si è annullato.
1551
1552 Infatti subito dopo la creazione del socket \var{list\_fd} ha una referenza, e
1553 lo stesso vale per \var{conn\_fd} dopo il ritorno di \func{accept}, ma dopo la
1554 \func{fork} i descrittori vengono duplicati nel padre e nel figlio per cui
1555 entrambi i socket si trovano con due referenze. Questo fa si che quando il
1556 padre chiude \var{sock\_fd} esso resta con una referenza da parte del figlio,
1557 e sarà definitivamente chiuso solo quando quest'ultimo, dopo aver completato
1558 le sue operazioni, chiamerà (\texttt{\small 45}) la funzione \func{close}.
1559
1560 In realtà per il figlio non sarebbe necessaria nessuna chiamata a
1561 \func{close}, in quanto con la \func{exit} finale (\texttt{\small 45}) tutti i
1562 file descriptor, quindi anche quelli associati ai socket, vengono
1563 automaticamente chiusi.  Tuttavia si è preferito effettuare esplicitamente le
1564 chiusure per avere una maggiore chiarezza del codice, e per evitare eventuali
1565 errori, prevenendo ad esempio un uso involontario del \textit{listening
1566   descriptor}.
1567
1568 Si noti invece come sia essenziale che il padre chiuda ogni volta il socket
1569 connesso dopo la \func{fork}; se così non fosse nessuno di questi socket
1570 sarebbe effettivamente chiuso dato che alla chiusura da parte del figlio
1571 resterebbe ancora un riferimento nel padre. Si avrebbero così due effetti: il
1572 padre potrebbe esaurire i descrittori disponibili (che sono un numero limitato
1573 per ogni processo) e soprattutto nessuna delle connessioni con i client
1574 verrebbe chiusa.
1575
1576 Come per ogni server iterativo il lavoro di risposta viene eseguito
1577 interamente dal processo figlio. Questo si incarica (\texttt{\small 34}) di
1578 chiamare \func{time} per leggere il tempo corrente, e di stamparlo
1579 (\texttt{\small 35}) sulla stringa contenuta in \var{buffer} con l'uso di
1580 \func{snprintf} e \func{ctime}. Poi la stringa viene scritta (\texttt{\small
1581   36--39}) sul socket, controllando che non ci siano errori. Anche in questo
1582 caso si è evitato il ricorso a \func{FullWrite} in quanto la stringa è
1583 estremamente breve e verrà senz'altro scritta in un singolo segmento.
1584
1585 Inoltre nel caso sia stato abilitato il \textit{logging} delle connessioni, si
1586 provvede anche (\texttt{\small 40--43}) a stampare sullo standard output
1587 l'indirizzo e la porta da cui il client ha effettuato la connessione, usando i
1588 valori contenuti nelle strutture restituite da \func{accept}, eseguendo le
1589 opportune conversioni con \func{inet\_ntop} e \func{atohs}.
1590
1591 Ancora una volta l'esempio è estremamente semplificato, si noti come di nuovo
1592 non si sia gestita né la terminazione del processo né il suo uso come demone,
1593 che tra l'altro sarebbe stato incompatibile con l'uso della opzione di logging
1594 che stampa gli indirizzi delle connessioni sullo standard output. Un altro
1595 aspetto tralasciato è la gestione della terminazione dei processi figli,
1596 torneremo su questo più avanti quando tratteremo alcuni esempi di server più
1597 complessi.
1598
1599
1600
1601 \section{Un esempio più completo: il servizio \textit{echo}}
1602 \label{sec:TCP_echo_application}
1603
1604 L'esempio precedente, basato sul servizio \textit{daytime}, è un esempio molto
1605 elementare, in cui il flusso dei dati va solo nella direzione dal server al
1606 client. In questa sezione esamineremo un esempio di applicazione client/server
1607 un po' più complessa, che usi i socket TCP per una comunicazione in entrambe
1608 le direzioni.
1609
1610 Ci limiteremo a fornire una implementazione elementare, che usi solo le
1611 funzioni di base viste finora, ma prenderemo in esame, oltre al comportamento
1612 in condizioni normali, anche tutti i possibili scenari particolari (errori,
1613 sconnessione della rete, crash del client o del server durante la connessione)
1614 che possono avere luogo durante l'impiego di un'applicazione di rete, partendo
1615 da una versione primitiva che dovrà essere rimaneggiata di volta in volta per
1616 poter tenere conto di tutte le evenienze che si possono manifestare nella vita
1617 reale di un'applicazione di rete, fino ad arrivare ad un'implementazione
1618 completa.
1619
1620
1621 \subsection{Il servizio \textit{echo}}
1622 \label{sec:TCP_echo}
1623
1624
1625 Nella ricerca di un servizio che potesse fare da esempio per una comunicazione
1626 bidirezionale, si è deciso, seguendo la scelta di Stevens in \cite{UNP1}, di
1627 usare il servizio \textit{echo}, che si limita a restituire in uscita quanto
1628 immesso in ingresso. Infatti, nonostante la sua estrema semplicità, questo
1629 servizio costituisce il prototipo ideale per una generica applicazione di rete
1630 in cui un server risponde alle richieste di un client.  Nel caso di una
1631 applicazione più complessa quello che si potrà avere in più è una elaborazione
1632 dell'input del client, che in molti casi viene interpretato come un comando,
1633 da parte di un server che risponde fornendo altri dati in uscita.
1634
1635 Il servizio \textit{echo} è uno dei servizi standard solitamente provvisti
1636 direttamente dal superserver \cmd{inetd}, ed è definito
1637 dall'\href{http://www.ietf.org/rfc/rfc0862.txt}{RFC~862}. Come dice il nome il
1638 servizio deve riscrivere indietro sul socket i dati che gli vengono inviati in
1639 ingresso. L'RFC descrive le specifiche del servizio sia per TCP che UDP, e per
1640 il primo stabilisce che una volta stabilita la connessione ogni dato in
1641 ingresso deve essere rimandato in uscita fintanto che il chiamante non ha
1642 chiude la connessione. Al servizio è assegnata la porta riservata 7.
1643
1644 Nel nostro caso l'esempio sarà costituito da un client che legge una linea di
1645 caratteri dallo standard input e la scrive sul server. A sua volta il server
1646 leggerà la linea dalla connessione e la riscriverà immutata all'indietro. Sarà
1647 compito del client leggere la risposta del server e stamparla sullo standard
1648 output.
1649
1650
1651 \subsection{Il client \textit{echo}: prima versione}
1652 \label{sec:TCP_echo_client}
1653
1654 Il codice della prima versione del client per il servizio \textit{echo},
1655 disponibile nel file \file{TCP\_echo\_first.c}, è riportato in
1656 \figref{fig:TCP_echo_client_1}. Esso ricalca la struttura del precedente
1657 client per il servizio \textit{daytime} (vedi
1658 \secref{sec:TCP_daytime_client}), e la prima parte (\texttt{\small 10--27}) è
1659 sostanzialmente identica, a parte l'uso di una porta diversa.
1660
1661 \begin{figure}[!htb]
1662   \footnotesize \centering
1663   \begin{minipage}[c]{15.6 cm}
1664     \includecodesample{listati/TCP_echo_first.c}
1665   \end{minipage} 
1666   \normalsize
1667   \caption{Codice della prima versione del client \textit{echo}.}
1668   \label{fig:TCP_echo_client_1}
1669 \end{figure}
1670
1671 Al solito si è tralasciata la sezione relativa alla gestione delle opzioni a
1672 riga di comando.  Una volta dichiarate le variabili, si prosegue
1673 (\texttt{\small 10--13}) con della creazione del socket con l'usuale controllo
1674 degli errori, alla preparazione (\texttt{\small 14--17}) della struttura
1675 dell'indirizzo, che stavolta usa la porta 7 riservata al servizio
1676 \textit{echo}, infine si converte (\texttt{\small 18--22}) l'indirizzo
1677 specificato a riga di comando.  A questo punto (\texttt{\small 23--27}) si può
1678 eseguire la connessione al server secondo la stessa modalità usata in
1679 \secref{sec:TCP_daytime_client}.
1680
1681 Completata la connessione, per gestire il funzionamento del protocollo si usa
1682 la funzione \code{ClientEcho}, il cui codice si è riportato a parte in
1683 \figref{fig:TCP_client_echo_sub}. Questa si preoccupa di gestire tutta la
1684 comunicazione, leggendo una riga alla volta dallo standard input \file{stdin},
1685 scrivendola sul socket e ristampando su \file{stdout} quanto ricevuto in
1686 risposta dal server. Al ritorno dalla funzione (\texttt{\small 30--31}) anche
1687 il programma termina.
1688
1689 La funzione \code{ClientEcho} utilizza due buffer (\texttt{\small 3}) per
1690 gestire i dati inviati e letti sul socket.  La comunicazione viene gestita
1691 all'interno di un ciclo (\texttt{\small 5--10}), i dati da inviare sulla
1692 connessione vengono presi dallo \file{stdin} usando la funzione \func{fgets},
1693 che legge una linea di testo (terminata da un \texttt{CR} e fino al massimo di
1694 \const{MAXLINE} caratteri) e la salva sul buffer di invio.
1695
1696 Si usa poi (\texttt{\small 6}) la funzione \func{FullWrite}, vista in
1697 \secref{sec:sock_io_behav}, per scrivere i dati sul socket, gestendo
1698 automaticamente l'invio multiplo qualora una singola \func{write} non sia
1699 sufficiente.  I dati vengono riletti indietro (\texttt{\small 7}) con una
1700 \func{read}\footnote{si è fatta l'assunzione implicita che i dati siano
1701   contenuti tutti in un solo segmento, così che la chiamata a \texttt{read} li
1702   restituisca sempre tutti; avendo scelto una dimensione ridotta per il buffer
1703   questo sarà sempre vero, vedremo più avanti come superare il problema di
1704   rileggere indietro tutti e soli i dati disponibili, senza bloccarsi.} sul
1705 buffer di ricezione e viene inserita (\texttt{\small 8}) la terminazione della
1706 stringa e per poter usare (\texttt{\small 9}) la funzione \func{fputs} per
1707 scriverli su \file{stdout}.
1708
1709 \begin{figure}[!htb]
1710   \footnotesize \centering
1711   \begin{minipage}[c]{15.6cm}
1712     \includecodesample{listati/ClientEcho_first.c}
1713   \end{minipage} 
1714   \normalsize
1715   \caption{Codice della prima versione della funzione \texttt{ClientEcho} per 
1716     la gestione del servizio \textit{echo}.}
1717   \label{fig:TCP_client_echo_sub}
1718 \end{figure}
1719
1720 Quando si concluderà l'invio di dati mandando un end-of-file sullo standard
1721 input si avrà il ritorno di \func{fgets} con un puntatore nullo (si riveda
1722 quanto spiegato in \secref{sec:file_line_io}) e la conseguente uscita dal
1723 ciclo; al che la subroutine ritorna ed il nostro programma client termina.
1724
1725 Si può effettuare una verifica del funzionamento del client abilitando il
1726 servizio \textit{echo} nella configurazione di \cmd{initd} sulla propria
1727 macchina ed usandolo direttamente verso di esso in locale, vedremo in
1728 dettaglio più avanti (in \secref{sec:TCP_echo_startup}) il funzionamento del
1729 programma, usato però con la nostra versione del server \textit{echo}, che
1730 illustriamo immediatamente.
1731
1732
1733 \subsection{Il server \textit{echo}: prima versione}
1734 \label{sec:TCPsimp_server_main}
1735
1736 La prima versione del server, contenuta nel file \file{TCP\_echod\_first.c}, è
1737 riportata in \figref{fig:TCP_echo_server_first_code}. Come abbiamo fatto per
1738 il client anche il server è stato diviso in un corpo principale, costituito
1739 dalla funzione \code{main}, che è molto simile a quello visto nel precedente
1740 esempio per il server del servizio \textit{daytime} di
1741 \secref{sec:TCP_daytime_cunc_server}, e da una funzione ausiliaria
1742 \code{ServEcho} che si cura della gestione del servizio.
1743
1744 \begin{figure}[!htbp]
1745   \footnotesize \centering
1746   \begin{minipage}[c]{15.6cm}
1747     \includecodesample{listati/TCP_echod_first.c}
1748   \end{minipage} 
1749   \normalsize
1750   \caption{Codice del corpo principale della prima versione del server
1751     per il servizio \textit{echo}.}
1752   \label{fig:TCP_echo_server_first_code}
1753 \end{figure}
1754
1755 In questo caso però, rispetto a quanto visto nell'esempio di
1756 \figref{fig:TCP_daytime_cunc_server_code} si è preferito scrivere il server
1757 curando maggiormente alcuni dettagli, per tenere conto anche di alcune
1758 esigenze generali (che non riguardano direttamente la rete), come la
1759 possibilità di lanciare il server anche in modalità interattiva e la cessione
1760 dei privilegi di amministratore non appena questi non sono più necessari.
1761
1762 La sezione iniziale del programma (\texttt{\small 8--21}) è la stessa del
1763 server di \secref{sec:TCP_daytime_cunc_server}, ed ivi descritta in dettaglio:
1764 crea il socket, inizializza l'indirizzo e esegue \func{bind}; dato che
1765 quest'ultima funzione viene usata su una porta riservata, il server dovrà
1766 essere eseguito da un processo con i privilegi di amministratore, pena il
1767 fallimento della chiamata.
1768
1769 Una volta eseguita la funzione \func{bind} però i privilegi di amministratore
1770 non sono più necessari, per questo è sempre opportuno rilasciarli, in modo da
1771 evitare problemi in caso di eventuali vulnerabilità del server.  Per questo
1772 prima (\texttt{\small 22--26}) si esegue \func{setgid} per assegnare il
1773 processo ad un gruppo senza privilegi,\footnote{si è usato il valore 65534,
1774   ovvero -1 per il formato \ctyp{short}, che di norma in tutte le
1775   distribuzioni viene usato per identificare il gruppo \texttt{nogroup} e
1776   l'utente \texttt{nobody}, usati appunto per eseguire programmi che non
1777   richiedono nessun privilegio particolare.} e poi si ripete (\texttt{\small
1778   27--30}) l'operazione usando \func{setuid} per cambiare anche
1779 l'utente.\footnote{si tenga presente che l'ordine in cui si eseguono queste
1780   due operazioni è importante, infatti solo avendo i privilegi di
1781   amministratore si può cambiare il gruppo di un processo ad un'altro di cui
1782   non si fa parte, per cui chiamare prima \func{setuid} farebbe fallire una
1783   successiva chiamata a \func{setgid}.  Inoltre si ricordi (si riveda quanto
1784   esposto in \secref{sec:proc_perms}) che usando queste due funzioni il
1785   rilascio dei privilegi è irreversibile.}  Infine (\texttt{\small 30--36}),
1786 qualora sia impostata la variabile \var{demonize}, prima (\texttt{\small 31})
1787 si apre il sistema di logging per la stampa degli errori, e poi
1788 (\texttt{\small 32--35}) si invoca \func{daemon} per eseguire in background il
1789 processo come demone.
1790
1791 A questo punto il programma riprende di nuovo lo schema già visto usato dal
1792 server per il servizio \textit{daytime}, con l'unica differenza della chiamata
1793 alla funzione \code{PrintErr}, riportata in \figref{fig:TCP_PrintErr}, al
1794 posto di \func{perror} per la stampa degli errori. 
1795
1796 Si inizia con il porre (\texttt{\small 37--41}) in ascolto il socket, e poi si
1797 esegue indefinitamente il ciclo principale (\texttt{\small 42--59}).
1798 All'interno di questo si ricevono (\texttt{\small 43--47}) le connessioni,
1799 creando (\texttt{\small 48--51}) un processo figlio per ciascuna di esse.
1800 Quest'ultimo (\texttt{\small 52--56}), chiuso (\texttt{\small 53}) il
1801 \textit{listening socket}, esegue (\texttt{\small 54}) la funzione di gestione
1802 del servizio \code{ServEcho}, ed al ritorno di questa esce (\texttt{\small
1803   55}).
1804
1805 Il padre invece si limita (\texttt{\small 57}) a chiudere il \textit{connected
1806   socket} per ricominciare da capo il ciclo in attesa di nuove connessioni. In
1807 questo modo si ha un server concorrente. La terminazione del padre non è
1808 gestita esplicitamente, e deve essere effettuata inviando un segnale al
1809 processo.
1810
1811 Avendo trattato direttamente la gestione del programma come demone, si è
1812 dovuto anche provvedere alla necessità di poter stampare eventuali messaggi di
1813 errore attraverso il sistema del \textit{syslog} trattato in
1814 \secref{sec:sess_daemon}. Come accennato questo è stato fatto utilizzando come
1815 \textit{wrapper} la funzione \code{PrintErr}, il cui codice è riportato in
1816 \figref{fig:TCP_PrintErr}. 
1817
1818 In essa ci si limita a controllare (\texttt{\small 2}) se è stato impostato
1819 (valore attivo per default) l'uso come demone, nel qual caso (\texttt{\small
1820   3}) si usa \func{syslog} (vedi \secref{sec:sess_daemon}) per stampare il
1821 messaggio di errore fornito come argomento sui log di sistema. Se invece si è
1822 in modalità interattiva (attivabile con l'opzione \texttt{-i}) si usa
1823 (\texttt{\small 5}) semplicemente la funzione \func{perror} per stampare sullo
1824 standard error.
1825
1826 \begin{figure}[!htb]
1827   \footnotesize \centering
1828   \begin{minipage}[c]{15.6cm}
1829     \includecodesample{listati/PrintErr.c}
1830   \end{minipage} 
1831   \normalsize
1832   \caption{Codice della funzione \code{PrintErr} per la
1833     generalizzazione della stampa degli errori sullo standard input o
1834     attraverso il \texttt{syslog}.}
1835   \label{fig:TCP_PrintErr}
1836 \end{figure}
1837
1838 La gestione del servizio \textit{echo} viene effettuata interamente nella
1839 funzione \code{ServEcho}, il cui codice è mostrato in
1840 \figref{fig:TCP_ServEcho_first}, e la comunicazione viene gestita all'interno
1841 di un ciclo (\texttt{\small 6--13}).  I dati inviati dal client vengono letti
1842 (\texttt{\small 6}) dal socket con una semplice \func{read}, di cui non si
1843 controlla lo stato di uscita, assumendo che ritorni solo in presenza di dati
1844 in arrivo. La riscrittura (\texttt{\small 7}) viene invece gestita dalla
1845 funzione \func{FullWrite} (descritta in \figref{fig:sock_FullWrite_code}) che
1846 si incarica di tenere conto automaticamente della possibilità che non tutti i
1847 dati di cui è richiesta la scrittura vengano trasmessi con una singola
1848 \func{write}.
1849
1850 \begin{figure}[!htb] 
1851   \footnotesize \centering
1852   \begin{minipage}[c]{15.6cm}
1853     \includecodesample{listati/ServEcho_first.c}
1854   \end{minipage} 
1855   \normalsize
1856   \caption{Codice della prima versione della funzione \code{ServEcho} per la
1857     gestione del servizio \textit{echo}.}
1858   \label{fig:TCP_ServEcho_first}
1859 \end{figure}
1860
1861 In caso di errore di scrittura (si ricordi che \func{FullWrite} restituisce un
1862 valore nullo in caso di successo) si provvede (\texttt{\small 8--10}) a
1863 stampare il relativo messaggio con \func{PrintErr}.  Quando il client chiude
1864 la connessione il ricevimento del FIN fa ritornare la \func{read} con un
1865 numero di byte letti pari a zero, il che causa l'uscita dal ciclo e il ritorno
1866 (\texttt{\small 12}) della funzione, che a sua volta causa la terminazione del
1867 processo figlio.
1868
1869
1870 \subsection{L'avvio e il funzionamento normale}
1871 \label{sec:TCP_echo_startup}
1872
1873 Benché il codice dell'esempio precedente sia molto ridotto, esso ci permetterà
1874 di considerare in dettaglio le varie problematiche che si possono incontrare
1875 nello scrivere un'applicazione di rete. Infatti attraverso l'esame delle sue
1876 modalità di funzionamento normali, all'avvio e alla terminazione, e di quello
1877 che avviene nelle varie situazioni limite, da una parte potremo approfondire
1878 la comprensione del protocollo TCP/IP e dall'altra ricavare le indicazioni
1879 necessarie per essere in grado di scrivere applicazioni robuste, in grado di
1880 gestire anche i casi limite.
1881
1882 Il primo passo è compilare e lanciare il server (da root, per poter usare la
1883 porta 7 che è riservata), alla partenza esso eseguirà l'apertura passiva con
1884 la sequenza delle chiamate a \func{socket}, \func{bind}, \func{listen} e poi
1885 si bloccherà nella \func{accept}. A questo punto si potrà controllarne lo
1886 stato con \cmd{netstat}:
1887 \begin{verbatim}
1888 [piccardi@roke piccardi]$ netstat -at
1889 Active Internet connections (servers and established)
1890 Proto Recv-Q Send-Q Local Address           Foreign Address         State 
1891 ...
1892 tcp        0      0 *:echo                  *:*                     LISTEN
1893 ...
1894 \end{verbatim} %$
1895 che ci mostra come il socket sia in ascolto sulla porta richiesta, accettando
1896 connessioni da qualunque indirizzo e da qualunque porta e su qualunque
1897 interfaccia locale.
1898
1899 A questo punto si può lanciare il client, esso chiamerà \func{socket} e
1900 \func{connect}; una volta completato il three way handshake la connessione è
1901 stabilita; la \func{connect} ritornerà nel client\footnote{si noti che è
1902   sempre la \func{connect} del client a ritornare per prima, in quanto
1903   questo avviene alla ricezione del secondo segmento (l'ACK del server) del
1904   three way handshake, la \func{accept} del server ritorna solo dopo
1905   un altro mezzo RTT quando il terzo segmento (l'ACK del client) viene
1906   ricevuto.} e la \func{accept} nel server, ed usando di nuovo
1907 \cmd{netstat} otterremmo che:
1908 \begin{verbatim}
1909 Active Internet connections (servers and established)
1910 Proto Recv-Q Send-Q Local Address           Foreign Address         State
1911 tcp        0      0 *:echo                  *:*                     LISTEN
1912 tcp        0      0 roke:echo               gont:32981              ESTABLISHED
1913 \end{verbatim}
1914 mentre per quanto riguarda l'esecuzione dei programmi avremo che:
1915 \begin{itemize}
1916 \item il client chiama la funzione \code{ClientEcho} che si blocca sulla
1917   \func{fgets} dato che non si è ancora scritto nulla sul terminale.
1918 \item il server eseguirà una \func{fork} facendo chiamare al processo figlio
1919   la funzione \code{ServEcho}, quest'ultima si bloccherà sulla \func{read}
1920   dal socket sul quale ancora non sono presenti dati.
1921 \item il processo padre del server chiamerà di nuovo \func{accept}
1922   bloccandosi fino all'arrivo di un'altra connessione.
1923 \end{itemize}
1924 e se usiamo il comando \cmd{ps} per esaminare lo stato dei processi otterremo
1925 un risultato del tipo:
1926 \begin{verbatim}
1927 [piccardi@roke piccardi]$ ps ax
1928   PID TTY      STAT   TIME COMMAND
1929  ...  ...      ...    ...  ...
1930  2356 pts/0    S      0:00 ./echod
1931  2358 pts/1    S      0:00 ./echo 127.0.0.1
1932  2359 pts/0    S      0:00 ./echod
1933 \end{verbatim} %$
1934 (dove si sono cancellate le righe inutili) da cui si evidenzia la presenza di
1935 tre processi, tutti in stato di \textit{sleep} (vedi
1936 \tabref{tab:proc_proc_states}).
1937
1938 Se a questo punto si inizia a scrivere qualcosa sul client non sarà trasmesso
1939 niente fin tanto che non si prema il tasto di a capo (si ricordi quanto detto
1940 in \secref{sec:file_line_io} a proposito dell'I/O su terminale), solo allora
1941 \func{fgets} ritornerà ed il client scriverà quanto immesso sul socket, per
1942 poi passare a rileggere quanto gli viene inviato all'indietro dal server, che
1943 a sua volta sarà inviato sullo standard output, che nel caso ne provoca
1944 l'immediatamente stampa a video.
1945
1946
1947 \subsection{La conclusione normale}
1948 \label{sec:TCP_echo_conclusion}
1949
1950 Tutto quello che scriveremo sul client sarà rimandato indietro dal server e
1951 ristampato a video fintanto che non concluderemo l'immissione dei dati; una
1952 sessione tipica sarà allora del tipo: 
1953 \begin{verbatim}
1954 [piccardi@roke sources]$ ./echo 127.0.0.1
1955 Questa e` una prova
1956 Questa e` una prova
1957 Ho finito
1958 Ho finito
1959 \end{verbatim} %$
1960 che termineremo inviando un EOF dal terminale (usando la combinazione di tasti
1961 ctrl-D, che non compare a schermo); se eseguiamo un \cmd{netstat} a questo
1962 punto avremo:
1963 \begin{verbatim}
1964 [piccardi@roke piccardi]$ netstat -at 
1965 tcp        0      0 *:echo                  *:*                     LISTEN
1966 tcp        0      0 localhost:33032         localhost:echo          TIME_WAIT
1967 \end{verbatim} %$
1968 con il client che entra in \texttt{TIME\_WAIT}.
1969
1970 Esaminiamo allora in dettaglio la sequenza di eventi che porta alla
1971 terminazione normale della connessione, che ci servirà poi da riferimento
1972 quando affronteremo il comportamento in caso di conclusioni anomale:
1973
1974 \begin{enumerate}
1975 \item inviando un carattere di EOF da terminale la \func{fgets} ritorna
1976   restituendo un puntatore nullo che causa l'uscita dal ciclo di \code{while},
1977   così la funzione \code{ClientEcho} ritorna.
1978 \item al ritorno di \code{ClientEcho} ritorna anche la funzione \code{main}, e
1979   come parte del processo terminazione tutti i file descriptor vengono chiusi
1980   (si ricordi quanto detto in \secref{sec:proc_term_conclusion}); questo causa
1981   la chiusura del socket di comunicazione; il client allora invierà un FIN al
1982   server a cui questo risponderà con un ACK.  A questo punto il client verrà a
1983   trovarsi nello stato \texttt{FIN\_WAIT\_2} ed il server nello stato
1984   \texttt{CLOSE\_WAIT} (si riveda quanto spiegato in
1985   \secref{sec:TCP_conn_term}).
1986 \item quando il server riceve il FIN la \func{read} del processo figlio che
1987   gestisce la connessione ritorna restituendo 0 causando così l'uscita dal
1988   ciclo e il ritorno di \code{ServEcho}, a questo punto il processo figlio
1989   termina chiamando \func{exit}.
1990 \item all'uscita del figlio tutti i file descriptor vengono chiusi, la
1991   chiusura del socket connesso fa sì che venga effettuata la sequenza finale
1992   di chiusura della connessione, viene emesso un FIN dal server che riceverà
1993   un ACK dal client, a questo punto la connessione è conclusa e il client
1994   resta nello stato \texttt{TIME\_WAIT}.
1995 \end{enumerate}
1996
1997
1998 \subsection{La gestione dei processi figli}
1999 \label{sec:TCP_child_hand}
2000
2001 Tutto questo riguarda la connessione, c'è però da tenere conto dell'effetto
2002 del procedimento di chiusura del processo figlio nel server (si veda quanto
2003 esaminato in \secref{sec:proc_termination}). In questo caso avremo l'invio del
2004 segnale \const{SIGCHLD} al padre, ma dato che non si è installato un
2005 gestore e che l'azione predefinita per questo segnale è quella di essere
2006 ignorato, non avendo predisposto la ricezione dello stato di terminazione,
2007 otterremo che il processo figlio entrerà nello stato di zombie\index{zombie}
2008 (si riveda quanto illustrato in \secref{sec:sig_sigchld}), come risulterà
2009 ripetendo il comando \cmd{ps}:
2010 \begin{verbatim}
2011  2356 pts/0    S      0:00 ./echod
2012  2359 pts/0    Z      0:00 [echod <defunct>]
2013 \end{verbatim}
2014
2015 Dato che non è il caso di lasciare processi zombie\index{zombie}, occorrerà
2016 ricevere opportunamente lo stato di terminazione del processo (si veda
2017 \secref{sec:proc_wait}), cosa che faremo utilizzando \const{SIGCHLD} secondo
2018 quanto illustrato in \secref{sec:sig_sigchld}. Una prima modifica al nostro
2019 server è pertanto quella di inserire la gestione della terminazione dei
2020 processi figli attraverso l'uso di un gestore.  Per questo useremo la funzione
2021 \code{Signal} (che abbiamo illustrato in \figref{fig:sig_Signal_code}), per
2022 installare il gestore che riceve i segnali dei processi figli terminati già
2023 visto in \figref{fig:sig_sigchld_handl}.  Basterà allora aggiungere il
2024 seguente codice: \includecodesnip{listati/sigchildhand.c}
2025 \noindent
2026 all'esempio illustrato in \figref{fig:TCP_echo_server_first_code}.
2027
2028 In questo modo però si introduce un altro problema. Si ricordi infatti che,
2029 come spiegato in \secref{sec:sig_gen_beha}, quando un programma si trova in
2030 stato di \texttt{sleep} durante l'esecuzione di una system call, questa viene
2031 interrotta alla ricezione di un segnale. Per questo motivo, alla fine
2032 dell'esecuzione del gestore del segnale, se questo ritorna, il programma
2033 riprenderà l'esecuzione ritornando dalla system call interrotta con un errore
2034 di \errcode{EINTR}.
2035
2036 Vediamo allora cosa comporta tutto questo nel nostro caso: quando si chiude il
2037 client, il processo figlio che gestisce la connessione terminerà, ed il padre,
2038 per evitare la creazione di zombie, riceverà il segnale \const{SIGCHLD}
2039 eseguendo il relativo gestore. Al ritorno del gestore però l'esecuzione nel
2040 padre ripartirà subito con il ritorno della funzione \func{accept} (a meno di
2041 un caso fortuito in cui il segnale arriva durante l'esecuzione del programma
2042 in risposta ad una connessione) con un errore di \errcode{EINTR}. Non avendo
2043 previsto questa eventualità il programma considera questo un errore fatale
2044 terminando a sua volta con un messaggio del tipo:
2045 \begin{verbatim}
2046 [root@gont sources]# ./echod -i
2047 accept error: Interrupted system call
2048 \end{verbatim}%#
2049
2050 Come accennato in \secref{sec:sig_gen_beha} le conseguenze di questo
2051 comportamento delle system call possono essere superate in due modi diversi,
2052 il più semplice è quello di modificare il codice di \func{Signal} per
2053 richiedere il riavvio automatico delle system call interrotte secondo la
2054 semantica di BSD, usando l'opzione \const{SA\_RESTART} di \func{sigaction};
2055 rispetto a quanto visto in \figref{fig:sig_Signal_code}. Definiremo allora la
2056 nuova funzione \func{SignalRestart}\footnote{anche questa è definita, insieme
2057   alle altre funzioni riguardanti la gestione dei segnali, nel file
2058   \file{SigHand.c}, il cui contento completo può essere trovato negli esempi
2059   allegati.} come mostrato in \figref{fig:sig_SignalRestart_code}, ed
2060 installeremo il gestore usando quest'ultima.
2061
2062 \begin{figure}[!htb]
2063   \footnotesize  \centering
2064   \begin{minipage}[c]{15.6cm}
2065     \includecodesample{listati/SignalRestart.c}
2066   \end{minipage}  
2067   \normalsize 
2068   \caption{La funzione \funcd{SignalRestart}, che installa un gestore di
2069     segnali in semantica BSD per il riavvio automatico delle system call
2070     interrotte.}
2071   \label{fig:sig_SignalRestart_code}
2072 \end{figure}
2073
2074 Come si può notare questa funzione è identica alla precedente \func{Signal},
2075 illustrata in \figref{fig:sig_Signal_code}, solo che in questo caso invece di
2076 inizializzare a zero il campo \var{sa\_flags} di \struct{sigaction}, lo si
2077 inizializza (\texttt{\small 5}) al valore \const{SA\_RESTART}. Usando questa
2078 funzione al posto di \func{Signal} nel server non è necessaria nessuna altra
2079 modifica: le system call interrotte saranno automaticamente riavviate, e
2080 l'errore \errcode{EINTR} non si manifesterà più.
2081
2082 La seconda soluzione è più invasiva e richiede di controllare tutte le volte
2083 l'errore restituito dalle varie system call, ripetendo la chiamata qualora
2084 questo corrisponda ad \errcode{EINTR}. Questa soluzione ha però il pregio
2085 della portabilità, infatti lo standard POSIX dice che la funzionalità di
2086 riavvio automatico delle system call, fornita da \const{SA\_RESTART}, è
2087 opzionale, per cui non è detto che essa sia disponibile su qualunque sistema.
2088 Inoltre in certi casi,\footnote{Stevens in \cite{UNP1} accenna che la maggior
2089   parte degli Unix derivati da BSD non fanno ripartire \func{select}; altri
2090   non riavviano neanche \func{accept} e \func{recvfrom}, cosa che invece nel
2091   caso di Linux viene sempre fatta.} anche quando questa è presente, non è
2092 detto possa essere usata con \func{accept}. 
2093
2094
2095 La portabilità nella gestione dei segnali però viene al costo di una
2096 riscrittura parziale del server, la nuova versione di questo, in cui si sono
2097 introdotte una serie di nuove opzioni che ci saranno utili per il debug, è
2098 mostrata in \figref{fig:TCP_echo_server_code_second}, dove si sono riportate
2099 la sezioni di codice modificate nella seconda versione del programma, il
2100 codice completo di quest'ultimo si trova nel file \file{TCP\_echod\_second.c}
2101 dei sorgenti allegati alla guida.
2102
2103 La prima modifica effettuata è stata quella di introdurre una nuova opzione a
2104 riga di comando, \texttt{-c}, che permette di richiedere il comportamento
2105 compatibile nella gestione di \const{SIGCHLD} al posto della semantica BSD
2106 impostando la variabile \var{compat} ad un valore non nullo. Questa è
2107 preimpostata al valore nullo, cosicché se non si usa questa opzione il
2108 comportamento di default del server è di usare la semantica BSD. 
2109
2110 Una seconda opzione aggiunta è quella di inserire un tempo di attesa fisso
2111 specificato in secondi fra il ritorno della funzione \func{listen} e la
2112 chiamata di \func{accept}, specificabile con l'opzione \texttt{-w}, che
2113 permette di impostare la variabile \var{waiting}.  Infine si è introdotta una
2114 opzione \texttt{-d} per abilitare il debugging che imposta ad un valore non
2115 nullo la variabile \var{debugging}. Al solito si è omessa da
2116 \figref{fig:TCP_echo_server_code_second} la sezione di codice relativa alla
2117 gestione di tutte queste opzioni, che può essere trovata nel sorgente del
2118 programma.
2119
2120 \begin{figure}[!htb]
2121   \footnotesize \centering
2122   \begin{minipage}[c]{15.6cm}
2123     \includecodesample{listati/TCP_echod_second.c}
2124   \end{minipage} 
2125   \normalsize
2126   \caption{La sezione nel codice della seconda versione del server
2127     per il servizio \textit{echo} modificata per tener conto dell'interruzione
2128     delle system call.}
2129   \label{fig:TCP_echo_server_code_second}
2130 \end{figure}
2131
2132 Vediamo allora come è cambiato il nostro server; una volta definite le
2133 variabili e trattate le opzioni il primo passo (\texttt{\small 9--13}) è
2134 verificare la semantica scelta per la gestione di \const{SIGCHLD}, a seconda
2135 del valore di \var{compat} (\texttt{\small 9}) si installa il gestore con la
2136 funzione \func{Signal} (\texttt{\small 10}) o con \texttt{SignalRestart}
2137 (\texttt{\small 12}), essendo quest'ultimo il valore di default.
2138
2139 Tutta la sezione seguente, che crea il socket, cede i privilegi di
2140 amministratore ed eventualmente lancia il programma come demone, è rimasta
2141 invariata e pertanto è stata omessa in
2142 \figref{fig:TCP_echo_server_code_second}; l'unica modifica effettuata prima
2143 dell'entrata nel ciclo principale è stata quella di aver introdotto, subito
2144 dopo la chiamata (\texttt{\small 17--20}) alla funzione \func{listen}, una
2145 eventuale pausa con una condizione (\texttt{\small 21}) sulla variabile
2146 \var{waiting}, che viene inizializzata, con l'opzione \code{-w Nsec}, al
2147 numero di secondi da aspettare (il valore preimpostato è nullo).
2148
2149 Si è potuto lasciare inalterata tutta la sezione di creazione del socket
2150 perché nel server l'unica chiamata ad una system call critica, che può essere
2151 interrotta dall'arrivo di \const{SIGCHLD}, è quella ad \func{accept}, che è
2152 l'unica funzione che può mettere il processo padre in stato di sleep nel
2153 periodo in cui un figlio può terminare; si noti infatti come le altre
2154 \index{system call lente} \textit{slow system call}\footnote{si ricordi la
2155   distinzione fatta in \secref{sec:sig_gen_beha}.} o sono chiamate prima di
2156 entrare nel ciclo principale, quando ancora non esistono processi figli, o
2157 sono chiamate dai figli stessi e non risentono di \const{SIGCHLD}.
2158
2159 Per questo l'unica modifica sostanziale nel ciclo principale (\texttt{\small
2160   23--42}), rispetto precedente versione di \figref{fig:TCP_ServEcho_first}, è
2161 nella sezione (\texttt{\small 25--31}) in cui si effettua la chiamata di
2162 \func{accept}.  Quest'ultima viene effettuata (\texttt{\small 26--27})
2163 all'interno di un ciclo di \code{while}\footnote{la sintassi del C relativa a
2164   questo ciclo può non essere del tutto chiara. In questo caso infatti si è
2165   usato un ciclo vuoto che non esegue nessuna istruzione, in questo modo
2166   quello che viene ripetuto con il ciclo è soltanto il codice che esprime la
2167   condizione all'interno del \code{while}.}  che la ripete indefinitamente
2168 qualora in caso di errore il valore di \var{errno} sia \errcode{EINTR}. Negli
2169 altri casi si esce in caso di errore effettivo (\texttt{\small 27--29}),
2170 altrimenti il programma prosegue.
2171
2172 Si noti che in questa nuova versione si è aggiunta una ulteriore sezione
2173 (\texttt{\small 32--40}) di aiuto per il debug del programma, che eseguita con
2174 un controllo (\texttt{\small 33}) sul valore della variabile \var{debugging}
2175 impostato dall'opzione \texttt{-d}. Qualora questo sia nullo, come
2176 preimpostato, non accade nulla. altrimenti (\texttt{\small 33}) l'indirizzo
2177 ricevuto da \var{accept} viene convertito in una stringa che poi
2178 (\texttt{\small 34--39}) viene opportunamente stampata o sullo schermo o nei
2179 log.
2180
2181 Infine come ulteriore miglioria si è perfezionata la funzione \code{ServEcho},
2182 sia per tenere conto della nuova funzionalità di debugging, che per effettuare
2183 un controllo in caso di errore; il codice della nuova versione è mostrato in
2184 \figref{fig:TCP_ServEcho_second}.
2185
2186 \begin{figure}[!htb] 
2187   \footnotesize \centering
2188   \begin{minipage}[c]{15.6cm}
2189     \includecodesample{listati/ServEcho_second.c}
2190   \end{minipage} 
2191   \normalsize
2192   \caption{Codice della seconda versione della funzione \code{ServEcho} per la
2193     gestione del servizio \textit{echo}.}
2194   \label{fig:TCP_ServEcho_second}
2195 \end{figure}
2196
2197 Rispetto alla precedente versione di \figref{fig:TCP_ServEcho_first} in questo
2198 caso si è provveduto a controllare (\texttt{\small 7--10}) il valore di
2199 ritorno di \func{read} per rilevare un eventuale errore, in modo da stampare
2200 (\texttt{\small 8}) un messaggio di errore e ritornare (\texttt{\small 9})
2201 concludendo la connessione.
2202
2203 Inoltre qualora sia stata attivata la funzionalità di debug (avvalorando
2204 \var{debugging} tramite l'apposita opzione \texttt{-d}) si provvederà a
2205 stampare (tenendo conto della modalità di invocazione del server, se
2206 interattiva o in forma di demone) il numero di byte e la stringa letta dal
2207 client (\texttt{\small 16--24}).
2208
2209
2210 \section{I vari scenari critici}
2211 \label{sec:TCP_echo_critical}
2212
2213 Con le modifiche viste in \secref{sec:TCP_child_hand} il nostro esempio
2214 diventa in grado di affrontare la gestione ordinaria delle connessioni, ma un
2215 server di rete deve tenere conto che, al contrario di quanto avviene per i
2216 server che operano nei confronti di processi presenti sulla stessa macchina,
2217 la rete è di sua natura inaffidabile, per cui è necessario essere in grado di
2218 gestire tutta una serie di situazioni critiche che non esistono per i processi
2219 locali.
2220
2221
2222 \subsection{La terminazione precoce della connessione}
2223 \label{sec:TCP_conn_early_abort}
2224
2225 La prima situazione critica è quella della terminazione precoce, causata da un
2226 qualche errore sulla rete, della connessione effettuata da un client. Come
2227 accennato in \secref{sec:TCP_func_accept} la funzione \func{accept} riporta
2228 tutti gli eventuali errori di rete pendenti su una connessione sul
2229 \textit{connected socket}. Di norma questo non è un problema, in quanto non
2230 appena completata la connessione, \func{accept} ritorna e l'errore sarà
2231 rilevato in seguito, dal processo che gestisce la connessione, alla prima
2232 chiamata di una funzione che opera sul socket.
2233
2234 È però possibile, dal punto di vista teorico, incorrere anche in uno scenario
2235 del tipo di quello mostrato in \figref{fig:TCP_early_abort}, in cui la
2236 connessione viene abortita sul lato client per un qualche errore di rete con
2237 l'invio di un segmento RST, prima che nel server sia stata chiamata la
2238 funzione \func{accept}.
2239
2240 \begin{figure}[htb]
2241   \centering
2242   \includegraphics[width=10cm]{img/tcp_client_early_abort}  
2243   \caption{Un possibile caso di terminazione precoce della connessione.}
2244   \label{fig:TCP_early_abort}
2245 \end{figure}
2246
2247 Benché questo non sia un fatto comune, un evento simile può essere osservato
2248 con dei server molto occupati. In tal caso, con una struttura del server
2249 simile a quella del nostro esempio, in cui la gestione delle singole
2250 connessioni è demandata a processi figli, può accadere che il three way
2251 handshake venga completato e la relativa connessione abortita subito dopo,
2252 prima che il padre, per via del carico della macchina, abbia fatto in tempo ad
2253 eseguire la chiamata ad \func{accept}. Di nuovo si ha una situazione analoga
2254 a quella illustrata in \figref{fig:TCP_early_abort}, in cui la connessione
2255 viene stabilita, ma subito dopo si ha una condizione di errore che la chiude
2256 prima che essa sia stata accettata dal programma.
2257
2258 Questo significa che, oltre alla interruzione da parte di un segnale, che
2259 abbiamo trattato in \secref{sec:TCP_child_hand} nel caso particolare di
2260 \const{SIGCHLD}, si possono ricevere altri errori non fatali all'uscita di
2261 \func{accept}, che come nel caso precedente, necessitano semplicemente la
2262 ripetizione della chiamata senza che si debba uscire dal programma. In questo
2263 caso anche la versione modificata del nostro server non sarebbe adatta, in
2264 quanto uno di questi errori causerebbe la terminazione dello stesso. In Linux
2265 i possibili errori di rete non fatali, riportati sul socket connesso al
2266 ritorno di \func{accept}, sono \errcode{ENETDOWN}, \errcode{EPROTO},
2267 \errcode{ENOPROTOOPT}, \errcode{EHOSTDOWN}, \errcode{ENONET},
2268 \errcode{EHOSTUNREACH}, \errcode{EOPNOTSUPP} e \errcode{ENETUNREACH}.
2269
2270 Si tenga presente che questo tipo di terminazione non è riproducibile
2271 terminando il client prima della chiamata ad \func{accept}, come si potrebbe
2272 fare usando l'opzione \texttt{-w} per introdurre una pausa dopo il lancio del
2273 demone, in modo da poter avere il tempo per lanciare e terminare una
2274 connessione usando il programma client. In tal caso infatti, alla terminazione
2275 del client, il socket associato alla connessione viene semplicemente chiuso,
2276 attraverso la sequenza vista in \secref{sec:TCP_conn_term}, per cui la
2277 \func{accept} ritornerà senza errori, e si avrà semplicemente un end-of-file
2278 al primo accesso al socket. Nel caso di Linux inoltre, anche qualora si
2279 modifichi il client per fargli gestire l'invio di un segmento di RST alla
2280 chiusura dal socket (come suggerito da Stevens in \cite{UNP1}), non si ha
2281 nessun errore al ritorno di \funcd{accept}, quanto un errore di
2282 \errcode{ECONNRESET} al primo tentativo di accesso al socket.
2283
2284
2285
2286 \subsection{La terminazione precoce del server}
2287 \label{sec:TCP_server_crash}
2288
2289 Un secondo caso critico è quello in cui si ha una terminazione precoce del
2290 server, ad esempio perché il programma ha un crash. In tal caso si suppone che
2291 il processo termini per un errore fatale, cosa che potremo simulare
2292 inviandogli un segnale di terminazione. La conclusione del processo comporta
2293 la chiusura di tutti i file descriptor aperti, compresi tutti i socket
2294 relativi a connessioni stabilite; questo significa che al momento del crollo
2295 del servizio il client riceverà un FIN dal server in corrispondenza della
2296 chiusura del socket.
2297
2298 Vediamo allora cosa succede nel nostro caso, facciamo partire una connessione
2299 con il server e scriviamo una prima riga, poi terminiamo il server con un
2300 \texttt{C-c}. A questo punto scriviamo una seconda riga e poi un'altra riga
2301 ancora. Il risultato finale della sessione è il seguente:
2302 \begin{verbatim}
2303 [piccardi@gont sources]$ ./echo 192.168.1.141
2304 Prima riga
2305 Prima riga
2306 Seconda riga dopo il C-c
2307 Altra riga
2308 [piccardi@gont sources]$
2309 \end{verbatim}
2310
2311 Come si vede il nostro client, nonostante la connessione sia stata interrotta
2312 prima dell'invio della seconda riga, non solo accetta di inviarla, ma prende
2313 anche un'altra riga prima di terminare senza riportare nessun
2314 errore. 
2315
2316 Per capire meglio cosa è successo conviene analizzare il flusso dei pacchetti
2317 utilizzando un analizzatore di traffico come \cmd{tcpdump}. Il comando
2318 permette di selezionare, nel traffico di rete generato su una macchina, i
2319 pacchetti che interessano, stampando a video (o salvando su disco) il loro
2320 contenuto. Non staremo qui ad entrare nei dettagli dell'uso del programma, che
2321 sono spiegati dalla pagina di manuale; per l'uso che vogliamo farne quello che
2322 ci interessa è, posizionandosi sulla macchina che fa da client, selezionare
2323 tutti i pacchetti che sono diretti o provengono dalla macchina che fa da
2324 server. In questo modo (posto che non ci siano altre connessioni col server,
2325 cosa che avremo cura di evitare) tutti i pacchetti rilevati apparterranno alla
2326 nostra sessione di interrogazione del servizio. 
2327
2328 Il comando \cmd{tcpdump} permette selezioni molto complesse, basate sulle
2329 interfacce su cui passano i pacchetti, sugli indirizzi IP, sulle porte, sulle
2330 caratteristiche ed il contenuto dei pacchetti stessi, inoltre permette di
2331 combinare fra loro diversi criteri di selezione con degli operatori logici;
2332 quando un pacchetto che corrisponde ai criteri di selezione scelti viene
2333 rilevato i suoi dati vengono stampati sullo schermo (anche questi secondo un
2334 formato configurabile in maniera molto precisa).  
2335
2336 Lanciando il comando prima di ripetere la sessione di lavoro mostrata
2337 nell'esempio precedente potremo allora catturare tutti pacchetti scambiati fra
2338 il client ed il server; i risultati\footnote{in realtà si è ridotta la
2339   lunghezza dell'output rispetto al reale tagliando alcuni dati non necessari
2340   alla comprensione del flusso.} prodotti in questa occasione da \cmd{tcpdump}
2341 sono allora i seguenti:
2342 \begin{verbatim}
2343 [root@gont gapil]# tcpdump src 192.168.1.141 or dst 192.168.1.141 -N -t
2344 tcpdump: listening on eth0
2345 gont.34559 > anarres.echo: S 800922320:800922320(0) win 5840 
2346 anarres.echo > gont.34559: S 511689719:511689719(0) ack 800922321 win 5792 
2347 gont.34559 > anarres.echo: . ack 1 win 5840 
2348 gont.34559 > anarres.echo: P 1:12(11) ack 1 win 5840 
2349 anarres.echo > gont.34559: . ack 12 win 5792 
2350 anarres.echo > gont.34559: P 1:12(11) ack 12 win 5792 
2351 gont.34559 > anarres.echo: . ack 12 win 5840 
2352 anarres.echo > gont.34559: F 12:12(0) ack 12 win 5792 
2353 gont.34559 > anarres.echo: . ack 13 win 5840 
2354 gont.34559 > anarres.echo: P 12:37(25) ack 13 win 5840 
2355 anarres.echo > gont.34559: R 511689732:511689732(0) win 0 
2356 \end{verbatim}
2357
2358 Le prime tre righe vengono prodotte al momento in cui lanciamo il nostro
2359 client, e corrispondono ai tre pacchetti del three way handshake. L'output del
2360 comando riporta anche i numeri di sequenza iniziali, mentre la lettera
2361 \texttt{S} indica che per quel pacchetto si aveva il SYN flag attivo. Si noti
2362 come a partire dal secondo pacchetto sia sempre attivo il campo \texttt{ack},
2363 seguito dal numero di sequenza per il quale si da il ricevuto; quest'ultimo, a
2364 partire dal terzo pacchetto, viene espresso in forma relativa per maggiore
2365 compattezza.  Il campo \texttt{win} in ogni riga indica la \textit{advertising
2366   window} di cui parlavamo in \secref{sec:TCP_TCP_opt}. Allora si può
2367 verificare dall'output del comando come venga appunto realizzata la sequenza
2368 di pacchetti descritta in \secref{sec:TCP_conn_cre}: prima viene inviato dal
2369 client un primo pacchetto con il SYN che inizia la connessione, a cui il
2370 server risponde dando il ricevuto con un secondo pacchetto, che a sua volta
2371 porta un SYN, cui il client risponde con un il terzo pacchetto di ricevuto.
2372
2373 Ritorniamo allora alla nostra sessione con il servizio echo: dopo le tre righe
2374 del three way handshake non avremo nulla fin tanto che non scriveremo una
2375 prima riga sul client; al momento in cui facciamo questo si genera una
2376 sequenza di altri quattro pacchetti. Il primo, dal client al server,
2377 contraddistinto da una lettera \texttt{P} che significa che il flag PSH è
2378 impostato, contiene la nostra riga (che è appunto di 11 caratteri), e ad esso
2379 il server risponde immediatamente con un pacchetto vuoto di ricevuto. Poi
2380 tocca al server riscrivere indietro quanto gli è stato inviato, per cui sarà
2381 lui a mandare indietro un terzo pacchetto con lo stesso contenuto appena
2382 ricevuto, e a sua volta riceverà dal client un ACK nel quarto pacchetto.
2383 Questo causerà la ricezione dell'eco nel client che lo stamperà a video.
2384
2385 A questo punto noi procediamo ad interrompere l'esecuzione del server con un
2386 \texttt{C-c} (cioè con l'invio di \const{SIGTERM}): nel momento in cui
2387 facciamo questo vengono immediatamente generati altri due pacchetti. La
2388 terminazione del processo infatti comporta la chiusura di tutti i suoi file
2389 descriptor, il che comporta, per il socket che avevamo aperto, l'inizio della
2390 sequenza di chiusura illustrata in \secref{sec:TCP_conn_term}.  Questo
2391 significa che dal server partirà un FIN, che è appunto il primo dei due
2392 pacchetti, contraddistinto dalla lettera \texttt{F}, cui seguirà al solito un
2393 ACK da parte del client.  
2394
2395 A questo punto la connessione dalla parte del server è chiusa, ed infatti se
2396 usiamo \cmd{netstat} per controllarne lo stato otterremo che sul server si ha:
2397 \begin{verbatim}
2398 anarres:/home/piccardi# netstat -ant
2399 Active Internet connections (servers and established)
2400 Proto Recv-Q Send-Q Local Address           Foreign Address         State
2401 ...      ...    ... ...                     ...                     ...
2402 tcp        0      0 192.168.1.141:7         192.168.1.2:34626       FIN_WAIT2
2403 \end{verbatim}
2404 cioè essa è andata nello stato \texttt{FIN\_WAIT2}, che indica l'avvenuta
2405 emissione del segmento FIN, mentre sul client otterremo che essa è andata
2406 nello stato \texttt{CLOSE\_WAIT}:
2407 \begin{verbatim}
2408 [root@gont gapil]# netstat -ant
2409 Active Internet connections (servers and established)
2410 Proto Recv-Q Send-Q Local Address           Foreign Address         State
2411 ...      ...    ... ...                     ...                     ...
2412 tcp        1      0 192.168.1.2:34582       192.168.1.141:7         CLOSE_WAIT 
2413 \end{verbatim}
2414
2415 Il problema è che in questo momento il client è bloccato dentro la funzione
2416 \texttt{ClientEcho} nella chiamata a \func{fgets}, e sta attendendo dell'input
2417 dal terminale, per cui non è in grado di accorgersi di nulla. Solo quando
2418 inseriremo la seconda riga il comando uscirà da \func{fgets} e proverà a
2419 scriverla sul socket. Questo comporta la generazione degli ultimi due
2420 pacchetti riportati da \cmd{tcpdump}: il primo, inviato dal client contenente
2421 i 25 caratteri della riga appena letta, e ad esso la macchina server
2422 risponderà, non essendoci più niente in ascolto sulla porta 7, con un segmento
2423 di RST, contraddistinto dalla lettera \texttt{R}, che causa la conclusione
2424 definitiva della connessione anche nel client, dove non comparirà più
2425 nell'output di \cmd{netstat}.
2426
2427 Come abbiamo accennato in \secref{sec:TCP_conn_term} e come vedremo più avanti
2428 in \secref{sec:TCP_shutdown} la chiusura di un solo capo di un socket è
2429 una operazione lecita, per cui la nostra scrittura avrà comunque successo
2430 (come si può constatare lanciando usando \cmd{strace}\footnote{il comando
2431   \cmd{strace} è un comando di debug molto utile che prende come parametro un
2432   altro comando e ne stampa a video tutte le invocazioni di una system call,
2433   coi relativi parametri e valori di ritorno, per cui usandolo in questo
2434   contesto potremo verificare che effettivamente la \func{write} ha scritto la
2435   riga, che in effetti è stata pure trasmessa via rete.}), in quanto il nostro
2436 programma non ha a questo punto alcun modo di sapere che dall'altra parte non
2437 c'è più nessuno processo in grado di leggere quanto scriverà. Questo sarà
2438 chiaro solo dopo il tentativo di scrittura, e la ricezione del segmento RST di
2439 risposta che indica che dall'altra parte non si è semplicemente chiuso un capo
2440 del socket, ma è completamente terminato il programma.
2441
2442 Per questo motivo il nostro client proseguirà leggendo dal socket, e dato che
2443 questo è stato chiuso avremo che, come spiegato in \secref{sec:TCP_conn_term},
2444 la funzione \func{read} ritorna normalmente con un valore nullo. Questo
2445 comporta che la seguente chiamata a \func{fputs} non ha effetto (viene
2446 stampata una stringa nulla) ed il client si blocca di nuovo nella successiva
2447 chiamata a \func{fgets}. Per questo diventa possibile inserire una terza riga
2448 e solo dopo averlo fatto si avrà la terminazione del programma.
2449
2450 Per capire come questa avvenga comunque, non avendo inserito nel codice nessun
2451 controllo di errore, occorre ricordare che, a parte la bidirezionalità del
2452 flusso dei dati, dal punto di vista del funzionamento nei confronti delle
2453 funzioni di lettura e scrittura, i socket sono del tutto analoghi a delle
2454 pipe. Allora, da quanto illustrato in \secref{sec:ipc_pipes}, sappiamo che
2455 tutte le volte che si cerca di scrivere su una pipe il cui altro capo non è
2456 aperto il lettura il processo riceve un segnale di \const{SIGPIPE}, e questo è
2457 esattamente quello che avviene in questo caso, e siccome non abbiamo un
2458 gestore per questo segnale, viene eseguita l'azione preimpostata, che è quella
2459 di terminare il processo.
2460
2461 Per gestire in maniera più corretta questo tipo di evento dovremo allora
2462 modificare il nostro client perché sia in grado di trattare le varie tipologie
2463 di errore, per questo dovremo riscrivere la funzione \func{ClientEcho}, in
2464 modo da controllare gli stati di uscita delle varie chiamate. Si è riportata
2465 la nuova versione della funzione in \figref{fig:TCP_ClientEcho_second}.
2466
2467 \begin{figure}[!htb]
2468   \footnotesize \centering
2469   \begin{minipage}[c]{15.6cm}
2470     \includecodesample{listati/ClientEcho_second.c}
2471   \end{minipage} 
2472   \normalsize
2473   \caption{La sezione nel codice della seconda versione della funzione
2474     \func{ClientEcho} usata dal client per il servizio \textit{echo}
2475     modificata per tener conto degli eventuali errori.}
2476   \label{fig:TCP_ClientEcho_second}
2477 \end{figure}
2478
2479 Come si può vedere in questo caso si controlla il valore di ritorno di tutte
2480 le funzioni, ed inoltre si verifica la presenza di un eventuale end of file in
2481 caso di lettura. Con questa modifica il nostro client echo diventa in grado di
2482 accorgersi della chiusura del socket da parte del server, per cui ripetendo la
2483 sequenza di operazioni precedenti stavolta otterremo che:
2484 \begin{verbatim}
2485 [piccardi@gont sources]$ ./echo 192.168.1.141
2486 Prima riga
2487 Prima riga
2488 Seconda riga dopo il C-c
2489 EOF sul socket
2490 \end{verbatim}%$
2491 ma di nuovo si tenga presente che non c'è modo di accorgersi della chiusura
2492 del socket fin quando non si esegue la scrittura della seconda riga; il
2493 protocollo infatti prevede che ci debba essere una scrittura prima di ricevere
2494 un RST che confermi la chiusura del file, e solo alle successive scritture si
2495 potrà ottenere un errore.
2496
2497 Questa caratteristica dei socket ci mette di fronte ad un altro problema
2498 relativo al nostro client, e che cioè esso non è in grado di accorgersi di
2499 nulla fintanto che è bloccato nella lettura del terminale fatta con
2500 \func{gets}. In questo caso il problema è minimo, ma esso riemergerà più
2501 avanti, ed è quello che si deve affrontare tutte le volte quando si ha a che
2502 fare con la necessità di lavorare con più descrittori, nel qual caso diventa
2503 si pone la questione di come fare a non restare bloccati su un socket quando
2504 altri potrebbero essere liberi. Vedremo come affrontare questa problematica in
2505 \secref{sec:TCP_sock_multiplexing}.
2506  
2507
2508 \subsection{Altri scenari di terminazione della connessione}
2509 \label{sec:TCP_conn_crash}
2510
2511 La terminazione del server è solo uno dei possibili scenari di terminazione
2512 della connessione, un altro caso è ad esempio quello in cui si ha un crollo
2513 della rete, cosa che potremo simulare facilmente staccando il cavo di rete.
2514 Un'altra condizione è quella di un blocco della macchina completo della su cui
2515 gira il server che deve essere riavviata, cosa che potremo simulare sia
2516 premendo il bottone di reset,\footnote{un normale shutdown non va bene; in tal
2517   caso infatti il sistema provvede a terminare tutti i processi, per cui la
2518   situazione sarebbe sostanzialmente identica alla precedente.} che, in
2519 maniera più gentile, riavviando la macchina dopo aver interrotto la
2520 connessione di rete.
2521
2522 Cominciamo ad analizzare il primo caso, il crollo della rete. Ripetiamo la
2523 nostra sessione di lavoro precedente, lanciamo il client, scriviamo una prima
2524 riga, poi stacchiamo il cavo e scriviamo una seconda riga. Il risultato che
2525 otterremo è:
2526 \begin{verbatim}
2527 [piccardi@gont sources]$ ./echo 192.168.1.141
2528 Prima riga
2529 Prima riga
2530 Seconda riga dopo l'interruzione
2531 Errore in lettura: No route to host
2532 \end{verbatim}%$
2533
2534 Quello che succede in questo è che il programma, dopo aver scritto la seconda
2535 riga, resta bloccato per un tempo molto lungo, prima di dare l'errore
2536 \errcode{EHOSTUNREACH}.  Se andiamo ad osservare con \cmd{strace} cosa accade
2537 nel periodo in cui il programma è bloccato vedremo che stavolta, a differenza
2538 del caso precedente, il programma è bloccato nella lettura dal socket.
2539
2540 Se poi, come nel caso precedente, usiamo l'accortezza di analizzare il
2541 traffico di rete fra client e server con \cmd{tcpdump}, otterremo il seguente
2542 risultato:
2543 \begin{verbatim}
2544 [root@gont sources]# tcpdump src 192.168.1.141 or dst 192.168.1.141 -N -t
2545 tcpdump: listening on eth0
2546 gont.34685 > anarres.echo: S 1943495663:1943495663(0) win 5840
2547 anarres.echo > gont.34685: S 1215783131:1215783131(0) ack 1943495664 win 5792 
2548 gont.34685 > anarres.echo: . ack 1 win 5840
2549 gont.34685 > anarres.echo: P 1:12(11) ack 1 win 5840 
2550 anarres.echo > gont.34685: . ack 12 win 5792 
2551 anarres.echo > gont.34685: P 1:12(11) ack 12 win 5792 
2552 gont.34685 > anarres.echo: . ack 12 win 5840 
2553 gont.34685 > anarres.echo: P 12:45(33) ack 12 win 5840 
2554 gont.34685 > anarres.echo: P 12:45(33) ack 12 win 5840 
2555 gont.34685 > anarres.echo: P 12:45(33) ack 12 win 5840 
2556 gont.34685 > anarres.echo: P 12:45(33) ack 12 win 5840 
2557 gont.34685 > anarres.echo: P 12:45(33) ack 12 win 5840 
2558 gont.34685 > anarres.echo: P 12:45(33) ack 12 win 5840 
2559 gont.34685 > anarres.echo: P 12:45(33) ack 12 win 5840 
2560 gont.34685 > anarres.echo: P 12:45(33) ack 12 win 5840 
2561 gont.34685 > anarres.echo: P 12:45(33) ack 12 win 5840 
2562 arp who-has anarres tell gont
2563 arp who-has anarres tell gont
2564 arp who-has anarres tell gont
2565 arp who-has anarres tell gont
2566 arp who-has anarres tell gont
2567 arp who-has anarres tell gont
2568 ...
2569 \end{verbatim}
2570
2571 In questo caso l'andamento dei primi sette pacchetti è esattamente lo stesso
2572 di prima. Solo che stavolta, non appena inviata la seconda riga, il programma
2573 si bloccherà nella successiva chiamata a \func{read}, non ottendo nessuna
2574 risposta. Quello che succede è che nel frattempo il kernel provvede, come
2575 richiesto dal protocollo TCP, a tentare la ritrasmissione della nostra riga un
2576 certo numero di volte, con tempi di attesa crescente fra un tentativo ed il
2577 successivo, per tentare di ristabilire la connessione.
2578
2579 Il risultato finale qui dipende dall'implementazione dello stack TCP, e nel
2580 caso di Linux anche dall'impostazione di alcuni dei parametri di sistema che
2581 si trovano in \file{/proc/sys/net/ipv4}, che ne controllano il comportamento:
2582 in questo caso in particolare da \file{tcp\_retries2}. Questo parametro
2583 infatti specifica il numero di volte che deve essere ritentata la
2584 ritrasmissione di un pacchetto nel mezzo di una connessione prima di riportare
2585 un errore di timeout.  Il valore preimpostato è pari a 15, il che
2586 comporterebbe 15 tentativi di ritrasmissione, ma nel nostro caso le cose sono
2587 andate diversamente, dato che le ritrasmissioni registrate da \cmd{tcpdump}
2588 sono solo 8; inoltre l'errore riportato all'uscita del client non è stato
2589 \errcode{ETIMEDOUT}, come dovrebbe essere in questo caso, ma
2590 \errcode{EHOSTUNREACH}.
2591
2592 Per capire l'accaduto continuiamo ad analizzare l'output di \cmd{tcpdump}:
2593 esso ci mostra che a un certo punto i tentativi di ritrasmissione del
2594 pacchetto sono cessati, per essere sostituiti da una serie di richieste di
2595 protocollo ARP in cui il client richiede l'indirizzo del server.
2596
2597 Come abbiamo accennato in \secref{sec:net_tcpip_general} ARP è il protocollo
2598 che si incarica di trovare le corrispondenze corrispondenze fra indirizzo IP e
2599 indirizzo hardware sulla scheda di rete. È evidente allora che nel nostro
2600 caso, essendo client e server sulla stessa rete, è scaduta la voce nella
2601 \textit{ARP cache}\footnote{la \textit{ARP chache} è una tabella mantenuta
2602   internamente dal kernel che contiene tutte le corrispondenze fra indirizzi
2603   IP e indirizzi fisici, ottenute appunto attraverso il protocollo ARP; le
2604   voci della tabella hanno un tempo di vita limitato, passato il quale scadono
2605   e devono essere nuovamente richieste.} relativa ad \texttt{anarres}, ed il
2606 nostro client ha iniziato ad effettuare richieste ARP sulla rete per sapere
2607 l'IP di quest'ultimo, che essendo scollegato non poteva rispondere. Anche per
2608 questo tipo di richieste esiste un timeout, per cui dopo un certo numero di
2609 tentativi il meccanismo si è interrotto, e l'errore riportato al programma a
2610 questo punto è stato \errcode{EHOSTUNREACH}, in quanto non si era più in grado
2611 di contattare il server.
2612
2613 Un altro errore possibile in questo tipo di situazione, che si può avere
2614 quando la macchina è su una rete remota, è \errcode{ENETUNREACH}; esso viene
2615 riportato alla ricezione di un pacchetto ICMP di \textit{destination
2616   unreachable} da parte del router che individua l'interruzione della
2617 connessione. Di nuovo anche qui il risultato finale dipende da quale è il
2618 meccanismo più veloce ad accorgersi del problema.
2619
2620 Se però agiamo sui parametri del kernel, e scriviamo in \file{tcp\_retries2}
2621 un valore di tentativi più basso, possiamo evitare la scadenza della
2622 \textit{ARP cache} e vedere cosa succede. Così se ad esempio richiediamo 4
2623 tentativi di ritrasmissione, l'analisi di \cmd{tcpdump} ci riporterà il
2624 seguente scambio di pacchetti:
2625 \begin{verbatim}
2626 [root@gont gapil]# tcpdump src 192.168.1.141 or dst 192.168.1.141 -N -t
2627 tcpdump: listening on eth0
2628 gont.34752 > anarres.echo: S 3646972152:3646972152(0) win 5840
2629 anarres.echo > gont.34752: S 2735190336:2735190336(0) ack 3646972153 win 5792 
2630 gont.34752 > anarres.echo: . ack 1 win 5840 
2631 gont.34752 > anarres.echo: P 1:12(11) ack 1 win 5840
2632 anarres.echo > gont.34752: . ack 12 win 5792 
2633 anarres.echo > gont.34752: P 1:12(11) ack 12 win 5792 
2634 gont.34752 > anarres.echo: . ack 12 win 5840 
2635 gont.34752 > anarres.echo: P 12:45(33) ack 12 win 5840 
2636 gont.34752 > anarres.echo: P 12:45(33) ack 12 win 5840 
2637 gont.34752 > anarres.echo: P 12:45(33) ack 12 win 5840 
2638 gont.34752 > anarres.echo: P 12:45(33) ack 12 win 5840 
2639 gont.34752 > anarres.echo: P 12:45(33) ack 12 win 5840 
2640 \end{verbatim}
2641 e come si vede in questo caso i tentativi di ritrasmissione del pacchetto
2642 iniziale sono proprio 4 (per un totale di 5 voci con quello trasmesso la prima
2643 volta), ed in effetti, dopo un tempo molto più breve rispetto a prima ed in
2644 corrispondenza dell'invio dell'ultimo tentativo, quello che otterremo come
2645 errore all'uscita del client sarà diverso, e cioè:
2646 \begin{verbatim}
2647 [piccardi@gont sources]$ ./echo 192.168.1.141
2648 Prima riga
2649 Prima riga
2650 Seconda riga dopo l'interruzione
2651 Errore in lettura: Connection timed out
2652 \end{verbatim}%$
2653 che corrisponde appunto, come ci aspettavamo, alla ricezione di un
2654 \errcode{ETIMEDOUT}.
2655
2656 Analizziamo ora il secondo scenario, in cui si ha un crollo della macchina che
2657 fa da server. Al solito lanciamo il nostro client, scriviamo una prima riga
2658 per verificare che sia tutto a posto, poi stacchiamo il cavo e riavviamo il
2659 server. A questo punto, ritornato attivo il server, scriviamo una seconda
2660 riga. Quello che otterremo in questo caso è:
2661 \begin{verbatim}
2662 [piccardi@gont sources]$ ./echo 192.168.1.141
2663 Prima riga
2664 Prima riga
2665 Seconda riga dopo l'interruzione
2666 Errore in lettura Connection reset by peer
2667 \end{verbatim}%$
2668 e l'errore ricevuti da \func{read} stavolta è \errcode{ECONNRESET}. Se al
2669 solito riportiamo l'analisi dei pacchetti effettuata con \cmd{tcpdump},
2670 avremo:
2671 \begin{verbatim}
2672 [root@gont gapil]# tcpdump src 192.168.1.141 or dst 192.168.1.141 -N -t
2673 tcpdump: listening on eth0
2674 gont.34756 > anarres.echo: S 904864257:904864257(0) win 5840 
2675 anarres.echo > gont.34756: S 4254564871:4254564871(0) ack 904864258 win 5792
2676 gont.34756 > anarres.echo: . ack 1 win 5840 
2677 gont.34756 > anarres.echo: P 1:12(11) ack 1 win 5840
2678 anarres.echo > gont.34756: . ack 12 win 5792 
2679 anarres.echo > gont.34756: P 1:12(11) ack 12 win 5792
2680 gont.34756 > anarres.echo: . ack 12 win 5840 
2681 gont.34756 > anarres.echo: P 12:45(33) ack 12 win 5840
2682 anarres.echo > gont.34756: R 4254564883:4254564883(0) win 0 
2683 \end{verbatim}
2684
2685 Ancora una volta i primi sette pacchetti sono gli stessi; ma in questo caso
2686 quello che succede dopo lo scambio iniziale è che, non avendo inviato nulla
2687 durante il periodo in cui si è riavviato il server, il client è del tutto
2688 ignaro dell'accaduto per cui quando effettuerà una scrittura, dato che la
2689 macchina server è stata riavviata e che tutti gli stati relativi alle
2690 precedenti connessioni sono completamente persi, anche in presenza di una
2691 nuova istanza del server echo non sarà possibile consegnare i dati in arrivo,
2692 per cui alla loro ricezione il kernel risponderà con un segmento di RST.
2693
2694 Il client da parte sua, dato che neanche in questo caso non è stato emesso un
2695 FIN, dopo aver scritto verrà bloccato nella successiva chiamata a \func{read},
2696 che però adesso ritornerà immediatamente alla ricezione del segmento RST,
2697 riportando appunto come errore \errcode{ECONNRESET}. Occorre precisare che se
2698 si vuole che il client sia in grado di accorgersi del crollo del server anche
2699 quando non sta effettuando uno scambio di dati, è possibile usare una
2700 impostazione speciale del socket (ci torneremo in
2701 \secref{sec:TCP_sock_options}) che provvede all'esecuzione di questo
2702 controllo.
2703
2704 \section{L'uso dell'I/O multiplexing}
2705 \label{sec:TCP_sock_multiplexing}
2706
2707 Affronteremo in questa sezione l'utilizzo dell'I/O multiplexing, affrontato in
2708 \secref{sec:file_multiplexing}, nell'ambito delle applicazioni di rete. Già in
2709 \secref{sec:TCP_server_crash} era emerso il problema relativo al client del
2710 servizio echo che non era in grado di accorgersi della terminazione precoce
2711 del server, essendo bloccato nella lettura dei dati immessi da tastiera.
2712
2713 Abbiamo visto in \secref{sec:file_multiplexing} quali sono le funzionalità del
2714 sistema che ci permettono di tenere sotto controllo più file descriptor in
2715 contemporanea; in quella occasione non abbiamo fatto esempi, in quanto quando
2716 si tratta con file normali questa tipologia di I/O normalmente non viene
2717 usata, è invece un caso tipico delle applicazioni di rete quello di dover
2718 gestire varie connessioni da cui possono arrivare dati comuni in maniera
2719 asincrona, per cui riprenderemo l'argomento in questa sezione.
2720
2721
2722 \subsection{Il comportamento della funzione \func{select} con i socket.}
2723 \label{sec:TCP_sock_select}
2724
2725 Iniziamo con la prima delle funzioni usate per l'I/O multiplexing,
2726 \func{select}; il suo funzionamento è già stato descritto in dettaglio in
2727 \secref{sec:file_multiplexing} e non staremo a ripetere quanto detto lì; 
2728 sappiamo che la funzione ritorna quando uno o più dei file descriptor messi
2729 sotto controllo è pronto per la relativa operazione.
2730
2731 In quell'occasione non abbiamo però definito cosa si intende per pronto,
2732 infatti per dei normali file, o anche per delle pipe, la condizione di essere
2733 pronti per la lettura o la scrittura è ovvia; invece lo è molto meno nel caso
2734 dei socket, visto che possono intervenire tutte una serie di possibili
2735 condizioni di errore dovute alla rete. Occorre allora specificare chiaramente
2736 quali sono le condizioni per cui un socket risulta essere ``\textsl{pronto}''
2737 quando viene passato come membro di uno dei tre \textit{file descriptor set}
2738 usati da \func{select}.
2739
2740 Le condizioni che fanno si che la funzione \func{select} ritorni segnalando
2741 che un socket (che sarà riportato nel primo insieme di file descriptor) è
2742 pronto per la lettura sono le seguenti:
2743 \begin{itemize*}
2744 \item nel buffer di ricezione del socket sono arrivati dei dati in quantità
2745   sufficiente a superare il valore di una \textsl{soglia di basso livello} (il
2746   cosiddetto \textit{low watermark}). Questo valore è espresso in numero di
2747   byte e può essere impostato con l'opzione del socket \const{SO\_RCVLOWAT}
2748   (tratteremo le opzioni dei socket in \secref{sec:TCP_sock_options}); il suo
2749   valore di default è 1 per i socket TCP e UDP. In questo caso una operazione
2750   di lettura avrà successo e leggerà un numero di byte maggiore di zero.
2751 \item il lato in lettura della connessione è stato chiuso; si è cioè ricevuto
2752   un segmento FIN (si ricordi quanto illustrato in \secref{sec:TCP_conn_term})
2753   sulla connessione. In questo caso una operazione di lettura avrà successo,
2754   ma non risulteranno presenti dati (in sostanza \func{read} ritornerà con un
2755   valore nullo) per indicare la condizione di end-of-file.
2756 \item c'è stato un errore sul socket. In questo caso una operazione di lettura
2757   non si bloccherà ma restituirà una condizione di errore (ad esempio
2758   \func{read} restituirà -1) e imposterà la variabile \var{errno} al relativo
2759   valore. Vedremo in \secref{sec:TCP_sock_options} come sia possibile estrarre
2760   e cancellare errori pendenti su un socket usando l'opzione
2761   \const{SO\_ERROR}.
2762 \item quando si sta utilizzando un \textit{listening socket} ed ci sono delle
2763   connessioni completate. In questo caso la funzione \func{accept} non si
2764   bloccherà.\footnote{in realtà questo non è sempre vero, come accennato in
2765     \secref{sec:TCP_conn_early_abort} una connessione può essere abortita
2766     dalla ricezione di un segmento RST una volta che è stata completata,
2767     allora se questo avviene dopo che \func{select} è ritornata, ma prima
2768     della chiamata ad \func{accept}, quest'ultima, in assenza di altre
2769     connessioni, potrà bloccarsi.}
2770 \end{itemize*}
2771
2772 Le condizioni che fanno si che la funzione \func{select} ritorni segnalando
2773 che un socket (che sarà riportato nel secondo insieme di file descriptor) è
2774 pronto per la scrittura sono le seguenti:
2775 \begin{itemize*}
2776 \item nel buffer di invio è disponibile una quantità di spazio superiore al
2777   valore della \textsl{soglia di basso livello} in scrittura ed inoltre o il
2778   socket è già connesso o non necessita (ad esempio è UDP) di connessione.  Il
2779   valore della soglia è espresso in numero di byte e può essere impostato con
2780   l'opzione del socket \const{SO\_SNDLOWAT}; il suo valore di default è 2048
2781   per i socket TCP e UDP. In questo caso una operazione di scrittura non si
2782   bloccherà e restituirà un valore positivo pari al numero di byte accettati
2783   dal livello di trasporto.
2784 \item il lato in scrittura della connessione è stato chiuso. In questo caso
2785   una operazione di scrittura sul socket genererà il segnale \const{SIGPIPE}.
2786 \item c'è stato un errore sul socket. In questo caso una operazione di
2787   scrittura non si bloccherà ma restituirà una condizione di errore ed
2788   imposterà opportunamente la variabile \var{errno}. Vedremo in
2789   \secref{sec:TCP_sock_options} come sia possibile estrarre e cancellare
2790   errori pendenti su un socket usando l'opzione \const{SO\_ERROR}.
2791 \end{itemize*}
2792
2793 Infine c'è una sola condizione che fa si che \func{select} ritorni segnalando
2794 che un socket (che sarà riportato nel terzo insieme di file descriptor) ha una
2795 condizione di eccezione pendente, e cioè la ricezione sul socket di dati
2796 \textsl{fuori banda} (o \textit{out-of-band}), una caratteristica specifica
2797 dei socket TCP su cui torneremo in \secref{sec:TCP_urgent_data}.
2798
2799 Si noti come nel caso della lettura \func{select} si applichi anche ad
2800 operazioni che non hanno nulla a che fare con l'I/O di dati come il
2801 riconoscimento della presenza di connessioni pronte, in modo da consentire
2802 anche l'utilizzo di \func{accept} in modalità non bloccante. Si noti infine
2803 come in caso di errore un socket venga sempre riportato come pronto sia per la
2804 lettura che per la scrittura.
2805
2806 Lo scopo dei due valori di soglia per i buffer di ricezione e di invio è
2807 quello di consentire maggiore flessibilità nell'uso di \func{select} da parte
2808 dei programmi, se infatti si sa che una applicazione non è in grado di fare
2809 niente fintanto che non può ricevere o inviare una certa quantità di dati, si
2810 possono utilizzare questi valori per far si che \func{select} ritorni solo
2811 quando c'è la certezza di avere dati a sufficienza.\footnote{questo tipo di
2812   controllo è utile di norma solo per la lettura, in quanto in genere le
2813   operazioni di scrittura sono già controllate dall'applicazione, che sà
2814   sempre quanti dati invia, mentre non è detto possa conoscere la quantità di
2815   dati in ricezione; per cui, nella situazione in cui si conosce almeno un
2816   valore minimo, per evitare la penalizzazione dovuta alla ripetizione delle
2817   operazioni di lettura per accumulare dati sufficienti, si può lasciare al
2818   kernel il compito di impostare un minimo al di sotto del quale il file
2819   descriptor, pur avendo disponibili dei dati, non viene dato per pronto in
2820   lettura.}
2821
2822
2823
2824 \subsection{Un esempio di I/O multiplexing}
2825 \label{sec:TCP_multiplex_example}
2826
2827 Abbiamo incontrato la problematica tipica che conduce all'uso dell'I/O
2828 multiplexing nella nostra analisi degli errori in
2829 \secref{sec:TCP_conn_early_abort}, quando il nostro client non era in grado di
2830 rendersi conto di errori sulla connessione essendo impegnato nella attesa di
2831 dati in ingresso dallo standard input.
2832
2833 In questo caso il problema è quello di dover tenere sotto controllo due
2834 diversi file descriptor, lo standard input, da cui viene letto il testo che
2835 vogliamo inviare al server, e il socket connesso con il server su cui detto
2836 testo sarà scritto e dal quale poi si vorrà ricevere la risposta. L'uso
2837 dell'I/O multiplexing consente di tenere sotto controllo entrambi, senza
2838 restare bloccati.
2839
2840 Nel nostro caso quello che ci interessa è non essere bloccati in lettura sullo
2841 standard input in caso di errori sulla connessione o chiusura della stessa da
2842 parte del server. Entrambi questi casi possono essere rilevati usando
2843 \func{select}, per quanto detto in \secref{sec:TCP_sock_select}, mettendo
2844 sotto osservazione i file descriptor per la condizione di essere pronti in
2845 lettura: sia infatti che si ricevano dati, che la connessione sia chiusa
2846 regolarmente (con la ricezione di un segmento FIN) che si riceva una
2847 condizione di errore (con un segmento RST) il socket connesso sarà pronto in
2848 lettura (nell'ultimo caso anche in scrittura, ma questo non è necessario ai
2849 nostri scopi).
2850
2851 \begin{figure}[!htb]
2852   \footnotesize \centering
2853   \begin{minipage}[c]{15.6cm}
2854     \includecodesample{listati/ClientEcho_third.c}
2855   \end{minipage} 
2856   \normalsize
2857   \caption{La sezione nel codice della terza versione della funzione
2858     \func{ClientEcho} usata dal client per il servizio \textit{echo}
2859     modificata per l'uso di \func{select}.}
2860   \label{fig:TCP_ClientEcho_third}
2861 \end{figure}
2862
2863 Riprendiamo allora il codice del client, modificandolo per l'uso di
2864 \func{select}. Quello che dobbiamo modificare è la funzione \func{ClientEcho}
2865 di \figref{fig:TCP_ClientEcho_second}, dato che tutto il resto, che riguarda
2866 le modalità in cui viene stabilita la connessione con il server, resta
2867 assolutamente identico. La nostra nuova versione di \func{ClientEcho}, la
2868 terza della serie, è riportata in \figref{fig:TCP_ClientEcho_third}, il codice
2869 completo si trova nel file \file{TCP\_echo\_third.c} dei sorgenti allegati alla
2870 guida.
2871
2872 In questo caso la funzione comincia (\texttt{\small 8--9}) con l'azzeramento
2873 del file descriptor set \var{fset} e l'impostazione del valore \var{maxfd}, da
2874 passare a \func{select} come massimo per il numero di file descriptor. Per
2875 determinare quest'ultimo si usa la macro \code{max} definita nel nostro file
2876 \file{macro.h} che raccoglie una collezione di macro di preprocessore di varia
2877 utilità.
2878
2879 La funzione prosegue poi (\texttt{\small 10--41}) con il ciclo principale, che
2880 viene ripetuto indefinitamente. Per ogni ciclo si reinizializza
2881 (\texttt{\small 11--12}) il file descriptor set, impostando i valori per il
2882 file descriptor associato al socket \var{socket} e per lo standard input (il
2883 cui valore si recupera con la funzione \func{fileno}). Questo è necessario in
2884 quanto la successiva (\texttt{\small 13}) chiamata a \func{select} comporta
2885 una modifica dei due bit relativi, che quindi devono essere reimpostati
2886 all'inizio di ogni ciclo.
2887
2888 Si noti come la chiamata a \func{select} venga eseguita usando come primo
2889 argomento il valore di \var{maxfd}, precedentemente calcolato, e passando poi
2890 il solo file descriptor set per il controllo dell'attività in lettura, negli
2891 altri argomenti sono passati tutti puntatori nulli, non interessando né il
2892 controllo delle altre attività, né l'impostazione di un valore di timeout.
2893
2894 Al ritorno di \func{select} si provvede a controllare quale dei due file
2895 descriptor presenta attività in lettura, cominciando (\texttt{\small 14--24})
2896 con il file descriptor associato allo standard input. In caso di attività
2897 (quando cioè \macro{FD\_ISSET} ritorna una valore diverso da zero) si esegue
2898 (\texttt{\small 15}) una \func{fgets} per leggere gli eventuali dati presenti;
2899 se non ve ne sono (e la funzione restituisce pertanto un puntatore nullo) si
2900 ritorna immediatamente (\texttt{\small 16}) dato che questo significa che si è
2901 chiuso lo standard input e quindi concluso l'utilizzo del client; altrimenti
2902 (\texttt{\small 18--22}) si scrivono i dati appena letti sul socket,
2903 prevedendo una uscita immediata in caso di errore di scrittura.
2904
2905 Controllato lo standard input si passa a controllare (\texttt{\small 25--40})
2906 il socket connesso, in caso di attività (\texttt{\small 26}) si esegue subito
2907 una \func{read} di cui si controlla il valore di ritorno; se questo è negativo
2908 (\texttt{\small 27--30}) si è avuto un errore e pertanto si esce
2909 immediatamente segnalandolo, se è nullo (\texttt{\small 31--34}) significa che
2910 il server ha chiuso la connessione, e di nuovo si esce con stampando prima un
2911 messaggio di avviso, altrimenti (\texttt{\small 35--39}) si effettua la
2912 terminazione della stringa e la si stampa a sullo standard output (uscendo in
2913 caso di errore), per ripetere il ciclo da capo.
2914
2915 Con questo meccanismo il programma invece di essere bloccato in lettura sullo
2916 standard input resta bloccato sulla \func{select}, che ritorna soltanto quando
2917 viene rilevata attività su uno dei due file descriptor posti sotto controllo.
2918 Questo di norma avviene solo quando si è scritto qualcosa sullo standard
2919 input, o quando si riceve dal socket la risposta a quanto si era appena
2920 scritto. Ma adesso il client diventa capace di accorgersi immediatamente della
2921 terminazione del server; in tal caso infatti il server chiuderà il socket
2922 connesso, ed alla ricezione del FIN la funzione \func{select} ritornerà (come
2923 illustrato in \secref{sec:TCP_sock_select}) segnalando una condizione di end
2924 of file, per cui il nostro client potrà uscire immediatamente.
2925
2926 Riprendiamo la situazione affrontata in \secref{sec:TCP_server_crash},
2927 terminando il server durante una connessione, in questo caso quello che
2928 otterremo, una volta scritta una prima riga ed interrotto il server con un
2929 \texttt{C-c}, sarà:
2930 \begin{verbatim}
2931 [piccardi@gont sources]$ ./echo 192.168.1.1
2932 Prima riga
2933 Prima riga
2934 EOF sul socket
2935 \end{verbatim}%$
2936 dove l'ultima riga compare immediatamente dopo aver interrotto il server. Il
2937 nostro client infatti è in grado di accorgersi immediatamente che il socket
2938 connesso è stato chiuso ed uscire immediatamente.
2939
2940 Veniamo allora agli altri scenari di terminazione anomala visti in
2941 \secref{sec:TCP_conn_crash}. Il primo di questi è l'interruzione fisica della
2942 connessione; in questo caso avremo un comportamento analogo al precedente, in
2943 cui si scrive una riga e non si riceve risposta dal server e non succede
2944 niente fino a quando non si riceve un errore di \errcode{EHOSTUNREACH} o
2945 \errcode{ETIMEDOUT} a seconda dei casi.
2946
2947 La differenza è che stavolta potremo scrivere più righe dopo l'interruzione,
2948 in quanto il nostro client dopo aver inviato i dati non si bloccherà più nella
2949 lettura dal socket, ma nella \func{select}; per questo potrà accettare
2950 ulteriore dati che scriverà di nuovo sul socket, fintanto che c'è spazio sul
2951 buffer di uscita (ecceduto il quale si bloccherà in scrittura). Si ricordi
2952 infatti che il client non ha modo di determinare se la connessione è attiva o
2953 meno (dato che in molte situazioni reali l'inattività può essere temporanea).
2954 Tra l'altro se si ricollega la rete prima della scadenza del timeout, potremo
2955 anche verificare come tutto quello che si era scritto viene poi effettivamente
2956 trasmesso non appena la connessione ridiventa attiva, per cui otterremo
2957 qualcosa del tipo:
2958 \begin{verbatim}
2959 [piccardi@gont sources]$ ./echo 192.168.1.1
2960 Prima riga
2961 Prima riga
2962 Seconda riga dopo l'interruzione
2963 Terza riga
2964 Quarta riga
2965 Seconda riga dopo l'interruzione
2966 Terza riga
2967 Quarta riga
2968 \end{verbatim}
2969 in cui, una volta riconnessa la rete, tutto quello che abbiamo scritto durante
2970 il periodo di disconnessione restituito indietro e stampato immediatamente.
2971
2972 Lo stesso comportamento visto in \secref{sec:TCP_server_crash} si riottiene
2973 nel caso di un crollo completo della macchina su cui sta il server. In questo
2974 caso di nuovo il client non è in grado di accorgersi di niente dato che si
2975 suppone che il programma server non venga terminato correttamente, ma si
2976 blocchi tutto senza la possibilità di avere l'emissione di un segmento FIN che
2977 segnala la terminazione della connessione. Di nuovo fintanto che la
2978 connessione non si riattiva )con il riavvio della macchina del server) il
2979 client non è in grado di fare altro che accettare dell'input e tentare di
2980 inviarlo. La differenza in questo caso è che non appena la connessione
2981 ridiventa attiva i dati verranno sì trasmessi, ma essendo state perse tutte le
2982 informazioni relative alle precedenti connessioni ai tentativi di scrittura
2983 del client sarà risposto con un segmento RST che provocherà il ritorno di
2984 \func{select} per la ricezione di un errore di \errcode{ECONNRESET}.
2985
2986
2987 \subsection{La funzione \func{shutdown}}
2988 \label{sec:TCP_shutdown}
2989
2990 Come spiegato in \secref{sec:TCP_conn_term} il procedimento di chiusura di un
2991 socket TCP prevede che da entrambe le parti venga emesso un segmento FIN. È
2992 pertanto del tutto normale dal punto di vista del protocollo che uno dei due
2993 capi chiuda la connessione, quando l'altro capo la lascia
2994 aperta.\footnote{abbiamo incontrato questa situazione nei vari scenari critici
2995   di \secref{sec:TCP_echo_critical}.}
2996
2997 È pertanto possibile avere una situazione in cui un capo della connessione non
2998 avendo più nulla da scrivere, possa chiudere il socket, segnalando così
2999 l'avvenuta terminazione della trasmissione (l'altro capo riceverà infatti un
3000 end-of-file in lettura) mentre dall'altra parte si potrà proseguire la
3001 trasmissione dei dati scrivendo sul socket che da quel lato è ancora aperto.
3002 Questa è quella situazione in cui si dice che il socket è \textit{half
3003   closed}.
3004
3005 Il problema che si pone è che se la chiusura del socket è effettuata con la
3006 funzione \func{close}, come spiegato in \secref{sec:TCP_func_close}, si perde
3007 ogni possibilità di poter rileggere quanto l'altro capo può continuare a
3008 scrivere. Per poter permettere allora di segnalare che si è concluso con la
3009 scrittura, continuando al contempo a leggere quanto può provenire dall'altro
3010 capo del socket si può allora usare la funzione \funcd{shutdown}, il cui
3011 prototipo è:
3012 \begin{prototype}{sys/socket.h}
3013 {int shutdown(int sockfd, int how)}
3014
3015 Chiude un lato della connessione fra due socket.
3016   
3017   \bodydesc{La funzione restituisce zero in caso di successo e -1 per un
3018     errore, nel qual caso \var{errno} assumerà i valori:
3019   \begin{errlist}
3020   \item[\errcode{ENOTSOCK}] il file descriptor non corrisponde a un socket.
3021   \item[\errcode{ENOTCONN}] il socket non è connesso.
3022   \end{errlist}
3023   ed inoltre \errval{EBADF}.}
3024 \end{prototype}
3025
3026 La funzione prende come primo argomento il socket \param{sockfd} su cui si
3027 vuole operare e come secondo argomento un valore intero \param{how} che indica
3028 la modalità di chiusura del socket, quest'ultima può prendere soltanto tre
3029 valori: 
3030 \begin{basedescript}{\desclabelwidth{2.2cm}\desclabelstyle{\nextlinelabel}}
3031 \item[\macro{SHUT\_RD}] chiude il lato in lettura del socket, non sarà più
3032   possibile leggere dati da esso, tutti gli eventuali dati trasmessi
3033   dall'altro capo del socket saranno automaticamente scartati dal kernel, che,
3034   in caso di socket TCP, provvederà comunque ad inviare i relativi segmenti di
3035   ACK.
3036 \item[\macro{SHUT\_WR}] chiude il lato in scrittura del socket, non sarà più
3037   possibile scrivere dati su di esso. Nel caso di socket TCP la chiamata causa
3038   l'emissione di un segmento FIN, secondo la procedura chiamata
3039   \textit{half-close}. Tutti i dati presenti nel buffer di scrittura prima
3040   della chiamata saranno inviati, seguiti dalla sequenza di chiusura
3041   illustrata in \secref{sec:TCP_conn_term}.
3042 \item[\macro{SHUT\_RDWR}] chiude sia il lato in lettura che quello in
3043   scrittura del socket. È equivalente alla chiamata in sequenza con
3044   \macro{SHUT\_RD} e \macro{SHUT\_WR}.
3045 \end{basedescript}
3046
3047 Ci si può chiedere quale sia l'utilità di avere introdotto \macro{SHUT\_RDWR}
3048 quando questa sembra rendere \funcd{shutdown} del tutto equivalente ad una
3049 \func{close}. In realtà non è così, esiste infatti un'altra differenza con
3050 \func{close}, più sottile. Finora infatti non ci siamo presi la briga di
3051 sottolineare in maniera esplicita che, come per i file e le fifo, anche per i
3052 socket possono esserci più riferimenti contemporanei ad uno stesso socket. Per
3053 cui si avrebbe potuto avere l'impressione che sia una corrispondenza univoca
3054 fra un socket ed il file descriptor con cui vi si accede. Questo non è
3055 assolutamente vero, (e lo abbiamo già visto nel codice del server di
3056 \figref{fig:TCP_echo_server_first_code}), ed è invece assolutamente normale
3057 che, come per gli altri oggetti, ci possano essere più file descriptor che
3058 fanno riferimento allo stesso socket.
3059
3060 Allora se avviene uno di questi casi quello che succederà è che la chiamata a
3061 \func{close} darà effettivamente avvio alla sequenza di chiusura di un socket
3062 soltanto quando il numero di riferimenti a quest'ultimo diventerà nullo.
3063 Fintanto che ci sono file descriptor che fanno riferimento ad un socket l'uso
3064 di \func{close} si limiterà a deallocare nel processo corrente il file
3065 descriptor utilizzato, ma il socket resterà pienamente accessibile attraverso
3066 tutti gli altri riferimenti. Se torniamo all'esempio originale del server di
3067 \figref{fig:TCP_echo_server_first_code} abbiamo infatti che ci sono due
3068 \func{close}, una sul socket connesso nel padre, ed una sul socket in ascolto
3069 nel figlio, ma queste non effettuano nessuna chiusura reale di detti socket,
3070 dato che restano altri riferimenti attivi, uno al socket connesso nel figlio
3071 ed uno a quello in ascolto nel padre.
3072
3073 Questo non avviene affatto se si usa \func{shutdown} con argomento
3074 \macro{SHUT\_RDWR} al posto di \func{close}; in questo caso infatti la
3075 chiusura del socket viene effettuata immediatamente, indipendentemente dalla
3076 presenza di altri riferimenti attivi, e pertanto sarà efficace anche per tutti
3077 gli altri file descriptor con cui, nello stesso o in altri processi, si fa
3078 riferimento allo stesso socket.
3079
3080 Il caso più comune di uso di \func{shutdown} è comunque quello della chiusura
3081 del lato in scrittura, per segnalare all'altro capo della connessione che si è
3082 concluso l'invio dei dati, restando comunque in grado di ricevere quanto
3083 questi potrà ancora inviarci. Questo è ad esempio l'uso che ci serve per
3084 rendere finalmente completo il nostro esempio sul servizio \textit{echo}. Il
3085 nostro client infatti presenta ancora un problema, che nell'uso che finora ne
3086 abbiamo fatto non è emerso, ma che ci aspetta dietro l'angolo non appena
3087 usciamo dall'uso interattivo e proviamo ad eseguirlo redirigendo standard
3088 input e standard output. Così se eseguiamo:
3089 \begin{verbatim}
3090 [piccardi@gont sources]$ ./echo 192.168.1.1 < ../fileadv.tex  > copia
3091 \end{verbatim}%$
3092 vedremo che il file \texttt{copia} risulta mancare della parte finale.
3093
3094 Per capire cosa avviene in questo caso occorre tenere presente come avviene la
3095 comunicazione via rete; quando redirigiamo lo standard input il nostro client
3096 inizierà a leggere il contenuto del file \texttt{../fileadv.tex} a blocchi di
3097 dimensione massima pari a \texttt{MAXLINE} per poi scriverlo, alla massima
3098 velocità consentitagli dalla rete, sul socket. Dato che la connessione è con
3099 una macchina remota occorre un certo tempo perché i pacchetti vi arrivino,
3100 vengano processati, e poi tornino indietro. Considerando trascurabile il tempo
3101 di processo, questo tempo è quello impiegato nella trasmissione via rete, che
3102 viene detto RTT (dalla denominazione inglese \textit{Round Trip Time}) ed è
3103 quello che viene stimato con l'uso del comando \cmd{ping}.
3104
3105 A questo punto, se torniamo al codice mostrato in
3106 \figref{fig:TCP_ClientEcho_third}, possiamo vedere che mentre i pacchetti sono
3107 in transito sulla rete il client continua a leggere e a scrivere fintanto che
3108 il file in ingresso finisce. Però non appena viene ricevuto un end-of-file in
3109 ingresso il nostro client termina. Nel caso interattivo, in cui si inviavano
3110 brevi stringhe una alla volta, c'era sempre il tempo di eseguire la lettura
3111 completa di quanto il server rimandava indietro. In questo caso invece, quando
3112 il client termina, essendo la comunicazione saturata e a piena velocità, ci
3113 saranno ancora pacchetti in transito sulla rete che devono arrivare al server
3114 e poi tornare indietro, ma siccome il client esce immediatamente dopo la fine
3115 del file in ingresso, questi non faranno a tempo a completare il percorso e
3116 verranno persi.
3117
3118 Per evitare questo tipo di problema, invece di uscire una volta completata la
3119 lettura del file in ingresso, occorre usare \func{shutdown} per effettuare la
3120 chiusura del lato in scrittura del socket. In questo modo il client segnalerà
3121 al server la chiusura del flusso dei dati, ma potrà continuare a leggere
3122 quanto il server gli sta ancora inviando indietro, fino a quando anch'esso,
3123 riconosciuta la chiusura del socket in scrittura da parte del client,
3124 effettuerà la chiusura dalla sua parte. Solo alla ricezione della chiusura del
3125 socket da parte del server il client potrà essere sicuro della ricezione di
3126 tutti i dati e della terminazione effettiva della connessione.
3127
3128 \begin{figure}[!htb]
3129   \footnotesize \centering
3130   \begin{minipage}[c]{15.6cm}
3131     \includecodesample{listati/ClientEcho.c}
3132   \end{minipage} 
3133   \normalsize
3134   \caption{La sezione nel codice della versione finale della funzione
3135     \func{ClientEcho}, che usa \func{shutdown} per una conclusione corretta
3136     della connessione.}
3137   \label{fig:TCP_ClientEcho}
3138 \end{figure}
3139
3140 Si è allora riportato in \figref{fig:TCP_ClientEcho} la versione finale della
3141 nostra funzione \func{ClientEcho}, in grado di gestire correttamente l'intero
3142 flusso di dati fra client e server. Il codice completo del client,
3143 comprendente la gestione delle opzioni a riga di comando e le istruzioni per
3144 la creazione della connessione, si trova nel file \file{TCP\_echo.c},
3145 distribuito coi sorgenti allegati alla guida.
3146
3147 La nuova versione è molto simile alla precedente di
3148 \figref{fig:TCP_ClientEcho_third}; la prima differenza è l'introduzione
3149 (\texttt{\small 7}) della variabile \var{eof}, inizializzata ad un valore
3150 nullo, che serve a mantenere traccia dell'avvenuta conclusione della lettura
3151 del file in ingresso.
3152
3153 La seconda modifica (\texttt{\small 12--15}) è stata quella di rendere
3154 subordinato ad un valore nullo di \var{eof} l'impostazione del file descriptor
3155 set per l'osservazione dello standard input. Se infatti il valore di \var{eof}
3156 è non nullo significa che si è già raggiunta la fine del file in ingresso ed è
3157 pertanto inutile continuare a tenere sotto controllo lo standard input nella
3158 successiva (\texttt{\small 16}) chiamata a \func{select}.
3159
3160 Le maggiori modifiche rispetto alla precedente versione sono invece nella
3161 gestione (\texttt{\small 18--22}) del caso in cui la lettura con \func{fgets}
3162 restituisce un valore nullo, indice della fine del file. Questa nella
3163 precedente versione causava l'immediato ritorno della funzione; in questo caso
3164 prima (\texttt{\small 19}) si imposta opportunamente \var{eof} ad un valore
3165 non nullo, dopo di che (\texttt{\small 20}) si effettua la chiusura del lato
3166 in scrittura del socket con \func{shutdown}. Infine (\texttt{\small 21}) si
3167 usa la macro \macro{FD\_CLR} per togliere lo standard input dal file
3168 descriptor set.
3169
3170 In questo modo anche se la lettura del file in ingresso è conclusa, la
3171 funzione non esce dal ciclo principale (\texttt{\small 11--50}), ma continua
3172 ad eseguirlo ripetendo la chiamata a \func{select} per tenere sotto controllo
3173 soltanto il socket connesso, dal quale possono arrivare altri dati, che
3174 saranno letti (\texttt{\small 31}), ed opportunamente trascritti
3175 (\texttt{\small 44--48}) sullo standard output.
3176
3177 Il ritorno della funzione, e la conseguente terminazione normale del client,
3178 viene invece adesso gestito all'interno (\texttt{\small 30--49}) della lettura
3179 dei dati dal socket; se infatti dalla lettura del socket si riceve una
3180 condizione di end-of-file, la si tratterà (\texttt{\small 36--43}) in maniera
3181 diversa a seconda del valore di \var{eof}. Se infatti questa è diversa da zero
3182 (\texttt{\small 37--39}), essendo stata completata la lettura del file in
3183 ingresso, vorrà dire che anche il server ha concluso la trasmissione dei dati
3184 restanti, e si potrà uscire senza errori, altrimenti si stamperà
3185 (\texttt{\small 40--42}) un messaggio di errore per la chiusura precoce della
3186 connessione.
3187
3188
3189 \subsection{Un server basato sull'I/O multiplexing}
3190 \label{sec:TCP_serv_select}
3191
3192 Seguendo di nuovo le orme di Stevens in \cite{UNP1} vediamo ora come con
3193 l'utilizzo dell'I/O multiplexing diventi possibile riscrivere completamente il
3194 nostro server \textit{echo} con una architettura completamente diversa, in
3195 modo da evitare di dover creare un nuovo processo tutte le volte che si ha una
3196 connessione.\footnote{ne faremo comunque una implementazione diversa rispetto
3197   a quella presentata da Stevens in \cite{UNP1}.}
3198
3199 La struttura del nuovo server è illustrata in \figref{fig:TCP_echo_multiplex},
3200 in questo caso avremo un solo processo che ad ogni nuova connessione da parte
3201 di un client sul socket in ascolto si limiterà a registrare l'entrata in uso
3202 di un nuovo file descriptor ed utilizzerà \func{select} per rilevare la
3203 presenza di dati in arrivo su tutti i file descriptor attivi, operando
3204 direttamente su ciascuno di essi.
3205
3206 \begin{figure}[htb]
3207   \centering
3208   \includegraphics[width=13cm]{img/TCPechoMult}
3209   \caption{Schema del nuovo server echo basato sull'I/O multiplexing.}
3210   \label{fig:TCP_echo_multiplex}
3211 \end{figure}
3212
3213 La sezione principale del codice del nuovo server è illustrata in
3214 \figref{fig:TCP_SelectEchod}. Si è tralasciata al solito la gestione delle
3215 opzioni, che è identica alla versione precedente. Resta invariata anche tutta
3216 la parte relativa alla gestione dei segnali, degli errori, e della cessione
3217 dei privilegi, così come è identica la gestione della creazione del socket (si
3218 può fare riferimento al codice già illustrato in
3219 \secref{sec:TCPsimp_server_main}); al solito il codice completo del server è
3220 disponibile coi sorgenti allegati nel file \texttt{select\_echod.c}.
3221
3222 \begin{figure}[!htbp]
3223   \footnotesize \centering
3224   \begin{minipage}[c]{15.6cm}
3225     \includecodesample{listati/select_echod.c}
3226   \end{minipage} 
3227   \normalsize
3228   \caption{La sezione principale del codice della nuova versione di server
3229     \textit{echo} basati sull'uso della funzione \func{select}.}
3230   \label{fig:TCP_SelectEchod}
3231 \end{figure}
3232
3233 In questo caso, una volta aperto e messo in ascolto il socket, tutto quello
3234 che ci servirà sarà chiamare \func{select} per rilevare la presenza di nuove
3235 connessioni o di dati in arrivo, e processarli immediatamente. Per
3236 implementare lo schema mostrato in \figref{fig:TCP_echo_multiplex}, il
3237 programma usa una tabella dei socket connessi mantenuta nel vettore
3238 \var{fd\_open} dimensionato al valore di \macro{FD\_SETSIZE}, ed una variabile
3239 \var{max\_fd} per registrare il valore più alto dei file descriptor aperti.
3240
3241 Prima di entrare nel ciclo principale (\texttt{\small 6--56}) la nostra
3242 tabella viene inizializzata (\texttt{\small 2}) a zero (valore che
3243 utilizzeremo come indicazione del fatto che il relativo file descriptor non è
3244 aperto), mentre il valore massimo (\texttt{\small 3}) per i file descriptor
3245 aperti viene impostato a quello del socket in ascolto,\footnote{in quanto esso
3246   è l'unico file aperto, oltre i tre standard, e pertanto avrà il valore più
3247   alto.} che verrà anche (\texttt{\small 4}) inserito nella tabella.
3248
3249 La prima sezione (\texttt{\small 7--10}) del ciclo principale esegue la
3250 costruzione del \textit{file descriptor set} \var{fset} in base ai socket
3251 connessi in un certo momento; all'inizio ci sarà soltanto il socket in
3252 ascolto, ma nel prosieguo delle operazioni, verranno utilizzati anche tutti i
3253 socket connessi registrati nella tabella \var{fd\_open}.  Dato che la chiamata
3254 di \func{select} modifica il valore del \textit{file descriptor set}, è
3255 necessario ripetere (\texttt{\small 7}) ogni volta il suo azzeramento, per poi
3256 procedere con il ciclo (\texttt{\small 8--10}) in cui si impostano i socket
3257 trovati attivi.
3258
3259 Per far questo si usa la caratteristica dei file descriptor, descritta in
3260 \secref{sec:file_open}, per cui il kernel associa sempre ad ogni nuovo file il
3261 file descriptor con il valore più basso disponibile. Questo fa sì che si possa
3262 eseguire il ciclo (\texttt{\small 8}) a partire da un valore minimo, che sarà
3263 sempre quello del socket in ascolto, mantenuto in \var{list\_fd}, fino al
3264 valore massimo di \var{max\_fd} che dovremo aver cura di tenere aggiornato.
3265 Dopo di che basterà controllare (\texttt{\small 9}) nella nostra tabella se il
3266 file descriptor è in uso o meno,\footnote{si tenga presente che benché il
3267   kernel assegni sempre il primo valore libero, dato che nelle operazioni i
3268   socket saranno aperti e chiusi in corrispondenza della creazione e
3269   conclusione delle connessioni, si potranno sempre avere dei \textsl{buchi}
3270   nella nostra tabella.} e impostare \var{fset} di conseguenza.
3271
3272 Una volta inizializzato con i socket aperti il nostro \textit{file descriptor
3273   set} potremo chiamare \func{select} per fargli osservare lo stato degli
3274 stessi (in lettura, presumendo che la scrittura sia sempre consentita). Come
3275 per il precedente esempio di \secref{sec:TCP_child_hand}, essendo questa
3276 l'unica funzione che può bloccarsi, ed essere interrotta da un segnale, la
3277 eseguiremo (\texttt{\small 11--12}) all'interno di un ciclo di \code{while}
3278 che la ripete indefinitamente qualora esca con un errore di \errcode{EINTR}.
3279 Nel caso invece di un errore normale si provvede (\texttt{\small 13--16}) ad
3280 uscire stampando un messaggio di errore.
3281
3282 Se invece la funzione ritorna normalmente avremo in \var{n} il numero di
3283 socket da controllare. Nello specifico si danno due possibili casi diversi per
3284 cui \func{select} può essere ritornata: o si è ricevuta una nuova connessione
3285 ed è pronto il socket in ascolto, sul quale si può eseguire \func{accept} o
3286 c'è attività su uno dei socket connessi, sui quali si può eseguire
3287 \func{read}.
3288
3289 Il primo caso viene trattato immediatamente (\texttt{\small 17--26}): si
3290 controlla (\texttt{\small 17}) che il socket in ascolto sia fra quelli attivi,
3291 nel qual caso anzitutto (\texttt{\small 18}) se ne decrementa il numero in
3292 \var{n}; poi, inizializzata (\texttt{\small 19}) la lunghezza della struttura
3293 degli indirizzi, si esegue \func{accept} per ottenere il nuovo socket connesso
3294 controllando che non ci siano errori (\texttt{\small 20--23}). In questo caso
3295 non c'è più la necessità di controllare per interruzioni dovute a segnali, in
3296 quanto siamo sicuri che \func{accept} non si bloccherà. Per completare la
3297 trattazione occorre a questo punto aggiungere (\texttt{\small 24}) il nuovo
3298 file descriptor alla tabella di quelli connessi, ed inoltre, se è il caso,
3299 aggiornare (\texttt{\small 25}) il valore massimo in \var{max\_fd}.
3300
3301 Una volta controllato l'arrivo di nuove connessioni si passa a verificare se
3302 vi sono dati sui socket connessi, per questo si ripete un ciclo
3303 (\texttt{\small 29--55}) fintanto che il numero di socket attivi \var{n} resta
3304 diverso da zero; in questo modo se l'unico socket con attività era quello
3305 connesso, avendo opportunamente decrementato il contatore, il ciclo verrà
3306 saltato, e si ritornerà immediatamente (ripetuta l'inizializzazione del file
3307 descriptor set con i nuovi valori nella tabella) alla chiamata di
3308 \func{accept}. Se il socket attivo non è quello in ascolto, o ce ne sono
3309 comunque anche altri, il valore di \var{n} non sarà nullo ed il controllo sarà
3310 eseguito. Prima di entrare nel ciclo comunque si inizializza (\texttt{\small
3311   28}) il valore della variabile \var{i} che useremo come indice nella tabella
3312 \var{fd\_open} al valore minimo, corrispondente al file descriptor del socket
3313 in ascolto.
3314
3315 Il primo passo (\texttt{\small 30}) nella verifica è incrementare il valore
3316 dell'indice \var{i} per posizionarsi sul primo valore possibile per un file
3317 descriptor associato ad un eventuale socket connesso, dopo di che si controlla
3318 (\texttt{\small 31}) se questo è nella tabella dei socket connessi, chiedendo
3319 la ripetizione del ciclo in caso contrario. Altrimenti si passa a verificare
3320 (\texttt{\small 32}) se il file descriptor corrisponde ad uno di quelli
3321 attivi, e nel caso si esegue (\texttt{\small 33}) una lettura, uscendo con un
3322 messaggio in caso di errore (\texttt{\small 34--38}).
3323
3324 Se (\texttt{\small 39}) il numero di byte letti \var{nread} è nullo si è in
3325 presenza del caso di un \textit{end-of-file}, indice che una connessione che
3326 si è chiusa, che deve essere trattato (\texttt{\small 39--48}) opportunamente.
3327 Il primo passo è chiudere (\texttt{\small 40}) anche il proprio capo del
3328 socket e rimuovere (\texttt{\small 41}) il file descriptor dalla tabella di
3329 quelli aperti, inoltre occorre verificare (\texttt{\small 42}) se il file
3330 descriptor chiuso è quello con il valore più alto, nel qual caso occorre
3331 trovare (\texttt{\small 42--46}) il nuovo massimo, altrimenti (\texttt{\small
3332   47}) si può ripetere il ciclo da capo per esaminare (se ne restano)
3333 ulteriori file descriptor attivi.
3334
3335 Se però è stato chiuso il file descriptor più alto, dato che la scansione dei
3336 file descriptor attivi viene fatta a partire dal valore più basso, questo
3337 significa che siamo anche arrivati alla fine della scansione, per questo
3338 possiamo utilizzare direttamente il valore dell'indice \var{i} con un ciclo
3339 all'indietro (\texttt{\small 43}) che trova il primo valore per cui la tabella
3340 presenta un file descriptor aperto, e lo imposta (\texttt{\small 44}) come
3341 nuovo massimo, per poi tornare (\texttt{\small 44}) al ciclo principale con un
3342 \code{break}, e rieseguire \func{select}.
3343
3344 Se infine si sono effettivamente letti dei dati dal socket (ultimo caso
3345 rimasto) si potrà invocare immediatamente (\texttt{\small 49})
3346 \func{FullWrite} per riscriverli indietro sul socket stesso, avendo cura di
3347 uscire con un messaggio in caso di errore (\texttt{\small 50--53}). Si noti
3348 che nel ciclo si esegue una sola lettura, contrariamente a quanto fatto con la
3349 precedente versione (si riveda il codice di \secref{fig:TCP_ServEcho_second})
3350 in cui si continuava a leggere fintanto che non si riceveva un
3351 \textit{end-of-file}, questo perché usando l'\textit{I/O multiplexing} non si
3352 vuole essere bloccati in lettura.  L'uso di \func{select} ci permette di
3353 trattare automaticamente anche il caso in cui la \func{read} non è stata in
3354 grado di leggere tutti i dati presenti sul socket, dato che alla iterazione
3355 successiva \func{select} ritornerà immediatamente segnalando l'ulteriore
3356 disponibilità.
3357
3358 Il nostro server comunque soffre di una vulnerabilità per un attacco di tipo
3359 \textit{Denial of Service}. Il problema è che in caso di blocco di una
3360 qualunque delle funzioni di I/O, non avendo usato processi separati, tutto il
3361 server si ferma e non risponde più a nessuna richiesta. Abbiamo scongiurato
3362 questa evenienza per l'I/O in ingresso con l'uso di \func{select}, ma non vale
3363 altrettanto per l'I/O in uscita. Il problema pertanto può sorgere qualora una
3364 delle chiamate a \func{write} effettuate da \func{FullWrite} si blocchi. Con
3365 il funzionamento normale questo non accade in quanto il server si limita a
3366 scrivere quanto riceve in ingresso, ma qualora venga utilizzato un client
3367 malevolo che esegua solo scritture e non legga mai indietro l'\textsl{eco} del
3368 server, si potrebbe giungere alla saturazione del buffer di scrittura, ed al
3369 conseguente blocco del server su di una \func{write}.
3370
3371 Le possibili soluzioni in questo caso sono quelle di ritornare ad eseguire il
3372 ciclo di risposta alle richieste all'interno di processi separati, utilizzare
3373 un timeout per le operazioni di scrittura, o eseguire queste ultime in
3374 modalità non bloccante, concludendo le operazioni qualora non vadano a buon
3375 fine.
3376
3377
3378
3379 \subsection{I/O multiplexing con \func{poll}}
3380 \label{sec:TCP_serv_poll}
3381
3382 Finora abbiamo trattato le problematiche risolubili con l'I/O multiplexing
3383 impiegando la funzione \func{select}; questo è quello che avviene nella
3384 maggior parte dei casi, in quanto essa è nata sotto BSD proprio per affrontare
3385 queste problematiche con i socket.  Abbiamo però visto in
3386 \secref{sec:file_multiplexing} come la funzione \func{poll} possa costituire
3387 una alternativa a \func{select}, con alcuni vantaggi.\footnote{non soffrendo
3388   delle limitazioni dovute all'uso dei \textit{file descriptor set}.}
3389
3390 Ancora una volta in \secref{sec:file_poll} abbiamo trattato la funzione in
3391 maniera generica, parlando di file descriptor, ma come per \func{select}
3392 quando si ha a che fare con dei socket il concetto di essere \textsl{pronti}
3393 per l'I/O deve essere specificato nei dettagli, per tener conto delle
3394 condizioni della rete. Inoltre deve essere specificato come viene classificato
3395 il traffico nella suddivisione fra dati normali e prioritari. In generale
3396 pertanto:
3397 \begin{itemize}
3398 \item i dati trasmessi su un socket vengono considerati traffico normale,
3399   pertanto vengono rilevati da una selezione con \const{POLLIN} o
3400   \const{POLLRDNORM}.
3401 \item i dati \textit{out-of-band} su un socket TCP vengono considerati
3402   traffico prioritario e vengono rilevati da una condizione \const{POLLIN},
3403   \const{POLLPRI} o \const{POLLRDBAND}.
3404 \item la chiusura di una connessione (cioè la ricezione di un segmento FIN)
3405   viene considerato traffico normale, pertanto viene rilevato da una
3406   condizione \const{POLLIN} o \const{POLLRDNORM}, ma una conseguente chiamata
3407   a \func{read} restituirà 0.
3408 \item la presenza di un errore sul socket (sia dovuta ad un segmento RST che a
3409   timeout) viene considerata traffico normale, ma viene segnalata anche dalla
3410   condizione \const{POLLERR}.
3411 \item la presenza di una nuova connessione su un socket in ascolto può essere
3412   considerata sia traffico normale che prioritario, nel caso di Linux
3413   l'implementazione la classifica come normale.
3414 \end{itemize}
3415
3416 Come esempio dell'uso di \func{poll} proviamo allora a reimplementare il
3417 server \textit{echo} secondo lo schema di \figref{fig:TCP_echo_multiplex}
3418 usando \func{poll} al posto di \func{select}. In questo caso dovremo fare
3419 qualche modifica, per tenere conto della diversa sintassi delle due funzioni,
3420 ma la struttura del programma resta sostanzialmente la stessa.
3421
3422
3423 \begin{figure}[!htbp]
3424   \footnotesize \centering
3425   \begin{minipage}[c]{15.6cm}
3426     \includecodesample{listati/poll_echod.c}
3427   \end{minipage} 
3428   \normalsize
3429   \caption{La sezione principale del codice della nuova versione di server
3430     \textit{echo} basati sull'uso della funzione \func{poll}.}
3431   \label{fig:TCP_PollEchod}
3432 \end{figure}
3433
3434 In \figref{fig:TCP_PollEchod} è riportata la sezione principale della nuova
3435 versione del server, la versione completa del codice è riportata nel file
3436 \file{poll\_echod.c} dei sorgenti allegati alla guida. Al solito nella figura
3437 si sono tralasciate la gestione delle opzioni, la creazione del socket in
3438 ascolto, la cessione dei privilegi e le operazioni necessarie a far funzionare
3439 il programma come demone, privilegiando la sezione principale del programma.
3440
3441 Come per il precedente server basato su \func{select} il primo passo
3442 (\texttt{\small 2--8}) è quello di inizializzare le variabili necessarie. Dato
3443 che in questo caso dovremo usare un vettore di strutture occorre anzitutto
3444 (\texttt{\small 2}) allocare la memoria necessaria utilizzando il numero
3445 massimo \var{n} di socket osservabili, che viene impostato attraverso
3446 l'opzione \texttt{-n} ed ha un valore di default di 256. 
3447
3448 Dopo di che si preimposta (\texttt{\small 3}) il valore \var{max\_fd} del file
3449 descriptor aperto con valore più alto a quello del socket in ascolto (al
3450 momento l'unico), e si provvede (\texttt{\small 4--7}) ad inizializzare le
3451 strutture, disabilitando (\texttt{\small 5}) l'osservazione con un valore
3452 negativo del campo \var{fd} ma predisponendo (\texttt{\small 6}) il campo
3453 \var{events} per l'osservazione dei dati normali con \const{POLLRDNORM}.
3454 Infine (\texttt{\small 8}) si attiva l'osservazione del socket in ascolto
3455 inizializzando la corrispondente struttura. Questo metodo comporta, in
3456 modalità interattiva, lo spreco di tre strutture (quelle relative a standard
3457 input, output ed error) che non vengono mai utilizzate in quanto la prima è
3458 sempre quella relativa al socket in ascolto.
3459
3460 Una volta completata l'inizializzazione tutto il lavoro viene svolto
3461 all'interno del ciclo principale \texttt{\small 10--55}) che ha una struttura
3462 sostanzialmente identica a quello usato per il precedente esempio basato su
3463 \func{select}. La prima istruzione (\texttt{\small 11--12}) è quella di
3464 eseguire \func{poll} all'interno di un ciclo che la ripete qualora venisse
3465 interrotta da un segnale, da cui si esce soltanto quando la funzione ritorna,
3466 restituendo nella variabile \var{n} il numero di file descriptor trovati
3467 attivi.  Qualora invece si sia ottenuto un errore si procede (\texttt{\small
3468   13--16}) alla terminazione immediata del processo provvedendo a stampare una
3469 descrizione dello stesso.
3470
3471 Una volta ottenuta dell'attività su un file descriptor si hanno di nuovo due
3472 possibilità. La prima possibilità è che ci sia attività sul socket in ascolto,
3473 indice di una nuova connessione, nel qual caso si controlla (\texttt{\small
3474   17}) se il campo \var{revents} della relativa struttura è attivo; se è così
3475 si provvede (\texttt{\small 18}) a decrementare la variabile \var{n} (che
3476 assume il significato di numero di file descriptor attivi rimasti da
3477 controllare) per poi (\texttt{\small 19--23}) effettuare la chiamata ad
3478 \func{accept}, terminando il processo in caso di errore. Se la chiamata ad
3479 \func{accept} ha successo si procede attivando (\texttt{\small 24}) la
3480 struttura relativa al nuovo file descriptor da essa ottenuto, modificando
3481 (\texttt{\small 24}) infine quando necessario il valore massimo dei file
3482 descriptor aperti mantenuto in \var{max\_fd}.
3483
3484 La seconda possibilità è che vi sia dell'attività su uno dei socket aperti in
3485 precedenza, nel qual caso si inizializza (\texttt{\small 27}) l'indice \var{i}
3486 del vettore delle strutture \struct{pollfd} al valore del socket in ascolto,
3487 dato che gli ulteriori socket aperti avranno comunque un valore superiore.  Il
3488 ciclo (\texttt{\small 28--54}) prosegue fintanto che il numero di file
3489 descriptor attivi, mantenuto nella variabile \var{n}, è diverso da zero. Se
3490 pertanto ci sono ancora socket attivi da individuare si comincia con
3491 l'incrementare (\texttt{\small 30}) l'indice e controllare (\texttt{\small
3492   31}) se corrisponde ad un file descriptor in uso analizzando il valore del
3493 campo \var{fd} della relativa struttura e chiudendo immediatamente il ciclo
3494 qualora non lo sia. Se invece il file descriptor è in uso si verifica
3495 (\texttt{\small 31}) se c'è stata attività controllando il campo
3496 \var{revents}. 
3497
3498 Di nuovo se non si verifica la presenza di attività il ciclo si chiude subito,
3499 altrimenti si provvederà (\texttt{\small 32}) a decrementare il numero \var{n}
3500 di file descriptor attivi da controllare e ad eseguire (\texttt{\small 33}) la
3501 lettura, ed in caso di errore (\texttt{\small 34--37}) al solito lo si
3502 notificherà uscendo immediatamente. Qualora invece si ottenga una condizione
3503 di end-of-file (\texttt{\small 38--47}) si provvederà a chiudere
3504 (\texttt{\small 39}) anche il nostro capo del socket e a marcarlo
3505 (\texttt{\small 40}) nella struttura ad esso associata come inutilizzato.
3506 Infine dovrà essere ricalcolato (\texttt{\small 41--45}) un eventiale nuovo
3507 valore di \var{max\_fd}. L'ultimo passo è (\texttt{\small 46}) chiudere il
3508 ciclo in quanto in questo caso non c'è più niente da riscrivere all'indietro
3509 sul socket.
3510
3511 Se invece si sono letti dei dati si provvede (\texttt{\small 48}) ad
3512 effettuarne la riscrittura all'indietro, con il solito controllo ed eventuale
3513 uscita e notifica in caso si errore (\texttt{\small 49--52}).
3514
3515 Come si può notare la logica del programma è identica a quella vista in
3516 \figref{fig:TCP_SelectEchod} per l'analogo server basato su \func{select}; la
3517 sola differenza significativa è che in questo caso non c'è bisogno di
3518 rigenerare i file descriptor set in quanto l'uscita è indipendente dai dati in
3519 ingresso. Si applicano comunque anche a questo server le considerazioni finali
3520 di \secref{sec:TCP_serv_select}.
3521
3522
3523
3524 %%% Local Variables: 
3525 %%% mode: latex
3526 %%% TeX-master: "gapil"
3527 %%% End: