dn_thread.h

Go to the documentation of this file.

#ifndef DN_THREAD_H_
#define DN_THREAD_H_

#ifndef _DN_EXP_THREAD
#define _DN_EXP_THREAD
#endif /* _DN_EXP_THREAD */

#if defined(_USE_WIN_API)
#define begin_thread(p_thread, function, arg) { *p_thread = (HANDLE)_beginthreadex(NULL, 0, function, arg, 0, NULL); }
#define exit_thread(thread) { if(thread != NULL) { WaitForSingleObject(thread, INFINITE); CloseHandle(thread); thread = NULL; } }
#define dn_sleep(n) Sleep(n)
typedef HANDLE MUTEX;
typedef HANDLE THREAD;
typedef unsigned int THRET;
#define THTYPE __stdcall
typedef HANDLE EVENT;
#elif defined(_USE_LINUX_API)
#define begin_thread(p_thread, function, arg) pthread_create(p_thread, NULL, function, arg)
#define exit_thread(thread) pthread_join(thread, NULL)
#define dn_sleep(n) usleep((n) * 1000)
typedef pthread_mutex_t MUTEX;
typedef pthread_t THREAD;
typedef void *THRET;
#define THTYPE
#define STATUS_WAIT_0 ((uint32_t)0x00000000L)
#define WAIT_OBJECT_0 ((STATUS_WAIT_0) + 0)
typedef struct EVENT
  {
    pthread_mutex_t mutex;
    pthread_cond_t cond;
    int mode;
    int signal;
  }EVENT;
#endif

#ifndef INFINITE
#define INFINITE ((uint32_t)-1)
#endif

#ifdef __cplusplus
extern "C"
{
#endif

  _DN_EXP_THREAD HRESULT
  initialize_mutex(MUTEX *pmutex);

  _DN_EXP_THREAD HRESULT
  release_mutex(MUTEX *pmutex);

  _DN_EXP_THREAD HRESULT
  lock_mutex(MUTEX *pmutex, uint32_t timeout);

  _DN_EXP_THREAD HRESULT
  unlock_mutex(MUTEX *pmutex);

  _DN_EXP_THREAD HRESULT
  create_event(EVENT *pevt, int reset_mode, int init_signal);

  _DN_EXP_THREAD HRESULT
  destroy_event(EVENT *pevt);

  _DN_EXP_THREAD HRESULT
  set_event(EVENT *pevt);

  _DN_EXP_THREAD HRESULT
  reset_event(EVENT *pevt);

  _DN_EXP_THREAD HRESULT
  wait_event(EVENT *pevt, uint32_t timeout);

  _DN_EXP_THREAD HRESULT
  wait_event_multi(EVENT **pevt, uint32_t count, uint32_t timeout,
      int wait_all);

#define calc_time_diff(start, end) (((end) >= (start)) ? ((end) - (start)) : ((((uint32_t)-1) - (end)) + (start)))

  _DN_EXP_THREAD uint32_t
  gettimeofday_msec();

#ifdef __cplusplus
}
#endif

#endif /* DN_THREAD_H_ */