[socket & windows & accept]

Version imprimable

25/04/2004, 12h38
Magique

[socket & windows & accept]
Bonjour à tous !

après une recherche sur ce forum, j'ai trouvé quelques sujets qui touchent a mon probleme (http://www.developpez.net/forums/vie...=socket+accept) mais qui ne le traitent pas vraiment...

Je bosse avec un ami sur un client tcp/ip sous windows et je souhaite gérer le time out au serveur : lors de l'accept du serveur.
J'essaie de faire en sorte qu'au bout de X secondes, si le client ne s'est pas connecté, le serveur quitte.
Jusqu'à présent je travaillais avec des socketes bloquantes , donc on restait sur l'instruction

Code:

sock3 = accept(sock2, (struct sockaddr*)&mytcp,&len);

J'ai essayé de changer la nature de la socket pour incorporer le time out
Code:

1 2 3 4 5 6 u_long val = 0; ioctlsocket(sock3,FIONBIO,&val); printf("[*] waiting for shell\n"); timeout = 500; endtime=(clock_t) (((double) timeout)/1000)*CLOCKS_PER_SEC + clock(); sock3=INVALID_SOCKET
Code:

1 2 3 4 5 6 7 do { sock3 = accept(sock2, (struct sockaddr*)&tcp,&taille); printf(".."); fflush(stdout); } while(sock3==INVALID_SOCKET && endtime>clock());
apres test, sock3 est bien différent de invalid, car on sort de la boucle (et que le temps n'est pas ecoulé, j'ai fais une verif). Mais le client ne s'est pas connecté !
donc pourquoi change t'il de valeur ? j'ai essayé de remplacer INVALID_SOCKET par SOCKET_ERROR , on sort quand meme de la boucle, immédiatement.
S'il faut que je rechange ma socket en bloquante, alors peut on gérer le time out en bloquant ?

(je sais qu'avec ma boucle et cette socket non bloquante je vais allégrement puiser dans les ressources machines :( )

merci de vos réponses
27/04/2004, 00h17
Magique

y a t'il une possibilité en passant par un select ?
27/04/2004, 02h16
darkalia

Oui le select est la reponse a ta question et permet de gerer bien plus facilement que ioctl le probleme de fonctions bloquantes sur les serveurs.
27/04/2004, 21h20
Magique

j'ai cherché sur le select , mais rien sur la gestion du time out. Il sert seulement à surveiller des sockets ouvertes, et je n'en ai qu'une ouverte... A moins que j'ai raté un épisode ?

On employe select() avant d'appeler accept().

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
 
SOCKET AcceptTimeout(SOCKET s, struct sockaddr * addr, int addrlen, long ms)
{
	u_long val = 0; 
	struct timeval tv;
	fd_set readfds;
	int result;
 
	tv.tv_sec  = 0;
	tv.tv_usec = ms * 1000; // le temps d'attendre en micro-secondes
 
	ioctlsocket(s, FIONBIO, &val);
 
	FD_ZERO(&readfds);
	FD_SET(s, &readfds);
 
	// Attendre pour le socket devenir lisible
	result = select(s + 1, &readfds, NULL, NULL, &tv);
 
	if (result == 1 && FD_ISSET(s, &readfds)) // le socket est lisable (accept() retournera immédiatement)
		return accept(s, (struct sockaddr*) addr, &addrlen);
	else // le temps a ecoulé
		return SOCKET_ERROR;
}

28/04/2004, 14h12
Magique

Merci beaucoup pour ce code excellent, que j'ai immédiatement testé.

Le time out marche très bien (si mon client ne se connecte pas, mon serveur quitte au bout de x secondes), par contre j'aboutis toujours au meme probleme que lorsque je travaillais avec ma socket non bloquante : ma socket n'est pas lisible.

Code:

result = select(s + 1, &readfds, NULL, NULL, &tv);

ceci me renvoie 0, même si mon client se connecte ...
et forcément le accept me renvoie -1 D'où déconnection de mon serveur.
J'ai essayé de changer readfds à writefds mais ca ne change rien, je suis toujours à 0...

Code:

1
2
3
 
u_long val = 0; 
ioctlsocket(sock3,FIONBIO,&val);

La val était incorrecte! Zéro est bloquant et non zéro est non bloquant!
Ce code travaille bien pour moi:

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
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
 
SOCKET AcceptTimeout(SOCKET s, struct sockaddr * addr, int addrlen, long ms) 
{ 
   u_long val = 1; 
   struct timeval tv; 
   fd_set readfds; 
   int result; 
 
   tv.tv_sec  = 0; 
   tv.tv_usec = ms * 1000;
 
   ioctlsocket(s, FIONBIO, &val); 
 
   FD_ZERO(&readfds); 
   FD_SET(s, &readfds); 
 
   result = select(s + 1, &readfds, NULL, NULL, &tv); 
 
   if (result == 1 && FD_ISSET(s, &readfds))
   {
      return accept(s, (struct sockaddr*) addr, &addrlen); 
   }
   else
   {
      if (result != SOCKET_ERROR) WSASetLastError(WSAETIMEDOUT);
      return INVALID_SOCKET; 
   }
} 
 
 
int main(void)
{
   WSADATA wsaData;
   SOCKET serverSocket, recvSocket;
   struct sockaddr_in local  = { 0 };
   struct sockaddr_in remote = { 0 };
 
   WSAStartup(0x202,&wsaData);
 
   local.sin_family      = AF_INET;
   local.sin_port        = htons(80);
   local.sin_addr.s_addr = INADDR_ANY;
 
   serverSocket = socket(AF_INET, SOCK_STREAM, 0);
 
   bind(serverSocket, (struct sockaddr *) &local, sizeof(local));
   listen(serverSocket, SOMAXCONN);
 
   recvSocket = AcceptTimeout(serverSocket, (struct sockaddr *) &remote , sizeof(remote), 5000);
 
   if (recvSocket == INVALID_SOCKET)
   {
      printf("AcceptTimeout Erreur: %d\n", WSAGetLastError());
   }
   else
   {
      u_long val = 0;
      char buf[512];
      int cnt;
 
      printf("AcceptTimeout a réussi. Addr: %s\n", inet_ntoa(remote.sin_addr));
 
      // rechange socket en bloquant
      ioctlsocket(recvSocket, FIONBIO, &val); 
 
      cnt = recv(recvSocket, buf, sizeof(buf) - 1, 0);
 
      if (cnt > 0)
      {
          buf[cnt] = '\0';
          printf("\n%s\n", buf);
      }
      else
      {
          printf("recv Erreur: %d\n", WSAGetLastError());
      }
   }
 
   getchar();
   return 0;
}

30/04/2004, 23h34
Magique

j'ai trouvé mon erreur, et ce code est adapté pour réponde à mon probleme.
J'en profite pour dire que le s+1 dans

Code:

result = select(s + 1, &readfds, NULL, NULL, &tv);

n'avais aucune incidence (on aurait pu mettre n'importe quoi, cf msdn)

merci encore !