Forum |  HardWare.fr | News | Articles | PC | S'identifier | S'inscrire | Shop Recherche
1253 connectés 

  FORUM HardWare.fr
  Programmation
  C++

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

 
 


 Mot :   Pseudo :  
 
Bas de page
Auteur Sujet :

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

n°1425691
xwindoo
Posté le 15-08-2006 à 20:51:28  profilanswer
 

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.
 
 

mood
Publicité
Posté le 15-08-2006 à 20:51:28  profilanswer
 

n°1425701
farib
Posté le 15-08-2006 à 21:19:57  profilanswer
 

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
n°1425703
xwindoo
Posté le 15-08-2006 à 21:24:40  profilanswer
 

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.


Aller à :
Ajouter une réponse
  FORUM HardWare.fr
  Programmation
  C++

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

 

Sujets relatifs
Comment éviter de tricher sur le nombre de fois qu'un lien est cliqué?J'étais en première page de google, je n'y suis plus du tout... [Help]
Supprimer des éléments de la fenêtre une fois celle-ci chargée[C]Problème de socket.
[resolu] afficher une fois si il existe déjàblocage sur la lecture d'un socket
[C] "correspondance" possible entre FILE * et socket ? [résolu]HTML - mettre une image de fond une seule fois
Socket, recv, send et select qui ne marche pas 
Plus de sujets relatifs à : [C++][SOCKET]recv() bloque la première fois

Forum MesDiscussions.Net, Version 2010.2
(c) 2000-2011 Doctissimo
Page générée en 0.089 secondes

Copyright © 1997-2022 Hardware.fr SARL (Signaler un contenu illicite / Données personnelles) / Groupe LDLC / Shop HFR