UDP multicast et traitement de données

Bonjour

Je reçois un flux important de données en UDP multicast (toutes les 5 ms) et je dois les traiter rapidement.
J'ai donc une CAsyncSocket pour la réception et la récupération des data dans le OnReceive.
Je fais transiter la trame via un PostMessage (qui n'est pas bloquant) à une classe qui s'occupe du traitement.
Or j'arrive à avoir des pertes de réceptions (j'ai contrôlé l'émission pour être sûr).
Pour moi, une CAsyncSocket est un thread et donc le message WM_RECEIVE est capté quoi qu'il arrive, et là ce n'est pas le cas.

Pour info, j'ai mis mon traitement dans un thread.

Est-ce que j'ai loupé quelque chose ?

Merci d'avance.

J'ai vérifié dans les sources de MFC (2005):
CAsyncSocket est juste un wrapper sur WSAAsyncSelect() utilisant une fenêtre globale au thread appelant (plutôt que prendre un HWND en paramètre).
Et connaissant le fonctionnement de WSAAsyncSelect(), ça veut dire que le OnReceive() du CAsyncSocket est exécuté sur le thread appelant, et non sur un thread à part.

Donc, si tu crées déjà ton CAsyncSocket depuis ton thread UI, le PostMessage() est une perte de temps.

En plus de la remarque de @Médinoc, UDP n'est pas un protocole sécurisé en terme de perte de trame.
Rien ne garantit qu'une trame émisse sera reçu par votre machine.
Pour en être sûr, utilisez un sniffer réseau type Wireshark sur votre machine cliente qui vous permettra de voir si au moins la stack IP du système à bien réceptionner ces packets UDP.

Citation:

---

Envoyé par bacelar

Rien ne garantit qu'une trame émisse sera reçu par votre machine.

---

J'ai vérifié ce point avant en m'assurant de bien tout recevoir si je ne fais pas de traitement après réception.

Citation:

---

Envoyé par Médinoc

Et connaissant le fonctionnement de WSAAsyncSelect(), ça veut dire que le OnReceive() du CAsyncSocket est exécuté sur le thread appelant, et non sur un thread à part.

---

Est-ce que la solution serait d'utiliser les fonctions de base [socket, bind, select, read/readfrom, shutdown, closesocket] ?

Citation:

---

Envoyé par coincoin73

Est-ce que la solution serait d'utiliser les fonctions de base [socket, bind, select, read/readfrom, shutdown, closesocket] ?

---

Si ton application est une application graphique, CAsyncSocket est approprié. Mais il faut faire les Receive() le plus vite possible (quitte à faire la MaJ des contrôles la fenêtre plus tard avec un timer ou un truc du genre), pas les "remettre à demain" dans un contexte où "demain" est mesuré en intervalles de 15.625ms.

Est-ce que je n'ai pas intérêt à faire du polling à la place du OnReceive ?