7.14. Асинхронный ввод/вывод 269

Чтобы справиться с этой проблемой, мы последователь}ю читаем по одному символу и обрабатываем готовую строку при получении "\п". При этом отпадает необходимость в синхронном вызове <FILEHANDLE>. Другое решение (без проверки файлов) описано в рецепте 7.15.

Модуль IO::Select скрывает от вас операции с битовыми векторами. Метод 10: :Select->new() возвращает новый объект, для которого можно вызвать метод add, чтобы дополнить набор новыми файловыми манипуляторами. После включениях всех интересующих вас манипуляторов вызываются функции can read, can write и can exception. Функции возвращают список манипуляторов, ожидающих чтения, записи или непрочитанных срочных данных (например, информации о нарушении диапазона TCP).

Вызовы 4-аргументной версии select не должны чередоваться с вызовами каких-либо функций буферизованного вывода, перечисленных во введении (read, о, seek, tell и т. д.). Вместо этого следует использовать sysread - вместе с sysseek, если вы хотите изменить позицию внутри файла для данного манипулятора.

Чтение данных из сокета или канала с немедленным продолжением работы описано в рецепте 17.13. Асинхронному чтению с терминала посвящены рецепты 15.6 и 15.8.

t> Смотри также-

Описание функции select ъpeHfunc{\); документация но стандартному модулю IO::Select; рецепт 7.14.

7.14. Асинхронный ввод/вывод

Проблема

требуется прочитать или :аписать данные через файловый манипулятор так, чтобы система не приостанавливала процесс до наступления готовности программы, файла, сокета или устройства на другом конце. Такая задача чаще возникает для специальных, нежели для обычных файлов.

Решение

Откройте файл функцией sysopen с параметром 0 NOCBLOCK: use Fcntl;

sysopen(MODEM, "/dev/cuaO", 0 NONBLOCK0 RDWR) or die "Cant open modem: $!\n";

Если у вас уже есть файловый манипулятор, измените флаги с помощью функции fcntl:

use Fcntl; $flags = ;

fcntKHANDLE, F GETFL, Sflags)

or die "Couldnt get flags for HANDLE : $!\n";

$flags 1= 0 NONBLOCK; fcntKHANOLE, F SETFL, $flags)

or die "Couldnt set flags for HANDLE: $!\n";

После того как файловый манипулятор будет открыт для асинхронного ввода/вывода, измените флаги с помощью функции fcntl:

use POSIX qw(:errno h);

$rv = syswrite(HANDLE, $buffer, length $buffer); if (!defined($rv) && $! == EAGAIN) {

# Ожидание

} elsif ($rv != length Sbuffer) {

# Незавершенная запись } else {

n Успешная запись

$rv = sysread(HANDLE, Sbuffer, SBUFSIZ);

or die "sysread: $!"; if (!defined($rv) 8.8, $! == EAGAIN) {

# Ожидание } else {

# Успешно прочитано $rv байт из HANDLE

Комментарий

Константа 0 NONBLOCK входит в стандарт POSIX и потому поддерживается больщинством компьютеров. Мы используем модуль POSIX для получения числового значения ошибки EAGAIN.

t> Смотри также-

Описание функций sysopen и fcntl вperlfunc{i); документация по стандартному модулю POSIX; страницы руководства ореп(2) и fcntl(2); рецепты 7.13 и 7.15.

7.15. Определение количества читаемых байтов

Проблема

Требуется узнать, сколько байтов может быть прочитано через файловый манипулятор функцией read или sys read.

Решение

Воспользуйтесь функцией ioctl в режиме FIONREAD: $size = packCL", 0);

ioctKFH, $FI0NREAD, Ssize) or die "Couldnt call ioctl: S!\n";

7.15. Определение количества читаемых байтов 271

Ssize = unpackCL", Ssize);

# Могут быть прочитаны Ssize байт

Комментарий

Функция Perl ioctl предоставляет прямой интерфейс к системной функции ioctl(2). Если ваш компьютер не поддерживает запросы FIONREAD при вызове ioctl(2), вам не удастся использовать этот рецепт. FIONREAD и другие запросы ioctl(2) соответствуют числовым значениям, которые обычно хранятся в заголовочных файлах С.

Вам может понадобиться утилита Perl h2ph, преобразующая заголовочные файлы С в код Perl. FIONREAD в конечном счете определяется как функция в файле sys/ioctl.ph:

require sys/iootl,ph; Ssize = paokCL", 0);

lOGtKFH, FIONREADO, Ssize) or die "Couldnt call ioctl: S!\n"; Ssize = unpackCL", Ssize);

Если утилита h2ph не установлена или не подходит вам, найдите нужное место в заголовочном файле с помощью grep:

%grep FIONREAD /usr/include/*/*

/usr/include/asm/ioctls.h:#define FIONREAD 0x541B

Также можно написать небольшую программу на С в «редакторе настоящего программиста»:

% cat > fionread.c #include <sys/ioctl.h> main() {

printf("%#08x\n", FIONREAD);

"D

% cc -0 fion read fion read % ./fionread 0x4004667f

Затем жестко закодируйте полученное значение в программе. С переносимостью пускай возится ваш преемник:

SFIONREAD = 0x4004667f; # XXX; зависит от операционной системы

Ssize = pack("L", 0);

ioctUFH, SFIONREAD, Ssize) or die "Couldnt call ioctl; S!\n"; Ssize = unpackCL", Ssize);

FIONREAD требует, чтобы файловый манипулятор был подключен к потоку. Следовательно, сокеты, каналы и терминальные устройства будут работать, а файлы - нет.

Если вам это покажется чем-то вроде системного программирования, взгляните на проблему под другим углом. Выполните асинхронное чтение данных из ма-