Winsock et création de thread

Winsock et création de thread - C++ - Programmation

Marsh Posté le 04-06-2003 à 09:02:02    

Salut
 
Pour un programme que je dois faire, j'utilise winsock. Pour ce faire j'utilise 2 thread, le premier thread principal pour envoyé des infos sur le réso et un deuxième thread pour recevoir des infos en permanance sur le réso.
 
En faite le premier se connecte sur le port 5001 d'un serveur. Et le deuxième attend une connexion sur le port 5000.  
 
Mon problème est le suivant, quand je n'utilise que le premier thread (pour envoyer des infos), je n'ai pas de problème, tout marche bien. Mais quand j'utilise le deuxième tread, je ne suis plus capable d'envoyer des infos (premier thread) dès que je commance à écouter sur le port 5000 (deuxieme thread). Pourtant la connexion au serveur (par le premier thread) se passe bien. Je pense que mon deuxième thread fonctionne bien, c'est juste quand je fais un listen pour écouter le port 5000 que ca bloque.
 
Est-ce que quelqu'un saurait m'aider ???
 
Un grand merci.

Reply

Marsh Posté le 04-06-2003 à 09:02:02   

Reply

Marsh Posté le 04-06-2003 à 09:03:48    

Avec ton code peut être.


---------------
Le Tyran
Reply

Marsh Posté le 04-06-2003 à 09:07:30    

LetoII a écrit :

Avec ton code peut être.


Ok
 
Une partie du main
 

Code :
  1. port = 5001;
  2. initSock ();
  4. test = createSocket();
  5. connexionError = connect(test, "x.x.x.x", 5001);
  7. //if (connexionError == 0)
  8.  threadStart(5000);
  9. //else
  10. // threadStart(5001);


 
Voici mon fichier pour le réso.
 
H

Code :
  1. void initSock (void);
  3. SOCKET createSocket(void);
  5. void assignPort(SOCKET s, int port);
  7. void listen(SOCKET s);
  9. int connect(SOCKET s, char *adress, int port);
  11. SOCKET acceptConnexion(SOCKET s);
  13. void write(SOCKET s, char *string);
  15. int read(SOCKET s, char *buffer);
  17. void close(SOCKET s);


CPP

Code :
  1. #include <winsock2.h>
  2. #include <string.h>
  3. #include <stdio.h>
  5. #define BUFFER_SIZE 256
  8. void initSock (void){
  9. // Must be done at the beginning of every WinSock program
  10. WSADATA w;    // used to store information about WinSock version
  11. int error = WSAStartup (0x0202, &w);   // Fill in w
  13. if (error)
  14. { // there was an error
  15.  return;
  16. }
  18. if (w.wVersion != 0x0202)
  19. { // wrong WinSock version!
  20.  WSACleanup (); // unload ws2_32.dll
  21.  return;
  22. }
  23. }
  25. SOCKET createSocket(void) {
  26. return socket (AF_INET, SOCK_STREAM, 0); // Create socket
  27. }
  29. void assignPort(SOCKET s, int port) {
  30. // Note that you should only bind server sockets, not client sockets
  31. // SOCKET s is a valid socket
  32. // WSAStartup has been called
  34. sockaddr_in addr; // the address structure for a TCP socket
  36. addr.sin_family = AF_INET;      // Address family Internet
  37. addr.sin_port = htons (port);   // Assign port to this socket
  38. addr.sin_addr.s_addr = htonl (INADDR_ANY);   // No destination
  40. if (bind(s, (LPSOCKADDR)&addr, sizeof(addr)) == SOCKET_ERROR)
  41. { // error
  42.  WSACleanup ();  // unload WinSock
  43.  return;         // quit
  44. }
  45. }
  47. void listen(SOCKET s) {
  48. // WSAStartup () has been called
  49. // SOCKET s is valid
  50. // s has been bound to a port using sockaddr_in sock
  51. if (listen(s,5)==SOCKET_ERROR)
  52. { // error!  unable to listen
  53.  printf("error!  unable to listen" );
  54.  WSACleanup ();
  55.  return;
  56. }
  57. }
  59. int connect(SOCKET s, char *adress, int port){
  60. // WSAStartup () has been called
  61. // SOCKET s is valid
  62. // s has been bound to a port using sockaddr_in sock
  63. sockaddr_in target;
  65. target.sin_family = AF_INET;           // address family Internet
  66. target.sin_port = htons (port);        // set server?s port number
  67. target.sin_addr.s_addr = inet_addr (adress);  // set server?s IP
  69. if (connect(s, (LPSOCKADDR)&target, sizeof(target)) == SOCKET_ERROR)
  70. { // an error connecting has occurred!
  71.  printf("an error connecting has occurred!" );
  72.  WSACleanup ();
  73.  return -1;
  74. }
  75. return 0;
  76. }
  78. SOCKET acceptConnexion(SOCKET s){
  79. // WSAStartup () has been called
  80. // SOCKET s is valid
  81. // s has been bound to a port using sockaddr_in sock
  82. // s is listening
  84. //#define MAX_CLIENTS 1;             // just used for clearness
  86. int number_of_clients = 0;
  87. SOCKET client[1/*MAX_CLIENTS*/];        // socket handles to clients
  88. sockaddr client_sock[1/*MAX_CLIENTS*/]; // info on client sockets
  90. while (number_of_clients < 1/*MAX_CLIENTS*/) // let MAX_CLIENTS connect
  91. {
  92.  client[number_of_clients] =  // accept a connection
  93.  accept (s, NULL/*client_sock[number_of_clients]*/, NULL/*&addr_size*/);
  94.  if (client[number_of_clients] == INVALID_SOCKET)
  95.  { // error accepting connection
  96.   printf("error accepting connection" );
  97.      WSACleanup ();
  98.   return client[0];
  99.  } else { // client connected successfully
  100.   // start a thread that will communicate with client
  101.   //startThread (client[number_of_clients]);
  102.   number_of_clients++;
  103.   return client[0];
  104.  }
  105. }
  106. }
  108. void write(SOCKET s, char *string) {
  109. // SOCKET s is initialized
  110. char buffer[BUFFER_SIZE];
  111. sprintf (buffer, string);
  112. //buffer[23] = '\0';
  113. send (s, buffer, BUFFER_SIZE, 0);
  114. printf("%s %d\n", buffer, strlen(buffer));
  116. }
  118. int read(SOCKET s, char *buffer){
  119. int toto;
  120. toto = recv (s, buffer, BUFFER_SIZE, 0);
  121. //printf("%s, buffer: %d, string: %d, recv: %d\n", buffer, sizeof(buffer), strlen(buffer), toto);
  122. return toto;
  123. }
  125. void close(SOCKET s) {
  126. shutdown (s, SD_SEND);  // s cannot send anymore
  128. // you should check to see if any last data has arrived here
  130. closesocket (s);   // close
  131. }


Message édité par Imhotep le 04-06-2003 à 10:18:04
Reply

Marsh Posté le 04-06-2003 à 09:09:05    

Pour le thread
 

Code :
  1. #include "stdio.h"
  2. #include "process.h"
  4. #include "network2.h"
  6. #define BUFFER_SIZE 256
  8. int port;
  10. float xNet, yNet, zNet;
  11. int tmpFrameNew = -1, part = 0;
  13. // déclaration de la section critique
  14. // code de la première tâche : PremierThread
  15. DWORD WINAPI readThread ( LPVOID IpvThreadParam )
  16. {
  17. SOCKET test;
  18. SOCKET testClient;
  19. char buffer[BUFFER_SIZE];
  20. //int port = 5001;
  21. int rint;
  22. int tempInt, tmpX, tmpY, tmpZ;
  24. /*
  25. if (argc == 2) port = (int)argv[1];
  26. printf("arg: %d.\nport: %d.\n", argc, port);
  27. */
  28. initSock ();
  29. //
  30. test = createSocket();
  31. assignPort(test, port);
  33. listen(test);
  35. testClient = acceptConnexion(test);
  37. while(true){
  38.  rint = read(testClient, buffer);
  39.  if (rint > 0) {
  40.   tempInt = sscanf(buffer,"%d %d %f %f %f", tmpFrameNew, part, tmpX, tmpY, tmpZ);
  41.   if (tempInt == 5 ) {
  42.    xNet = tmpX;
  43.    yNet = tmpY;
  44.    zNet = tmpZ;
  45.   }
  46.  }
  47. }
  48. //printf("%s %d", buffer, strlen(buffer));
  49. close(testClient);
  50. close(test);
  51. return (0);
  52. }
  54. // point d'entrée du programme
  55. void threadStart (int por)
  56. {
  57.   // Initialisation de la section critique
  59. port = por;
  61.   HANDLE hThreads [ 1 ] ;
  62.   DWORD dwThreadId ;
  63.   DWORD dwThreadParam = 1 ;
  65.   // création des Threads
  66.  
  67.   hThreads [ 0 ] = CreateThread ( NULL, NULL, readThread, &dwThreadParam, 0, &dwThreadId ) ;
  69.   // attente de fin d'exécution des Threads
  70.    //WaitForMultipleObjects ( 1, hThreads, TRUE, INFINITE) ;
  72.   // destruction des Threads et de la section critique  
  73.   //CloseHandle ( hThreads [ 0 ] ) ;
  74.   // destruction de la section critique
  75. }
  77. float retourXYZ(int nb) {
  78. if (nb == 1)
  79.  return xNet;
  80. else if (nb == 2)
  81.  return yNet;
  82. else
  83.  return zNet;
  84. }
  86. int retourFrame() {
  87. return tmpFrameNew;
  88. }
  90. int retourPart() {
  91. return part;
  92. }


Message édité par Imhotep le 04-06-2003 à 09:24:33
Reply

Marsh Posté le 04-06-2003 à 09:12:14    

tu devrais utiliser les balises de codes c pas top lisible là.


Message édité par LetoII le 04-06-2003 à 10:20:10

---------------
Le Tyran
Reply

Marsh Posté le 04-06-2003 à 09:23:43    

LetoII a écrit :

tu devrais utiliser les balises de codes c pas top lisible là.


 
Merci  :D

Reply

Marsh Posté le 04-06-2003 à 09:38:43    

Le main ça pourait être sympa aussi :D


Message édité par LetoII le 04-06-2003 à 09:39:10

---------------
Le Tyran
Reply

Marsh Posté le 04-06-2003 à 10:18:43    

Vala (voir plus haut)
 :)

Reply

Sujets relatifs:

Leave a Replay

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