Dotaz: komunikace s FIFO a poll()

[ext3fs]

Dobry den, hraji si ted s komunikaci pres FIFO v C a stale mi program stoji u read() a bere veskere CPU. Zde je maly priklad:

master proces:

int main(void)
{             
int pipe_fd;  
int ret;      
int n;        
struct pollfd ufds[1];
char buff[32];        

        pipe_fd = mkfifo("./pipe",660);

        pipe_fd = open("./pipe", O_RDONLY | O_NONBLOCK, 660);

        ufds[0].fd = pipe_fd;
        ufds[0].events = POLLIN;
        ufds[0].revents = 0;    

        while(1)
        {
                ret = poll(ufds, 1, 1000);

                if (ret == -1)
                {
                        printf("poll error\n");
                        close (pipe_fd);
                        exit (1);
                }
                else if (ret == 0)
                        printf("no data...\n");
                else
                {
                        if (ufds[0].revents == POLLIN)
                        {
                                do
                                {
                                    n = read(pipe_fd, buff, 32);
                                    if (n == -1)
                                    {
                                        printf("read error\n");
                                        break;
                                    }
                                    else
                                        printf("recv (%d)\n",n);
                                } while (n != 0);
                        }
                }
        }

        close(pipe_fd);

        return(0);
}

slave proces:

int main(void)
{
int pipe_fd;
char buff[32];

        pipe_fd = open("./pipe",O_WRONLY | O_NONBLOCK ,660);

        strcpy(buff, "ahoj");

        write(pipe_fd, buff, 5);

        close(pipe_fd);

        return(0);

}

Nevite kde je problem? Dekuji.

Odpovědi

[Jirka P]

Dost ti tam chybí ošetření chyb, takže:

- proč otvíráš rouru pro zapisování s O_NONBLOCK, ale neošetřuješ situaci, kdy druhý konec roury není otevřený (vrátí to chybu)

- když otevřeš rouru pro čtení s O_NONBLOCK bez otevřeného protějšku, roura se sice otevře, ale čtení bude pořád vracet 0 (a tedy bude roura pořád připravena pro čtení z hlediska select() nebo poll()

Doporučil bych vykašlat se na O_NONBLOCK a důsledně ošetřit všechny chyby, včetně konce čtení. Pak by to mělo fungovat.

[ext3fs]

Priklad je jen ilustrativni a opravdu jsem tam osetreni neresil.

V podstate jde o to, ze master proces (daemon) bezi stale a mimo ostatni funkce se obcas zepta roury zda tam nema data od slave procesu, ktery se spousti jen pro zadavani prikazu daemonu (tedy velmi malo casto). Takze nejprve se stejne roura otevira pro cteni.

[ext3fs]

Problem je take v tom, ze pokud oteviram rouru bez priznaku O_NDELAY nebo O_NONBLOCK, tak se proces zastavi (dle strace) na open() a ceka na otevreni druheho konece coz je v mem pripade nezadouci. Jak tohle osetrit bez pouziti O_NDELAY nebo O_NONBLOCK?

[Jirka P]

Pokud vím, tak něco jako select() na podmínku "někdo jiný otevřel rouru a já z ní tedy můžu číst" neexistuje. Popsané chování open() je normální, bez O_NONBLOCK se oba procesy rozběhnou až potom, co jsou oba konce otevřeny.

Sice to považuji za prasárnu, ale doporučil bych v tom master (čtecím) procesu otevřít tu rouru O_RDWR, bez O_NONBLOCK. To se povede vždycky, na nic to nečeká a můžete pak čekat select()em na data, která do ní někdo zapíše (samozřejmě do ní v master procesu zapisovat nebudete).

[ext3fs]

Funguje to, ale pouze s otevrenim pro cteni a s priznakem O_NONBLOCK, jinak to stale stalo na read() i po prijeti dat a ukonceni slave procesu.

[Fuky]

do
{

// Tady Ti chybí poll() nebo select(), který musíš použít vždy, 
// když máš file descriptor otevřený v neblokujícím režimu,
// jelikož ho tam nemáš fce read() je okamžitě opuštěna a proto
// Ti to "žere" procesor

    n = read(pipe_fd, buff, 32);
    if (n == -1)
    {
        printf("read error\n");
        break;
    }
    else
        printf("recv (%d)\n",n);
} while (n != 0);