Probleme de socket dans un thread

Version imprimable

Bonjour à tous, j'ai réaliser un petit programme de discution entre une camera et un logiciel par TCP. Les fonctions de connections sont appelées dans un thread qui est lancer par un bouton start. Je réussi la connection, reçoie les données de plusieurs acquisition: c'est à dire qu'entre chaque acquisition je ferme la conncetion puis relance la connection quand la camera envoie les donnée. J'appuie sur le bouton stop, le thread semble s'arreté mais si je rappuis sur le bouton start le program plante. Après un débug j'ai trouvé que la fonction suivante n'attandait plus l'envoie de la socket par la camera (la premiere fois que j'appuis sur start le debug fait une pause sur la fonction accept en attendant la connection de la camera, mais plus une fois que le thread est arreté puis relancer). Si je stop le thread, stop le programme et le relance puis relance une acquisition (bouton start) tout marche bien.
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 void WComm::waitForClient() { AcceptSocket = accept( m_backup, NULL, NULL ); m_socket = AcceptSocket; } //voila mon constructeur de class et destructeur WComm::WComm() { // Initialize Winsock. int iResult = WSAStartup( MAKEWORD(2,2), &wsaData ); if ( iResult != NO_ERROR ) printf("Error at WSAStartup()\n"); // Create a socket. m_socket = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP ); if ( m_socket == INVALID_SOCKET ) { printf( "Error at socket(): %ld\n", WSAGetLastError() ); WSACleanup(); return; } m_backup = m_socket; } WComm::~WComm(){WSACleanup();}
Cela vient-il du thread ou de la fonction accept qui est ma réinitialisé?
Merci de votre aide ça fait deux jour que je bloque j'ai le cerveau qui commence à surchauffer...Juste une petite précision, je programme sous Visual C++.

Nico

21/06/2008, 00h46
nicroman

normal... tu écrase le m_socket de listening par un autre socket (de transmission) dès la première occurence...
23/06/2008, 09h39
nikus

Tu parle de cette ligne de code la?

Code:

AcceptSocket = accept( m_backup, NULL, NULL );

ou de celle la?

Code:

m_socket = AcceptSocket;

Peus tu me donner une piste sur la marche à suivre car je ne vois pas se que je fait de travers et pourquoi je ne doit pas écraser cette variable?

Merci
23/06/2008, 18h34
nikus

probleme de thread

En fait mon thread ne ferme pas la connection quand il s'arrete et mon proc monte à 100% si je relance le thread. La boucle de wait for client tourne à l'infini.
Comment faire pour arreter toutes les fonction ou dll utilisé par un thread, j'ai implémenté un truc à partir des FAQ mais rien n'y fait....

merci

Heu....
On peu prendre le code ligne par ligne:

Code:

1
2
3
4
 
void WComm::waitForClient()
{
            AcceptSocket = accept( m_backup, NULL, NULL );

La variable membre (ou globale 'AcceptSocket' de type SOCKET) contiendra le socket (tunnel) contenant la connection qui est arrivée.

Code:

1
2
 
        m_socket = AcceptSocket;

et... on copie le socket dans la variable (membre ?) m_socket.

Code:

1
2
3
4
5
6
7
8
9
10
11
 
WComm::WComm()
{
 
    // Initialize Winsock.
    int iResult = WSAStartup( MAKEWORD(2,2), &wsaData );
    if ( iResult != NO_ERROR )
        printf("Error at WSAStartup()\n");
 
    // Create a socket.
    m_socket = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );

m_socket contient donc le socket "d'écoute"....

Code:

1
2
3
4
5
6
7
 
    if ( m_socket == INVALID_SOCKET ) {
        printf( "Error at socket(): %ld\n", WSAGetLastError() );
        WSACleanup();
        return;
    }
    m_backup = m_socket;

Maintenant m_backup contient *aussi* le socket d'écoute...

Maintenant je ne sais pas ce que fait ton code....
J'imagine un truc genre:

Code:

1
2
3
4
5
6
 
WSAComm newComm;
while (1) {
    newComm.waitForClient();
    newComm.readData();
}

Du coup....

Code:

1
2
3
4
5
6
7
8
9
10
 
WSAComm newComm;
// ici... newComm.m_backup et newComm.m_socket contiennent le socket d'écoute
// BOUCLE 1
newComm.waitForClient();
// ici... newComm.m_socket contient le socket de connection
newComm.readData();
// probablement depuis m_socket
// BOUCLE 2
newComm.waitForClient(); // VA FAIRE UN ACCEPT SUR UNE CONNECTION !!!!

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
class WSAComm
{
    SOCKET  m_listener;
    SOCKET  m_connection;
    public:
        /** Initialise la communication. */
        void init() { m_listener = socket(...); listen(m_listener); }
        /** Désinitialise la communication. */
        void uninit() { socketclose(m_listener); }
 
        /** Attends un client. */
        void waitForClient() { m_connection = accept(m_listener); }
        /** Lis les données. */
        void readData() { // from m_connection }
        /** Ferme le client. */
        void closeClient() { socketclose(m_connection); }
};
 
// avec en utilisation:
int main()
{
     WSAComm comm;
     comm.init();
     while (1) {
         comm.waitForClient();
         comm.readData();
         comm.closeClient();
      }
}