[C++][SOCKET]recv() bloque la première fois

recv() bloque la première fois [C++][SOCKET] - C++ - Programmation

Marsh Posté le 15-08-2006 à 20:51:28    

Bonjour à tous,
je suis en train de programmer un jeu (rpg 2D avec direct3D) en réseau. J'ai structuré mon programme en différentes classes à savoir pour le réseau une classe CSocket ainsi qu'un fichier cpp contenant les fonctions (statiques) des threads des sockets (serveur et clients). A l'intérieur de ces fonctions, j'ai mis recv() dans une boucle while infinie. Lorsque un thread correspondant aussi bien au client qu'au serveur est crée, la fonction s'arrète bien sur recv() qui est bloquante mais, dès qu'elle reçoit des données, elle ne se bloque plus et le programme passe dessus indéfiniment. Voila mon code :
 
Socket.cpp :

Code :
  1. // Socket.cpp: implementation of the CSocket class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include <winsock.h>
  6. #pragma comment(lib, "wsock32.lib" )
  7. #include <windows.h>
  8. #include <stdarg.h>
  9. #include "RecvMsg.h"
  10. #include "Socket.h"
  12. //////////////////////////////////////////////////////////////////////
  13. // Construction/Destruction
  14. //////////////////////////////////////////////////////////////////////
  16. CSocket::CSocket()
  17. {
  18. Serveur = 0;
  19. nClient = 0;
  20. }
  22. CSocket::~CSocket()
  23. {
  25. }
  27. //////////////////////////////////////////////////////////////////////
  28. // Fonctions
  29. //////////////////////////////////////////////////////////////////////
  31. int CSocket::Init(HWND hWnd, int Type, char DNS[20], int Port, int MaxClient, LPVOID pMP, char *NomJoueur)
  32. {
  33. WSADATA wsa;
  34. SOCKADDR_IN addr;
  36. SetVar(pMP, (LPVOID)this);
  38. if(Type == SERVEUR)
  39. {
  40.  if(WSAStartup(MAKEWORD(2,0), &wsa))
  41.   return 29;
  43.  if((Serveur = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == 0)
  44.   return 30;
  46.  ZeroMemory(&addr, sizeof(addr));
  47.  addr.sin_family = AF_INET;
  48.  addr.sin_addr.S_un.S_addr = INADDR_ANY;
  49.  addr.sin_port = htons(Port);
  51.  if(bind(Serveur, (SOCKADDR*)&addr, sizeof(addr)))
  52.   return 31;
  54.  if(listen(Serveur, 5))
  55.  {
  56.   closesocket(Serveur);
  57.   return 32;
  58.  }
  60.  hThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)fnServeur, (LPVOID)Serveur, 0, &dwThread);
  61.  mMaxClient = MaxClient-1;
  62. }
  63. else if(Type == CLIENT)
  64. {
  65.  if(WSAStartup(MAKEWORD(2,0), &wsa) != 0)
  66.   return 29;
  68.  if(!(Serveur = socket(AF_INET, SOCK_STREAM, 0)))
  69.   return 30;
  71.  HOSTENT *Hote;
  72.  Hote = gethostbyname(DNS);
  73.  if(!Hote)
  74.   return 33;
  76.  ZeroMemory(&addr,sizeof(addr));
  77.  addr.sin_family = (*Hote).h_addrtype;
  78.  addr.sin_port = htons(Port);
  79.  addr.sin_addr = *((IN_ADDR*)(*Hote).h_addr);
  81.  if(connect(Serveur, (const struct sockaddr*)&addr, sizeof(addr)))
  82.   return 34;
  84.  int IDMsg = 11;
  85.  send(Serveur, (char*)&IDMsg, sizeof(IDMsg), 0);
  86.  send(Serveur, NomJoueur, sizeof(NomJoueur), 0);
  88.  hThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)RecvMsgC, (LPVOID)Serveur, 0, &dwThread);
  89. }
  91. return 0;
  92. }
  94. ...


 
RecvMsg.cpp :

Code :
  1. #include "RecvMsg.h"
  2. #include "MenuPrincipal.h"
  3. #include "Socket.h"
  5. CMenuPrincipal *rmMP;
  6. CSocket *rmSocket;
  8. void SetVar(LPVOID MP, LPVOID Sock)
  9. {
  10. rmMP = (CMenuPrincipal*)MP;
  11. rmSocket = (CSocket*)Sock;
  12. }
  14. void fnServeur(LPVOID param)
  15. {
  16. SOCKET s = (SOCKET)param;
  17. while(rmSocket->nClient < rmSocket->mMaxClient)
  18. {
  19.  rmSocket->Client[rmSocket->nClient] = accept(rmSocket->Serveur, NULL, NULL);
  20.  rmSocket->hThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)RecvMsgS, (LPVOID)rmSocket->Client[rmSocket->nClient], 0, &rmSocket->dwThread);
  22.  if(rmSocket->nClient == rmSocket->mMaxClient)
  23.   closesocket(rmSocket->Serveur);
  24.  else
  25.   rmSocket->nClient++;
  26. }
  27. }
  29. void RecvMsgS(LPVOID param)
  30. {
  31. SOCKET s = (SOCKET)param;
  32. PACKET p;
  34. int IDMsg,t;
  36. bool quit = false;
  37. while(!quit)
  38. {
  39.  recv(s,(char*)&IDMsg, sizeof(IDMsg),0);
  40.  send(s,"a",1,0);
  41.  switch(IDMsg)
  42.  {
  43.  case MTSM_DATA:
  44.   {
  45.                                 ...
  46.   }
  47.   break;
  49.  case MTSM_CLOSE:
  50.   {
  51.    MessageBox(0,"close",0,0);
  52.    quit = true;
  53.   }
  54.   break;
  56.  default:
  57.   break;
  58.  }
  59.  ZeroMemory(&p, sizeof(p));
  60. }
  61. }
  63. void RecvMsgC(LPVOID param)
  64. {
  65. SOCKET s = (SOCKET)param;
  66. PACKET p;
  68. while(1)
  69. {
  70.  recv(s,(char *)&p, sizeof(p), 0);
  71.  switch(p.IDMsg)
  72.  {
  73.  case MTSM_INFOPARTIE:
  74.   {
  75.                                  ...
  76.   }
  77.   break;
  79.  default:
  80.   break;
  81.  }
  83.  ZeroMemory(&p, sizeof(p));
  84. }
  85. closesocket(s);
  86. }


 
J'ai cherché en vain la réponse, une seule personne avait le même problème que mais sa solution ne correspondais pas.
Merci d'avance.
 
 

Reply

Marsh Posté le 15-08-2006 à 20:51:28   

Reply

Marsh Posté le 15-08-2006 à 21:19:57    

Tu lis les donnees entre tes deux selects ?
 
edit j'ai lu de travers j'ai rien dit


Message édité par farib le 15-08-2006 à 21:36:35

---------------
Bitcoin, Magical Thinking, and Political Ideology
Reply

Marsh Posté le 15-08-2006 à 21:24:40    

Comment ca entre deux select() ? je ne fais pas de select(), je crée des thread et dans ces thread j'inclus un recv() dans une boucle while infinie.

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed