home *** CD-ROM | disk | FTP | other *** search
/ PC World 2002 July & August / PCWorld_2002-07-08_cd.bin / Komunik / MySQL / mysql / data1.cab / Development / include / my_pthread.h < prev    next >
C/C++ Source or Header  |  2002-02-21  |  22KB  |  628 lines
  1. /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
  2.    
  3.    This library is free software; you can redistribute it and/or
  4.    modify it under the terms of the GNU Library General Public
  5.    License as published by the Free Software Foundation; either
  6.    version 2 of the License, or (at your option) any later version.
  7.    
  8.    This library is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  11.    Library General Public License for more details.
  12.    
  13.    You should have received a copy of the GNU Library General Public
  14.    License along with this library; if not, write to the Free
  15.    Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  16.    MA 02111-1307, USA */
  17.  
  18. /* Defines to make different thread packages compatible */
  19.  
  20. #ifndef _my_pthread_h
  21. #define _my_pthread_h
  22.  
  23. #include <errno.h>
  24. #ifndef ETIME
  25. #define ETIME ETIMEDOUT                /* For FreeBSD */
  26. #endif
  27.  
  28. #ifdef  __cplusplus
  29. extern "C" {
  30. #endif /* __cplusplus */ 
  31.  
  32. #if defined(__WIN__) || defined(OS2)
  33.  
  34. #ifdef OS2
  35. typedef ULONG     HANDLE;
  36. typedef ULONG     DWORD;
  37. typedef int sigset_t;
  38. #endif
  39.  
  40. #ifdef OS2
  41. typedef HMTX             pthread_mutex_t;
  42. #else
  43. typedef CRITICAL_SECTION pthread_mutex_t;
  44. #endif
  45. typedef HANDLE         pthread_t;
  46. typedef struct thread_attr {
  47.     DWORD dwStackSize ;
  48.     DWORD dwCreatingFlag ;
  49.     int priority ;
  50. } pthread_attr_t ;
  51.  
  52. typedef struct { int dummy; } pthread_condattr_t;
  53.  
  54. /* Implementation of posix conditions */
  55.  
  56. typedef struct st_pthread_link {
  57.   DWORD thread_id;
  58.   struct st_pthread_link *next;
  59. } pthread_link;
  60.  
  61. typedef struct {
  62.   uint32 waiting;
  63. #ifdef OS2
  64.   HEV    semaphore;
  65. #else
  66.   HANDLE semaphore;
  67. #endif
  68. } pthread_cond_t;
  69.  
  70.  
  71. #ifndef OS2
  72. struct timespec {        /* For pthread_cond_timedwait() */
  73.     time_t tv_sec;
  74.     long tv_nsec;
  75. };
  76. #endif
  77.  
  78. typedef int pthread_mutexattr_t;
  79. #define win_pthread_self my_thread_var->pthread_self
  80. #ifdef OS2
  81. #define pthread_handler_decl(A,B) void * _Optlink A(void *B)
  82. typedef void * (_Optlink *pthread_handler)(void *);
  83. #else
  84. #define pthread_handler_decl(A,B) void * __cdecl A(void *B)
  85. typedef void * (__cdecl *pthread_handler)(void *);
  86. #endif
  87.  
  88. void win_pthread_init(void);
  89. int win_pthread_setspecific(void *A,void *B,uint length);
  90. int pthread_create(pthread_t *,pthread_attr_t *,pthread_handler,void *);
  91. int pthread_cond_init(pthread_cond_t *cond, const pthread_condattr_t *attr);
  92. int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex);
  93. int pthread_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex,
  94.                struct timespec *abstime);
  95. int pthread_cond_signal(pthread_cond_t *cond);
  96. int pthread_cond_broadcast(pthread_cond_t *cond);
  97. int pthread_cond_destroy(pthread_cond_t *cond);
  98. int pthread_attr_init(pthread_attr_t *connect_att);
  99. int pthread_attr_setstacksize(pthread_attr_t *connect_att,DWORD stack);
  100. int pthread_attr_setprio(pthread_attr_t *connect_att,int priority);
  101. int pthread_attr_destroy(pthread_attr_t *connect_att);
  102. struct tm *localtime_r(const time_t *timep,struct tm *tmp);
  103.  
  104. void pthread_exit(void *a);     /* was #define pthread_exit(A) ExitThread(A)*/
  105.  
  106. #ifndef OS2
  107. #define ETIMEDOUT 145            /* Win32 doesn't have this */
  108. #define getpid() GetCurrentThreadId()
  109. #endif
  110. #define pthread_self() win_pthread_self
  111. #define HAVE_LOCALTIME_R        1
  112. #define _REENTRANT            1
  113. #define HAVE_PTHREAD_ATTR_SETSTACKSIZE    1
  114.  
  115. #ifdef USE_TLS                    /* For LIBMYSQL.DLL */
  116. #undef SAFE_MUTEX                /* This will cause conflicts */
  117. #define pthread_key(T,V)  DWORD V
  118. #define pthread_key_create(A,B) ((*A=TlsAlloc())==0xFFFFFFFF)
  119. #define pthread_getspecific(A) (TlsGetValue(A))
  120. #define my_pthread_getspecific(T,A) ((T) TlsGetValue(A))
  121. #define my_pthread_getspecific_ptr(T,V) ((T) TlsGetValue(V))
  122. #define my_pthread_setspecific_ptr(T,V) (!TlsSetValue((T),(V)))
  123. #define pthread_setspecific(A,B) (!TlsSetValue((A),(B)))
  124. #else
  125. #define pthread_key(T,V) __declspec(thread) T V
  126. #define pthread_key_create(A,B) pthread_dummy(0)
  127. #define pthread_getspecific(A) (&(A))
  128. #define my_pthread_getspecific(T,A) (&(A))
  129. #define my_pthread_getspecific_ptr(T,V) (V)
  130. #define my_pthread_setspecific_ptr(T,V) ((T)=(V),0)
  131. #define pthread_setspecific(A,B) win_pthread_setspecific(&(A),(B),sizeof(A))
  132. #endif /* USE_TLS */
  133.  
  134. #define pthread_equal(A,B) ((A) == (B))
  135. #ifdef OS2
  136. int pthread_mutex_init (pthread_mutex_t *, const pthread_mutexattr_t *);
  137. int pthread_mutex_lock (pthread_mutex_t *);
  138. int pthread_mutex_unlock (pthread_mutex_t *);
  139. int pthread_mutex_destroy (pthread_mutex_t *);
  140. #define my_pthread_setprio(A,B)  DosSetPriority(PRTYS_THREAD,PRTYC_NOCHANGE, B, A)
  141. #define pthread_kill(A,B) raise(B)
  142. #define pthread_exit(A) pthread_dummy()
  143. #else
  144. #define pthread_mutex_init(A,B)  InitializeCriticalSection(A)
  145. #define pthread_mutex_lock(A)     (EnterCriticalSection(A),0)
  146. #define pthread_mutex_unlock(A)  LeaveCriticalSection(A)
  147. #define pthread_mutex_destroy(A) DeleteCriticalSection(A)
  148. #define my_pthread_setprio(A,B)  SetThreadPriority(GetCurrentThread(), (B))
  149. #define pthread_kill(A,B) pthread_dummy(0)
  150. #endif /* OS2 */
  151.  
  152. /* Dummy defines for easier code */
  153. #define pthread_attr_setdetachstate(A,B) pthread_dummy(0)
  154. #define my_pthread_attr_setprio(A,B) pthread_attr_setprio(A,B)
  155. #define pthread_attr_setscope(A,B)
  156. #define pthread_detach_this_thread()
  157. #define pthread_condattr_init(A)
  158. #define pthread_condattr_destroy(A)
  159.  
  160. /*Irena: compiler does not like this: */
  161. /*#define my_pthread_getprio(pthread_t thread_id) pthread_dummy(0) */
  162. #define my_pthread_getprio(thread_id) pthread_dummy(0)
  163.  
  164. #elif defined(HAVE_UNIXWARE7_THREADS)
  165.  
  166. #include <thread.h>
  167. #include <synch.h>
  168.  
  169. #ifndef _REENTRANT
  170. #define _REENTRANT
  171. #endif
  172.  
  173. #define HAVE_NONPOSIX_SIGWAIT
  174. #define pthread_t thread_t
  175. #define pthread_cond_t cond_t
  176. #define pthread_mutex_t mutex_t
  177. #define pthread_key_t thread_key_t
  178. typedef int pthread_attr_t;            /* Needed by Unixware 7.0.0 */
  179.  
  180. #define pthread_key_create(A,B) thr_keycreate((A),(B))
  181.  
  182. #define pthread_handler_decl(A,B) void *A(void *B)
  183. #define pthread_key(T,V) pthread_key_t V
  184.  
  185. void *    my_pthread_getspecific_imp(pthread_key_t key);
  186. #define my_pthread_getspecific(A,B) ((A) my_pthread_getspecific_imp(B))
  187. #define my_pthread_getspecific_ptr(T,V) my_pthread_getspecific(T,V)
  188.  
  189. #define pthread_setspecific(A,B) thr_setspecific(A,B)
  190. #define my_pthread_setspecific_ptr(T,V) pthread_setspecific(T,V)
  191.  
  192. #define pthread_create(A,B,C,D) thr_create(NULL,65536L,(C),(D),THR_DETACHED,(A))
  193. #define pthread_cond_init(a,b) cond_init((a),USYNC_THREAD,NULL)
  194. #define pthread_cond_destroy(a) cond_destroy(a)
  195. #define pthread_cond_signal(a) cond_signal(a)
  196. #define pthread_cond_wait(a,b) cond_wait((a),(b))
  197. #define pthread_cond_timedwait(a,b,c) cond_timedwait((a),(b),(c))
  198. #define pthread_cond_broadcast(a) cond_broadcast(a)
  199.  
  200. #define pthread_mutex_init(a,b) mutex_init((a),USYNC_THREAD,NULL)
  201. #define pthread_mutex_lock(a) mutex_lock(a)
  202. #define pthread_mutex_unlock(a) mutex_unlock(a)
  203. #define pthread_mutex_destroy(a) mutex_destroy(a)
  204.  
  205. #define pthread_self() thr_self()
  206. #define pthread_exit(A) thr_exit(A)
  207. #define pthread_equal(A,B) (((A) == (B)) ? 1 : 0)
  208. #define pthread_kill(A,B) thr_kill((A),(B))
  209. #define HAVE_PTHREAD_KILL
  210.  
  211. #define pthread_sigmask(A,B,C) thr_sigsetmask((A),(B),(C))
  212.  
  213. extern int my_sigwait(const sigset_t *set,int *sig);
  214.  
  215. #define pthread_detach_this_thread() pthread_dummy(0)
  216.  
  217. #define pthread_attr_init(A) pthread_dummy(0)
  218. #define pthread_attr_destroy(A) pthread_dummy(0)
  219. #define pthread_attr_setscope(A,B) pthread_dummy(0)
  220. #define pthread_attr_setdetachstate(A,B) pthread_dummy(0)
  221. #define my_pthread_setprio(A,B) pthread_dummy (0)
  222. #define my_pthread_getprio(A) pthread_dummy (0)
  223. #define my_pthread_attr_setprio(A,B) pthread_dummy(0)
  224.  
  225. #else /* Normal threads */
  226.  
  227. #ifdef HAVE_rts_threads
  228. #define sigwait org_sigwait
  229. #include <signal.h>
  230. #undef sigwait
  231. #endif
  232. #undef _REENTRANT            /* Fix if _REENTRANT is in pthread.h */
  233. #include <pthread.h>
  234. #ifndef _REENTRANT
  235. #define _REENTRANT
  236. #endif
  237. #ifdef HAVE_THR_SETCONCURRENCY
  238. #include <thread.h>            /* Probably solaris */
  239. #endif
  240. #ifdef HAVE_SCHED_H
  241. #include <sched.h>
  242. #endif
  243. #ifdef HAVE_SYNCH_H
  244. #include <synch.h>
  245. #endif
  246. #if defined(__EMX__) && (!defined(EMX_PTHREAD_REV) || (EMX_PTHREAD_REV < 2))
  247. #error Requires at least rev 2 of EMX pthreads library.
  248. #endif
  249.  
  250. extern int my_pthread_getprio(pthread_t thread_id);
  251.  
  252. #define pthread_key(T,V) pthread_key_t V
  253. #define my_pthread_getspecific_ptr(T,V) my_pthread_getspecific(T,(V))
  254. #define my_pthread_setspecific_ptr(T,V) pthread_setspecific(T,(void*) (V))
  255. #define pthread_detach_this_thread()
  256. #define pthread_handler_decl(A,B) void *A(void *B)
  257. typedef void *(* pthread_handler)(void *);
  258.  
  259. /* Test first for RTS or FSU threads */
  260.  
  261. #if defined(PTHREAD_SCOPE_GLOBAL) && !defined(PTHREAD_SCOPE_SYSTEM)
  262. #define HAVE_rts_threads
  263. extern int my_pthread_create_detached;
  264. #define pthread_sigmask(A,B,C) sigprocmask((A),(B),(C))
  265. #define PTHREAD_CREATE_DETACHED &my_pthread_create_detached
  266. #define PTHREAD_SCOPE_SYSTEM  PTHREAD_SCOPE_GLOBAL
  267. #define PTHREAD_SCOPE_PROCESS PTHREAD_SCOPE_LOCAL
  268. #define USE_ALARM_THREAD
  269. #elif defined(HAVE_mit_thread)
  270. #define USE_ALARM_THREAD
  271. #undef    HAVE_LOCALTIME_R
  272. #define HAVE_LOCALTIME_R
  273. #undef    HAVE_PTHREAD_ATTR_SETSCOPE
  274. #define HAVE_PTHREAD_ATTR_SETSCOPE
  275. #undef HAVE_GETHOSTBYNAME_R_GLIBC2_STYLE    /* If we are running linux */
  276. #undef HAVE_RWLOCK_T
  277. #undef HAVE_RWLOCK_INIT
  278. #undef HAVE_PTHREAD_RWLOCK_RDLOCK
  279. #undef HAVE_SNPRINTF
  280.  
  281. #define sigset(A,B) pthread_signal((A),(void (*)(int)) (B))
  282. #define signal(A,B) pthread_signal((A),(void (*)(int)) (B))
  283. #define my_pthread_attr_setprio(A,B)
  284. #endif /* defined(PTHREAD_SCOPE_GLOBAL) && !defined(PTHREAD_SCOPE_SYSTEM) */
  285.  
  286. #if defined(_BSDI_VERSION) && _BSDI_VERSION < 199910
  287. int sigwait(sigset_t *set, int *sig);
  288. #endif
  289.  
  290. #if defined(HAVE_UNIXWARE7_POSIX)
  291. #undef HAVE_NONPOSIX_SIGWAIT
  292. #define HAVE_NONPOSIX_SIGWAIT    /* sigwait takes only 1 argument */
  293. #endif
  294.  
  295. #ifndef HAVE_NONPOSIX_SIGWAIT
  296. #define my_sigwait(A,B) sigwait((A),(B))
  297. #else
  298. int my_sigwait(const sigset_t *set,int *sig);
  299. #endif
  300.  
  301. #ifdef HAVE_NONPOSIX_PTHREAD_MUTEX_INIT
  302. #ifndef SAFE_MUTEX
  303. #define pthread_mutex_init(a,b) my_pthread_mutex_init((a),(b))
  304. extern int my_pthread_mutex_init(pthread_mutex_t *mp,
  305.                  const pthread_mutexattr_t *attr);
  306. #endif /* SAFE_MUTEX */
  307. #define pthread_cond_init(a,b) my_pthread_cond_init((a),(b))
  308. extern int my_pthread_cond_init(pthread_cond_t *mp,
  309.                 const pthread_condattr_t *attr);
  310. #endif /* HAVE_NONPOSIX_PTHREAD_MUTEX_INIT */
  311.  
  312. #if defined(HAVE_SIGTHREADMASK) && !defined(HAVE_PTHREAD_SIGMASK)
  313. #define pthread_sigmask(A,B,C) sigthreadmask((A),(B),(C))
  314. #endif
  315.  
  316. #if !defined(HAVE_SIGWAIT) && !defined(HAVE_mit_thread) && !defined(HAVE_rts_threads) && !defined(sigwait) && !defined(alpha_linux_port) && !defined(HAVE_NONPOSIX_SIGWAIT) && !defined(HAVE_DEC_3_2_THREADS) && !defined(_AIX)
  317. int sigwait(sigset_t *setp, int *sigp);        /* Use our implemention */
  318. #endif
  319. #if !defined(HAVE_SIGSET) && !defined(HAVE_mit_thread) && !defined(sigset)
  320. #define sigset(A,B) do { struct sigaction s; sigset_t set;              \
  321.                          sigemptyset(&set);                             \
  322.                          s.sa_handler = (B);                            \
  323.                          s.sa_mask    = set;                            \
  324.                          s.sa_flags   = 0;                              \
  325.                          sigaction((A), &s, (struct sigaction *) NULL); \
  326.                        } while (0)
  327. #endif
  328.  
  329. #ifndef my_pthread_setprio
  330. #if defined(HAVE_PTHREAD_SETPRIO_NP)        /* FSU threads */
  331. #define my_pthread_setprio(A,B) pthread_setprio_np((A),(B))
  332. #elif defined(HAVE_PTHREAD_SETPRIO)
  333. #define my_pthread_setprio(A,B) pthread_setprio((A),(B))
  334. #else
  335. extern void my_pthread_setprio(pthread_t thread_id,int prior);
  336. #endif
  337. #endif
  338.  
  339. #ifndef my_pthread_attr_setprio
  340. #ifdef HAVE_PTHREAD_ATTR_SETPRIO
  341. #define my_pthread_attr_setprio(A,B) pthread_attr_setprio((A),(B))
  342. #else
  343. extern void my_pthread_attr_setprio(pthread_attr_t *attr, int priority);
  344. #endif
  345. #endif
  346.  
  347. #if !defined(HAVE_PTHREAD_ATTR_SETSCOPE) || defined(HAVE_DEC_3_2_THREADS)
  348. #define pthread_attr_setscope(A,B)
  349. #undef    HAVE_GETHOSTBYADDR_R            /* No definition */
  350. #endif
  351.  
  352. #if defined(OS2)
  353. #define my_pthread_getspecific(T,A) ((T) &(A))
  354. #define pthread_setspecific(A,B) win_pthread_setspecific(&(A),(B),sizeof(A))
  355. #elif !defined( HAVE_NONPOSIX_PTHREAD_GETSPECIFIC)
  356. #define my_pthread_getspecific(A,B) ((A) pthread_getspecific(B))
  357. #else
  358. #define my_pthread_getspecific(A,B) ((A) my_pthread_getspecific_imp(B))
  359. void *my_pthread_getspecific_imp(pthread_key_t key);
  360. #endif /* OS2 */
  361.  
  362. #ifndef HAVE_LOCALTIME_R
  363. struct tm *localtime_r(const time_t *clock, struct tm *res);
  364. #endif
  365.  
  366. #ifdef HAVE_PTHREAD_CONDATTR_CREATE
  367. /* DCE threads on HPUX 10.20 */
  368. #define pthread_condattr_init pthread_condattr_create
  369. #define pthread_condattr_destroy pthread_condattr_delete
  370. #endif
  371.  
  372. #ifdef HAVE_CTHREADS_WRAPPER            /* For MacOSX */
  373. #define pthread_cond_destroy(A) pthread_dummy(0)
  374. #define pthread_mutex_destroy(A) pthread_dummy(0)
  375. #define pthread_attr_delete(A) pthread_dummy(0)
  376. #define pthread_condattr_delete(A) pthread_dummy(0)
  377. #define pthread_attr_setstacksize(A,B) pthread_dummy(0)
  378. #define pthread_equal(A,B) ((A) == (B))
  379. #define pthread_cond_timedwait(a,b,c) pthread_cond_wait((a),(b))
  380. #define pthread_attr_init(A) pthread_attr_create(A)
  381. #define pthread_attr_destroy(A) pthread_attr_delete(A)
  382. #define pthread_attr_setdetachstate(A,B) pthread_dummy(0)
  383. #define pthread_create(A,B,C,D) pthread_create((A),*(B),(C),(D))
  384. #define pthread_sigmask(A,B,C) sigprocmask((A),(B),(C))
  385. #define pthread_kill(A,B) pthread_dummy(0)
  386. #undef    pthread_detach_this_thread
  387. #define pthread_detach_this_thread() { pthread_t tmp=pthread_self() ; pthread_detach(&tmp); }
  388. #endif
  389.  
  390. #ifdef HAVE_DARWIN_THREADS
  391. #define pthread_sigmask(A,B,C) sigprocmask((A),(B),(C))
  392. #define pthread_kill(A,B) pthread_dummy(0)
  393. #define pthread_condattr_init(A) pthread_dummy(0)
  394. #define pthread_condattr_destroy(A) pthread_dummy(0)
  395. #define pthread_signal(A,B) pthread_dummy(0)
  396. #undef    pthread_detach_this_thread
  397. #define pthread_detach_this_thread() { pthread_t tmp=pthread_self() ; pthread_detach(tmp); }
  398. #undef sigset
  399. #define sigset(A,B) pthread_signal((A),(void (*)(int)) (B))
  400. #endif
  401.  
  402. #if ((defined(HAVE_PTHREAD_ATTR_CREATE) && !defined(HAVE_SIGWAIT)) || defined(HAVE_DEC_3_2_THREADS)) && !defined(HAVE_CTHREADS_WRAPPER)
  403. /* This is set on AIX_3_2 and Siemens unix (and DEC OSF/1 3.2 too) */
  404. #define pthread_key_create(A,B) \
  405.         pthread_keycreate(A,(B) ?\
  406.                   (pthread_destructor_t) (B) :\
  407.                   (pthread_destructor_t) pthread_dummy)
  408. #define pthread_attr_init(A) pthread_attr_create(A)
  409. #define pthread_attr_destroy(A) pthread_attr_delete(A)
  410. #define pthread_attr_setdetachstate(A,B) pthread_dummy(0)
  411. #define pthread_create(A,B,C,D) pthread_create((A),*(B),(C),(D))
  412. #ifndef pthread_sigmask
  413. #define pthread_sigmask(A,B,C) sigprocmask((A),(B),(C))
  414. #endif
  415. #define pthread_kill(A,B) pthread_dummy(0)
  416. #undef    pthread_detach_this_thread
  417. #define pthread_detach_this_thread() { pthread_t tmp=pthread_self() ; pthread_detach(&tmp); }
  418. #else /* HAVE_PTHREAD_ATTR_CREATE && !HAVE_SIGWAIT */
  419. #define HAVE_PTHREAD_KILL
  420. #endif
  421.  
  422. #if defined(HAVE_PTHREAD_ATTR_CREATE) || defined(_AIX) || defined(HAVE_GETHOSTBYNAME_R_GLIBC2_STYLE)
  423. #if !defined(HPUX)
  424. struct hostent;
  425. #endif /* HPUX */
  426. struct hostent *my_gethostbyname_r(const char *name,
  427.                    struct hostent *result, char *buffer,
  428.                    int buflen, int *h_errnop);
  429. #if defined(HAVE_GETHOSTBYNAME_R_GLIBC2_STYLE)
  430. #define GETHOSTBYNAME_BUFF_SIZE 2048
  431. #else
  432. #define GETHOSTBYNAME_BUFF_SIZE sizeof(struct hostent_data)
  433. #endif /* defined(HAVE_GETHOSTBYNAME_R_GLIBC2_STYLE) */
  434.  
  435. #else
  436. #ifdef HAVE_GETHOSTBYNAME_R_RETURN_INT
  437. #define GETHOSTBYNAME_BUFF_SIZE sizeof(struct hostent_data)
  438. struct hostent *my_gethostbyname_r(const char *name,
  439.                    struct hostent *result, char *buffer,
  440.                    int buflen, int *h_errnop);
  441. #else
  442. #define GETHOSTBYNAME_BUFF_SIZE 2048
  443. #define my_gethostbyname_r(A,B,C,D,E) gethostbyname_r((A),(B),(C),(D),(E))
  444. #endif /* HAVE_GETHOSTBYNAME_R_RETURN_INT */
  445. #endif /* defined(HAVE_PTHREAD_ATTR_CREATE) || defined(_AIX) || defined(HAVE_GETHOSTBYNAME_R_GLIBC2_STYLE) */
  446.  
  447. #endif /* defined(__WIN__) */
  448.  
  449.     /* safe_mutex adds checking to mutex for easier debugging */
  450.  
  451. typedef struct st_safe_mutex_t
  452. {
  453.   pthread_mutex_t global,mutex;
  454.   char *file;
  455.   uint line,count;
  456.   pthread_t thread;
  457. } safe_mutex_t;
  458.  
  459. int safe_mutex_init(safe_mutex_t *mp, const pthread_mutexattr_t *attr);
  460. int safe_mutex_lock(safe_mutex_t *mp,const char *file, uint line);
  461. int safe_mutex_unlock(safe_mutex_t *mp,const char *file, uint line);
  462. int safe_mutex_destroy(safe_mutex_t *mp,const char *file, uint line);
  463. int safe_cond_wait(pthread_cond_t *cond, safe_mutex_t *mp,const char *file,
  464.            uint line);
  465. int safe_cond_timedwait(pthread_cond_t *cond, safe_mutex_t *mp,
  466.             struct timespec *abstime, const char *file, uint line);
  467.  
  468.     /* Wrappers if safe mutex is actually used */
  469. #ifdef SAFE_MUTEX
  470. #undef pthread_mutex_init
  471. #undef pthread_mutex_lock
  472. #undef pthread_mutex_unlock
  473. #undef pthread_mutex_destroy
  474. #undef pthread_mutex_wait
  475. #undef pthread_mutex_timedwait
  476. #undef pthread_mutex_t
  477. #undef pthread_cond_wait
  478. #undef pthread_cond_timedwait
  479. #define pthread_mutex_init(A,B) safe_mutex_init((A),(B))
  480. #define pthread_mutex_lock(A) safe_mutex_lock((A),__FILE__,__LINE__)
  481. #define pthread_mutex_unlock(A) safe_mutex_unlock((A),__FILE__,__LINE__)
  482. #define pthread_mutex_destroy(A) safe_mutex_destroy((A),__FILE__,__LINE__)
  483. #define pthread_cond_wait(A,B) safe_cond_wait((A),(B),__FILE__,__LINE__)
  484. #define pthread_cond_timedwait(A,B,C) safe_cond_timedwait((A),(B),(C),__FILE__,__LINE__)
  485. #define pthread_mutex_trylock(A) pthread_mutex_lock(A)
  486. #define pthread_mutex_t safe_mutex_t
  487. #endif /* SAFE_MUTEX */
  488.  
  489.     /* READ-WRITE thread locking */
  490.  
  491. #if defined(USE_MUTEX_INSTEAD_OF_RW_LOCKS)
  492. /* use these defs for simple mutex locking */
  493. #define rw_lock_t pthread_mutex_t
  494. #define my_rwlock_init(A,B) pthread_mutex_init((A),(B))
  495. #define rw_rdlock(A) pthread_mutex_lock((A))
  496. #define rw_wrlock(A) pthread_mutex_lock((A))
  497. #define rw_unlock(A) pthread_mutex_unlock((A))
  498. #define rwlock_destroy(A) pthread_mutex_destroy((A))
  499. #elif defined(HAVE_PTHREAD_RWLOCK_RDLOCK)
  500. #define rw_lock_t pthread_rwlock_t
  501. #define my_rwlock_init(A,B) pthread_rwlock_init((A),(B))
  502. #define rw_rdlock(A) pthread_rwlock_rdlock(A)
  503. #define rw_wrlock(A) pthread_rwlock_wrlock(A)
  504. #define rw_unlock(A) pthread_rwlock_unlock(A)
  505. #define rwlock_destroy(A) pthread_rwlock_destroy(A)
  506. #elif defined(HAVE_RWLOCK_INIT)
  507. #ifdef HAVE_RWLOCK_T                /* For example Solaris 2.6-> */
  508. #define rw_lock_t rwlock_t
  509. #endif
  510. #define my_rwlock_init(A,B) rwlock_init((A),USYNC_THREAD,0)
  511. #else
  512. /* Use our own version of read/write locks */
  513. typedef struct _my_rw_lock_t {
  514.     pthread_mutex_t lock;        /* lock for structure        */
  515.     pthread_cond_t    readers;    /* waiting readers        */
  516.     pthread_cond_t    writers;    /* waiting writers        */
  517.     int        state;        /* -1:writer,0:free,>0:readers    */
  518.     int        waiters;    /* number of waiting writers    */
  519. } my_rw_lock_t;
  520.  
  521. #define rw_lock_t my_rw_lock_t
  522. #define rw_rdlock(A) my_rw_rdlock((A))
  523. #define rw_wrlock(A) my_rw_wrlock((A))
  524. #define rw_unlock(A) my_rw_unlock((A))
  525. #define rwlock_destroy(A) my_rwlock_destroy((A))
  526.  
  527. extern    int    my_rwlock_init( my_rw_lock_t *, void * );
  528. extern    int    my_rwlock_destroy( my_rw_lock_t * );
  529. extern    int    my_rw_rdlock( my_rw_lock_t * );
  530. extern    int    my_rw_wrlock( my_rw_lock_t * );
  531. extern    int    my_rw_unlock( my_rw_lock_t * );
  532. #endif /* USE_MUTEX_INSTEAD_OF_RW_LOCKS */
  533.  
  534. #define GETHOSTBYADDR_BUFF_SIZE 2048
  535.  
  536. #ifndef HAVE_THR_SETCONCURRENCY
  537. #define thr_setconcurrency(A) pthread_dummy(0)
  538. #endif
  539. #if !defined(HAVE_PTHREAD_ATTR_SETSTACKSIZE) && ! defined(pthread_attr_setstacksize)
  540. #define pthread_attr_setstacksize(A,B) pthread_dummy(0)
  541. #endif
  542.  
  543. /* Define mutex types */
  544. #define MY_MUTEX_INIT_SLOW   NULL
  545. #define MY_MUTEX_INIT_FAST   NULL
  546. #define MY_MUTEX_INIT_ERRCHK NULL
  547. #ifdef PTHREAD_ADAPTIVE_MUTEX_INITIALIZER_NP
  548. extern pthread_mutexattr_t my_fast_mutexattr;
  549. #undef  MY_MUTEX_INIT_FAST
  550. #define MY_MUTEX_INIT_FAST &my_fast_mutexattr
  551. #endif
  552. #ifdef PTHREAD_ERRORCHECK_MUTEX_INITIALIZER_NP
  553. extern pthread_mutexattr_t my_errchk_mutexattr;
  554. #undef MY_INIT_MUTEX_ERRCHK
  555. #define MY_INIT_MUTEX_ERRCHK &my_errchk_mutexattr
  556. #endif
  557.  
  558. extern my_bool my_thread_global_init(void);
  559. extern void my_thread_global_end(void);
  560. extern my_bool my_thread_init(void);
  561. extern void my_thread_end(void);
  562. extern const char *my_thread_name(void);
  563. extern long my_thread_id(void);
  564. extern int pthread_no_free(void *);
  565. extern int pthread_dummy(int);
  566.  
  567. /* All thread specific variables are in the following struct */
  568.  
  569. #define THREAD_NAME_SIZE 10
  570. #if defined(__ia64__)
  571. #define DEFAULT_THREAD_STACK    (128*1024)
  572. #else
  573. #define DEFAULT_THREAD_STACK    (64*1024)
  574. #endif
  575.  
  576. struct st_my_thread_var
  577. {
  578.   int thr_errno;
  579.   pthread_cond_t suspend;
  580.   pthread_mutex_t mutex;
  581.   pthread_mutex_t * volatile current_mutex;
  582.   pthread_cond_t * volatile current_cond;
  583.   pthread_t pthread_self;
  584.   long id;
  585.   int cmp_length;
  586.   int volatile abort;
  587. #ifndef DBUG_OFF
  588.   gptr dbug;
  589.   char name[THREAD_NAME_SIZE+1];
  590. #endif
  591. };
  592.  
  593. extern struct st_my_thread_var *_my_thread_var(void) __attribute__ ((const));
  594. #define my_thread_var (_my_thread_var())
  595. #define my_errno my_thread_var->thr_errno
  596.  
  597.     /* statistics_xxx functions are for not essential statistic */
  598.  
  599. #ifndef thread_safe_increment
  600. #ifdef HAVE_ATOMIC_ADD
  601. #define thread_safe_increment(V,L) atomic_add(1,(atomic_t*) &V);
  602. #define thread_safe_add(V,C,L)     atomic_add((C),(atomic_t*) &V);
  603. #define thread_safe_sub(V,C,L)     atomic_sub((C),(atomic_t*) &V);
  604. #define statistic_increment(V,L)   thread_safe_increment((V),(L))
  605. #define statistic_add(V,C,L)       thread_safe_add((V),(C),(L))
  606. #else
  607. #define thread_safe_increment(V,L) \
  608.     pthread_mutex_lock((L)); (V)++; pthread_mutex_unlock((L));
  609. #define thread_safe_add(V,C,L) \
  610.     pthread_mutex_lock((L)); (V)+=(C); pthread_mutex_unlock((L));
  611. #define thread_safe_sub(V,C,L) \
  612.     pthread_mutex_lock((L)); (V)-=(C); pthread_mutex_unlock((L));
  613. #ifdef SAFE_STATISTICS
  614. #define statistic_increment(V,L)   thread_safe_increment((V),(L))
  615. #define statistic_add(V,C,L)       thread_safe_add((V),(C),(L))
  616. #else
  617. #define statistic_increment(V,L) (V)++
  618. #define statistic_add(V,C,L)     (V)+=(C)
  619. #endif /* SAFE_STATISTICS */
  620. #endif /* HAVE_ATOMIC_ADD */
  621. #endif /* thread_safe_increment */
  622.  
  623. #ifdef  __cplusplus
  624. }
  625. #endif
  626.  
  627. #endif /* _my_ptread_h */
  628.