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
|
/*-
* Copyright (c) 2014-2015 MongoDB, Inc.
* Copyright (c) 2008-2014 WiredTiger, Inc.
* All rights reserved.
*
* See the file LICENSE for redistribution information.
*/
#include "wt_internal.h"
/*
* __wt_filename --
* Build a file name in a scratch buffer, automatically calculate the
* length of the file name.
*/
int
__wt_filename(WT_SESSION_IMPL *session, const char *name, char **path)
{
return (__wt_nfilename(session, name, strlen(name), path));
}
/*
* __wt_nfilename --
* Build a file name in a scratch buffer. If the name is already an
* absolute path duplicate it, otherwise generate a path relative to the
* connection home directory.
*/
int
__wt_nfilename(
WT_SESSION_IMPL *session, const char *name, size_t namelen, char **path)
{
WT_CONNECTION_IMPL *conn;
size_t len;
char *buf;
conn = S2C(session);
*path = NULL;
if (__wt_absolute_path(name))
WT_RET(__wt_strndup(session, name, namelen, path));
else {
len = strlen(conn->home) + 1 + namelen + 1;
WT_RET(__wt_calloc(session, 1, len, &buf));
snprintf(buf, len, "%s%s%.*s",
conn->home, __wt_path_separator(), (int)namelen, name);
*path = buf;
}
return (0);
}
/*
* __wt_remove_if_exists --
* Remove a file if it exists.
*/
int
__wt_remove_if_exists(WT_SESSION_IMPL *session, const char *name)
{
bool exist;
WT_RET(__wt_exist(session, name, &exist));
if (exist)
WT_RET(__wt_remove(session, name));
return (0);
}
/*
* __wt_sync_and_rename_fh --
* Sync and close a file, and swap it into place.
*/
int
__wt_sync_and_rename_fh(
WT_SESSION_IMPL *session, WT_FH **fhp, const char *from, const char *to)
{
WT_DECL_RET;
WT_FH *fh;
fh = *fhp;
*fhp = NULL;
/* Flush to disk and close the handle. */
ret = __wt_fsync(session, fh);
WT_TRET(__wt_close(session, &fh));
WT_RET(ret);
/* Rename the source file to the target. */
WT_RET(__wt_rename(session, from, to));
/* Flush the backing directory to guarantee the rename. */
return (__wt_directory_sync(session, NULL));
}
/*
* __wt_sync_and_rename_fp --
* Sync and close a file, and swap it into place.
*/
int
__wt_sync_and_rename_fp(
WT_SESSION_IMPL *session, FILE **fpp, const char *from, const char *to)
{
FILE *fp;
fp = *fpp;
*fpp = NULL;
/* Flush to disk and close the handle. */
WT_RET(__wt_fclose(session, &fp, WT_FHANDLE_WRITE));
/* Rename the source file to the target. */
WT_RET(__wt_rename(session, from, to));
/* Flush the backing directory to guarantee the rename. */
return (__wt_directory_sync(session, NULL));
}
|
