[timer & thread] timeout & socket non bloquant

**untipy** · 16/08/2007, 14h27

bonjour
Un thread lance un timer (qui fonctionne bien). Comment faire simplement opur que la thread soit informé du timeout de ce timer . J'ai pensé à la création d'une pipe entre le deux mais y a t'il plus simple? Petre avec la gestion des signaux (unix)?
merci

**nicolas.sitbon** · 16/08/2007, 19h06

Mets un bout de code au moins s'il te plait car on sait même pas de quelle thread tu parles (main ou fille).
Cordialement.

**untipy** · 17/08/2007, 08h18

Voici le programme de la thread. a un moment donné elle lance le timer. Mais comment lui dire que letimeout est franchi

Code :

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

1
2
3
4
5
6
Thread  {
...
startimer();
...
 
}

le prog timer:

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
void action() {...}
 
void starttimer() {
#ifdef BSD
signal(SIGALRM, action);
#else
struct sigaction act;
act.sa_handler = action;
act.sa_flags = SA_RESTART;
if(sigaction(SIGALRM, &act, NULL) == -1) {
    fprintf(stderr, "error %d in sigaction\n");
}
#endif                                                               
tempo.it_interval.tv_sec = INTERVAL_SEC;                                        
tempo.it_interval.tv_usec = INTERVAL_MICROSEC;                                  
tempo.it_value.tv_sec = INTERVAL_SEC;                                           
tempo.it_value.tv_usec = INTERVAL_MICROSEC;                                     
setitimer(ITIMER_REAL, &tempo, 0);     
}

**Emmanuel Delahaye** · 17/08/2007, 08h42

Envoyé par untipy

Voici le programme de la thread. a un moment donné elle lance le timer. Mais comment lui dire que letimeout est franchi
<...>

En général, on utilise select() pour bloquer la boucle du thread. On peut régler un timeout.

**untipy** · 17/08/2007, 08h50

ok, mais j'aimerai ne pas bloqué le thread, car le timer peux etre long, et la thread doit faire autre chose a coté.
en fait je voudrais gérer çà comme une interruption et la ... ail ....!!

**untipy** · 17/08/2007, 08h51

dans la fonction action() peux t'on ajouté un lien vers la thread pour lui dire 'timer fini'??

**Emmanuel Delahaye** · 17/08/2007, 09h10

Envoyé par untipy

ok, mais j'aimerai ne pas bloqué le thread, car le timer peux etre long, et la thread doit faire autre chose a coté.
en fait je voudrais gérer çà comme une interruption et la ... ail ....!!

En principe, un thread est bloqué et ne se débloque que sur évènements. Avec select(), les évènements sont (pour simplifier) :

- échéance du timer()
- réception sur flux entrant (y compris sockets)
- émission sur flux sortant (idem)

Une interruption et un thread sont deux concepts différents. Tu peux néanmoins débloquer un thread cycliquement si tu veux faire une sorte de polling en réglant le timeout de select() sur une valeur courte (tick)... Tu peux alors gérer un timeout long en comptant les ticks... Tout dépend de l'application.

Nota : un thread qui tourne en permanence (boucle 'blanche') est considéré comme 'asocial"'. Il doit y avoir au moins une suspension (sleep(1)) dans la boucle pour laisser le système respirer, surtout si il est de type 'coopératif' (Linux, par exemple).

**Emmanuel Delahaye** · 17/08/2007, 09h13

Envoyé par untipy

dans la fonction action() peux t'on ajouté un lien vers la thread pour lui dire 'timer fini'??

Personnellement, j'utilise un flag du contexte pour signaler la fin à un thread 'fils'. Je crois qu'il y a des exemples dans mon article...

http://emmanuel-delahaye.developpez.com/pthreads.htm

**untipy** · 17/08/2007, 09h34

j'ai inséré un flag dans le prog timer

Code :

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

void action() { toto=1;}

et toto est globale, connu de la thread également
mais celle-ci ne le voit pas
prog thread

Code :

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

1
2
3
4
5
6
7
8
while (1){
...
if (toto ==1){ 
printf("\nVAL TOTO:%d\n",toto);
toto=0;
}
...
}

**untipy** · 17/08/2007, 10h08

j'ai trouvé en fait le drapeau fonctionne mais a un moment dans le prgramme thread j'utilise la fonction read et cette fonction est bloquante ...

**nicolas.sitbon** · 17/08/2007, 10h40

surtout si il est de type 'coopératif' (Linux, par exemple)

Linux n'est pas coopératif, il utilise 3 politiques d'ordonnancement : la première pour les processus ordinaire, et les 2 autres pour les processus temps réels.
La politique appliquée varie selon le type de processus qui peut être soit SCHED_FIFO (temps réel non préemptible), soit SCHED_RR (temps réel préemptible) soit SCHED_OTHER (processus ordinaire préemptible).
Enfin untipy pourquoi utilises-tu signal() au lieu de sigaction dans le cas d'un bsd?

**untipy** · 17/08/2007, 10h48

si si j'utilise bien signal()

mais comment rendre un read() non bloquant, si il n'y a rien on continue l'éxécution du prog

c'est recv() ???

**nicolas.sitbon** · 17/08/2007, 10h55

J'attend toujours que tu postes ton code en entier sinon c'est du bricolage et on risque de perdre plus de temps qu'autre chose.
Cordialement.

**untipy** · 17/08/2007, 11h09

oups !!

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
void *thread(void *param)
int sck = *((int *) param);
while(1)
{
if (toto ==1)
{
printf("timeout");
}
 
len = recv (sck,msg,sizeof msg - 1,0);
if(len < 0)
{ ...}
/*apres c'est du traitement sur msg*/
}

**untipy** · 17/08/2007, 13h48

en fait je suis parti sur çà :
utilisation d'un timer

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
 fd_set rfds;
            struct timeval tv;
            int retval;
            FD_ZERO(&rfds);
            FD_SET(sck, &rfds); /* on ajoute la socket a regarder */
            tv.tv_sec = 2;
            tv.tv_usec = 0;
            retval = select(0, &rfds, NULL, NULL, &tv);
 
            if (retval)
            {
                /* infos reçues sur sck dans les 2 secondes*/
                len = read(sck,msg,4096);
}
else{printf"rienr recu");}

mais il détecte jamais rien en entrée du socket

**untipy** · 17/08/2007, 15h46

est-ce qq'un a un exemple de lecture sur socket non bloquant, que je puisse debbugé mon prog svp ?

**Emmanuel Delahaye** · 17/08/2007, 16h03

Envoyé par untipy

est-ce qq'un a un exemple de lecture sur socket non bloquant, que je puisse debbugé mon prog svp ?

Pourquoi faire un socket non bloquant .? C'est absurde et contre productif. Si on utilise les threads c'est pour que ça bloque sauf quand traire (réception etc.).

Refait ta conception en mode bloquant, tu verras que c'est beaucoup plus clair et plus simple. Des traitements en parallèle ? Faire plusieurs threads 'socialement corrects'...

**untipy** · 17/08/2007, 16h30

Voila j'ai trouvé mon bug .... oufff
alors petit retour d'expérience si cela peut être utile a d'autres programmeurs ...

je suis sur linux
donc pour faire une socket non bloquant en lecture, il faut configurer la fonction select

Code :

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

int select( int nfds,fd_set* readfds,fd_set* writefds,fd_set* exceptfds,const struct timeval* timeout );

sachant que nfds : [doit valoir le plus grand identifiant de socket, plus 1 (non utilisé sous Windows).

Code :

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

int select( socket+1,...)

Le plus 1 est SUPER important, c'était mon bug. (Le code qui va avec cette explication est page 1 en bas)

je fais cela car je fait du polling sur plusieurs socket ... y a plus classe ?

**Emmanuel Delahaye** · 17/08/2007, 17h10

Envoyé par untipy

je suis sur linux
donc pour faire une socket non bloquant en lecture, il faut configurer la fonction select

Non, rien à voir.

Code :

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

int select( int nfds,fd_set* readfds,fd_set* writefds,fd_set* exceptfds,const struct timeval* timeout );

sachant que nfds : [doit valoir le plus grand identifiant de socket, plus 1 (non utilisé sous Windows).

Code :

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

int select( socket+1,...)

Le plus 1 est SUPER important, c'était mon bug.

je fais cela car je fait du polling sur plusieurs socket ... y a plus classe ?

Bah oui. Tous les sockets sont bloquants (c'est le mode par défaut et ici, ça n'a pas beaucoup d'importance) et select() t'indique lequel s'est réveillé.

http://emmanuel-delahaye.developpez....aux.htm#select

En fait, c'est select() qui est bloquant ici et qui fait le tri...

**souviron34** · 19/08/2007, 17h30

Envoyé par untipy

Voila j'ai trouvé mon bug .... oufff
alors petit retour d'expérience si cela peut être utile a d'autres programmeurs ...

je suis sur linux
donc pour faire une socket non bloquant en lecture, il faut configurer la fonction select

Code :

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

int select( int nfds,fd_set* readfds,fd_set* writefds,fd_set* exceptfds,const struct timeval* timeout );

sachant que nfds : [doit valoir le plus grand identifiant de socket, plus 1 (non utilisé sous Windows).

Code :

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

int select( socket+1,...)

Le plus 1 est SUPER important, c'était mon bug. (Le code qui va avec cette explication est page 1 en bas)

je fais cela car je fait du polling sur plusieurs socket ... y a plus classe ?

Comme a dit Emmanuel, dans ton exemple tu n'utilises pas les sockets non bloquants, mais le select.

Pour un socket non bloquant, il faut le passer en mode asynchrone...du style :

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
 
  pid =getpid();
 
   bidon = (int) pid;
#ifndef LINUX
   retour = ioctl(requete,SIOCSPGRP,&bidon);
#else
   retour = fcntl(requete,F_SETOWN,(long)bidon);
#endif
   if ( retour < 0 )
     return retour ;
 
   /*
    *Initialiser l'option asynchrone pour le socket
    */
#ifndef LINUX
   bidon = 1;
   retour = ioctl(requete,FIOASYNC,&bidon);
#else
   bidon = O_ASYNC ;
   retour = fcntl(requete,F_SETFL,(long)bidon);
#endif

ET PUIS ajouter une routine de réception par signal :

Code :

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

1
2
 
       signal(SIGIO,fonction);

Note1 : Attention, dans le code donné ci-dessus, le "else" veut dire un autre système au moins unixoide (en tous cas pas Windows, car les appels ne sont pas les mêmes pour les sockets).

Note2 : il faut bien entendu inclure ioctl.h ou fnctl.h, plus signal.h, et vraisemblablement vérifier les définitions des signaux (il est possible que les POLL ne soient pas définis, suivant la version du kernel).

Ensuite, il n'est pas certain que le poll t'indique ce que tu veux. Il faut vérifier par rapport aux file descriptor. Il peut également indiquer une rupture de communication, que ce soit du fait d'un client, du serveur, ou d'un kill ou d'un ctrlC.

Mais c'est effectivement la philosophie à utiliser pour un serveur à multpile clients (et éventuellement multiples esclaves).

[timer & thread] timeout & socket non bloquant

Réseau C

Discussions similaires

Partager

Partager