semaphore.c

#include "semaphore.h"

#include <errno.h>
#include <unistd.h>
#include <time.h>




#define TEST_ERROR if (errno) {fprintf(stderr,				\
				       "%s:%d: PID=%5d: Error %d (%s)\n", \
				       __FILE__,			\
				       __LINE__,			\
				       getpid(),			\
				       errno,				\
				       strerror(errno));}

/* Set a semaphore to a user defined value */
int sem_set_val(int sem_id, int sem_num, int sem_val) {

	return semctl(sem_id, sem_num, SETVAL, sem_val);
}

/* Try to access the resource by 1 */
int sem_reserve_1(int sem_id, int sem_num) {
	struct sembuf sops;
	
	sops.sem_num = sem_num;
	sops.sem_op = -1;
	sops.sem_flg = 0;
	return semop(sem_id, &sops, 1);
}

int sem_reserve_1_no_wait(int sem_id, int sem_num) {
	struct sembuf sops;
	
	sops.sem_num = sem_num;
	sops.sem_op = -1;
	sops.sem_flg = IPC_NOWAIT;
	return semop(sem_id, &sops, 1);
}

int sem_reserve_1_time(int sem_id, int sem_num){
	struct sembuf sops;
	struct timespec timeout;

	sops.sem_num = sem_num;
	sops.sem_op = -1;
	sops.sem_flg = 0;

	timeout.tv_sec = 0;
	timeout.tv_nsec = 100000000;

	return semtimedop(sem_id, &sops, 1, &timeout);
}

int sem_reserve_0(int sem_id, int sem_num) {
	struct sembuf sops;
	
	sops.sem_num = sem_num;
	sops.sem_op = 0;
	sops.sem_flg = 0;
	return semop(sem_id, &sops, 1);
}

/* Release the resource */
int sem_release(int sem_id, int sem_num) {
	struct sembuf sops;
  
	sops.sem_num = sem_num;
	sops.sem_op = 1;
	sops.sem_flg = 0;
	
	return semop(sem_id, &sops, 1);
}

/* Print all semaphore values to a string */