Распечатайте содержимое fifo и выйдите - PullRequest
Новая
       17

Распечатайте содержимое fifo и выйдите

2 голосов
/ 15 мая 2009

Мне нужно напечатать содержимое fifo (именованного канала) на стандартный вывод.
Я мог бы использовать команду: 

cat fifo

Проблема в том, что cat не возвращается. Он продолжает работать, ожидая больше контента, поступающего с fifo. Но я знаю, что какое-то время контента больше не будет, поэтому я просто хочу напечатать то, что доступно.

Есть ли команда, которая просто печатает доступное содержимое и завершает работу?

EDIT:
В одном конце fifo время от времени пишется процесс вывода различных команд. Этот процесс работает постоянно, поэтому EOF не будет.

Ответы [ 2 ]

2 голосов
/ 15 мая 2009

Когда вы не можете отправить EOF, вы можете использовать «неблокирующую кошку». Я включил (протестированную) C-версию, которую нашел здесь (конечно же, это относится к первоначальному автору) Магия в fcntl(STDIN_FILENO, F_SETFL, O_NONBLOCK).

Первый аргумент этого неблокирующего кота - это количество секунд, которое вы хотите подождать, прежде чем снова выйти. 

#include <stdio.h>
#include <fcntl.h>
#include <time.h>
#include <unistd.h>
#include <string.h>


void read_loop(int fFile, double wWait)
{
    if (fFile < 0) return;

    double max_time = wWait, total_time = 0;
    struct timespec cycle_time = { 0, 50 * 1000 * 1000 };
    double add_time = (double) cycle_time.tv_sec + (double) cycle_time.tv_nsec / 1000000000.;

    char next_line[1024];

    FILE *input_file = fdopen(fFile, "r");

    while (total_time < max_time)
    {
    while (fgets(next_line, 1024, input_file))
     {
    write(STDOUT_FILENO, next_line, strlen(next_line));
    total_time = 0;
     }

    nanosleep(&cycle_time, NULL);
    total_time += add_time;
    }

    fclose(input_file);
}


int main(int argc, char *argv[])
{
    if (argc < 2)
    {
    fprintf(stderr, "%s [max time] (files...)\n", argv[0]);
    return 1;
    }

    int max_wait = strtoul(argv[1],0, 10);

    if (argc == 2)
    {
    fprintf(stderr, "%s: using standard input\n", argv[0]);
    fcntl(STDIN_FILENO, F_SETFL, O_NONBLOCK);
    read_loop(STDIN_FILENO, max_wait);
    return 0;
    }

    int current = 2;

    while (current < argc)
    {
    fprintf(stderr, "%s: switch to file '%s'\n", argv[0], argv[current]);
    int next_file = open(argv[current++], O_RDONLY | O_NONBLOCK);
    read_loop(next_file, max_wait);
    close(next_file);
    }

    return 0;
}
0 голосов
/ 15 мая 2009

Вы должны закрыть другой конец FIFO. Это должно отправить EOF процессу cat.

...