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
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
| #include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <unistd.h>
#define SERVER_PATH "/tmp/server"
#define BUFFER_LENGTH 250
#define FALSE 0
/* NCNX : nombre maximum d'entrées traitées en // */
#define NCNX 16
#define TOOMANY "Trop de connexion ouvertes. Désolé.\n"
#ifndef SUN_LEN
#define SUN_LEN(ptr) ((size_t) (((struct sockaddr_un *) 0)->sun_path) + strlen ((ptr)->sun_path))
#endif
int main(int argc, char *argv[])
{
int sd=-1, sd2=-1, rc,i,j,c;
char buffer[BUFFER_LENGTH],buffer1[BUFFER_LENGTH];
struct sockaddr_un serveraddr;
struct sockaddr clt;
socklen_t clt_l;
char d,cont=1, * fin=&cont;
pid_t pid;
int max = -1;
int on = 1;
int slot[NCNX]; fd_set efds;
fd_set rfds;
sd = socket(AF_UNIX, SOCK_STREAM, 0); /* création du socket AF_UNIX : on ne passe pas par un port, ce sera interne au PC */
if (sd < 0) /* retour un entier >=0 si ça c'est bien passé, sinon -1 */
{
perror("echec de socket()");
}
else
{
serveraddr.sun_family = AF_UNIX;
strcpy(serveraddr.sun_path, SERVER_PATH);
rc = connect(sd, (struct sockaddr *)&serveraddr, SUN_LEN(&serveraddr));
if (rc < 0) /* No such file or directory est gténéré par le connect */
{ /* car il n'y a pas de serveur à écouter */
perror("serveur absent : le programme devient serveur");
memset (slot,-1,sizeof slot); /* tous les slots sont déclarés libres */
memset(&serveraddr, 0, sizeof(serveraddr)); /* remplir de 0 la chaîne d'entrée sortie */
serveraddr.sun_family = AF_UNIX; /* choix de la forme de socket */
strcpy(serveraddr.sun_path, SERVER_PATH); /* emplacement du répertoire temporaire */
rc = bind(sd, (struct sockaddr *)&serveraddr, SUN_LEN(&serveraddr));
if (rc < 0) /* donne un nom à la socket */
{
perror("echec de bind()");
return 1;
}
rc = listen(sd, 0); /* socket utilisée pour accepter les demandes de connexions entrantes */
if (rc< 0)
{
perror("echec de listen()");
return 2;
}
do
{
max=sd; /* max retiend le + grand des descripteurs, pas le + grd nb d'entrées */
FD_ZERO (&rfds); /* efface rfds : uniquement en écoute */
FD_SET (sd,&rfds); /* ajoute un descripteur dans l'ensemble : l'écoute sur notre port */
for (i=0;i<NCNX;++i) /* Parcourt les entrées possibles */
if (slot[i]>=0) /* Si l'entrée est active */
{
FD_SET (slot[i],&rfds); /* la rajouter à l'ensemble des entrées à écouter */
if (max<slot[i]) max=slot[i]; /* la prendre en compte pour le max */
}
select (max+1,&rfds,NULL,NULL,NULL); /* on est uniquement en écoute : les trois autres entrées sont à NULL */
if (FD_ISSET (sd,&rfds))
{ /* s'il y a un nouveau appel : un nouveau client veut communiquer */
printf ("Connexion entrante ... "); fflush (stdout);
c = accept (sd,&clt,&clt_l);
for (i=0;i<NCNX;++i)
{
if (slot[i]==-1) /* trouver le premier emplacement libre dans slot[] */
{
slot[i]=c; /* l'affecter à la nouvelle entrée */
break; /* on sort du for sans mettre au max pour le if suvant */
}
}
if (i>=NCNX)
{
printf ("rejétée car plus de slots disponible.\n");
write (c,TOOMANY,sizeof TOOMANY); /* prévient le client potentiel qu'il ne sera pa pris en compte */
shutdown (c,SHUT_RDWR);
close (c);
}
else
{
int n;
char buffer [1024];
printf ("affectée au slot %d.\n",i); /* signal au client qu'il est accepté */
snprintf (buffer,sizeof buffer,"numéro %d a rejoint le canal.\n",i);
n = strlen (buffer);
write (slot[i],buffer,n); /* envoi du message */
}
}
for (i=0;i<NCNX;++i) /* Parcourt les entrées possibles */
if (slot[i]!=-1 && FD_ISSET (slot[i],&rfds))/* Si l'entrée a reçu un message */
{ /* traitement du message */
rc=read(slot[i],buffer,BUFFER_LENGTH-1);/* lecture du message */
if (rc < 0)
{
perror("echec de recv()");
}
else if (rc == 0 )
{ /* message pour signaler la fermeture du client */
printf("Le client %d a fermé la connexion\n",i);
slot[i]=-1; /* on libère le slot */
}
else
{
if (rc<BUFFER_LENGTH)
buffer[rc]=0; /*finir la chaine de caractères par un 0 car il n'est pas mis en fin du message */
c=0;
for (j=0;j<strlen(buffer);j++) /* fabrication du code de vérification */
{
c^=buffer[j]; /* un ou exclusif tout simple sur un octet */
}
if (strcmp(buffer,"fin")==0) on=0;
printf("%d bites de données ont été reçus du client %d signature %hu : %s\n", rc,i,c,buffer);
sprintf(buffer,"%hu",c); /* préparation et envoi du code de vérification à l'envoyeur */
rc = write(slot[i], buffer, strlen(buffer));
if (rc < 0)
{
perror("echec de send()");
}
}
}
} while (on);
remove (SERVER_PATH);
}
else /* le serveur est présent : le programme prend la version client */
{
rc = recv(sd,buffer1,BUFFER_LENGTH, 0); /* recception du signal d'entrée */
if (rc == 0)
{
printf("Le serveur a fermé la connexion\n");
return 0;
}
if (rc<BUFFER_LENGTH)
buffer1[rc]=0; /*finir la chaine de caractères par un 0 */
printf("%d : %s\n",rc,buffer1);
do
{ /* boucle sur la connexion ouverte */
printf("Message à envoyer au serveur (fin pour arrêter le serveur) : ");
fflush(stdin);
fgets(buffer, BUFFER_LENGTH, stdin);
buffer[strlen(buffer)-1]=0; /* enlever le /n de la fin, le remplacer par un 0 */
rc = send(sd, buffer, strlen(buffer), 0); /* envoie du message au serveur */
//rc = write(sd, buffer, strlen(buffer));
if (rc < 0)
{
perror("echec de send()");
break;
}
c=0; /* calcul du code de vérification */
for (i=0;i<strlen(buffer);i++)
{
c^=buffer[i];
} /* réception du code de vérification du serveur */
rc = recv(sd,buffer1,BUFFER_LENGTH, 0);
if (rc == 0)
{
printf("Le serveur a fermé la connexion\n");
break;
}
if (rc<BUFFER_LENGTH)
buffer1[rc]=0; /* finir la chaine de caractères par un 0 */
printf("%d : %s\n",rc,buffer1);
sscanf(buffer1,"%hu",&i); /* lecture du code de vérification envoyé par le serveur */
if (c==i) /* vérification du code */
printf("Vérification OK\n");
else
printf("Erreur dans le transfert ici %hu, là-bas : %hu\n",c,i);
fflush(stdin);
printf("Continuer ? (o/n) : ");
do
c=getchar();
while (c!='o' && c!='n');
do /* vider le buffer jusqu'au saut de ligne */
{
d=getchar();
printf("%c",d);
}
while (d!='\n');
}
while(c=='o');
}
}
if (sd != -1)
close(sd);
if (sd2 != -1)
close(sd2);
return 0;
} |
Envoyé par Obsidian
Répondre avec citation
Partager