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
|
/*-
* 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 */
/*
* __system_is_little_endian --
* Check if the system is little endian.
*/
static int
__system_is_little_endian(void)
{
uint64_t v;
int little;
v = 1;
little = *((uint8_t *)&v) == 0 ? 0 : 1;
if (little)
return (0);
fprintf(stderr,
"This release of the WiredTiger data engine does not support "
"big-endian systems; contact WiredTiger for more information.\n");
return (EINVAL);
}
/*
* __wt_global_once --
* Global initialization, run once.
*/
static void
__wt_global_once(void)
{
WT_DECL_RET;
if ((ret = __system_is_little_endian()) != 0) {
__wt_pthread_once_failed = ret;
return;
}
if ((ret =
__wt_spin_init(NULL, &__wt_process.spinlock, "global")) != 0) {
__wt_pthread_once_failed = ret;
return;
}
__wt_cksum_init();
TAILQ_INIT(&__wt_process.connqh);
#ifdef HAVE_DIAGNOSTIC
/* Verify the pre-computed metadata hash. */
WT_ASSERT(NULL, WT_METAFILE_NAME_HASH ==
__wt_hash_city64(WT_METAFILE_URI, strlen(WT_METAFILE_URI)));
/* Load debugging code the compiler might optimize out. */
(void)__wt_breakpoint();
#endif
}
/*
* __wt_library_init --
* Some things to do, before we do anything else.
*/
int
__wt_library_init(void)
{
static int first = 1;
WT_DECL_RET;
/*
* 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 = 0;
}
return (__wt_pthread_once_failed);
}
#ifdef HAVE_DIAGNOSTIC
/*
* __wt_breakpoint --
* A simple place to put a breakpoint, if you need one.
*/
int
__wt_breakpoint(void)
{
return (0);
}
/*
* __wt_attach --
* A routine to wait for the debugging to attach.
*/
void
__wt_attach(WT_SESSION_IMPL *session)
{
#ifdef HAVE_ATTACH
__wt_errx(session, "process ID %" PRIdMAX
": waiting for debugger...", (intmax_t)getpid());
/* Sleep forever, the debugger will interrupt us when it attaches. */
for (;;)
__wt_sleep(100, 0);
#else
WT_UNUSED(session);
#endif
}
#endif
|
