/*********************************************************************** * * * This software is part of the ast package * * Copyright (c) 1985-2007 AT&T Knowledge Ventures * * and is licensed under the * * Common Public License, Version 1.0 * * by AT&T Knowledge Ventures * * * * A copy of the License is available at * * http://www.opensource.org/licenses/cpl1.0.txt * * (with md5 checksum 059e8cd6165cb4c31e351f2b69388fd9) * * * * Information and Software Systems Research * * AT&T Research * * Florham Park NJ * * * * Glenn Fowler <gsf@research.att.com> * * David Korn <dgk@research.att.com> * * Phong Vo <kpv@research.att.com> * * * ***********************************************************************/ #ifndef _VTHREAD_H #define _VTHREAD_H 1 #define VTHREAD_VERSION 20001201L /* Header for the Vthread library. ** Note that the macro vt_threaded may be defined ** outside of vthread.h to suppress threading. ** ** Written by Kiem-Phong Vo, kpv@research.att.com */ #include <ast_common.h> #include <errno.h> /* ast doesn't do threads yet */ #if _PACKAGE_ast && !defined(vt_threaded) #define vt_threaded 0 #endif #if !defined(vt_threaded) || (defined(vt_threaded) && vt_threaded == 1) #define _may_use_threads 1 #else #define _may_use_threads 0 #endif #undef vt_threaded #if _may_use_threads && !defined(vt_threaded) && _hdr_pthread #define vt_threaded 1 #include <pthread.h> typedef pthread_mutex_t _vtmtx_t; typedef pthread_once_t _vtonce_t; typedef pthread_t _vtself_t; typedef pthread_t _vtid_t; typedef pthread_attr_t _vtattr_t; #if !defined(PTHREAD_ONCE_INIT) && defined(pthread_once_init) #define PTHREAD_ONCE_INIT pthread_once_init #endif #endif #if _may_use_threads && !defined(vt_threaded) && _WIN32 #define vt_threaded 1 #include <windows.h> typedef CRITICAL_SECTION _vtmtx_t; typedef int _vtonce_t; typedef HANDLE _vtself_t; typedef DWORD _vtid_t; typedef SECURITY_ATTRIBUTES _vtattr_t; #endif #ifndef vt_threaded #define vt_threaded 0 #endif /* common attributes for various structures */ #define VT_RUNNING 000000001 /* thread is running */ #define VT_SUSPENDED 000000002 /* thread is suspended */ #define VT_WAITED 000000004 /* thread has been waited */ #define VT_FREE 000010000 /* object can be freed */ #define VT_INIT 000020000 /* object was initialized */ #define VT_BITS 000030007 /* bits that we care about */ /* directives for vtset() */ #define VT_STACK 1 /* set stack size */ typedef struct _vtmutex_s Vtmutex_t; typedef struct _vtonce_s Vtonce_t; typedef struct _vthread_s Vthread_t; #ifndef EINVAL #define EINVAL 22 #endif #ifndef EBUSY #define EBUSY 16 #endif #ifndef EDEADLK #define EDEADLK 45 #endif #ifndef EPERM #define EPERM 1 #endif _BEGIN_EXTERNS_ extern Vthread_t* vtopen _ARG_((Vthread_t*, int)); extern int vtclose _ARG_((Vthread_t*)); extern int vtset _ARG_((Vthread_t*, int, Void_t*)); extern int vtrun _ARG_((Vthread_t*, void*(*)(void*), void*)); extern int vtkill _ARG_((Vthread_t*)); extern int vtwait _ARG_((Vthread_t*)); extern int vtonce _ARG_((Vtonce_t*, void(*)() )); extern Vtmutex_t* vtmtxopen _ARG_((Vtmutex_t*, int)); extern int vtmtxclose _ARG_((Vtmutex_t*)); extern int vtmtxlock _ARG_((Vtmutex_t*)); extern int vtmtxtrylock _ARG_((Vtmutex_t*)); extern int vtmtxunlock _ARG_((Vtmutex_t*)); extern int vtmtxclrlock _ARG_((Vtmutex_t*)); extern Void_t* vtstatus _ARG_((Vthread_t*)); extern int vterror _ARG_((Vthread_t*)); extern int vtmtxerror _ARG_((Vtmutex_t*)); extern int vtonceerror _ARG_((Vtonce_t*)); _END_EXTERNS_ #if vt_threaded /* mutex structure */ struct _vtmutex_s { _vtmtx_t lock; int count; _vtid_t owner; int state; int error; }; /* structure for states of thread */ struct _vthread_s { _vtself_t self; /* self-handle */ _vtid_t id; /* thread id */ _vtattr_t attrs; /* attributes */ size_t stack; /* stack size */ int state; /* execution state */ int error; /* error status */ Void_t* exit; /* exit value */ }; /* structure for exactly once execution */ struct _vtonce_s { int done; _vtonce_t once; int error; }; #if _WIN32 #define VTONCE_INITDATA {0, 0} #else #define VTONCE_INITDATA {0, PTHREAD_ONCE_INIT } #endif #define vtstatus(vt) ((vt)->exit) #define vterror(vt) ((vt)->error) #define vtmtxerror(mtx) ((mtx)->error) #define vtonceerror(once) ((once)->error) #endif /*vt_threaded*/ /* fake structures and functions */ #if !vt_threaded struct _vtmutex_s { int error; }; struct _vtattr_s { int error; }; struct _vthread_s { int error; }; struct _vtonce_s { int error; }; typedef int _vtmtx_t; typedef int _vtonce_t; typedef int _vtself_t; typedef int _vtid_t; typedef int _vtattr_t; #define VTONCE_INITDATA {0} #define vtopen(vt,flgs) ((Vthread_t*)0) #define vtclose(vt) (-1) #define vtkill(vt) (-1) #define vtwait(vt) (-1) #define vtrun(vt,fn,arg) (-1) #define vtset(vt,t,v) (-1) #define vtonce(on,fu) (-1) #define vtmtxopen(mtx,flgs) ((Vtmutex_t*)0) #define vtmtxclose(mtx) (-1) #define vtmtxlock(mtx) (-1) #define vtmtxtrylock(mtx) (-1) #define vtmtxunlock(mtx) (-1) #define vtmtxclrlock(mtx) (-1) #define vtstatus(vt) ((Void_t*)0) #define vterror(vt) (0) #define vtmtxerror(mtx) (0) #define vtonceerror(once) (0) #endif /*!vt_threaded*/ #endif /*_VTHREAD_H*/