Читать «UNIX: взаимодействие процессов» онлайн - страница 259

solaris % clientintr3 /tmp/door3 33
calling door_call
calling door_call
result: 1089

Функция door_call вызывается в первый раз, обработчик сигнала срабатывает через 2 секунды после этого и переменной caught_sigchld присваивается значение 1. door_call при этом возвращает ошибку EINTR и мы вызываем door_call еще раз. Во второй раз процедура завершается успешно.

Посмотрев на выводимый сервером текст, мы увидим, что процедура сервера была вызвана дважды:

solaris % serverintr3 /tmp/door3
thread id 4 called
thread id 4 returning
thread id 5 called
thread id 5 returning

Когда клиент второй раз вызывает door_call, это приводит к запуску нового потока, вызывающего процедуру сервера еще раз. Если процедура сервера идемпотентна, проблем в такой ситуации не возникнет. Однако если она неидемпотентна, это может привести к ошибкам.

Термин «идемпотентность» по отношению к процедуре подразумевает, что процедура может быть вызвана произвольное число раз без возникновения ошибок. Наша процедура сервера, вычисляющая квадрат целого числа, идемпотентна: мы получаем правильный результат вне зависимости от того, сколько раз мы ее вызовем. Другим примером является процедура, возвращающая дату и время. Хотя эта процедура и будет возвращать разную информацию при новых вызовах (поскольку дата и время меняются), это не вызовет проблем. Классическим примером неидемпотентной процедуры является процедура уменьшения банковского счета на некоторую величину. Конечный результат будет неверным, если ее вызвать дважды.

Досрочное завершение клиента

Посмотрим, каким образом процедура сервера получает уведомление о досрочном завершении клиента. Пpoгрaммa-клиeнт приведена в листинге 15.25.

Листинг 15.25. Клиент, досрочно завершающий работу после вызова door_call

//doors/clientintr4.c
1  #include "unpipc.h"
2  int
3  main(int argc, char **argv)
4  {
5   int fd;
6   long ival, oval;
7   door_arg_t arg;
8   if (argc != 3)
9    err_quit("usage: clientintr4 <server-pathname> <integer-value>");
10  fd = Open(argv[1], O_RDWR); /* открываем дверь */
11  /* подготовка аргументов и указателя на результаты */
12  ival = atol(argv[2]);
13  arg.data_ptr = (char*)&ival; /* аргументы */
14  arg.data_size = sizeof(long); /* размер аргументов */
15  arg.desc_ptr = NULL;
16  arg.desc_num = 0;
17  arg.rbuf = (char*)&oval; /* возвращаемые данные */
18  arg.rsize = sizeof(long); /* размер возвращаемых данных */
19  /* вызов процедуры сервера и вывод результата */
20  alarm(3);
21  Door_call(fd, &arg);
22  printf("result: %ld\n", oval);
23  exit(0);
24 }

20 Единственное изменение заключается в добавлении вызова alarm(3) перед door_call. Эта функция приводит к отправке сигнала SIGALRM через три секунды после вызова, но, поскольку мы его не перехватываем, это приводит к завершению процесса. Поэтому клиент завершится до возврата из door_call, потому что в процедуру сервера вставлена шестисекундная пауза.

В листинге 15.26 приведен текст процедуры сервера и обработчик отмены потока.