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

   1 /* $OpenLDAP$ */
   2 /*
   3  * Copyright 1998-2000 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_int_thread_initialize( void )
  22 {
  23         return 0;
  24 }
  25
  26 int
  27 ldap_int_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         SignalObjectAndWait( *mutex, *cond, INFINITE, FALSE );
  99         WaitForSingleObject( *mutex, INFINITE );
 100         return( 0 );
 101 }
 102
 103 int
 104 ldap_pvt_thread_cond_broadcast( ldap_pvt_thread_cond_t *cond )
 105 {
 106         SetEvent( *cond );
 107         return( 0 );
 108 }
 109
 110 int
 111 ldap_pvt_thread_mutex_init( ldap_pvt_thread_mutex_t *mutex )
 112 {
 113         *mutex = CreateMutex( NULL, 0, NULL );
 114         return ( 0 );
 115 }
 116
 117 int
 118 ldap_pvt_thread_mutex_destroy( ldap_pvt_thread_mutex_t *mutex )
 119 {
 120         CloseHandle( *mutex );
 121         return ( 0 );
 122 }
 123
 124 int
 125 ldap_pvt_thread_mutex_lock( ldap_pvt_thread_mutex_t *mutex )
 126 {
 127         WaitForSingleObject( *mutex, INFINITE );
 128         return ( 0 );
 129 }
 130
 131 int
 132 ldap_pvt_thread_mutex_unlock( ldap_pvt_thread_mutex_t *mutex )
 133 {
 134         ReleaseMutex( *mutex );
 135         return ( 0 );
 136 }
 137
 138 int
 139 ldap_pvt_thread_mutex_trylock( ldap_pvt_thread_mutex_t *mp )
 140 {
 141         DWORD status;
 142
 143         status = WaitForSingleObject( *mp, 0 );
 144         if ( (status == WAIT_FAILED) || (status == WAIT_TIMEOUT) )
 145                 return 0;
 146         else
 147                 return 1;
 148 }
 149
 150 #endif