Thread et socket

Petite question.

J'ai créé un petit serveur avec un socket 'bloquant'. Etant donné que je désire que mon aplication ne soit pas bloquée j'ai créé un thread, dérivé de la class CWinThread dans lequel va tourner le socket d'écoute. J'espérais ainsi que mon application principale ne freeze pas. Et bien non! Ca freeze quand même. Peut on m'expliquer une telle chose?

A partir de là ne vaut il pas mieux tout recommencer avec CAsyncSocket?

Salut,
tu as mis quoi exactement dans ton thread ?


-------------------------------
Réponse au message :
-------------------------------

> Petite question.
>
> J'ai créé un petit serveur avec un socket 'bloquant'. Etant donné que je désire que mon aplication ne soit pas bloquée j'ai créé un thread, dérivé de la class CWinThread dans lequel va tourner le socket d'écoute. J'espérais ainsi que mon application principale ne freeze pas. Et bien non! Ca freeze quand même. Peut on m'expliquer une telle chose?
>
> A partir de là ne vaut il pas mieux tout recommencer avec CAsyncSocket?

Bon g résolu mon prob grace à ça :

lien msdn

en fait quand on crée un thread avec AfxBeginThread() y'a 2 possibilités, soit faire un thread d'interface, qui je suppose est lié à notre fenêtre principale ou un thread de travail, utilisé pour les calculs d'arrière plan. Moi au départ j'avais fait un thread d'interface (je savais pas pour l'autre). là g modifié ma source en thread de travail et ça fonctionne parfaitement.

dsl pour le dérangement et merci de t'être intéressé à mon prob ;-)

++

-------------------------------
Réponse au message :
-------------------------------

> Salut,
> tu as mis quoi exactement dans ton thread ?
>
>
> -------------------------------
> Réponse au message :
> -------------------------------
>
> > Petite question.
> >
> > J'ai créé un petit serveur avec un socket 'bloquant'. Etant donné que je désire que mon aplication ne soit pas bloquée j'ai créé un thread, dérivé de la class CWinThread dans lequel va tourner le socket d'écoute. J'espérais ainsi que mon application principale ne freeze pas. Et bien non! Ca freeze quand même. Peut on m'expliquer une telle chose?
> >
> > A partir de là ne vaut il pas mieux tout recommencer avec CAsyncSocket?
>

> tu as mis quoi exactement dans ton thread ?

Bonjour tr le monde ,

en faite je suis entrain de programmer une ptite application multithread qui envoie des sockets à des @ IP(10 @ en simultané) et selon le retour de select de socket il decode l'entete(IpHeader) et revoi le resultat ; si on teste la select avec un seul poste en simultané il marche trés biens alors que lorsque je tente de le testé avec plus que de 2 en simultanés la select retourne toujours 1 = sig que la select contient des donnees alors ce n est pas le cas ! (car ces adresses IP ne sont pas connectés ) !
voila un extrait de code :

// Initialisation du nombre de ping à faire = nombre de retrait
if(iNBPing == 0)
iNBPing = NBPINGDEFAULT;//si le nombre de retarit est a 0 on prend le nombre par default 1.

// Initialisation du délai d'attente
if(iTpsLimite == 0)
iTpsLimite = DEFALUTTIMEOUT;//si le delai d'attente est 0 on prend le timeout par defaut 1000 MS

while((CHote->iNbRetryUsed != iNBPing)&&(!bRstConn))
{
memset(szICMP_data,0,DATASIZE_ICMP);
iID = (unsigned short)GetCurrentProcessId() + CHote->iNbRetryUsed;
// Construction du paquet ICMP
IcmpHeader *icmp_hdr;
icmp_hdr = (IcmpHeader*)szICMP_data;
icmp_hdr->type = TYPE_ICMP_ECHO; // Type du paquet ICMP : echo request
icmp_hdr->code = CODE_ICMP_NULL; // Il n'y a pas de code spécifique pour ce type de paquet
icmp_hdr->id = iID;//identificateur de paquet
icmp_hdr->sequence = SEQU_ICMP_ECHO;
icmp_hdr->timestamp = GetTickCount(); // Initialisation du temps lors de l'envoi

// Somme de contrôle sur 16 bits
((IcmpHeader*)szICMP_data)->checksum = checksum((unsigned short*)szICMP_data, DATASIZE_ICMP);

// On envoie le paquet ICMP que l'on a construit
iEnvoi = sendto(sock, szICMP_data, DATASIZE_ICMP, 0, (struct sockaddr *)&sin, DATASIZE_ICMP);
FD_ZERO(&fdsr);
FD_SET(sock, &fdsr);

tv_timeout.tv_sec = iTpsLimite/1000;
tv_timeout.tv_usec = 0;


iFindelai = 0;

do{
if (select(sock+1, &fdsr, NULL, NULL, &tv_timeout) <= 0)
{
// Dans le cas où le temps est écoulé, on veut sortir de la boucle
// on compte le paquet comme envoyé mais perdu
// delai d'attente de la demande depassée
CHote->iNbRetryUsed = CHote->iNbRetryUsed+1;
iPerte= iPerte+1;
iFindelai = 1;

}

//Cette fonction vérifie si le descripteur "sock" est contenu dans l'ensemble "fdsr" après l'appel à select.
if (FD_ISSET(sock, &fdsr))
{
// Dans le cas où le buffer du socket contient des données,
// on les décode
iRecept=recvfrom(sock, szRecvbuf, MAX_PACKET, 0, (struct sockaddr *)&from, &iFromlen);

/***********************************************************/
iphdr = (IpHeader *)szRecvbuf;
iphdrlen = iphdr->h_len * 4 ;
icmphdr = (IcmpHeader*)(szRecvbuf + iphdrlen);

if(iID!=(icmphdr->id))
{
// Cas où le paquet n'est pas à nous
iFindelai= 0;
}
else
{
CHote->iNbRetryUsed = CHote->iNbRetryUsed +1;
iFindelai= 1;
}

/***************************************************/

memset(szRecvbuf,0,MAX_PACKET);
//dés la prmiere ping : si on a l'envoi est supérieur de perte on sort
if((CHote->iNbRetryUsed-iPerte)>0)
bRstConn=true;

}
}
while(iFindelai == 0);
}