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 #include "ldap_pvt_thread.h"
  15
  16 #if defined( HAVE_NT_THREADS )
  17
  18 int
  19 ldap_pvt_thread_initialize( void )
  20 {
  21         return 0;
  22 }
  23
  24 int
  25 ldap_pvt_thread_destroy( void )
  26 {
  27         return 0;
  28 }
  29
  30 int
  31 ldap_pvt_thread_create( ldap_pvt_thread_t * thread,
  32         int detach,
  33         void *(*start_routine)( void *),
  34         void *arg)
  35 {
  36         *thread = (ldap_pvt_thread_t)_beginthread( (void *) start_routine,
  37                                                 0, arg );
  38          return ( (unsigned long)*thread == -1 ? -1 : 0 );
  39 }
  40
  41 void
  42 ldap_pvt_thread_exit( void *retval )
  43 {
  44         _endthread( );
  45 }
  46
  47 int
  48 ldap_pvt_thread_join( ldap_pvt_thread_t thread, void **thread_return )
  49 {
  50         DWORD status;
  51         status = WaitForSingleObject( (HANDLE) thread, INFINITE );
  52         if (status == WAIT_FAILED) {
  53                 return -1;
  54         }
  55         return 0;
  56 }
  57
  58 int
  59 ldap_pvt_thread_kill( ldap_pvt_thread_t thread, int signo )
  60 {
  61         return 0;
  62 }
  63
  64 int
  65 ldap_pvt_thread_yield( void )
  66 {
  67         return 0;
  68 }
  69
  70 int
  71 ldap_pvt_thread_cond_init( ldap_pvt_thread_cond_t *cond )
  72 {
  73         *cond = CreateEvent( NULL, FALSE, FALSE, NULL );
  74         return( 0 );
  75 }
  76
  77 int
  78 ldap_pvt_thread_cond_destroy( ldap_pvt_thread_cond_t *cv )
  79 {
  80         CloseHandle( *cv );
  81         return( 0 );
  82 }
  83
  84 int
  85 ldap_pvt_thread_cond_signal( ldap_pvt_thread_cond_t *cond )
  86 {
  87         SetEvent( *cond );
  88         return( 0 );
  89 }
  90
  91 int
  92 ldap_pvt_thread_cond_wait( ldap_pvt_thread_cond_t *cond,
  93                           ldap_pvt_thread_mutex_t *mutex )
  94 {
  95         ReleaseMutex( *mutex );
  96         WaitForSingleObject( *cond, INFINITE );
  97         WaitForSingleObject( *mutex, INFINITE );
  98         return( 0 );
  99 }
 100
 101 int
 102 ldap_pvt_thread_cond_broadcast( ldap_pvt_thread_cond_t *cv )
 103 {
 104         SetEvent( *cv );
 105         return( 0 );
 106 }
 107
 108 int
 109 ldap_pvt_thread_mutex_init( ldap_pvt_thread_mutex_t *mutex )
 110 {
 111         *mutex = CreateMutex( NULL, 0, NULL );
 112         return ( 0 );
 113 }
 114
 115 int
 116 ldap_pvt_thread_mutex_destroy( ldap_pvt_thread_mutex_t *mutex )
 117 {
 118         CloseHandle( *mutex );
 119         return ( 0 );
 120 }
 121
 122 int
 123 ldap_pvt_thread_mutex_lock( ldap_pvt_thread_mutex_t *mutex )
 124 {
 125         WaitForSingleObject( *mutex, INFINITE );
 126         return ( 0 );
 127 }
 128
 129 int
 130 ldap_pvt_thread_mutex_unlock( ldap_pvt_thread_mutex_t *mutex )
 131 {
 132         ReleaseMutex( *mutex );
 133         return ( 0 );
 134 }
 135
 136 int
 137 ldap_pvt_thread_mutex_trylock( ldap_pvt_thread_mutex_t *mp )
 138 {
 139         DWORD status;
 140
 141         status = WaitForSingleObject( *mp, 0 );
 142         if ( (status == WAIT_FAILED) || (status == WAIT_TIMEOUT) )
 143                 return 0;
 144         else
 145                 return 1;
 146 }
 147
 148 #endif