Discussion :

[alexgille]

Bonjour,

je dois faire un programme qui contient deux processus qui communiquent via des pipes. Le processus fils doit à la fois pouvoir lire sur un pipe et écrire sur un autre. Concrètement le fils doit envoyer une commande au père, qui l'exécute et écrit le résultat sur un autre pipe, puis le fils doit de nouveau lire sur l'autre pipe le résultat pour l'afficher. Pour cela j'utilise select() de cette façon:

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
23
24
25
26
27
28
29
30
pipe(pr);
pipe(pw);
...
fd_set r_fdset, w_fdset;
FD_ZERO(&r_fdset);
FD_ZERO(&w_fdset);
FD_SET(pr[1], &w_fdset);
FD_SET(pw[0], &r_fdset);
 
max = (pr[1] > pw[0]) ? pr[1] : pw[0];
 
while(1) {
    state = select(max+1, &r_fdset, &w_fdset, NULL, NULL);
 
    if(state == -1) perror("select");
    else if(state > 0) {
 
        if (FD_ISSET(pr[1], &w_fdset)) {
            printf("Ecriture\n");
        }
 
        if (FD_ISSET(pw[0], &r_fdset)) {
            printf("Lecture\n");
        }
    } else {
        printf("Rien\n");
    }
}
 
...

Le problème que j'ai est que le select() ne retourne jamais avec la lecture possible sur pw[0]. J'ai essayé beaucoup de chose mais j'obtiens toujours un Bad file descriptor.

Merci pour voter aide.

[kwariz]

Salut,

as-tu ouvert les deux pipes en lecture et en écriture (c'est obligatoire, même si tu n'utilises qu'un bout) dans le père et le fils ?

[alexgille]

La fonction pipe() ouvre les deux pipes avant le fork(). Pour l'instant je ferme aucune des extrémités du pipe que ce soit dans le père ou dans le fils.

[Neckara]

Tu ne teste pas la valeur de retour de certaines fonctions (comme int pipe(int [2]) ).

Ensuite, je ne suis pas sûr, mais select peut-il regarder deux tubes à la fois?
Je dois avouer que je n'ai jamais eu à l'utiliser.

[cmoibal]

voici un example, mais en utilisant la methode poll():

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
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
#include <stdio.h>
#include <fcntl.h>
#include <poll.h>
#define MAX_BUFF_SIZE 128
 
int main(void){
    char buff[MAX_BUFF_SIZE + 1];
    char *buf = NULL;
    int fd = -1;
    int ret = -1;
    int len = 0;
    struct pollfd fdinfo[1];
 
    if((fd = open("/home/s/pipe", O_RDONLY)) == NULL) {
        printf("Error Opening File.\n");
        exit(1);
    }
 
    fdinfo[0].fd = fd;
    fdinfo[0].events = POLLIN|POLLPRI ;
 
    while(1)
    {
        ret = poll(fdinfo,1,-1);
        if (ret < 0) printf("\n\r error");
 
        if ( ((fdinfo[0].revents&POLLIN) == POLLIN) || ((fdinfo[0].revents&POLLPRI) == POLLPRI) )
        {
            len = read(fdinfo[0].fd, buff, MAX_BUFF_SIZE);
            if (len > 0){
                buff[len] = '\0';
                buf = (char *) calloc(1, len+1);
                memcpy(buf, buff, len);
                printf("\n read len %d\n %s",len, buf);
                free(buf);
             }
        }
 
    }
    return 0;
}

[alexgille]

En réalité je test la sortie de la fonction pipe. Mais pour plus de simplicité je ne l'ai pas mis dans le poste.

Pour ce qui est de la fonction poll(), je suis contraint d'utiliser select() :/

Merci