git.sur5r.net Git - openldap/blob - libraries/libldap_r/thr_nt.c

   1 /* $OpenLDAP$ */
   2 /*
   3  * Copyright 1998,1999 The OpenLDAP Foundation, Redwood City, California, USA
   4  * All rights reserved.
   5  *
   6  * Redistribution and use in source and binary forms are permitted only
   7  * as authorized by the OpenLDAP Public License.  A copy of this
   8  * license is available at http://www.OpenLDAP.org/license.html or
   9  * in file LICENSE in the top-level directory of the distribution.
  10  */
  11
  12 /* thr_nt.c - wrapper around NT threads */
  13
  14 #include "portable.h"
  15
  16 #if defined( HAVE_NT_THREADS )
  17
  18 #include "ldap_pvt_thread.h"
  19
  20 int
  21 ldap_pvt_thread_initialize( void )
  22 {
  23         return 0;
  24 }
  25
  26 int
  27 ldap_pvt_thread_destroy( void )
  28 {
  29         return 0;
  30 }
  31
  32 int
  33 ldap_pvt_thread_create( ldap_pvt_thread_t * thread,
  34         int detach,
  35         void *(*start_routine)( void *),
  36         void *arg)
  37 {
  38         *thread = (ldap_pvt_thread_t)_beginthread( (void *) start_routine,
  39                                                 0, arg );
  40          return ( (unsigned long)*thread == -1 ? -1 : 0 );
  41 }
  42
  43 void
  44 ldap_pvt_thread_exit( void *retval )
  45 {
  46         _endthread( );
  47 }
  48
  49 int
  50 ldap_pvt_thread_join( ldap_pvt_thread_t thread, void **thread_return )
  51 {
  52         DWORD status;
  53         status = WaitForSingleObject( (HANDLE) thread, INFINITE );
  54         if (status == WAIT_FAILED) {
  55                 return -1;
  56         }
  57         return 0;
  58 }
  59
  60 int
  61 ldap_pvt_thread_kill( ldap_pvt_thread_t thread, int signo )
  62 {
  63         return 0;
  64 }
  65
  66 int
  67 ldap_pvt_thread_yield( void )
  68 {
  69         Sleep( 0 );
  70         return 0;
  71 }
  72
  73 int
  74 ldap_pvt_thread_cond_init( ldap_pvt_thread_cond_t *cond )
  75 {
  76         *cond = CreateEvent( NULL, FALSE, FALSE, NULL );
  77         return( 0 );
  78 }
  79
  80 int
  81 ldap_pvt_thread_cond_destroy( ldap_pvt_thread_cond_t *cv )
  82 {
  83         CloseHandle( *cv );
  84         return( 0 );
  85 }
  86
  87 int
  88 ldap_pvt_thread_cond_signal( ldap_pvt_thread_cond_t *cond )
  89 {
  90         SetEvent( *cond );
  91         return( 0 );
  92 }
  93
  94 int
  95 ldap_pvt_thread_cond_wait( ldap_pvt_thread_cond_t *cond,
  96                           ldap_pvt_thread_mutex_t *mutex )
  97 {
  98         ReleaseMutex( *mutex );
  99         WaitForSingleObject( *cond, INFINITE );
 100         WaitForSingleObject( *mutex, INFINITE );
 101         return( 0 );
 102 }
 103
 104 int
 105 ldap_pvt_thread_cond_broadcast( ldap_pvt_thread_cond_t *cv )
 106 {
 107         SetEvent( *cv );
 108         return( 0 );
 109 }
 110
 111 int
 112 ldap_pvt_thread_mutex_init( ldap_pvt_thread_mutex_t *mutex )
 113 {
 114         *mutex = CreateMutex( NULL, 0, NULL );
 115         return ( 0 );
 116 }
 117
 118 int
 119 ldap_pvt_thread_mutex_destroy( ldap_pvt_thread_mutex_t *mutex )
 120 {
 121         CloseHandle( *mutex );
 122         return ( 0 );
 123 }
 124
 125 int
 126 ldap_pvt_thread_mutex_lock( ldap_pvt_thread_mutex_t *mutex )
 127 {
 128         WaitForSingleObject( *mutex, INFINITE );
 129         return ( 0 );
 130 }
 131
 132 int
 133 ldap_pvt_thread_mutex_unlock( ldap_pvt_thread_mutex_t *mutex )
 134 {
 135         ReleaseMutex( *mutex );
 136         return ( 0 );
 137 }
 138
 139 int
 140 ldap_pvt_thread_mutex_trylock( ldap_pvt_thread_mutex_t *mp )
 141 {
 142         DWORD status;
 143
 144         status = WaitForSingleObject( *mp, 0 );
 145         if ( (status == WAIT_FAILED) || (status == WAIT_TIMEOUT) )
 146                 return 0;
 147         else
 148                 return 1;
 149 }
 150
 151 #endif