C: est resté coincé avec dup2 () :-(

Question

nous avons préparé un programme qui émule enveloppe (cmd) interface à l'aide des tuyaux. Il existe deux versions du programme: 1. L'utilisation d'un tuyau (à l'aide d'un tuyau du parent à l'enfant de communication) 2. Utilisation de double pipe (à l'aide de deux tuyaux du parent à l'enfant et de l'enfant au parent de communiquer).

Ainsi, le premier programme fournit une interface désirée et fonctionne comme je veux, mais je ne peux pas atteindre le même résultat (interface) dans le deuxième programme (en utilisant dup2 () et similaire).

Alors, je relais sur votre aide et mettre les deux codes ci-dessous.

B.S .: Vous pouvez compiler et essayer les deux programmes avec la même utilisation de ces commandes:

gcc -o $ prog1.c prog1

run let suivant:

./prog1

Ensuite, nous allons exécuter nouveau terminal et d'essayer d'écrire des données à input.txt:

echo $ PWD> input.txt

Et puis regarder le résultat dans le premier terminal.

(Ce beau travail pour le premier programme, mais je dois obtenir ce travail d'esprit de la même interface dans le deuxième programme)

CODE DU PREMIER PROGRAMME (FIN DE TRAVAIL):

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/stat.h>

void do_child(int data_pipe[]) {
    int c;
    int rc;
    close(data_pipe[1]);

    dup2(data_pipe[0], 0); /* This string provides the desired interface of the program */

    char* cmd[] = { "bash", (char *)0 };
    execvp("bash", cmd);

    while ((rc = read(data_pipe[0], &c, 1)) > 0) 
    {
        putchar(c);
    }
    exit(0);
}

void do_parent(int data_pipe[])
{
    int c;
    int rc;
    FILE *in;

    close(data_pipe[0]);

    while (1)
    {
        in = fopen("input.txt", "r");
        while ((c = fgetc(in)) > 0) 
        {
            rc = write(data_pipe[1], &c, 1);
            if (rc == -1) 
            {
                perror("Parent: write");
                close(data_pipe[1]);
                exit(1);
            }
        }
        fclose(in);
    }
    close(data_pipe[1]);
    exit(0);
}

int main(int argc, char* argv[])
{
    int data_pipe[2];
    int pid;
    int rc;

    umask(0);
    mknod("input.txt", S_IFIFO|0666, 0);

    rc = pipe(data_pipe);
    if (rc == -1) 
    {
        perror("pipe");
        exit(1);
    }
    pid = fork();
    switch (pid) 
    {
    case -1:
        perror("fork");
        exit(1);
    case 0:
        do_child(data_pipe);
    default:
        do_parent(data_pipe);
    }
    return 0;
}

CODE DU DEUXIÈME PROGRAMME (DOIVENT ETRE CORRIGÉ UN PEU):

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/stat.h>

/* Original version got from http://www.iakovlev.org */

int parent_to_child[2];
int child_to_parent[2];

void do_parent()
{
    int c;
    char ch;
    int rc;
    FILE *in;

    close(child_to_parent[1]); /* we don't need to write to this pipe.  */
    close(parent_to_child[0]); /* we don't need to read from this pipe. */

    while (1)
    {
        in = fopen("input.txt", "r");
        while ((c = fgetc(in)) > 0) {
            ch = (char)c;
            /* write to child */
            rc = write(parent_to_child[1], &ch, 1);
            if (rc == -1) {
                perror("child: write");
                close(child_to_parent[0]);
                close(parent_to_child[1]);
                exit(1);
            }
            /* read back from child */
            rc = read(child_to_parent[0], &ch, 1);
            c = (int)ch;
            if (rc <= 0) {
                perror("parent: read");
                close(child_to_parent[0]);
                close(parent_to_child[1]);
                exit(1);
            }
            putchar(c);
        }
        fclose(in);
    }
    close(child_to_parent[0]);
    close(parent_to_child[1]);
    exit(0);
}

void do_child()
{
    int c;
    char ch;
    int rc;

    close(parent_to_child[1]); /* we don't need to write to this pipe.  */
    close(child_to_parent[0]); /* we don't need to read from this pipe. */

    //dup2(parent_to_child[0], STDIN_FILENO);
    //dup2(child_to_parent[1], STDOUT_FILENO);

    /* Some dup2() routines must be added here 
    to get this working as the first program above */

    char* cmd[] = { "bash", (char *)0 };
    execvp("bash", cmd);

    while (read(parent_to_child[0], &ch, 1) > 0) {
        c = (int)ch;
        ch = (char)c;
        putchar(ch);
        rc = write(child_to_parent[1], &ch, 1);
        if (rc == -1) {
            perror("child: write");
            close(parent_to_child[0]);
            close(child_to_parent[1]);
            exit(1);
        }
    }
    close(parent_to_child[0]);
    close(child_to_parent[1]);
    exit(0);
}

int main(int argc, char* argv[])
{
    int pid;
    int rc;

    umask(0);
    mknod("input.txt", S_IFIFO|0666, 0);    

    rc = pipe(parent_to_child);
    if (rc == -1) {
        perror("main: pipe parent_to_child");
        exit(1);
    }

    rc = pipe(child_to_parent);
    if (rc == -1) {
        perror("main: pipe child_to_parent");
        exit(1);
    }

    pid = fork();
    switch (pid) {
    case -1:
        perror("main: fork");
        exit(1);
    case 0:
        do_child();
    default:
        do_parent();
    }
    return 0;
}

Answer 1

La principale différence est ici:

    while ((c = fgetc(in)) > 0) {
        ch = (char)c;
        /* write to child */
        rc = write(parent_to_child[1], &ch, 1);
        /* .... */
        /* read back from child */
        rc = read(child_to_parent[0], &ch, 1);
        /* .... */
        putchar(c);
    }

Comme je suis paresseux pour compiler / test pour vous, je spéculer simplement que le parent est bloqué dans la lecture (). Parce que l'autre côté (bash dans le processus de l'enfant) n'est pas garanti écho chaque caractère réécrites. Ou il pourrait même décider d'imprimer plus d'un caractère que votre code est incapable de gérer.

Dans le cas, vous devez poll () pour voir s'il y a quelque chose à lire ou non. Ou mettre le drapeau O_NONBLOCK sur la branche child_to_parent [0] avec fcntl (F_SETFL) et quand errno == EAGAIN, sauter simplement la lecture (). Et la boucle alors qu'il ya encore des caractères à lire.

.

Edit1 BTW je totalement raté la partie: vous en do_parent () boucle doivent le deux child_to_parent[0] et in poll () l'utilisation, depuis un autre côté peut écrire quelque chose (lire () wouldn » t bloc), même si vous ne le faites pas écrire () tout caractère à lui.

Answer 2

Merci à vous, il semble que je l'ai travaille.

Ainsi, le code ici est mise à jour do_parent:

void do_parent()
{
    int c;
    char ch;
    int rc;
    FILE *in;

    struct pollfd fds[2];
    int pol_ret;

    fds[0].fd = child_to_parent[0];

    close(child_to_parent[1]); /* we don't need to write to this pipe.  */
    close(parent_to_child[0]); /* we don't need to read from this pipe. */

    while (1)
    {   
        in = fopen("input.txt", "r");
        fds[1].fd = fileno(in);
        pol_ret = poll(fds, 2, 500);

        while ((c = fgetc(in)) > 0) {
            ch = (char)c;
            /* write to child */
            rc = write(parent_to_child[1], &ch, 1);
            if (rc == -1) {
                perror("child: write");
                close(child_to_parent[0]);
                close(parent_to_child[1]);
                exit(1);
            }
            /* read back from child */
            if (fds[0].revents & POLLIN)
            {
                rc = read(child_to_parent[0], &ch, 1);
                c = (int)ch;
                if (rc <= 0) {
                    perror("parent: read");
                    close(child_to_parent[0]);
                    close(parent_to_child[1]);
                    exit(1);
                }
                putchar(c);
            }
        }
        fclose(in);
    }
    close(child_to_parent[0]);
    close(parent_to_child[1]);
    exit(0);
}

J'ai aussi ajouté ceci dans do_child ():

dup2(parent_to_child[0], STDIN_FILENO);