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
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
int main()
{
#if defined (_WIN32)
WSADATA wsa_data;
if ( WSAStartup(MAKEWORD(2,2),&wsa_data) != 0 )
{
perror("WSAStartup()");
return 1;
}
#endif
struct client* unClient = NULL;
int err = 0;
int max;
int s_ecoute;
/*Ensemble de socket surveillées en lecture */
fd_set fds_lecture;
FD_ZERO(&fds_lecture);
/* Création de la socket */
s_ecoute = socket(PF_INET,SOCK_STREAM,0);
max = s_ecoute;
if ( s_ecoute != SOCKET_ERROR )
{
/* "bindage" de la socket */
struct sockaddr_in myaddr;
struct sockaddr_in client_addr;
myaddr.sin_family = AF_INET;
myaddr.sin_port = htons(PORT);
myaddr.sin_addr.s_addr = (INADDR_ANY);
err = bind(s_ecoute,(struct sockaddr *) &myaddr, sizeof (myaddr));
if ( err != SOCKET_ERROR )
{
/* Ecoute sur le port */
printf("Attente de connexion sur le port %d...\n",PORT);
err = listen(s_ecoute,10);
if ( err != SOCKET_ERROR )
{
/* On met la socket d'ecoute dans l'ensemble de lecture */
FD_SET(s_ecoute,&fds_lecture);
while(1)
{
if ( select(max+1,&fds_lecture,NULL,NULL,NULL) != -1 )
{
/* On parcourt la liste des clients */
while( unClient )
{
/* Si il sait passer quelque chose dans l'emsemble de lecture avec ce client */
if ( FD_ISSET(unClient->fd,&fds_lecture))
{
/* Si c'est la socket d'ecoute ==> nouvelle connexion ! */
if ( unClient->fd == s_ecoute )
{
unsigned int size_client_addr = sizeof(client_addr);
int newClient = accept(s_ecoute,(struct sockaddr *)&client_addr,&size_client_addr);
int oct_rec;
if ( newClient != SOCKET_ERROR )
{
char login[16];
printf("Connexion d'un nouveau client : %s...\n",inet_ntoa(client_addr.sin_addr));
/* On attend la réception de son login */
oct_rec = recv(newClient,login,sizeof(login),0);
if ( oct_rec != - 1)
{
/* On procède à l'authentification du login */
int authent = authentification(login);
if ( authent == 0 )
{
/* Authentification reussie ! */
/* On met le nouveau client dans la liste */
ajouter_client(&unClient,login,"",newClient);
/* On le met aussi dans l'ensemble de lecture */
FD_SET(newClient,&fds_lecture);
}
else
{
/* Client inconnu ! */
char erreur404[] = "Désolé vous n'etes pas dans la base de donnees...\n";
int oct_env;
/* On envoie un message d'erreur au client inconnu */
oct_env = send(newClient,erreur404,sizeof(erreur404),0);
if ( oct_env == -1 )
{
perror("send() 404error");
}
}
}
else
{
perror("revc() login");
}
}
else
{
perror("accept()");
}
}
else
{
/* Le client en cours a fait une action ! */
int oct_rec;
int message[144]; /* 16 premiers octets pour le login du destinataire, le reste c'est le message */
oct_rec = recv(unClient->fd,message,sizeof(message),0);
if ( oct_rec <= 0 )
{
/* Erreur ou deconnexion client */
}
else
{
/* Le client a envoyé un message ! */
}
}
}
unClient = unClient->suivant;
} /* Fin du parcour de la liste */
}
else
{
perror("select()");
}
} /* Fin de la boucle infinie */
}
else
{
perror("listen()");
}
}
else
{
perror("bind()");
}
}
else
{
perror("socket()");
err = 1;
}
#if defined (_WIN32)
WSACleanup();
#endif
return err;
} |
