ThreadLib.h

/*
 *     ____             _________                __                _     
 *    / __ \___  ____ _/ /_  __(_)___ ___  ___  / /   ____  ____ _(_)____
 *   / /_/ / _ \/ __ `/ / / / / / __ `__ \/ _ \/ /   / __ \/ __ `/ / ___/
 *  / _, _/  __/ /_/ / / / / / / / / / / /  __/ /___/ /_/ / /_/ / / /__  
 * /_/ |_|\___/\__,_/_/ /_/ /_/_/ /_/ /_/\___/_____/\____/\__, /_/\___/  
 *                                                       /____/          
 *
 *                  Barracuda Embedded Web-Server
 *
 ****************************************************************************
 *                            HEADER
 *
 *   $Id: ThreadLib.h 4915 2021-12-01 18:26:55Z wini $
 *
 *   COPYRIGHT:  Real Time Logic LLC, 2004 - 2008
 *
 *   This software is copyrighted by and is the sole property of Real
 *   Time Logic LLC.  All rights, title, ownership, or other interests in
 *   the software remain the property of Real Time Logic LLC.  This
 *   software may only be used in accordance with the terms and
 *   conditions stipulated in the corresponding license agreement under
 *   which the software has been supplied.  Any unauthorized use,
 *   duplication, transmission, distribution, or disclosure of this
 *   software is expressly forbidden.
 *                                                                        
 *   This Copyright notice may not be removed or modified without prior
 *   written consent of Real Time Logic LLC.
 *                                                                         
 *   Real Time Logic LLC. reserves the right to modify this software
 *   without notice.
 *
 *               http://www.realtimelogic.com
 ****************************************************************************
 *
 */
 
#ifndef ThreadLib_hpp
 
#include <TargConfig.h>
 
typedef enum { 
   ThreadPrioLowest, 
   ThreadPrioLow, 
   ThreadPrioNormal, 
   ThreadPrioHigh, 
   ThreadPrioHighest 
} ThreadPriority;
 
 
#ifndef __DOXYGEN__
struct HttpRequest;
struct ThreadMutex;
struct Thread;
#endif
 
typedef void (*Thread_Run)(struct Thread* th);
 
#ifdef __cplusplus
extern "C" {
#else
struct ThreadReleaseLock;
#endif
 
BA_API void ThreadReleaseLock_internalConstructor(
   struct ThreadReleaseLock* o, struct HttpRequest* req);
 
#ifdef __cplusplus
}
#endif
 
 
 
 
#if defined(__cplusplus)
 
#ifndef __DOXYGEN__
struct ThreadReleaseLock;
#endif
 
struct ThreadLock
{
      ThreadLock(ThreadMutex& m);
 
      ThreadLock(ThreadMutex* m);
 
      ~ThreadLock();
   private:
      friend struct ThreadReleaseLock;
      struct ThreadMutex* mutex;
};
 
 
struct ThreadReleaseLock
{
      ThreadReleaseLock(struct HttpRequest* req);
      ThreadReleaseLock(ThreadMutex& m);
      ThreadReleaseLock(ThreadMutex* m);
      ThreadReleaseLock(ThreadLock& tl);
      ThreadReleaseLock(ThreadLock* tl);
      ~ThreadReleaseLock();
   private:
      struct ThreadMutex* mutex;
};
 
 
#else
#define ThreadMutexBase ThreadMutex
#define ThreadSemaphoreBase ThreadSemaphore
#define ThreadBase Thread
#endif
 
 
#include "ThreadLibArch.h"
 
#if defined(__cplusplus)
 
struct ThreadMutex : public ThreadMutexBase
{
      void *operator new(size_t s) { return ::baMalloc(s); }
      void operator delete(void* d) { if(d) ::baFree(d); }
      void *operator new(size_t, void *place) { return place; }
      void operator delete(void*, void *) { }
 
      ThreadMutex() { ThreadMutex_constructor(this); }
      ~ThreadMutex() { ThreadMutex_destructor(this); }
      void set() { ThreadMutex_set(this); }
      void release() { ThreadMutex_release(this); }
      bool isOwner() { return ThreadMutex_isOwner(this)?true:false; }
};
 
struct ThreadSemaphore : public ThreadSemaphoreBase
{
      void *operator new(size_t s) { return ::baMalloc(s); }
      void operator delete(void* d) { if(d) ::baFree(d); }
      void *operator new(size_t, void *place) { return place; }
      void operator delete(void*, void *) { }
 
      ThreadSemaphore(){ ThreadSemaphore_constructor(this); }
      ~ThreadSemaphore(void) { ThreadSemaphore_destructor(this); }
 
      void wait() { ThreadSemaphore_wait(this); }
 
      void signal() { ThreadSemaphore_signal(this); }
};
 
 
struct Thread : public ThreadBase
{
      Thread() {}
      void *operator new(size_t s) { return ::baMalloc(s); }
      void operator delete(void* d) { if(d) ::baFree(d); }
      void *operator new(size_t, void *place) { return place; }
      void operator delete(void*, void *) { }
 
      Thread(Thread_Run r, ThreadPriority priority, int stackSize) {
         Thread_constructor(this, r, priority, stackSize); }
      ~Thread() { Thread_destructor(this); }
      void start() {  Thread_start(this); }
 
      static void sleep(unsigned int milliseconds) {
         Thread_sleep(milliseconds); }
};
 
inline ThreadLock::ThreadLock(ThreadMutex& m) : mutex(&m) { mutex->set(); }
inline ThreadLock::ThreadLock(ThreadMutex* m) : mutex(m) { mutex->set(); }
inline ThreadLock::~ThreadLock() { mutex->release(); }
 
inline ThreadReleaseLock::ThreadReleaseLock(struct HttpRequest* req) {
   ThreadReleaseLock_internalConstructor(this, req);
}
inline ThreadReleaseLock::ThreadReleaseLock(ThreadMutex& m) :
   mutex(&m) { mutex->release(); }
inline ThreadReleaseLock::ThreadReleaseLock(ThreadMutex* m) : 
   mutex(m) { mutex->release(); }
inline ThreadReleaseLock::ThreadReleaseLock(ThreadLock& tl) :
   mutex(tl.mutex) { mutex->release(); }
inline ThreadReleaseLock::ThreadReleaseLock(ThreadLock* tl) :
   mutex(tl->mutex) { mutex->release(); }
inline ThreadReleaseLock::~ThreadReleaseLock() { mutex->set(); }
 
#endif
 /* end of ThreadLib group */
 
#endif