[unix] tubes nommés, ça bloque...

tubes nommés, ça bloque... [unix] - C - Programmation

Marsh Posté le 03-12-2004 à 20:40:41    

Salut,
je comprends pas ce code compile mais bloque à l'éxécution, comme si un seul des 2 open était réalisé, l'autre bloquant...
 

Code :
  1. #include <iostream>
  2. #include <cstdlib>
  3. #include <unistd.h>
  4. #include <fcntl.h>
  5. #include <sys/stat.h>
  7. using namespace std;
  9. int main()
  10. {
  11.   char buf[10];
  12.   int pid, fd;
  14.   unlink("toto" );
  15.   umask(0);
  16.   mkfifo("toto", 0777);
  17.   pid = fork();
  18.   switch(pid)
  19.   {
  20.   case -1: cout << "error" << endl; exit(1);
  22.   case 0: //fils
  23.     fd = open("toto", O_RDONLY);
  24.     if(fd < 0)
  25.     {
  26.       cout << "erreur open fils" << endl;
  27.       exit(2);
  28.     }
  29.     read(fd, buf, 5);
  30.     cout << buf << endl;
  31.     exit(0);
  33.   default:
  34.     fd = open("toto", O_WRONLY);
  35.     if(fd<0)
  36.     {
  37.       cout << "erreur open pere" << endl;
  38.       exit(2);
  39.     }
  40.     write(fd, "bonjour\n", 8);
  41.   }
  42. }


merci

Reply

Marsh Posté le 03-12-2004 à 20:40:41   

Reply

Marsh Posté le 03-12-2004 à 21:53:28    

Code :
  1. #include <stdlib.h>
  2. #include <unistd.h>
  3. #include <fcntl.h>
  4. #include <sys/stat.h>
  5. #include <stdio.h>
  6. #include <sys/types.h>
  7. #include <sys/wait.h>
  10. #define NAMED_PIPE_NAME "/tmp/hfr.fifo"
  12. static int child()
  13. {
  14. int fd;
  15. ssize_t n;
  16. char buffer[80];
  18. fd = open(NAMED_PIPE_NAME, O_RDONLY);
  20. if(fd < 0)
  21. {
  22.  perror("[child] open" );
  23.  return 2;
  24. }
  26. while((n = read(fd, buffer, sizeof buffer - 1)) > 0)
  27. {
  28.  buffer[sizeof buffer - 1] = '\0';
  29.  printf("[child] got \"%s\"\n", buffer);
  30. }
  32. if(n == -1)
  33. {
  34.  perror("[child] read" );
  35.  return 4;
  36. }
  38. close(fd);
  39. return 0;
  40. }
  43. static int parent()
  44. {
  45. int fd;
  46. ssize_t n;
  48. char buffer[] = "Hello world !";
  50. fd = open(NAMED_PIPE_NAME, O_WRONLY);
  52. if(fd < 0)
  53. {
  54.  perror("[parent] open" );
  55.  return 2;
  56. }
  58. n = write(fd, buffer, sizeof buffer);
  60. if(n == -1)
  61. {
  62.  perror("[parent] write" );
  63.  return 4;
  64. }
  66. printf("[parent] sent \"%s\"\n", buffer);
  68. close(fd);
  70. wait(NULL);
  72. return 0;
  73. }
  77. int main()
  78. {
  79. unlink(NAMED_PIPE_NAME);
  80. umask(0);
  81. mkfifo(NAMED_PIPE_NAME, 0777);
  83. switch(fork())
  84. {
  85. case -1:
  86.  perror("fork" );
  87.  return 1;
  89. case 0:
  90.  return child();
  93. default:
  94.  return parent();
  95. }
  96. }


Message édité par Taz le 03-12-2004 à 21:54:13
Reply

Marsh Posté le 03-12-2004 à 23:00:37    

merci!
malheureusement, ça bloque toujours et quand je kill le programme, je vois :
[parent] write: Bad file descriptor
 
je précise je suis sous cygwin, en ssh sous linux il semblerait que ça marche...

Reply

Marsh Posté le 04-12-2004 à 03:12:47    

ben les pipe sous windows, je sais pas

Reply

Marsh Posté le 04-12-2004 à 10:16:14    

Reply

Sujets relatifs:

Leave a Replay

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