Disposer d'un read non bloquant

Disposer d'un read non bloquant - C - Programmation

Marsh Posté le 31-12-2004 à 13:56:57    


Un problème récurrent évoqué sur le forum est le fameux read
bloquant, je vous propose d'y voir un peu plus clair.
 
Mettre un fd en mode non bloquant:

Code :
  1. #include <fcntl.h>
  2. #include <sys/types.h>
  3. #include <unistd.h>
  4. #include <stdio.h>
  5. #include <errno.h>
  7. int main()
  8. {
  9.         int     mode;
  10.         int     ret;
  11.         char    buf[512];
  12.         int     fd;
  13.         int     data = 1;
  14.         int     timeout = 3;
  16.         fd = 0;
  17.         mode = fcntl(fd, F_GETFL, 0);
  18.         mode |= O_NONBLOCK;
  19.         fcntl(fd, F_SETFL, mode);
  21.         while ( data ) {
  22.                 ret = read(0, buf, 512);
  23.                 switch (ret) {
  24.                         case -1:
  25.                                 if ( errno == EAGAIN ) {
  26.                                         printf("degoute, rien a lire, j'attends %d secondes\n", timeout);
  27.                                         sleep(timeout);
  28.                                         continue;
  29.                                 }
  30.                                 break;
  31.                         case 0:
  32.                                 data = 0;
  33.                                 break;
  34.                         default:
  35.   /* je ne mets pas de 0 terminal,
  36.    ** car je n'affiche que 'ret' caractères...  
  37.   */
  38.                                 printf(">> %.*s\n", ret, buf);
  39.                 }
  40.         }
  41.         return 1;
  42. }


 
Ce programme n'est pas capable d'executer quelquechose à l'instant
ou la donnée est disponible, il va forcément faire le
sleep(timeout) en entier.
 
Il faut utiliser select ou mieux poll pour sortir dès qu'une donnée
est disponible...

Code :
  1. int wait_for_input()
  2. {
  3.  int             ret = 0;
  4.  struct pollfd   fds;
  6.  /* on regarde sur l'entree standard */
  7.  fds.fd = 0;
  8.  fds.events = POLLIN;
  9.  if ( ! poll(&fds, 1, 5000) ) {
  10.   printf("rien à lire\n" );
  11.   /* ici ca fait 5 secondes que rien n'est
  12.   ** arrivé  
  13.   */
  14.  }
  16.  if ( fds.revents & ( POLLOUT | POLLERR | POLLHUP ) ) {
  17.   printf("Deconnexion ... fin de fichier\n" );
  18.   /* ici on sait que le read va retourner 0 */
  19.  }
  20.  if ( (ret = read( 0, buf, 512 )) < 0 ) {
  21.   printf("Probleme de lecture..." );
  22.   /* ici le read à foiré */
  23.  }
  24.  /* ici 'buf' est rempli de 'ret' caractères */
  25. }


 
 
 
Cadeau bonus, Spécial flex....

Code :
  1. %{
  3. #include <poll.h>
  6. /* variable externe utilisée dans une boucle quelconque permettant
  7. * d'arreter le déroulement du programme...
  8. *
  9. extern int  fatal;
  11. static void             fatal_error(const char *msg);
  12. #define YY_FATAL_ERROR(msg) fatal_error(msg);
  14. /* timeout de 5 secondes */
  15. #define YY_INPUT(buf, result, max_size) \
  16.         do { \
  17.                 int             ret = 0; \
  18.                 struct pollfd   fds; \
  19.                 fds.fd = 0; \
  20.                 fds.events = POLLIN; \
  21.                 if ( ! poll(&fds, 1, 5000) ) { \
  22.                         fatal = 1; \
  23.                         result = 0; \
  24.                         YY_FATAL_ERROR("input in flex scanner failed timeout reading" ) \
  25.                         goto skip_reading; \
  26.                 } \
  27.                 if ( fds.revents & ( POLLOUT | POLLERR | POLLHUP ) ) { \
  28.                         fatal = 1; \
  29.                         result = 0; \
  30.                         goto skip_reading; \
  31.                 } \
  32.                 if ( (result = read( 0, (char *) buf, max_size )) < 0 ) { \
  33.                         YY_FATAL_ERROR( "input in flex scanner failed" ) \
  34.                 } \
  35. skip_reading: \
  36.         } while (0)
  38. %}
  40. %%
  42. %%
  44. static void fatal_error(const char *msg)
  45. {
  46.         printf("fatal error: %s\n", msg);
  47. fatal = 1;
  48. }

Reply

Marsh Posté le 31-12-2004 à 13:56:57   

Reply

Marsh Posté le 13-03-2010 à 15:55:51    

Merci, votre code m'a avancé en ce qui concerne la création d'un getch() sous Linux. En revanche, j'essaie également de créer ma propre fonction au comportement similaire à getch() sous Windows, dans un but d'acquérir un contrôle accru sur l'entrée clavier. Select, poll, passer en mode non canonique avec fcntl, tout ça m'est refusé sous Windows. Je cherche non-stop depuis hier soir, auriez-vous une idée?

Reply

Marsh Posté le 02-04-2010 à 00:07:22    

Je sais que tu peux indiquer a un file-descriptor d'etre bloquand ou non via tcgetattr(fd, struct termios *w);
tu modifies les valeurs de ta structure termios:

Code :
  1. #include <termios.h>
  3.   struct termios  w;
  5.   tcgetattr(0, &w);
  6.   w.c_cc[VMIN] = 0;
  7.   w.c_cc[VTIME] = 0;
  8.   w.c_lflag &= ~(ICANON);
  9.   tcgetattr(0, TCSANOW, &w);


 
ce code fonctionne sous FreeBSD. ça pourrai peut être fonctionner sous un Linux mais dodows c'est mort

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed