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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
|
/*-
* Copyright (c) 2014-2016 MongoDB, Inc.
* Copyright (c) 2008-2014 WiredTiger, Inc.
* All rights reserved.
*
* See the file LICENSE for redistribution information.
*/
#define WT_SYSCALL_RETRY(call, ret) do { \
int __retry; \
for (__retry = 0; __retry < 10; ++__retry) { \
if ((call) == 0) { \
(ret) = 0; \
break; \
} \
switch ((ret) = __wt_errno()) { \
case 0: \
/* The call failed but didn't set errno. */ \
(ret) = WT_ERROR; \
break; \
case EAGAIN: \
case EBUSY: \
case EINTR: \
case EIO: \
case EMFILE: \
case ENFILE: \
case ENOSPC: \
__wt_sleep(0L, 50000L); \
continue; \
default: \
break; \
} \
break; \
} \
} while (0)
#define WT_TIMEDIFF_NS(end, begin) \
(WT_BILLION * (uint64_t)((end).tv_sec - (begin).tv_sec) + \
(uint64_t)(end).tv_nsec - (uint64_t)(begin).tv_nsec)
#define WT_TIMEDIFF_US(end, begin) \
(WT_TIMEDIFF_NS((end), (begin)) / WT_THOUSAND)
#define WT_TIMEDIFF_MS(end, begin) \
(WT_TIMEDIFF_NS((end), (begin)) / WT_MILLION)
#define WT_TIMEDIFF_SEC(end, begin) \
(WT_TIMEDIFF_NS((end), (begin)) / WT_BILLION)
#define WT_TIMECMP(t1, t2) \
((t1).tv_sec < (t2).tv_sec ? -1 : \
(t1).tv_sec == (t2.tv_sec) ? \
(t1).tv_nsec < (t2).tv_nsec ? -1 : \
(t1).tv_nsec == (t2).tv_nsec ? 0 : 1 : 1)
/*
* Macros to ensure a file handle is inserted or removed from both the main and
* the hashed queue, used by connection-level and in-memory data structures.
*/
#define WT_FILE_HANDLE_INSERT(h, fh, bucket) do { \
TAILQ_INSERT_HEAD(&(h)->fhqh, fh, q); \
TAILQ_INSERT_HEAD(&(h)->fhhash[bucket], fh, hashq); \
} while (0)
#define WT_FILE_HANDLE_REMOVE(h, fh, bucket) do { \
TAILQ_REMOVE(&(h)->fhqh, fh, q); \
TAILQ_REMOVE(&(h)->fhhash[bucket], fh, hashq); \
} while (0)
struct __wt_fh {
/*
* There is a file name field in both the WT_FH and WT_FILE_HANDLE
* structures, which isn't ideal. There would be compromises to keeping
* a single copy: If it were in WT_FH, file systems could not access
* the name field, if it were just in the WT_FILE_HANDLE internal
* WiredTiger code would need to maintain a string inside a structure
* that is owned by the user (since we care about the content of the
* file name). Keeping two copies seems most reasonable.
*/
const char *name; /* File name */
uint64_t name_hash; /* hash of name */
TAILQ_ENTRY(__wt_fh) q; /* internal queue */
TAILQ_ENTRY(__wt_fh) hashq; /* internal hash queue */
u_int ref; /* reference count */
WT_FILE_HANDLE *handle;
};
#ifdef _WIN32
struct __wt_file_handle_win {
WT_FILE_HANDLE iface;
/*
* Windows specific file handle fields
*/
HANDLE filehandle; /* Windows file handle */
HANDLE filehandle_secondary; /* Windows file handle
for file size changes */
bool direct_io; /* O_DIRECT configured */
};
#else
struct __wt_file_handle_posix {
WT_FILE_HANDLE iface;
/*
* POSIX specific file handle fields
*/
int fd; /* POSIX file handle */
bool direct_io; /* O_DIRECT configured */
};
#endif
struct __wt_file_handle_inmem {
WT_FILE_HANDLE iface;
/*
* In memory specific file handle fields
*/
uint64_t name_hash; /* hash of name */
TAILQ_ENTRY(__wt_file_handle_inmem) q; /* internal queue, hash queue */
TAILQ_ENTRY(__wt_file_handle_inmem) hashq;
size_t off; /* Read/write offset */
WT_ITEM buf; /* Data */
u_int ref; /* Reference count */
};
struct __wt_fstream {
const char *name; /* Stream name */
FILE *fp; /* stdio FILE stream */
WT_FH *fh; /* WT file handle */
wt_off_t off; /* Read/write offset */
wt_off_t size; /* File size */
WT_ITEM buf; /* Data */
#define WT_STREAM_APPEND 0x01 /* Open a stream for append */
#define WT_STREAM_READ 0x02 /* Open a stream for read */
#define WT_STREAM_WRITE 0x04 /* Open a stream for write */
uint32_t flags;
int (*close)(WT_SESSION_IMPL *, WT_FSTREAM *);
int (*fstr_flush)(WT_SESSION_IMPL *, WT_FSTREAM *);
int (*fstr_getline)(WT_SESSION_IMPL *, WT_FSTREAM *, WT_ITEM *);
int (*fstr_printf)(
WT_SESSION_IMPL *, WT_FSTREAM *, const char *, va_list);
};
|
