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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
/*-
* Copyright (c) 2014-2016 MongoDB, Inc.
* Copyright (c) 2008-2014 WiredTiger, Inc.
* All rights reserved.
*
* See the file LICENSE for redistribution information.
*/
#include "wt_internal.h"
WT_PROCESS __wt_process; /* Per-process structure */
static int __wt_pthread_once_failed; /* If initialization failed */
/*
* __wt_endian_check --
* Check the build matches the machine.
*/
static int
__wt_endian_check(void)
{
uint64_t v;
bool big;
const char *e;
v = 1;
big = *((uint8_t *)&v) == 0;
#ifdef WORDS_BIGENDIAN
if (big)
return (0);
e = "big-endian";
#else
if (!big)
return (0);
e = "little-endian";
#endif
fprintf(stderr,
"This is a %s build of the WiredTiger data engine, incompatible "
"with this system\n", e);
return (EINVAL);
}
/*
* __wt_global_once --
* Global initialization, run once.
*/
static void
__wt_global_once(void)
{
WT_DECL_RET;
if ((ret =
__wt_spin_init(NULL, &__wt_process.spinlock, "global")) != 0) {
__wt_pthread_once_failed = ret;
return;
}
__wt_checksum_init();
TAILQ_INIT(&__wt_process.connqh);
#ifdef HAVE_DIAGNOSTIC
/* Load debugging code the compiler might optimize out. */
__wt_breakpoint();
#endif
}
/*
* __wt_library_init --
* Some things to do, before we do anything else.
*/
int
__wt_library_init(void)
{
static bool first = true;
WT_DECL_RET;
/* Check the build matches the machine. */
WT_RET(__wt_endian_check());
/*
* Do per-process initialization once, before anything else, but only
* once. I don't know how heavy-weight the function (pthread_once, in
* the POSIX world), might be, so I'm front-ending it with a local
* static and only using that function to avoid a race.
*/
if (first) {
if ((ret = __wt_once(__wt_global_once)) != 0)
__wt_pthread_once_failed = ret;
first = false;
}
return (__wt_pthread_once_failed);
}
#ifdef HAVE_DIAGNOSTIC
/*
* __wt_breakpoint --
* A simple place to put a breakpoint, if you need one.
*/
void
__wt_breakpoint(void)
{
/*
* Yield the processor (just to keep the compiler from optimizing the
* function out).
*/
__wt_yield();
}
/*
* __wt_attach --
* A routine to wait for the debugging to attach.
*/
void
__wt_attach(WT_SESSION_IMPL *session)
{
#ifdef HAVE_ATTACH
u_int i;
__wt_errx(session, "process ID %" PRIdMAX
": waiting for debugger...", (intmax_t)getpid());
/* Sleep forever, the debugger will interrupt us when it attaches. */
for (i = 0; i < WT_MILLION; ++i)
__wt_sleep(10, 0);
#else
WT_UNUSED(session);
#endif
}
#endif
|
