/*******************************************************************************
* BCondInt.h BCondInt Class
* T.Barnaby, BEAM Ltd, 10/12/02
*******************************************************************************
*/
#ifndef BCONDINT_H
#define BCONDINT_H 1
#include <BTypes.h>
#include <pthread.h>
/// Thread conditional value
class BCondValue {
public:
BCondValue();
~BCondValue();
void setValue(int value); ///< Set the value. Wakes waiting
int value(); ///< Current value
int increment(int v = 1); ///< Increment. Wakes waiting
int decrement(int v = 1); ///< Decrement. Wakes waiting
int waitMoreThanOrEqual(int v, int decrement = 0, int timeOutUs = 0); ///< Wait until value is at least the value given
int waitLessThanOrEqual(int v, int increment = 0, int timeOutUs = 0); ///< Wait until value is equal to or below the value given
int waitLessThan(int v, int timeOutUs = 0); ///< Wait until value is equal to or below the value given
void operator+=(int v); ///< Add to value. Wakes waiting
void operator-=(int v); ///< Subtract from value. Wakes waiting
void operator++(int); ///< Increment value. Wakes waiting
void operator--(int); ///< Decrement value. Wakes waiting
private:
pthread_mutex_t omutex;
pthread_cond_t ocond;
int ovalue;
};
inline void BCondValue::operator+=(int v){
increment(v);
}
inline void BCondValue::operator-=(int v){
decrement(v);
}
inline void BCondValue::operator++(int){
increment(1);
}
inline void BCondValue::operator--(int){
decrement(1);
}
/// Thread conditional integer
class BCondInt {
public:
BCondInt();
~BCondInt();
void setValue(int value); ///< Set value
int increment(); ///< Increment
int decrement(); ///< Decrement
int value(); ///< Current value
int wait(); ///< Wait until value is 0
int waitIncrement(int timeOutUs = 0); ///< Wait until value is 0 then increment
int waitNotZero(); ///< Wait until value is not 0
int waitNotZeroDecrement(); ///< Wait until value is not 0 and then decrement
int tryNotZeroDecrement(); ///< Test if value is not 0, if not zero then decrement
int timedWait(int timeOutUs); ///< Wait for the condition, with timeout
void operator++(int);
void operator--(int);
private:
pthread_mutex_t omutex;
pthread_cond_t ocond;
int ovalue;
};
inline void BCondInt::operator++(int){
increment();
}
inline void BCondInt::operator--(int){
decrement();
}
/// Thread conditional boolean
class BCondBool {
public:
BCondBool();
~BCondBool();
int set(); ///< Set value. Wakes waiting
int clear(); ///< Clear Value
int value(); ///< Current value
int wait(); ///< Wait until value is true
int timedWait(int timeOutUs); ///< Wait until set, with timeout
private:
pthread_mutex_t omutex;
pthread_cond_t ocond;
int ovalue;
};
class BCondWrap {
public:
BCondWrap();
~BCondWrap();
void setValue(uint32_t value); ///< Set the value. Wakes waiting
uint32_t value(); ///< Current value
uint32_t increment(uint32_t v = 1); ///< Increment. Wakes waiting
uint32_t decrement(uint32_t v = 1); ///< Decrement. Wakes waiting
int waitMoreThanOrEqual(uint32_t v, uint32_t decrement = 0, uint32_t timeOutUs = 0); ///< Wait until value is at least the value given
int waitLessThanOrEqual(uint32_t v, uint32_t increment = 0, uint32_t timeOutUs = 0); ///< Wait until value is equal to or below the value given
int waitLessThan(uint32_t v, uint32_t timeOutUs = 0); ///< Wait until value is equal to or below the value given
void operator+=(int v); ///< Add to value. Wakes waiting
void operator-=(int v); ///< Subtract from value. Wakes waiting
void operator++(int); ///< Increment value. Wakes waiting
void operator--(int); ///< Decrement value. Wakes waiting
private:
int diff(uint32_t v);
pthread_mutex_t omutex;
pthread_cond_t ocond;
uint32_t ovalue;
};
inline void BCondWrap::operator+=(int v){
increment(v);
}
inline void BCondWrap::operator-=(int v){
decrement(v);
}
inline void BCondWrap::operator++(int){
increment(1);
}
inline void BCondWrap::operator--(int){
decrement(1);
}
#endif
