Dotaz: select() a roura

[Martin Tůma]

Snažím se v C napsat program, kde jsou 2 procesy propojený rourou, přičemž bych potřeboval dosáhnout takovýho chování, aby když od "zdroje" nepřicházejí žádná data, příjemce usnul a když nějaká data dorazí, tak aby se vzbudil. Snažim se to řešit pomocí select(), ale nějak mi to nefunguje...

sesmolil jsem toto:

#include <stdio.h>
#include <sys/time.h>
#include <sys/types.h>
#include <unistd.h>

  
int main(void) {
    int     i, fd[2];
    pid_t   pid;
    fd_set  rfds;
    struct  timeval tv;
    int     retval;	
	
    pipe(fd);
    pid = fork();

    if (pid > 0) {        /* parent */
        close(fd[0]);
		
        while(1) {
	    i = random()%10;
            write(fd[1], &i, sizeof(int));
            sleep(1);	
        }
		
    } else {                /* child */

        close(fd[1]);

        FD_ZERO(&rfds);
        FD_SET(fd[0], &rfds);
        tv.tv_sec = 0;
        tv.tv_usec = 500;

        while(1) {
            retval = select(1, &rfds, NULL, NULL, &tv);
  
            if (retval == -1)
                perror("select()");
            else if (retval) {
                printf("Data\n");
                read(fd[0], &i, sizeof(int));
            } else
                printf("No data\n");
        }
    }

    return(0);
}

Problém je ale ten, že to na data v rouře vůbec nereaguje (výsledkem je neustále se opakující výpis "No data"). Může mi někdo poradit, co dělám špatně, nebo jak tenhle problém případně řešit jinak? Díky

Odpovědi

[unchallenger]

aby když od "zdroje" nepřicházejí žádná data, příjemce usnul a když nějaká data dorazí, tak aby se vzbudil.

Jelikož read() blokuje, může být nejjednodušší řešení vůbec to neřešit. Zavoláš-li read() a nejsou k disposici data, proces se tím dobrovolně vzdá svého timeslice.

(Program jsem zatím pořádně nečetl.)

[unchallenger]

Jo, tak bug je zde:

retval = select(1, &rfds, NULL, NULL, &tv);

musí tam být něco jako

retval = select(fd[0]+1, &rfds, NULL, NULL, &tv);

[Martin Tůma]

Super, to je ono, díky moc. (Můžu se ještě s dovolením zeptat PROČ to tak musí být?).

Jelikož read() blokuje, může být nejjednodušší řešení vůbec to neřešit. Zavoláš-li read() a nejsou k disposici data, proces se tím dobrovolně vzdá svého timeslice.

Dá se to považovat za uspání, nebo se to nějak liší od toho, když v procesu pustim sleep(). Jde o to, že to musí vyhovovat tomuto zadání:

...Proces S třídí tyto čísla. rychlostí u komparací za jednotku času a zasílá nejnižší dostupná čísla procesu C (pokud nejsou k dispozici, je proces C uspán)...

Respektivě, můžu se na tebe odkazovat při obhajově své práce?

[unchallenger]

Ad fd[0]+1. Tato část je jednoduchá (select(2)):

n is the highest-numbered descriptor in any of the three sets, plus 1.

Ad usnutí v read(). Proces určitě nežere CPU, dokud se neobjeví data, ale jinak IANAKH. Pokud ti někdo napíše, že máš proces uspat, tak možná chce, abys ho uspal...

[Michal Marek (twofish)]

Pokud ti někdo napíše, že máš proces uspat, tak možná chce, abys ho uspal...

No já bych se určitě s nějakým select() ne**** a argumentoval bych, že spí v read() takže jsem splnil zadání