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
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 1998-2002
* Sleepycat Software. All rights reserved.
*/
#include "db_config.h"
#ifndef lint
static const char revid[] = "$Id: os_handle.c,v 1.1.1.1 2003/11/20 22:13:37 toshok Exp $";
#endif /* not lint */
#ifndef NO_SYSTEM_INCLUDES
#include <sys/types.h>
#include <fcntl.h>
#include <string.h>
#include <unistd.h>
#endif
#include "db_int.h"
/*
* __os_openhandle --
* Open a file, using POSIX 1003.1 open flags.
*
* PUBLIC: int __os_openhandle __P((DB_ENV *, const char *, int, int, DB_FH *));
*/
int
__os_openhandle(dbenv, name, flags, mode, fhp)
DB_ENV *dbenv;
const char *name;
int flags, mode;
DB_FH *fhp;
{
int ret, nrepeat;
#ifdef HAVE_VXWORKS
int newflags;
#endif
memset(fhp, 0, sizeof(*fhp));
/* If the application specified an interface, use it. */
if (DB_GLOBAL(j_open) != NULL) {
if ((fhp->fd = DB_GLOBAL(j_open)(name, flags, mode)) == -1)
return (__os_get_errno());
F_SET(fhp, DB_FH_VALID);
return (0);
}
for (nrepeat = 1; nrepeat < 4; ++nrepeat) {
ret = 0;
#ifdef HAVE_VXWORKS
/*
* VxWorks does not support O_CREAT on open, you have to use
* creat() instead. (It does not support O_EXCL or O_TRUNC
* either, even though they are defined "for future support".)
* We really want the POSIX behavior that if O_CREAT is set,
* we open if it exists, or create it if it doesn't exist.
* If O_CREAT is specified, single thread and try to open the
* file. If successful, and O_EXCL return EEXIST. If
* unsuccessful call creat and then end single threading.
*/
if (LF_ISSET(O_CREAT)) {
DB_BEGIN_SINGLE_THREAD;
newflags = flags & ~(O_CREAT | O_EXCL);
if ((fhp->fd =
open(name, newflags, mode)) != -1) {
if (LF_ISSET(O_EXCL)) {
/*
* If we get here, we want O_EXCL
* create, and it exists. Close and
* return EEXISTS.
*/
(void)close(fhp->fd);
DB_END_SINGLE_THREAD;
return (EEXIST);
}
/*
* XXX
* Assume any error means non-existence.
* Unfortunately return values (even for
* non-existence) are driver specific so
* there is no single error we can use to
* verify we truly got the equivalent of
* ENOENT.
*/
} else
fhp->fd = creat(name, newflags);
DB_END_SINGLE_THREAD;
} else
/* FALLTHROUGH */
#endif
#ifdef __VMS
/*
* !!!
* Open with full sharing on VMS.
*
* We use these flags because they are the ones set by the VMS
* CRTL mmap() call when it opens a file, and we have to be
* able to open files that mmap() has previously opened, e.g.,
* when we're joining already existing DB regions.
*/
fhp->fd = open(name, flags, mode, "shr=get,put,upd,del,upi");
#else
fhp->fd = open(name, flags, mode);
#endif
if (fhp->fd == -1) {
/*
* If it's a "temporary" error, we retry up to 3 times,
* waiting up to 12 seconds. While it's not a problem
* if we can't open a database, an inability to open a
* log file is cause for serious dismay.
*/
ret = __os_get_errno();
if (ret == ENFILE || ret == EMFILE || ret == ENOSPC) {
(void)__os_sleep(dbenv, nrepeat * 2, 0);
continue;
}
/*
* If it was an EINTR it's reasonable to retry
* immediately, and arbitrarily often.
*/
if (ret == EINTR) {
--nrepeat;
continue;
}
} else {
#if defined(HAVE_FCNTL_F_SETFD)
/* Deny file descriptor access to any child process. */
if (fcntl(fhp->fd, F_SETFD, 1) == -1) {
ret = __os_get_errno();
__db_err(dbenv, "fcntl(F_SETFD): %s",
strerror(ret));
(void)__os_closehandle(dbenv, fhp);
} else
#endif
F_SET(fhp, DB_FH_VALID);
}
break;
}
return (ret);
}
/*
* __os_closehandle --
* Close a file.
*
* PUBLIC: int __os_closehandle __P((DB_ENV *, DB_FH *));
*/
int
__os_closehandle(dbenv, fhp)
DB_ENV *dbenv;
DB_FH *fhp;
{
int ret;
/* Don't close file descriptors that were never opened. */
DB_ASSERT(F_ISSET(fhp, DB_FH_VALID) && fhp->fd != -1);
do {
ret = DB_GLOBAL(j_close) != NULL ?
DB_GLOBAL(j_close)(fhp->fd) : close(fhp->fd);
} while (ret != 0 && (ret = __os_get_errno()) == EINTR);
/* Unlink the file if we haven't already done so. */
if (F_ISSET(fhp, DB_FH_UNLINK)) {
(void)__os_unlink(dbenv, fhp->name);
(void)__os_free(dbenv, fhp->name);
}
/*
* Smash the POSIX file descriptor -- it's never tested, but we want
* to catch any mistakes.
*/
fhp->fd = -1;
F_CLR(fhp, DB_FH_VALID);
return (ret);
}
|
