Socket pour recevoir plus d'un packet

Version imprimable

Bonjour!

J'ai créé une fonction pour envoyer un message à un serveur, ce qui sert en fait à recevoir les informations d'un serveur de jeu.

Voici mon code:

Code:

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
 
 
static gchar *gfire_server_browser_send_packet(const guint32 server_ip, const gint server_port, const gchar server_query[])
{
	if(server_ip && server_port && server_query)
	{
		// Create socket and set options
		int query_socket;
 
		struct sockaddr_in query_address;
		unsigned short int query_port = server_port;
 
		// Open socket using UDP
		if((query_socket = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
			return NULL;
 
		query_address.sin_family = AF_INET;
		query_address.sin_addr.s_addr = server_ip;
		query_address.sin_port = htons(query_port);
 
		// Send query
		if(sendto(query_socket, server_query, strlen(server_query), 0, (struct sockaddr *)&query_address, sizeof(query_address)) < 0)
			return NULL;
 
		// Wait for response
		char response[GFIRE_SERVER_BROWSER_BUF];
		int n_read;
 
		// Define query timeout
		struct timeval timeout;
 
		timeout.tv_sec = 10;
		timeout.tv_usec = 500 * 1000;
		setsockopt(query_socket, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(struct timeval));
 
		// Read query response
		n_read = recvfrom(query_socket, response, GFIRE_SERVER_BROWSER_BUF, 0, NULL, NULL);
		if(n_read <= 0)
		{
			close(query_socket);
			return NULL;
		}
 
		// Close socket
		close(query_socket);
 
		// Return response
		return g_strdup_printf("%s", response);
	}
	else
		return NULL;
}

Ca marche bien pour certains jeux, mais d'autres renvoient plus d'un packet contenant les informations, comment faire cela?

Merci d'avance, cordialement.

17/02/2010, 14h54
Invité(e)

Bonjour,

Pour recevoir plusieurs paquets, le plus simple est d'utiliser la fonction select qui va permettre d'attendre le changement d'état d'un socket avec une notion de timeout :
Plus d'info là : http://broux.developpez.com/articles/c/sockets/#L4-1
17/02/2010, 21h45
clemnantes

Tu pourrais aussi faire une boucle sur ton recvfrom du type

while((nb_lu = recvfrom(args...))>0){
sauvegarder réponse
}

ainsi tant qu'il y aura quelque chose à lire sur ta socket tu reste en lecture pis si ya plus rien (nb_lu == 0) tu sort
17/02/2010, 23h08
Invité(e)

Citation:

Envoyé par clemnantes

ainsi tant qu'il y aura quelque chose à lire sur ta socket tu reste en lecture pis si ya plus rien (nb_lu == 0) tu sort

Hum, si la socket est bloquante, comme c'est le cas par défaut, il client attendra indéfiniment.
Pour ça, il faut changer le mode de la socket, voir fcntl.
18/02/2010, 17h19
clemnantes

Citation:

Envoyé par mabu

Hum, si la socket est bloquante, comme c'est le cas par défaut, il client attendra indéfiniment.
Pour ça, il faut changer le mode de la socket, voir fcntl.

C'est le recvfrom qui est bloquant enfin il me semble, la socket en elle même n'est qu'un descripteur comme l'est un descripteur de fichier.
Enfin il est vrais qu'avec ma méthode cela implique que le serveur doit envoyer une trame vide en fin de transmission...
18/02/2010, 17h34
Invité(e)

Citation:

Envoyé par clemnantes

C'est le recvfrom qui est bloquant enfin il me semble, la socket en elle même n'est qu'un descripteur comme l'est un descripteur de fichier.

Ce ne ne sont pas recv ou recvfrom qui sont bloquantes, mais les sockets elles-mêmes.

Citation:

Envoyé par clemnantes

Enfin il est vrais qu'avec ma méthode cela implique que le serveur doit envoyer une trame vide en fin de transmission...

Ça soulève un problème plus général : pour s'interfacer avec un serveur, il faut connaitre le protocole sur le bout des doigts et avoir une gestion des erreurs suffisamment bonne pour ne pas partir en sucette.
18/02/2010, 20h57
clemnantes

Ha ok j'avais mal compris le concept alors :aie:
merci pour ces précisions

Merci pour vos réponses, mais je n'y arrive pas, j'ai tenu compte de ce qui a été dit et voici mon code actuel:

Code:

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
 
static gchar *gfire_server_browser_send_packet(const guint32 server_ip, const gint server_port, const gchar server_query[])
{
	if(server_ip && server_port && server_query)
	{
		// Create socket and set options
		int query_socket;
 
		struct sockaddr_in query_address;
		unsigned short int query_port = server_port;
 
		// Open socket using UDP
		if((query_socket = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
			return NULL;
 
		query_address.sin_family = AF_INET;
		query_address.sin_addr.s_addr = server_ip;
		query_address.sin_port = htons(query_port);
 
		// Set socket timeout
		struct timeval timeout;
 
		timeout.tv_sec = 10;
		timeout.tv_usec = 500 * 1000;
		setsockopt(query_socket, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(struct timeval));
 
		// Set socket option(s)
		fcntl(query_socket, F_SETFL, O_NONBLOCK);
 
		// Send packet
		if(sendto(query_socket, server_query, strlen(server_query), 0, (struct sockaddr *)&query_address, sizeof(query_address)) < 0)
			return NULL;
 
		// Wait for response
		char response[GFIRE_SERVER_BROWSER_BUF];
		int n_read;
		int pos = 0;
 
		do
		{
			n_read = recvfrom(query_socket, response + pos, GFIRE_SERVER_BROWSER_BUF - pos, 0, NULL, NULL);
			pos += n_read;
 
			if(n_read <= 0)
				close(query_socket);
			else
				printf("We received something!\n");
		}
		while(n_read > 0);
 
		// Return response
		return g_strdup_printf("%s", response);
	}
	else
		return NULL;
}

Ca ne reçoit plus rien du tout maintent, alors que ca devrait exécuter un printf si quelque chose est reçu.

Pouvez-vois m'aider? Merci...

19/02/2010, 10h01
Invité(e)
Re,

Je n'avais pas vu en première lecture qu'il y avait un timeout sur la socket.

Je pense que si tu retires
Code:

1 2 // Set socket option(s) fcntl(query_socket, F_SETFL, O_NONBLOCK);
et le problème devrait se décoincer.
19/02/2010, 11h01
elwario91

Merci, ça marche!

Par contre maintenant cela dure toujours 500 ms pour tout recevoir (timeout?).
Avant quand je lisais avec recvfrom qu'une seule fois ce n'était pas toujours 500 ms, est-ce normal?

Cette fonction sert en fait à recevoir le statut d'un serveur de jeu pour mon "server browser"... Donc si chaque réponse dure 500 ms maintenant ça devient beaucoup trop lent.

Est-ce la faute du timeout? Pourquoi cela n'affecte pas la lecture d'un simple packet?
Puisque dans la boucle, directement après le premier packet, si'l n'y a plus rien la fonction devrait retourner?

Faute de logique?
19/02/2010, 11h30
Invité(e)

Citation:

Envoyé par elwario91

Merci, ça marche!

Par contre maintenant cela dure toujours 500 ms pour tout recevoir (timeout?).
Avant quand je lisais avec recvfrom qu'une seule fois ce n'était pas toujours 500 ms, est-ce normal?

Cette fonction sert en fait à recevoir le statut d'un serveur de jeu pour mon "server browser"... Donc si chaque réponse dure 500 ms maintenant ça devient beaucoup trop lent.

Est-ce la faute du timeout? Pourquoi cela n'affecte pas la lecture d'un simple packet?
Puisque dans la boucle, directement après le premier packet, si'l n'y a plus rien la fonction devrait retourner?

Faute de logique?

Le problème vient bien du timeout.

En fait, quand le serveur envoie un paquet, on attend très peut. Quand le serveur n'envoie rien, on attend le temps du timeout.
Avec cette nouvelle méthode, on attend toujours que le serveur ne dise plus rien avant de quitter.

Une solution serait de mesurer à chaque fois combien de temps le serveur met à répondre et régler ton timeout en fonction.

Une autre idée serait d'avoir deux timeout :
Un timeout long qui attend la réponse du serveur.
Un timeout court qui attend que le serveur ne réponde plus : il faudrait le mettre en place juste après le recvfrom.
19/02/2010, 12h08
elwario91

Oui, mais le problème dans ta solution pour moi c'est que le temps que met cette fonction à tout recevoir est très important puisque c'est comme ca que je détermine le ping du serveur, nécessaire vu que la fonction est utilisé pour lister un liste de serveurs avec leur ping...

Je suis un peu coincé...
19/02/2010, 16h54
elwario91

Quelqu'un a une idée?
Est-ce possible de faire recvrom sans attente?
19/02/2010, 18h23
Invité(e)

Alors, si le problème vient d'un grand nombre de serveur à questionner, on peut passer par des threads : un par serveur. Si tout se passe bien, le temps d'attente total sera celui d'attente pour une seule réponse serveur.
19/02/2010, 19h23
elwario91

Ce n'est pas le temps de réponse qui est le problème.
J'utilise déjà des threads, avec GThreadPool de la GLib pour être précis.

C'est le fait que le ping détecté est faussé, important pour une liste de serveurs! :)