14 va_start(ap, oflag); /* ар инициализируется последним аргументом */
15 mode = va_arg(ap, va_mode_t);
16 value = va_arg(ap, unsigned int);
17 va_end(ap);
18 if (mkfifo(pathname, mode) < 0) {
19 if (errno == EEXIST && (oflag & O_EXCL) == 0)
20 oflag &= ~O_CREAT; /* уже существует, OK */
21 else
22 return(SEM_FAILED);
23 }
24 }
25 if ((sem = malloc(sizeof(mysem_t))) == NULL)
26 return(SEM_FAILED);
27 sem->sem_fd[0] = sem->sem_fd[1] = –1;
28 if ((sem->sem_fd[0] = open(pathname, O_RDONLY | O_NONBLOCK)) < 0)
29 goto error;
30 if ((sem->sem_fd[1] = open(pathname, O_WRONLY | O_NONBLOCK)) < 0)
31 goto error;
32 /* отключение неблокируемого режима для sem_fd[0] */
33 if ((flags = fcntl(sem->sem_fd[0], F_GETFL, 0)) < 0)
34 goto error;
35 flags &= ~O_NONBLOCK;
36 if (fcntl(sem->sem_fd[0], F_SETFL, flags) < 0)
37 goto error;
38 if (oflag & O_CREAT) { /* инициализация семафора */
39 for (i = 0; i < value; i++)
40 if (write(sem->sem_fd[1], &c, 1) != 1)
41 goto error;
42 }
43 sem->sem_magic = SEM_MAGIC;
44 return(sem);
45 error:
46 save_errno = errno;
47 if (oflag & O_CREAT)
48 unlink(pathname); /* если мы создали FIFO */
49 close(sem->sem_fd[0]); /* игнорируем ошибку */
50 close(sem->sem_fd[1]); /* игнорируем ошибку */
51 free(sem);
52 errno = save_errno;
53 return(SEM_FAILED);
54 }
13-17 Если при вызове указан флаг O_CREAT, должно быть указано четыре аргумента, а не два. Мы вызываем va_start, после чего переменная ар указывает на последний явно указанный аргумент (oflag). Затем мы используем ар и функцию va_arg для получения значений третьего и четвертого аргументов. Работу со списком аргументов переменной длины и использование нашего типа va_mode_t мы обсуждали в связи с листингом 5.17.
18-23 Создается новый канал FIFO, имя которого было указано при вызове функции. Как мы отмечали в разделе 4.6, эта функция возвращает ошибку EEXIST, если канал уже существует. Если при вызове sem_open флаг O_EXCL не был указан, мы пропускаем эту ошибку; но нам не нужно будет инициализировать этот канал, так что мы при этом сбрасываем флаг O_CREAT.
25-37 Мы выделяем место для типа sem_t, который содержит два дескриптора. Затем мы дважды открываем канал FIFO: один раз только на чтение, а другой — только на запись. При этом мы не хотим блокирования при вызове open, поэтому указываем флаги O_NONBLOCK при открытии очереди только для чтения (вспомните табл. 4.1). Мы также указываем флаг O_NONBLOCK при открытии канала на запись, но это предназначено для обнаружения переполнения (на тот случай, если мы попытаемся записать больше, чем позволяет PIPE_BUF). После открытия канала мы отключаем неблокируемый режим для дескриптора, открытого на чтение.
38-42 Если мы создали семафор, его нужно проинициализировать, записав в канал FIFO value байтов. Если указанное при вызове значение value превышает определенное реализацией ограничение PIPE_BUF, вызов write после переполнения FIFO вернет ошибку с кодом EAGAIN.
Текст функции sem_close приведен в листинге 10.23.
11-15 Мы закрываем оба дескриптора и освобождаем память, выделенную под тип sem_t.
//my_pxsem_fifo/sem_close.с
1 #include "unpipc.h"
2 #include "semaphore.h"
3 int
4 mysem_close(mysem_t *sem)
5 {
6 if (sem->sem_magic != SEM_MAGIC) {
7 errno = EINVAL;
8 return(-1);
9 }