RSS Git Download  Clone
Raw View History
Blames found: 9 Mode: text/x-c++src Binary: false


Hang on, we reloading big blames...
/******************************************************************************* * BCondInt.h BCondInt Class * T.Barnaby, BEAM Ltd, 10/12/02
* Copyright (c) 2012 All Right Reserved, Beam Ltd, http://www.beam.ltd.uk
******************************************************************************* */ #ifndef BCONDINT_H #define BCONDINT_H 1 #include <BTypes.h> #include <pthread.h>
/// Thread conditional value class BCondInt { public: BCondInt(); ~BCondInt(); void setValue(BInt value); ///< Set the value. Wakes waiting BInt value() const; ///< Current value BInt increment(BInt v = 1); ///< Increment. Wakes waiting BInt decrement(BInt v = 1); ///< Decrement. Wakes waiting Bool waitMoreThanOrEqual(BInt v, Bool decrement = 0, BTimeout timeoutUs = BTimeoutForever); ///< Wait until value is at least the value given Bool waitLessThanOrEqual(BInt v, Bool increment = 0, BTimeout timeoutUs = BTimeoutForever); ///< Wait until value is equal to or below the value given Bool waitLessThan(BInt v, BTimeout timeoutUs = BTimeoutForever); ///< 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; BInt ovalue; }; inline void BCondInt::operator+=(BInt v){ increment(v); } inline void BCondInt::operator-=(BInt v){ decrement(v); } inline void BCondInt::operator++(int){ increment(1); } inline void BCondInt::operator--(int){ decrement(1); }
/// 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 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
operator int(){ return value(); }
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); }
/// Resource lock class BCondResource { public: BCondResource(); ~BCondResource(); int lock(uint32_t timeOutUs = 0); ///< Lock the resource, will wait for all usage to be 0 int unlock(); ///< Unlock the resource int start(uint32_t timeOutUs = 0); ///< Start using the resource int end(); ///< Finish using the resource int locked(); int inUse(); private: pthread_mutex_t omutex; pthread_cond_t ocond; int olock; int ouse; };
#endif