1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>
#include <strings.h>
#include <errno.h>
#include <unistd.h>
#include "tcpserver.h"
#include "utils.h"
#include "dispatcher.h"
int end=0;
int tcpserver() {
int res;
int sockServ, sockCli;
struct sockaddr_in servAddr, cliAddr;
socklen_t cliAddrLen;
// Création socket
sockServ = socket(AF_INET, SOCK_STREAM, 0);
if (sockServ < 0) { perror("socket"); return(2); }
// Accrochage du socket (adresse et port locaux)
bzero((char *) &servAddr, sizeof(servAddr));
servAddr.sin_family = AF_INET;
servAddr.sin_addr.s_addr = INADDR_ANY;
servAddr.sin_port = htons(LISTEN_PORT);
res=bind(sockServ, (struct sockaddr *) &servAddr, sizeof(servAddr));
if (res < 0) { perror("bind"); return(3); }
// On lance l'écoute
listen(sockServ,LISTEN_BACKLOG);
if (res < 0) { perror("listen"); return(4); }
res=initDispatcher();
if (res != 0 ) {
#ifdef DEBUG
logs("initDispatcher() error");
#endif
return(5);
}
// Boucle d'acceptation des clients
cliAddrLen = sizeof(cliAddr);
while ( ! end ) {
// Appel bloquant d'acceptation d'un nouveau client
sockCli=accept(sockServ, (struct sockaddr *) &cliAddr, &cliAddrLen);
// Il y plein de raisons pour qu'un accept echoue
if (sockCli < 0) {
switch(errno) {
case EAGAIN:
case EINTR:
// Cas qui ne sont pas des erreurs, mais nécessitent de rappeler accept
#ifdef DEBUG
perror("accept (info)");
#endif
break;
case EMFILE:
case ENFILE:
case ENOBUFS:
case ENOMEM:
// Cas d'erreur transitoire (attente d'une seconde histoire d'attendre un peu si ressources fichiers, ram épuisés
#ifdef DEBUG
perror("accept (warn)");
sleep(1);
#endif
break;
default:
// Cas d'erreur fatales
perror("accept (err)");
end=2;
}
} else {
// Cas nominal : un nouveau socket est disponible avec un client au bout
#ifdef HEAVYDEBUG
logs("Client accepté");
#endif
end=requestDispatcher(sockCli, &cliAddr, &cliAddrLen);
}
}
freeDispatcher();
if ( end != 1 ) {
#ifdef DEBUG
logs("Fin anormale du serveur");
#endif
return(6);
}
return 0;
}
|
