С++ and pipeline (in_avail() не работает)

[korisk]

Нужна утилита, которая работала как grep. Используем С++.
$echo blah|util
или
$util
Тестовый пример:

Код:

// in_avail () example #include <iostream> using namespace std; int main () { streamsize size; char ch; streambuf * pbuf; pbuf = cin.rdbuf(); // cin >> ch; size = pbuf->in_avail(); cout << size << endl; return 0; }

Для gcc всегда возвращает 0. Вроде для MS VS++ отрабатывает правильно(читал, но не проверял).

Так вот вопрос:
может быть кто-то уже знает какой-нибудь workaround?
Спасибо.

[/dev/random]

in_avail() возвращает длину _заполненной части буфера_. То, что в пайп передаются какие-то данные, вовсе не означает, что они уже были считаны из файлового дескриптора в буфер.

Что именно вы ожидаете увидеть? Полную длину потока? Или что?

[korisk]

in_avail() возвращает длину _заполненной части буфера_. То, что в пайп передаются какие-то данные, вовсе не означает, что они уже были считаны из файлового дескриптора в буфер.

Что именно вы ожидаете увидеть? Полную длину потока? Или что?

ожидаю увидеть число не считанных символов.
Основная цель - избежать блокировки на ожидании ввода и добиться поведения аналогичного grep.

В с этого можно добиться с помощью select, а вот с потоками - не ясно.

pbuf->pubsync();
не помогает.

[/dev/random]

Основная цель - избежать блокировки на ожидании ввода и добиться поведения аналогичного grep.

В с этого можно добиться с помощью select, а вот с потоками - не ясно.

Так. Я правильно понял? Вам нужно считать строку и начать её обрабатывать, не дожидаясь поступления первых символов следующей строки? Если так, то простого getline() должно быть достаточно. Или вам нужно что-то другое?

[korisk]

Основная цель - избежать блокировки на ожидании ввода и добиться поведения аналогичного grep.

В с этого можно добиться с помощью select, а вот с потоками - не ясно.

Так. Я правильно понял? Вам нужно считать строку и начать её обрабатывать, не дожидаясь поступления первых символов следующей строки? Если так, то простого getline() должно быть достаточно. Или вам нужно что-то другое?

getline() вызывает блокировку на ожидание первой строки.
Задача - избежать блокировки. что-то типа kbhit

[/dev/random]

getline() вызывает блокировку на ожидание первой строки.
Задача - избежать блокировки. что-то типа kbhit

Вам нужно что-то делать во время ожидания первой строки? Если да, то что? Читать из других потоков? Что-то считать? Общаться с пользователем? Что?

Все подобные решения всегда блокируют программу. Даже select() блокирует её и ждёт события. Вопрос лишь в том, когда и как блокировать. И это зависит от конкретной задачи.

[korisk]

getline() вызывает блокировку на ожидание первой строки.
Задача - избежать блокировки. что-то типа kbhit

Вам нужно что-то делать во время ожидания первой строки? Если да, то что? Читать из других потоков? Что-то считать? Общаться с пользователем? Что?

Все подобные решения всегда блокируют программу. Даже select() блокирует её и ждёт события. Вопрос лишь в том, когда и как блокировать. И это зависит от конкретной задачи.

для select можно указать время ожидания несколько миллисекунд.


echo asdfsdf > /tmp/file;
grep /tmp/file asd #не захватывает ввод
cat /tmp/file|grep asd #тоже не захватывает
как этого добиться в С++? вот и вся задача.

[/dev/random]

echo asdfsdf > /tmp/file;
grep /tmp/file asd #не захватывает ввод
cat /tmp/file|grep asd #тоже не захватывает
как этого добиться в С++? вот и вся задача.

Какой ввод оно не захватывает? Терминал? Оно с терминала не читает. Файл? В линуксе нет такого понятия как "захватывание файла", это только в винде пока из него читают, писать в него нельзя. Что вы имеете в виду под "захватыванием"?

[korisk]

echo asdfsdf > /tmp/file;
grep /tmp/file asd #не захватывает ввод
cat /tmp/file|grep asd #тоже не захватывает
как этого добиться в С++? вот и вся задача.

Какой ввод оно не захватывает? Терминал? Оно с терминала не читает. Файл? В линуксе нет такого понятия как "захватывание файла", это только в винде пока из него читают, писать в него нельзя. Что вы имеете в виду под "захватыванием"?

попробуйте скомпилировать этот код:

Код:

// in_avail () example #include <iostream> using namespace std; int main () { string ch; cin >> ch; cout << ch << endl; return 0; }

korisk@kaa:~/tmp$ echo "asdfsdf"|./a.out
asdfsdf
#прошло нормально
korisk@kaa:~/tmp$ ./a.out
^C
#заблокировано,захвачено итп. , но прервано сигналом

[/dev/random]

korisk@kaa:~/tmp$ echo "asdfsdf"|./a.out
asdfsdf
#прошло нормально
korisk@kaa:~/tmp$ ./a.out
^C
#заблокировано,захвачено итп. , но прервано сигналом

Не вижу разницы с этим:

Shell

$ grep qwe ^C

[korisk]

korisk@kaa:~/tmp$ echo "asdfsdf"|./a.out
asdfsdf
#прошло нормально
korisk@kaa:~/tmp$ ./a.out
^C
#заблокировано,захвачено итп. , но прервано сигналом

Не вижу разницы с этим:

Shell

$ grep qwe ^C

мде ) идея понятна, но в моем примере используются параметры. Возможно я чего-то не вижу, но не знаю как реализовать такую возможность.
Ведь если явные параметры у команды есть, то данные могут поступать и через канал...
(проверка на источник ввода - клавиатура или канал)

[Portnov]

man isatty
?

[/dev/random]

мде ) идея понятна, но в моем примере используются параметры. Возможно я чего-то не вижу, но не знаю как реализовать такую возможность.
Ведь если явные параметры у команды есть, то данные могут поступать и через канал...
(проверка на источник ввода - клавиатура или канал)

int main(int argc, char **argv) {
// если переданы параметры, открываем этот файл, иначе читаем stdin.
// Просто читаем построчно, не заботясь о буферах и задержках
// Именно так ведёт себя grep
}

[korisk]

man isatty
?

Спасибо! То что нужно

[korisk]

решение: http://www.ginac.de/~kreckel/fileno/