UNIX и семафоры (программа на С)

// time_server v0.2
// time сервер который разделяет память
// использование семафоров для реализации блокировки
// разделяемая память используется программой по ключу 99
// семафорный набор используется программой по ключу 9900
#include stdio.h
#include sys/shm.h
#include time.h
#include sys/types.h
#include sys/sem.h
#include signal.h
#include errno.h
#define TIME_MEM_KEY 99
#define TIME_SEM_KEY 9900
#define SEG_SIZE ((size_t)100) /* размер сегмента */
#define oops(m,x) { perror(m); exit(x); }

union isemun { int val ; struct semid_ds *buf ; ushort *array; };
int seg_id, semset_id; //глобальные переменные
void cleanup(int);

main ()
{
char *mem_ptr, *ctime();
time_t now;
int n;
//создание разделяемого сегмента памяти
seg_id = shmget(TIME_MEM_KEY, SEG_SIZE, IPC_CREAT|0777);
if (seg_id == -1)
oops("shmget",1);
//присоединение сигмента и получение указателя на сегмент
mem_ptr = shmat(seg_id, NULL, 0);
int a = -1;
if (mem_ptr == (void *) a)
oops("shmat", 2);
//создание набора семафоров semset: ключ 9900, 2 семафора и права доступа rw-rw-rw-
/* создаем семафор.если он существет, semget возвратит ошибку
поскольку указан флаг IPC_EXCL */
int b = 0;
//if (semset_id = semget(TIME_SEM_KEY, 2, (0666|IPC_CREAT|IPC_EXCL))) < (void *) b)
semset_id = semget(TIME_SEM_KEY, 2, (0666|IPC_CREAT|IPC_EXCL));
if (semset_id < (void *) b)
{
if (errno == EEXIST) // действительно ли ошибка вызвана существованием объекта
{
semset_id = semget(TIME_SEM_KEY, 2, 0666);
if (semset_id < (void *) b)
{
if (semset_id < (void *) b)
oops("semget",3);
return(-1);
}
}
else return(-1);
}
else
{
set_sem_value(semset_id, 0, 0); // установка счетчиков в 0
set_sem_value(semset_id, 1, 0);
if (semset_id == -1)
oops("semset_id", 9);
}
//if (semset_id == -1)
// oops("semset_id", 9);
//set_sem_value(semset_id, 0, 0); // установка счетчиков в 0
//set_sem_value(semset_id, 1, 0);
signal(SIGINT, cleanup);
// запуск на исполнение в течении минуты
for(n=0; n<60; n++)
{
time(&now); //получение значния текущего времени
printf("time_server waiting for lock\n");
wait_and_lock(semset_id); // блокировка памяти
printf("time_server updating memory\n");
strcpy(mem_ptr, ctime(&now)); //запись в память
sleep(5);
release_lock(semset_id); //снятие блокировки
printf("time_server released lock\n");
sleep(1); // ждать 1 секунду
}
cleanup(0);
}
void cleanup(int n) //удаление
{
shmctl(seg_id, IPC_RMID, NULL); //удалить разделяемую память
semctl(semset_id, 0, IPC_RMID, NULL); //удалить семафорный набор
}
// инициализация семафора
set_sem_value(int semset_id, int semnum, int val)
{
union isemun initval;
initval.val = val;
if (semctl(semset_id, semnum, SETVAL, initval) == -1)
oops("semctr", 4);
}
//построение и выполнение набора действий над элементами:
//ожидать достижение 0 на количестве читателей (n_readers) и
//инкремент счетчика количества писателей (n_writers)
wait_and_lock(int semset_id)
{
struct sembuf actions[2]; //набор действий
actions[0].sem_num = 0; // sem[0] - это счетчик n_readers
actions[0].sem_flg = SEM_UNDO; //автоматическое востановление
actions[0].sem_op = 0; //ожидать когда счетчик читателей достигнет нуля
actions[1].sem_num = 1; //sem[1] - это счетчик n_writers
actions[1].sem_flg = SEM_UNDO; //автоматическое востановление
actions[1].sem_op = +1; //инкремент счетчика писателей
if (semop(semset_id, actions, 2) == -1)
oops("semop:locking", 10);
}
//построение и выполнение набора действий из одного элемента
//декремент счетчика n_writers
release_lock(int semset_id)
{
struct sembuf actions[1]; //набор действий
actions[0].sem_num = 1; // sem[0] - это счетчик n_writers
actions[0].sem_flg = SEM_UNDO; //автоматическое востановление
actions[0].sem_op = -1; // декремент счетчика писателей
if (semop(semset_id, actions, 1) == -1)
oops ("semop: unlocking", 10);
}
/*unlock(int semset_id)
{
struct sembuf actions[2];
actions[0].sem_num = 0; // sem[0] - это счетчик n_readers
actions[0].sem_flg = SEM_UNDO; //автоматическое востановление
actions[0].sem_op = +1; // делаем положительным счетик
actions[1].sem_num = 1; // sem[1] - это счетчик n_writers
actions[1].sem_flg = SEM_UNDO; //автоматическое востановление
actions[1].sem_op = +1; // делаем положительным счетчик
if (semop(semset_id, actions, 2) == -1)
oops("semop:initialization", 11);
}*/