problème d'accès variable entre deux threads

problème d'accès variable entre deux threads - C++ - Programmation

Marsh Posté le 24-07-2007 à 13:44:05    

Salut à tous,
 
je suis en train de bosser sur un petit programme qui ouvre un thread pour écouter un port tcp (récupère donc un char* qui contient du xml) et qui a un second thread qui doit récupérer ce message xml pour le parser.
j'ai fais pour cela deux classe, une qui gère l'écoute et une qui gère le parsage mais j'ai un problème pour la récupération de la variable contenant le message xml de ma classe d'écoute avec ma classe de parsage.
 
voici les extraits de codes utiles à comprendre mon prog
 

Code :
  1. --- definition des methodes et classes ---
  3. typedef struct
  4. {
  5.     int nb;             // Nombre d'octets recus
  6.     char buf[1500];
  7. } Recv;
  10. class Listener
  11. {
  12.     public:
  14.     Listener();
  15.     void lecture(); // lecture sur la socket
  16.     Recv get_buffer(); // renvoie du buffer
  17.     void set_listener(Sock L_socket); //mis en place de la socket
  19.     pthread_mutex_t verrou;
  21.     private:
  23.     Sock listener; // structure contenant la socket
  24.     Recv ret;
  26. };
  29. void Listener::lecture()
  30. {
  31.     cout << "Lancement de la lecture" << endl;
  32.     while (1))
  33.     {
  34.         Recv temp;
  35.         temp.nb = -1;
  36.         memset (ret.buf, 0, sizeof (ret.buf));
  37.         temp=recv(listener);
  38.         pthread_mutex_lock( &verrou );
  39.         ret.nb = temp.nb;
  40.         strcpy(ret.buf, temp.buf);
  41.         pthread_mutex_unlock( &verrou );
  42.        cout << "sortie 1" << endl << ret.nb << endl << ret.buf  << endl;
  43.     }
  44. };
  47. Recv Listener::get_buffer()
  48. {
  49.     Recv temp;
  50.     pthread_mutex_lock( &verrou );
  51.     temp.nb =ret.nb;
  52.     strcpy(temp.buf, ret.buf);
  53.     cout << "sortie 2"  << endl << ret.nb << endl << ret.buf << endl;
  54.     pthread_mutex_unlock( &verrou );
  55.     return temp;
  56. };
  60. class Parseur
  61. {
  62.     public:
  64.     Parseur();
  65.     void make_parse(); // fct qui fait le parse !
  66.     void action();
  68.     private:
  70.     Listener *listen;
  71.     Recv buffer;
  73. };
  76. void Parseur::action()
  77. {
  78.     while (1)
  79.     {
  80.         buffer.nb = -1;
  81.         memset (buffer.buf, 0, sizeof (buffer.buf));
  82.         buffer = listen->get_buffer(); // on récup le Recv de l'objet listener (en gros la variable ret)
  83.         make_parse();
  84.     }
  85. };


 
ensuite on passe à ma fonction principale
pour créer mes threads, je me suis servi de la classe x_filament_amelioree trouvée ici :http://www.cppfrance.com/code.aspx?ID=19908
 

Code :
  1. ------Main------
  3. // initialisation des deux objets
  4. Listener ecouteur;
  5. Parseur decoupeur;
  6. decoupeur.set_listener(&ecouteur); //je passe l'adresse de l'objet Listener à l'objet Parseur,  
  7.                                                 //pour qu'il puisse récupérer le buffer !
  9. //lance un thread qui excute la methode Listener::lecture
  10. x_Filament_Ameliore<Listener> fil_ecouteur(&ecouteur, &Listener::lecture);
  12. //lance un thread qui excute la methode Parseur::action
  13. x_Filament_Ameliore<Parseur> fil_decoupeur(&decoupeur, &Parseur::action);
  15. // et là ça merde ! :D


 
au final, la lecture se déroule bien , j'ai bien le nombre d'octets lu et le contenu de mon buffer qui s'affiche au niveau de la sortie 1. Par contre sur la sortie 2, j'ai le nb d'octets, mais j'ai un truc vide pour ce qui est du buf.
j'ai essayé de voir si en exécutant mon get_buffer à la suite de ma ma boucle dans le Listener::lecture() et là tout marche nickel.
je comprends vraiment plus rien là, donc si quelqu'un peut m'aider !
 
merci d'avance
Wad

Reply

Marsh Posté le 24-07-2007 à 13:44:05   

Reply

Marsh Posté le 24-07-2007 à 15:25:42    

c'est quoi ce parser qui contient un listener ?
 
il n'ont rien a voir entre eux ces deux la ! le parser ne doit pas aller chercher les données a parser, on doit lui fournir (sous forme de stream pour bien faire)

Reply

Marsh Posté le 24-07-2007 à 16:31:06    

comment faire ?
 
oui, je débute un peu, donc j'ai du mal :d


Message édité par wadcyr8_197 le 24-07-2007 à 16:41:47
Reply

Sujets relatifs:

Leave a Replay

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