/* $NetBSD: thr_nt.c,v 1.1.1.6.6.1 2019/08/10 06:17:15 martin Exp $ */ /* thr_nt.c - wrapper around NT threads */ /* $OpenLDAP$ */ /* This work is part of OpenLDAP Software . * * Copyright 1998-2019 The OpenLDAP Foundation. * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted only as authorized by the OpenLDAP * Public License. * * A copy of this license is available in file LICENSE in the * top-level directory of the distribution or, alternatively, at * . */ #include __RCSID("$NetBSD: thr_nt.c,v 1.1.1.6.6.1 2019/08/10 06:17:15 martin Exp $"); #include "portable.h" #if defined( HAVE_NT_THREADS ) #define _WIN32_WINNT 0x0400 #include #include #include "ldap_pvt_thread.h" /* Get the thread interface */ #define LDAP_THREAD_IMPLEMENTATION #include "ldap_thr_debug.h" /* May rename the symbols defined below */ typedef struct ldap_int_thread_s { long tid; HANDLE thd; } ldap_int_thread_s; #ifndef NT_MAX_THREADS #define NT_MAX_THREADS 1024 #endif static ldap_int_thread_s tids[NT_MAX_THREADS]; static int ntids; /* mingw compiler very sensitive about getting prototypes right */ typedef unsigned __stdcall thrfunc_t(void *); int ldap_int_thread_initialize( void ) { return 0; } int ldap_int_thread_destroy( void ) { return 0; } int ldap_pvt_thread_create( ldap_pvt_thread_t * thread, int detach, void *(*start_routine)( void *), void *arg) { unsigned tid; HANDLE thd; int rc = -1; thd = (HANDLE) _beginthreadex(NULL, LDAP_PVT_THREAD_STACK_SIZE, (thrfunc_t *) start_routine, arg, 0, &tid); if ( thd ) { *thread = (ldap_pvt_thread_t) tid; tids[ntids].tid = tid; tids[ntids].thd = thd; ntids++; rc = 0; } return rc; } void ldap_pvt_thread_exit( void *retval ) { _endthread( ); } int ldap_pvt_thread_join( ldap_pvt_thread_t thread, void **thread_return ) { DWORD status; int i; for (i=0; i ntids ) return -1; status = WaitForSingleObject( tids[i].thd, INFINITE ); for (; i