1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
/*-
* Copyright (c) 2014-2019 MongoDB, Inc.
* Copyright (c) 2008-2014 WiredTiger, Inc.
* All rights reserved.
*
* See the file LICENSE for redistribution information.
*/
#include "wt_internal.h"
/*
* __wt_thread_create --
* Create a new thread of control.
*/
int
__wt_thread_create(
WT_SESSION_IMPL *session, wt_thread_t *tidret, WT_THREAD_CALLBACK (*func)(void *), void *arg)
{
/*
* Creating a thread isn't a memory barrier, but WiredTiger commonly sets flags and or state and
* then expects worker threads to start. Include a barrier to ensure safety in those cases.
*/
WT_FULL_BARRIER();
/* Spawn a new thread of control. */
tidret->id = (HANDLE)_beginthreadex(NULL, 0, func, arg, 0, NULL);
if (tidret->id != 0) {
tidret->created = true;
return (0);
}
WT_RET_MSG(session, __wt_errno(), "thread create: _beginthreadex");
}
/*
* __wt_thread_join --
* Wait for a thread of control to exit.
*/
int
__wt_thread_join(WT_SESSION_IMPL *session, wt_thread_t *tid)
{
WT_DECL_RET;
DWORD windows_error;
/* Only attempt to join if thread was created successfully */
if (!tid->created)
return (0);
tid->created = false;
/*
* Joining a thread isn't a memory barrier, but WiredTiger commonly sets flags and or state and
* then expects worker threads to halt. Include a barrier to ensure safety in those cases.
*/
WT_FULL_BARRIER();
if ((windows_error = WaitForSingleObject(tid->id, INFINITE)) != WAIT_OBJECT_0) {
if (windows_error == WAIT_FAILED)
windows_error = __wt_getlasterror();
__wt_err(session, __wt_map_windows_error(windows_error),
"thread join: WaitForSingleObject: %s", __wt_formatmessage(session, windows_error));
/* If we fail to wait, we will leak handles, do not continue. */
return (WT_PANIC);
}
if (CloseHandle(tid->id) == 0) {
windows_error = __wt_getlasterror();
ret = __wt_map_windows_error(windows_error);
__wt_err(
session, ret, "thread join: CloseHandle: %s", __wt_formatmessage(session, windows_error));
return (ret);
}
return (0);
}
/*
* __wt_thread_id --
* Return an arithmetic representation of a thread ID on POSIX.
*/
void
__wt_thread_id(uintmax_t *id)
{
*id = (uintmax_t)GetCurrentThreadId();
}
/*
* __wt_thread_str --
* Fill in a printable version of the process and thread IDs.
*/
int
__wt_thread_str(char *buf, size_t buflen)
{
return (__wt_snprintf(buf, buflen, "%" PRIu64 ":%" PRIu64, (uint64_t)GetCurrentProcessId(),
(uint64_t)GetCurrentThreadId));
}
/*
* __wt_process_id --
* Return the process ID assigned by the operating system.
*/
uintmax_t
__wt_process_id(void)
{
return (uintmax_t)GetCurrentProcessId();
}
|
