Multiples messages non reçus...:((

Bonsoir tout le monde!

Je suis actuellement en cours d'apprentissage des Sockets et j'ai crée une application Client/Server pouvant communiquer ensemble! Il n'y a pas de souci lors de la connexion etc...en fait, le client envoie 2 messages ("salut!!!", et "xpldr!!")...mais seul le premier ("salut!!!") est reçu, pas le second! En fait, le server récupère des buffers vides après des appels à recv()....comme si il n'attendais pas l'arrivée de données...:s ... j'spère que vous pourrez m'aider...et que mon code n'est pas trop tiré par les cheveux ;)

/* appli cliente */

#include <windows.h>
#include <winsock2.h>

SOCKET sock;
SOCKADDR_IN addr;

int port = 8554;

int WINAPI WinMain(HINSTANCE hInstance, HINSTANCE hPrevInstance, LPSTR lpCmdLine, int nCmdShow) {
 
  WSADATA wsa;
  WSAStartup(MAKEWORD(2,2), &wsa);
 
  addr.sin_family = AF_INET;
  addr.sin_addr.s_addr = inet_addr("213.44.147.196");
  addr.sin_port = htons(port);
 
  sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  connect(sock, (SOCKADDR*) &addr, sizeof(addr));
 
  send(sock, "Salut!!!", 15, 0);
  send(sock, "xpldr", 15, 0);
  MessageBox(0, "Voila, c'est envoyé!! :)", ":)", 0); 
 }

/* Appli server */

#include <windows.h>
#include <winsock2.h>

WSANETWORKEVENTS Network;
WSAEVENT Event[1];

SOCKET sock, dasock;
SOCKADDR_IN addr, sin;

int port = 8554;

DWORD WINAPI WaitTCPData(LPVOID pv) {
 
  char buffer[500];
  int result = SOCKET_ERROR;
 
  int TimedOut = 0;
 
  while(result == SOCKET_ERROR) {
 
   ZeroMemory(buffer, sizeof(buffer));
   result = recv(dasock, buffer, 500, 0);
   
   if(lstrlen(buffer) > 2) {
                  
     MessageBox(0, buffer, "Server a intercepé ceci :", 0);
     TimedOut = 0;
    }
   
   else TimedOut++;
  
   if(TimedOut >= 20000) return 0;
  } 
 }

int WINAPI WinMain(HINSTANCE hInstance, HINSTANCE hPrevInstance, LPSTR lpCmdLine, int nCmdShow) {
 
  WSADATA wsa;
  WSAStartup(MAKEWORD(2,2), &wsa);
 
  addr.sin_family = AF_INET;
  addr.sin_port = htons(port);
  addr.sin_addr.s_addr = INADDR_ANY;
 
  sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  bind(sock, (SOCKADDR*) &addr, sizeof(addr));
 
  Event[0] = WSACreateEvent();
  listen(sock, 5);
 
  char buffer[500]; 
  int sinsize;
 
  while(1) {
   
    sinsize = sizeof(sin);
    if((dasock = accept(sock, (SOCKADDR*) &sin, &sinsize)) != INVALID_SOCKET) {
     
      WSAEventSelect(dasock, Event[0], FD_READ);
     
      ZeroMemory(&Network, sizeof(WSANETWORKEVENTS));
      WSAWaitForMultipleEvents(1, Event, 0, WSA_INFINITE, 0);
      WSAEnumNetworkEvents(dasock, Event[0], &Network);
     
      switch(Network.lNetworkEvents) {
      
        case FD_READ:
         
          DWORD dwTemp;
          CreateThread(0, 0, WaitTCPData, (LPVOID) 0, 0, &dwTemp); 
         break;       
       } 
     }  
   }   
 }


Gendal67, Dev-C++ 4.9.9.1, J'adore cppfrance!! :-))

Moi déjà j'mettrai 127.0.0.1 comme IP histoire d'être sur que tu le recevra :)
Mais sinon les socket, je connais strictement rien
Faudrait j'mi mette également
Donc si quelqu'un pouvait répondre à sa question et me filer un lien de tutorial
Je  serais votre esclave ;)
mdr
Abusé pas qd mm
Bande de proxenete

By Moi

void Aurevoir( void ); //Bonne journée

Non Joky, pas 127.0.0.1....le message marche avec la vraie IP, donc pas de pb...le seul souci c'est l'envoie de plusieurs messages (= +d'un appel à send())

Gendal67, Dev-C++ 4.9.9.1, J'adore cppfrance!! :-))

Salut,
a quoi sert le thread WaitTCPData ?
La fonction WSAEventSelect() met automatiquement le socket dasock en mode non bloquant, donc lors du traitement du FD_READ, tu peux directement appeler recv().

Ensuite, ta boucle principale se compose comme ca:

while(1)
{
if(dasock = accept(...))
{
// traitement
}
}

A la premiere iteration, la connexion est acceptée et le traitement effectué, et dans la seconde iteration, le accept() bloque tout car sock est bloquant.

:s oki oki..mais comment faire alors pour recevoir +d'un message FD_READ sans que ça déconne ??

Gendal67, Dev-C++ 4.9.9.1, J'adore cppfrance!! :-))

euh, et ça, c'est mieux ?

int WINAPI WinMain(HINSTANCE hInstance, HINSTANCE hPrevInstance, LPSTR lpCmdLine, int nCmdShow) {
 
  WSADATA wsa;
  WSAStartup(MAKEWORD(2,2), &wsa);
 
  addr.sin_family = AF_INET;
  addr.sin_port = htons(port);
  addr.sin_addr.s_addr = INADDR_ANY;
 
  sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  bind(sock, (SOCKADDR*) &addr, sizeof(addr));
 
  Event[0] = WSACreateEvent();
  listen(sock, 0);
 
  char buffer[500]; 
  int sinsize;
 
  while(1) {
   
    sinsize = sizeof(sin);
    if((dasock = accept(sock, (SOCKADDR*) &sin, &sinsize)) != INVALID_SOCKET) {
     
      WSAEventSelect(dasock, Event[0], FD_READ);
     
      ZeroMemory(&Network, sizeof(WSANETWORKEVENTS));     
     
      WSAWaitForMultipleEvents(1, Event, 0, WSA_INFINITE, 0);
      WSAEnumNetworkEvents(dasock, Event[0], &Network);
     
      switch(Network.lNetworkEvents) {
      
        case FD_READ:
         
          ZeroMemory(buffer, sizeof(buffer));
          recv(dasock, buffer, 500, 0);
         break;       
       }     
        
    }
      
      closesocket(dasock);  
     }      
 }

Gendal67, Dev-C++ 4.9.9.1, J'adore cppfrance!! :-))

Salut,
Faudrait revoir la structure complete du prog, la tu as fait un mélange entre le modele WSAEventSelect, et le modele avec les sockets bloquants + threads.

Pour utiliser le modele WSAEventSelect seul, il faut appeler WSAEventSelect sur le socket sock apres l'avoir bindé, et dans ta boucle principale on doit trouver dans l'ordre: WSAWaitForMultipleEvents pour attendre qu'un event passe a l'état signalé,
puis pour chaque event signalé:
WSAEnumNetworkEvents pour savoir le type d'event (FD_READ, FD_CONNECT, etc..) et ensuite il faut traiter ces events.

Tout cela est bien mieux expliqué dans ce bouquin:
[ Lien ]

Je l'ai déja ce livre aardman, c'est un ebook que tu m'a déja conseillé et j'en ai déja lu un pti bout....mais bon, surtout parce que c'est entièrement en anglais, je n'ai pas passé des heures à raser tout au peigne fin....nan sérieux, tu pourrais pas m'expliquer toi ? Je ne te demande pas de tout me dire ni de tout me faire mais m'expliquer certains trucs....là j'ai fait ceci, et je ne comprend pas pourquoi ça ne marche pas :

  while(1) {
   
    sinsize = sizeof(sin);
    if((dasock = accept(sock, (SOCKADDR*) &sin, &sinsize)) != INVALID_SOCKET) {
    
    do {
     
      Event[0] = WSACreateEvent();
      WSAEventSelect(dasock, Event[0], FD_READ);
     
      ZeroMemory(&Network, sizeof(WSANETWORKEVENTS));      
     
      WSAWaitForMultipleEvents(1, Event, 0, WSA_INFINITE, 0);
      WSAEnumNetworkEvents(dasock, Event[0], &Network);
     
      switch(Network.lNetworkEvents) {
      
        case FD_READ:
         
          ZeroMemory(buffer, sizeof(buffer));
          recv(dasock, buffer, 500, 0);
         
          MessageBox(0, buffer, "Message reçu sur le server :", 0);
         break;       
       } 
                          
    } while(1); // c'est juste pour tester avec plusieurs messages...
      
      closesocket(dasock);  
     }

Gendal67, Dev-C++ 4.9.9.1, J'adore cppfrance!! :-))

Re-salut! J'ai regardé le book et j'ai trouvé et cru comprendre certaines choses  même si le programme ne marchent toujours pas...que dis tu de ça :

#include <windows.h>
#include <winsock2.h>

#include <stdio.h>

WSANETWORKEVENTS Network;
WSAEVENT Event[5];
SOCKET sockarray[5];

SOCKET sock, dasock;
SOCKADDR_IN addr, sin;
WSAEVENT hEvent;

int port = 8554;
int wsa_connection_cnt = 0;
int index = 0;

int WINAPI WinMain(HINSTANCE hInstance, HINSTANCE hPrevInstance, LPSTR lpCmdLine, int nCmdShow) {
 
  WSADATA wsa;
  WSAStartup(MAKEWORD(2,2), &wsa);
 
  addr.sin_family = AF_INET;
  addr.sin_port = htons(port);
  addr.sin_addr.s_addr = INADDR_ANY;
 
  sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  bind(sock, (SOCKADDR*) &addr, sizeof(addr));
 
  hEvent = WSACreateEvent();
  WSAEventSelect(sock, hEvent, FD_ACCEPT | FD_CLOSE); 
 
  listen(sock, 5);
 
  sockarray[wsa_connection_cnt] = sock;
  Event[wsa_connection_cnt] = hEvent;
  wsa_connection_cnt++;
 
  char buffer[500];
  int sizesin = sizeof(sin);
 
  while(1) {
 
     index = WSAWaitForMultipleEvents(wsa_connection_cnt, Event, FALSE, WSA_INFINITE, FALSE);
     index = index - WSA_WAIT_EVENT_0;
    
     WSAEnumNetworkEvents(sockarray[index], Event[index], &Network);
    
     switch(Network.lNetworkEvents) {
     
       case FD_ACCEPT:
       
         dasock = accept(sockarray[index], (SOCKADDR*) &sin, &sizesin);
        
         hEvent = WSACreateEvent();
         WSAEventSelect(dasock, hEvent, FD_READ | FD_WRITE | FD_CLOSE);
        
         sockarray[wsa_connection_cnt] = dasock;
         Event[wsa_connection_cnt] = hEvent;
         wsa_connection_cnt++;
        
         printf("Connexion interceptee et acceptee no: %d\n", wsa_connection_cnt);
        break;
       
       case FD_READ:
        
         ZeroMemory(buffer, sizeof(buffer));
         recv(sockarray[index], buffer, 500, 0);
        
         hEvent = WSACreateEvent();
         WSAEventSelect(sockarray[index], hEvent, FD_READ | FD_WRITE | FD_CLOSE);
        
         MessageBox(0, buffer, "Server a reçu ceci :", 0);
        break;
       
       case FD_CLOSE:
           
          closesocket(sockarray[index]);
         // CompressArrays(Event, sockarray, &wsa_connection_cnt); 
         break;                   
      } 
   }        
 }

Gendal67, Dev-C++ 4.9.9.1, J'adore cppfrance!! :-))

Salut,
FD_READ, FD_CLOSE etc. sont des flags, donc pour les tester ont fait:
if(Network.lNetworkEvent & FD_READ)
{ ... }