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
|
/*-
* Copyright (c) 2014-2017 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)
WT_GCC_FUNC_ATTRIBUTE((visibility("default")))
{
WT_DECL_RET;
/*
* 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. */
WT_SYSCALL_RETRY(pthread_create(&tidret->id, NULL, func, arg), ret);
if (ret == 0) {
tidret->created = true;
return (0);
}
WT_RET_MSG(session, ret, "pthread_create");
}
/*
* __wt_thread_join --
* Wait for a thread of control to exit.
*/
int
__wt_thread_join(WT_SESSION_IMPL *session, wt_thread_t tid)
WT_GCC_FUNC_ATTRIBUTE((visibility("default")))
{
WT_DECL_RET;
/* Only attempt to join if thread was created successfully */
if (!tid.created)
return (0);
/*
* 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();
WT_SYSCALL(pthread_join(tid.id, NULL), ret);
if (ret == 0) {
tid.created = false;
return (0);
}
WT_RET_MSG(session, ret, "pthread_join");
}
/*
* __wt_thread_id --
* Fill in a printable version of the process and thread IDs.
*/
int
__wt_thread_id(char *buf, size_t buflen)
WT_GCC_FUNC_ATTRIBUTE((visibility("default")))
{
pthread_t self;
/*
* POSIX 1003.1 allows pthread_t to be an opaque type; on systems where
* it's a pointer, print the pointer to match gdb output.
*/
self = pthread_self();
#ifdef __sun
return (__wt_snprintf(buf, buflen,
"%" PRIuMAX ":%u", (uintmax_t)getpid(), self));
#else
return (__wt_snprintf(buf, buflen,
"%" PRIuMAX ":%p", (uintmax_t)getpid(), (void *)self));
#endif
}
|
