/*******************************************************************************
 *	BSema.cc	BSema Classes
 *			T.Barnaby,	BEAM Ltd,	6/11/02
 *	updated by	D.Korchagin,	CERN AB-BI-SW,	2007-08-31
 *******************************************************************************
 */

#include <BSema.h>
#include <errno.h>
#include <sys/time.h>

BSema::BSema(int value){
	sem_init(&osema, 0, value);
}

BSema::BSema(const BSema& sema){
	sem_init(&osema, 0, sema.getValue());
}

BSema& BSema::operator=(const BSema& sema){
	sem_destroy(&osema);
	sem_init(&osema, 0, sema.getValue());
	return *this;
}

BSema::~BSema(){
	sem_destroy(&osema);
}

int BSema::post(){
	return sem_post(&osema);
}

int BSema::wait(){
	int	r;
	
	while(1){
		r = sem_wait(&osema);
		if(r >= 0)
			break;
		else if((r < 0) && (errno != EINTR))
			break;
	}
	
	return r;
}

int BSema::timedWait(int timeOutUs){
	struct timeval	tv;
	struct timespec	ts;
	
	gettimeofday(&tv, 0);
	ts.tv_sec = tv.tv_sec + timeOutUs / 1000000;
	ts.tv_nsec = (tv.tv_usec + timeOutUs % 1000000) * 1000;
	ts.tv_sec += (ts.tv_nsec / 1000000000);
	ts.tv_nsec %=  1000000000;
	
#ifndef __Lynx__
	return sem_timedwait(&osema, &ts);
#else
#ifdef HAVE_SEM_TIMEDWAIT
	// LynxOS 4.2 new features - support has been added for two routines from POSIX 1003.1-2001, sem_timedwait() and pthread_mutex_timedlock(), etc.
	return sem_timedwait(&osema, &ts);
#else
	// sem_timedwait() is not available for LynxOS 4.0 or previous versions - use sem_wait() instead.
	return sem_wait(&osema);
#endif
#endif
}

int BSema::tryWait(){
	return sem_trywait(&osema);
}

int BSema::getValue() const {
	int	v;
	
	sem_getvalue((sem_t*)&osema, &v);
	return v;
}