contrib/ntp/lib/isc/win32/thread.c

   1 /*
   2  * Copyright (C) 2004, 2005, 2007  Internet Systems Consortium, Inc. ("ISC")
   3  * Copyright (C) 1998-2001  Internet Software Consortium.
   4  *
   5  * Permission to use, copy, modify, and/or distribute this software for any
   6  * purpose with or without fee is hereby granted, provided that the above
   7  * copyright notice and this permission notice appear in all copies.
   8  *
   9  * THE SOFTWARE IS PROVIDED "AS IS" AND ISC DISCLAIMS ALL WARRANTIES WITH
  10  * REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
  11  * AND FITNESS.  IN NO EVENT SHALL ISC BE LIABLE FOR ANY SPECIAL, DIRECT,
  12  * INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
  13  * LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
  14  * OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
  15  * PERFORMANCE OF THIS SOFTWARE.
  16  */
  17
  18 /* $Id: thread.c,v 1.24 2007/06/19 23:47:19 tbox Exp $ */
  19
  20 #include <config.h>
  21
  22 #include <process.h>
  23
  24 #include <isc/thread.h>
  25
  26 isc_result_t
  27 isc_thread_create(isc_threadfunc_t start, isc_threadarg_t arg,
  28                   isc_thread_t *threadp)
  29 {
  30         isc_thread_t thread;
  31         unsigned int id;
  32
  33         thread = (isc_thread_t)_beginthreadex(NULL, 0, start, arg, 0, &id);
  34         if (thread == NULL) {
  35                 /* XXX */
  36                 return (ISC_R_UNEXPECTED);
  37         }
  38
  39         *threadp = thread;
  40
  41         return (ISC_R_SUCCESS);
  42 }
  43
  44 isc_result_t
  45 isc_thread_join(isc_thread_t thread, isc_threadresult_t *rp) {
  46         DWORD result;
  47         DWORD threadrc;
  48
  49         result = WaitForSingleObject(thread, INFINITE);
  50         if (result != WAIT_OBJECT_0) {
  51                 /* XXX */
  52                 return (ISC_R_UNEXPECTED);
  53         }
  54         if (rp != NULL) {
  55                 if(!GetExitCodeThread(thread, &threadrc)) {
  56                         /* XXX */
  57                         return (ISC_R_UNEXPECTED);
  58                 }
  59                 *rp = threadrc;
  60         }
  61         (void)CloseHandle(thread);
  62
  63         return (ISC_R_SUCCESS);
  64 }
  65
  66 void
  67 isc_thread_setconcurrency(unsigned int level) {
  68         /*
  69          * This is unnecessary on Win32 systems, but is here so that the
  70          * call exists
  71          */
  72 }
  73
  74 void *
  75 isc_thread_key_getspecific(isc_thread_key_t key) {
  76         return(TlsGetValue(key));
  77 }
  78
  79 int
  80 isc_thread_key_setspecific(isc_thread_key_t key, void *value) {
  81         return (TlsSetValue(key, value) ? 0 : GetLastError());
  82 }
  83
  84 int
  85 isc_thread_key_create(isc_thread_key_t *key, void (*func)(void *)) {
  86         *key = TlsAlloc();
  87
  88         return ((*key != -1) ? 0 : GetLastError());
  89 }
  90
  91 int
  92 isc_thread_key_delete(isc_thread_key_t key) {
  93         return (TlsFree(key) ? 0 : GetLastError());
  94 }