2-8 Объявляем глобальную переменную caught_sigchld, устанавливая ее в единицу при перехвате сигнала SIGCHLD. 31-42 Вызываем door_call в цикле, пока он не завершится успешно. Глядя на выводимые клиентом результаты, мы можем подумать, что все в порядке: Функция door_call вызывается в первый раз, обработчик сигнала срабатывает через 2 секунды после этого и переменной caught_sigchld присваивается значение 1. door_call при этом возвращает ошибку EINTR и мы вызываем door_call еще раз. Во второй раз процедура завершается успешно. Посмотрев на выводимый сервером текст, мы увидим, что процедура сервера была вызвана дважды: Когда клиент второй раз вызывает door_call, это приводит к запуску нового потока, вызывающего процедуру сервера еще раз. Если процедура сервера идемпотентна, проблем в такой ситуации не возникнет. Однако если она неидемпотентна, это может привести к ошибкам. Термин «идемпотентность» по отношению к процедуре подразумевает, что процедура может быть вызвана произвольное число раз без возникновения ошибок. Наша процедура сервера, вычисляющая квадрат целого числа, идемпотентна: мы получаем правильный результат вне зависимости от того, сколько раз мы ее вызовем. Другим примером является процедура, возвращающая дату и время. Хотя эта процедура и будет возвращать разную информацию при новых вызовах (поскольку дата и время меняются), это не вызовет проблем. Классическим примером неидемпотентной процедуры является процедура уменьшения банковского счета на некоторую величину. Конечный результат будет неверным, если ее вызвать дважды.Листинг 15.24. Клиент, вызывающий door_call еще раз, после перехвата EINTR
//doors/clientintr3.c
1 #include "unpipc.h"
2 volatile sig_atomic_t caught_sigchld;
3 void
4 sig_chld(int signo)
5 {
6 caught_sigchld = 1;
7 return; /* прерываем вызов door_call() */
8 }
9 int
10 main(int argc, char **argv)
11 {
12 int fd, rc;
13 long ival, oval;
14 door_arg_t arg;
15 if (argc != 3)
16 err_quit("usage: clientintr3
17 fd = Open(argv[1], O_RDWR); /* открытие двери */
18 /* подготовка аргументов и указателя на результаты */
19 ival = atol(argv[2]);
20 arg.data_ptr = (char*)&ival; /* аргументы */
21 arg.data_size = sizeof(long); /* размер аргументов */
22 arg.desc_ptr = NULL;
23 arg.desc_num = 0;
24 arg.rbuf = (char*)&oval; /* возвращаемые данные */
25 arg.rsize = sizeof(long); /* размер данных */
26 Signal(SIGCHLD, sig_chld);
27 if (Fork() == 0) {
28 sleep(2); /* дочерний процесс */
29 exit(0); /* отправка SIGCHLD */
30 }
31 /* родительский процесс : вызов процедуры сервера и вывод результата */
32 for (;;) {
33 printf("calling door_call\n");
34 if ((rc = door_call(fd, &arg)) == 0)
35 break; /* успешное завершение */
36 if (errno == EINTR && caught_sigchld) {
37 caught_sigchld = 0;
38 continue; /* повторный вызов door_call */
39 }
40 err_sys("door_call error");
41 }
42 printf("result: %ld\n", oval);
43 exit(0);
44 }
solaris % clientintr3 /tmp/door3 33
calling door_call
calling door_call
result: 1089
solaris % serverintr3 /tmp/door3
thread id 4 called
thread id 4 returning
thread id 5 called
thread id 5 returning