FIFO-pipe ist immer lesbar, im select()

In C-pseudo-code:

while (1) {
    fifo = open("fifo", O_RDONLY | O_NONBLOCK);
    fd_set read;
    FD_SET(fifo, &read);
    select(nfds, &read, NULL, NULL, NULL);
}

Den Prozess schläft, als sich-ausgelöst durch die select() bis ein anderer Prozess schreibt in fifo. Danach wird es immer finden fifo als eine lesbare Datei-Deskriptor.

Wie dieses Verhalten zu vermeiden (das ist, nach fifo wurde einmal gelesen, wie man es als unlesbar wird, bis man es bekommt noch ein schreiben?)

  • Also, was willst du auftreten?
InformationsquelleAutor Matoe | 2013-01-30
  1. 31

    Ihnen eröffnet, dass FIFO nur Lesen (O_RDONLY), wenn dort ist kein Schriftsteller, der FIFO Lesen, die Ende erhalten Sie eine EOF.

    Wählen Sie system-Aufruf zurück auf EOF und für jeden EOF Sie Griff wird es eine neue EOF. Dies ist der Grund für das beobachtete Verhalten.

    Um dies zu vermeiden, öffnen Sie das FIFO zum Lesen und schreiben (O_RDWR). Dies stellt sicher, dass Sie mindestens einen writer haben nach dem FIFO-es gibt also nicht eine EOF und als Ergebnis wählen Sie nicht zurückkehren, es sei denn, jemand schreibt, dass FIFO.

    • Das war die richtige Antwort um zu verhindern, läuft eine Endlosschleife von EOL-Erkennung
    • dies war die richtige Antwort für mich. Obwohl, in meinem Fall hatte ich kleinere Variante: Rohr gibt immer 2 fds 1 Lesen und 1 schreiben; in meinem Fall habe ich explizit geschlossen wird das schreiben Ende (der folgende code-Beispiel aus einer C/S-Anwendung). Daher bin ich auf dasselbe problem, das das Lesen zu Ende war, immer bereit zum Lesen, da der EOF. DANKE FÜR DEN TIPP
    • OMG, war auf der Suche nach sowas für buchstäblich 4 Stunden. Endlich hier die Lösung gefunden. +1
    • wenn ich das Tue ich nie registrieren, eine Antwort in der select-block aus der schreib-Ende des fifo. es ist einfach Stände. Auch wenn ich umleiten string vom terminal, um die fifo habe ich noch nichts bekommen
    InformationsquelleAutor Fox
  2. 3

    Ist die einfache Antwort, zu Lesen, bis read() zurück EWOULDBLOCK (oder EAGAIN), oder craps mit Fehler.

    Was Sie sagen, einfach nicht passiert, außer das Betriebssystem (bzw. die Laufzeitumgebung), die Sie verwenden, ist buggy. Ansonsten müssen Sie etwas falsch machen. Zum Beispiel select() ist die Verwendung von level-triggered-I/O. ich würde denken, dass, wahrscheinlich, Sie werden nicht ablassen, den socket komplett, und so select() immer bedeutet, dass Sie etwas Links in es (dies geschieht nicht mit edge-triggered event-Benachrichtigungen).

    Unten ist ein einfaches Beispiel, das zeigt, wie man Lesen sollte, bis die read() zurück EWOULDBLOCK um zu vermeiden, dass Deskriptor in einem lesbaren Zustand (ich habe Sie kompiliert und getestet auf OS X, und es ist meist auch kein Fehler zu überprüfen, aber Sie sollten Sie bekommen die Idee):

    /*
 * FIFO example using select.
 *
 * $ mkfifo /tmp/fifo
 * $ clang -Wall -o test ./test.c
 * $ ./test &
 * $ echo 'hello' > /tmp/fifo
 * $ echo 'hello world' > /tmp/fifo
 * $ killall test
 */

#include <sys/types.h>
#include <sys/select.h>
#include <errno.h>
#include <stdlib.h>
#include <stdio.h>
#include <fcntl.h>
#include <unistd.h>

int main()
{
    int fd;
    int n;
    fd_set set;
    ssize_t bytes;
    size_t total_bytes;
    char buf[1024];

    fd = open("/tmp/fifo", O_RDWR | O_NONBLOCK);
    if (fd == -1) {
        perror("open");
        return EXIT_FAILURE;
    }

    FD_ZERO(&set);
    FD_SET(fd, &set);

    for (;;) {
        n = select(fd+1, &set, NULL, NULL, NULL);
        if (!n)
            continue;
        if (n == -1) {
            perror("select");
            return EXIT_FAILURE;
        }
        if (FD_ISSET(fd, &set)) {
            printf("Descriptor %d is ready.\n", fd);
            total_bytes = 0;
            for (;;) {
                bytes = read(fd, buf, sizeof(buf));
                if (bytes > 0) {
                    total_bytes += (size_t)bytes;
                } else {
                    if (errno == EWOULDBLOCK) {
                        /* Done reading */
                        printf("done reading (%lu bytes)\n", total_bytes);
                        break;
                    } else {
                        perror("read");
                        return EXIT_FAILURE;
                    }
                }
            }
        }
    }

    return EXIT_SUCCESS;
}

    Grundsätzlich level-triggered-I/O bedeutet, dass Sie benachrichtigt, wenn es etwas zu Lesen, obwohl Sie möglicherweise nicht benachrichtigt wurden, vor. Auf Gegenteil, edge-triggered-I/O bedeutet, dass Sie immer nur einmal benachrichtigt jedes mal, wenn neue Daten ankommen und es ist egal, ob Sie es Lesen oder nicht. select() ist ein level-triggered-I/O-Schnittstelle.

    Hoffe, es hilft. Viel Glück!

    • Ich denke, dass die andere Antwort widerspricht dieser, und richtig ist. select gibt, wenn eine Blockierung read zurückkehren würde, und read zurück 0 (Signalisierung EOF), wenn keiner deine fifo zum schreiben geöffnet. Dein Beispiel-Programm überhaupt nicht, weil es die fifo zum schreiben geöffnet selbst.
    InformationsquelleAutor
Schreibe einen Kommentar