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
149
150
151
|
/*-
* Copyright (c) 2014-2016 MongoDB, Inc.
* Copyright (c) 2008-2014 WiredTiger, Inc.
* All rights reserved.
*
* See the file LICENSE for redistribution information.
*/
/*
* Number of directory entries can grow dynamically.
*/
#define WT_DIR_ENTRY 32
#define WT_DIRLIST_EXCLUDE 0x1 /* Exclude files matching prefix */
#define WT_DIRLIST_INCLUDE 0x2 /* Include files matching prefix */
#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)
/*
* The underlying OS calls return ENOTSUP if posix_fadvise functionality isn't
* available, but WiredTiger uses the POSIX flag names in the API. Use distinct
* values so the underlying code can distinguish.
*/
#ifndef POSIX_FADV_DONTNEED
#define POSIX_FADV_DONTNEED 0x01
#endif
#ifndef POSIX_FADV_WILLNEED
#define POSIX_FADV_WILLNEED 0x02
#endif
#define WT_OPEN_CREATE 0x001 /* Create */
#define WT_OPEN_DIRECTIO 0x002 /* Direct I/O (if available) */
#define WT_OPEN_EXCLUSIVE 0x004 /* Open exclusively */
#define WT_OPEN_FIXED 0x008 /* Path isn't relative to home */
#define WT_OPEN_READONLY 0x010 /* Open readonly (internal) */
struct __wt_fh {
const char *name; /* File name */
uint64_t name_hash; /* Hash of name */
TAILQ_ENTRY(__wt_fh) q; /* List of open handles */
TAILQ_ENTRY(__wt_fh) hashq; /* Hashed list of handles */
u_int ref; /* Reference count */
/*
* Underlying file system handle support.
*/
#ifdef _WIN32
HANDLE filehandle; /* Windows file handle */
HANDLE filehandle_secondary; /* Windows file handle
for file size changes */
#else
int fd; /* POSIX file handle */
#endif
/* In-memory specific fields. */
size_t off; /* Read/write offset */
WT_ITEM buf; /* Data */
bool direct_io; /* O_DIRECT configured */
enum { /* file extend configuration */
WT_FALLOCATE_AVAILABLE,
WT_FALLOCATE_NOT_AVAILABLE,
WT_FALLOCATE_POSIX,
WT_FALLOCATE_STD,
WT_FALLOCATE_SYS } fallocate_available;
bool fallocate_requires_locking;
#define WT_FH_IN_MEMORY 0x01 /* In-memory, don't remove */
uint32_t flags;
int (*fh_advise)(WT_SESSION_IMPL *, WT_FH *, wt_off_t, wt_off_t, int);
int (*fh_allocate)(WT_SESSION_IMPL *, WT_FH *, wt_off_t, wt_off_t);
int (*fh_close)(WT_SESSION_IMPL *, WT_FH *);
int (*fh_lock)(WT_SESSION_IMPL *, WT_FH *, bool);
int (*fh_map)(WT_SESSION_IMPL *, WT_FH *, void *, size_t *, void **);
int (*fh_map_discard)(WT_SESSION_IMPL *, WT_FH *, void *, size_t);
int (*fh_map_preload)(WT_SESSION_IMPL *, WT_FH *, const void *, size_t);
int (*fh_map_unmap)(
WT_SESSION_IMPL *, WT_FH *, void *, size_t, void **);
int (*fh_read)(WT_SESSION_IMPL *, WT_FH *, wt_off_t, size_t, void *);
int (*fh_size)(WT_SESSION_IMPL *, WT_FH *, wt_off_t *);
int (*fh_sync)(WT_SESSION_IMPL *, WT_FH *, bool);
int (*fh_truncate)(WT_SESSION_IMPL *, WT_FH *, wt_off_t);
int (*fh_write)(
WT_SESSION_IMPL *, WT_FH *, wt_off_t, size_t, const void *);
};
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_LINE_BUFFER 0x02 /* Line buffer the stream */
#define WT_STREAM_READ 0x04 /* Open a stream for read */
#define WT_STREAM_WRITE 0x08 /* Open a stream for write */
uint32_t flags;
int (*close)(WT_SESSION_IMPL *, WT_FSTREAM *);
int (*flush)(WT_SESSION_IMPL *, WT_FSTREAM *);
int (*getline)(WT_SESSION_IMPL *, WT_FSTREAM *, WT_ITEM *);
int (*printf)(WT_SESSION_IMPL *, WT_FSTREAM *, const char *, va_list);
};
|
