Discussion :

[nanosoft]

Bonjour,

J’ai une fonction appelée par un thread qui écoute et attends une connexion client.
La fonction est bloquée par accept() .

A la première fois tout se passe bien mais lorsque l’attente est trop longue : je tue le thread pour le redémarrer plus tard.
Les nouveaux threads débutent bien mais on ne réalise plus le listen ni l’attente client.
J’imagine que c’est parce que la socket n’a pas été fermée proprement et que j’ai alors un INVALID_SOCKET ou un SOCKET_ERROR.
Est-ce bien cela ?
Merci pour vos réponses et si vous pouvez me proposer une solution de contournement.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
void * fn_Rxc(void * p_data)        // Serveur
{
    printf("Début tread Rx \n");
    WSADATA wsa;
    WSAStartup(MAKEWORD(2,0),&wsa);
 
    SOCKET sock_attente;
    SOCKET sock_dialogue;
    SOCKADDR_IN csin;
    int len;
    // int port= xx;    // affecté en variable globale
    csin.sin_family=AF_INET;
    csin.sin_addr.s_addr=htonl(INADDR_ANY);
    csin.sin_port=htons(port);
    sock_attente = socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
    if (sock_attente == INVALID_SOCKET)
        return NULL;
    if (bind(sock_attente,(SOCKADDR*)&csin,sizeof(csin)) == SOCKET_ERROR)
        return NULL;
    printf("Listen...\n");
    if (listen(sock_attente, 1) == SOCKET_ERROR)
        return NULL;
    len = sizeof(csin);
    printf("Attente client...\n");
    sock_dialogue = accept(sock_attente, (SOCKADDR *)&csin, &len);
    if (sock_dialogue==INVALID_SOCKET)
        return NULL;
    printf("Connection en Serveur :\n");
 
    return NULL;
}

[Bousk]

Ton socket n'est pas libéré, donc le système le garde. Donc quand tu recrées un socket sur le même port, le système râle, puisqu'il n'est pas disponible.
La question c'est : pourquoi créer un socket dans un thread, et surtout pourquoi tuer ce thread ?!?
T'es quand même conscient que si tu libères ton socket, tous les clients connectés ne le seront plus ??!
C'est sencée être quoi la logique derrière ça ?

[nanosoft]

Salut Bousk,
Pour l’instant je ne tue le thread que lorsque je n’ai pas de connexion au bout d’un certain temps.
En cas de connexion j’avais imaginé de tuer aussi ce thread et d’en ouvrir un autre pour le dialogue. Cela devrait pouvoir marcher puisque apparemment donc le socket n’est pas libéré ?

Je suis conscient que si je libère le socket, tous les clients connectés ne le seront plus mais puis-je tuer ce thread sans libérer le socket ? C’est ce qui se passe actuellement, non ?

Mon idée et la logique sont :
- Pas de connexion au bout d’un certain temps : on tue le thread ET on libère le socket
- Connexion : on tue le thread sans libérer et on ouvre un autre thread sur le même socket qui gère le dialogue.
Est-ce possible ?

Je pense que pour libérer le thread en l’absence de connexion je devrais utiliser select() pour éviter d’être bloqué.
Si je n’ai plus de fonction bloquante, ni trop longue, je pourrais peut-être tout faire dans le même thread comme tu le suggères mais j’en doute.
Je ne suis pas familiarisé avec les sockets non bloquants, j’ai vu ton cours mais si me lance là-dedans je crains d’y passer beaucoup de temps.

[nanosoft]

Alors j’ai trouvé une solution simple :
En même temps que je tue le thread, je libère le socket avec

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

WSACleanup();

Lorsque il y a connexion, le thread se termine tout seul à la fin de la fonction (sans libérer) et j’en ouvre un autre pour gérer le dialogue.
Cela fonctionne.