Discussion :

[muad'dib]

Bonjour à tous,

Je réalise actuellement un serveur recevant plusieurs clients. Pour chaque client se connectant, je realise un accept() suivi d'un fork() afin que le processus enfant s'occupe du traitement des données recues par le client et que le processus parent puisse continuer l'écoute des nouvelles connexions entrantes.

Jusque là rien que du très classique. Seulement je suis confronté à un problème, surement très connu, mais que je ne connais pas, aussi je vais tenter de vous l'expliquer:
Je connecte 3 clients, les uns à la suite des autres. Nommons les A B C. Lorsqu'un client se connecte, le serveur doit alerter tous les clients déja connectés de l'arrivée du nouvel utilisateur. Idem pour une déconnexion:
A se connecte: il est le premier, donc personne à alerter.
B se connecte: le processus fils s'occupant du client B envoie une trame à A l'informant de la connexion de B.
C se connecte: le processus fils s'occupant du client C envoie une trame à A et B les informant de la connexion de C.

Jusqu'ici tout va bien ! Les différents clients connectés ainsi que leur descripteurs de fichiers sont stockés dans un segment de mémoire partagée, ce qui permet à tous les processus de connaitre en permanence quels sont les clients connectés.

Les choses se compliquent lorsque je veux alerter les utilisateurs A et C de la déconnexion de B:
B se déconnecte, le processus s'occupant de B envoie au descripteur de socket de A l'information de déconnexion -> OK, en revanche, le processus s'occupant de B envoie au descripteur de socket de C l'information de déconnexion -> KO et je me retrouve avec une erreur:

send: Socket operation on non-socket

Dans mon code, cela se traduit ainsi:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
	for (i = 0; i < MAX_CLIENTS; i++) {
		if (cl->sockfd > 0) {
			printf("Alerting to socket %d - pid = %d\n", cl->sockfd, getpid());
			if (send(cl->sockfd, data, strlen(data), 0) == -1) {
				perror("send");
			}
		}
		cl += sizeof(client);
	}

Où la variable cl correspond au pointeur sur les clients stockée en mémoire partagée.
Je précise que la déconnexion du client n'est pas réelle, il s'agit juste d'une désautentification, la socket reste toujours connectée.

J'ai l'impression que la méthode accept ne replique pas les descripteurs de sockets ouverts dans les processus enfants, me trompe-je ? Comment puis-je solutionner mon problème?

[fearyourself]

Ceci n'est pas logique :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

		cl += sizeof(client);

cl est un pointeur donc on fait

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

 cl++;

Le compilateur C fera le reste pour que cela pointe sur la prochaine entrée.

Jc

[muad'dib]

Ah super merci je savais pas je vais essayer

[EDIT] A marche po ... je met tout mon bout de code :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
int alert_everyone(conn_alert_weave h_conn_alert) {
	int i;
	client *cl;
	char data[256] = {0};
 
	cl = (client*)shm_connected_clis;
 
	sprintf(data, "%c%c%s", h_conn_alert.code, h_conn_alert.operation, h_conn_alert.login);
	for (i = 0; i < MAX_CLIENTS; i++) {
		if (cl->sockfd > 0 && cl->sockfd != h_conn_alert.sockfd) {
			printf("Alerting to socket %d - pid = %d\n", cl->sockfd, getpid());
			if (send(cl->sockfd, data, strlen(data), 0) == -1) {
				perror("send");
			}
		}
		cl++; //= sizeof(client);
	}
 
	return 0;
}

[souviron34]

euh.. Comme tu boucles en continu, il faudrait peut-être juste tester que tu ne prends pas le numéro en cours non ?

Si c'est en mémoire partagée comme tu as l'air de le suggérer, les numéros sont stockés dans l'ordre de création, donc A, B, C.

Quand ensuite dans B tu fais :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
 
	for (i = 0; i < MAX_CLIENTS; i++) {

Comment c'est passé la déconnection ? est-ce que ton numéro de socket est déjà retiré de la liste ou non ? si oui, ton erreur est normale....

ça me semble une mauvaise approche de faire comme ça...
Parce que si de l'extérieur tu fais un KILL sur B, tu ne passeras pas par ta routine. De la même mnaière tu n'y passeras pas si il y a cordump, socket gelé, etc..

J'aurais plutot fait un truc du genre :

• chaque fois qu'un client est créé, il demande au serveur les autres clients, et les mets dans un tableau.
  
• Chaque client a aussi une routine de signalisation en cas d'interruption de communication avec le serveur (quit sans bye)
  
• Le serveur, quant à lui, garde l'ensemble en mémoire. Et il a une routine de vérification de connection pour chacun des clients, plus une routine de signalisation en cas d'interruption d'un des clients.
  
• Quand un des clients quitte (volontairement ou non), le serveur passe à travers la liste des clients, envoie le message que le client no x a quitté, puis chacun remet à jour sa liste...

[muad'dib]

Finalement, après concertation avec mon maitre de stage, j'ai utilisé une technique similaire à la tienne souviron. C'est à dire que chaque processus responsable de chaque client va comparer regulierement en mémoire partagée les clients connectés avec ceux de sa mémoire locale. S'il y a une différence, alors j'indique au processus du client d'alerter le client en question !!!!

Merci pour ton aide en tout cas

[souviron34]

de rien ..