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

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