1 | /*
|
---|
2 | Unix SMB/CIFS implementation.
|
---|
3 |
|
---|
4 | trivial database library
|
---|
5 |
|
---|
6 | Copyright (C) Andrew Tridgell 1999-2005
|
---|
7 | Copyright (C) Paul `Rusty' Russell 2000
|
---|
8 | Copyright (C) Jeremy Allison 2000-2003
|
---|
9 |
|
---|
10 | ** NOTE! The following LGPL license applies to the tdb
|
---|
11 | ** library. This does NOT imply that all of Samba is released
|
---|
12 | ** under the LGPL
|
---|
13 |
|
---|
14 | This library is free software; you can redistribute it and/or
|
---|
15 | modify it under the terms of the GNU Lesser General Public
|
---|
16 | License as published by the Free Software Foundation; either
|
---|
17 | version 3 of the License, or (at your option) any later version.
|
---|
18 |
|
---|
19 | This library is distributed in the hope that it will be useful,
|
---|
20 | but WITHOUT ANY WARRANTY; without even the implied warranty of
|
---|
21 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
---|
22 | Lesser General Public License for more details.
|
---|
23 |
|
---|
24 | You should have received a copy of the GNU Lesser General Public
|
---|
25 | License along with this library; if not, see <http://www.gnu.org/licenses/>.
|
---|
26 | */
|
---|
27 |
|
---|
28 | #include "tdb_private.h"
|
---|
29 |
|
---|
30 | /* all contexts, to ensure no double-opens (fcntl locks don't nest!) */
|
---|
31 | static struct tdb_context *tdbs = NULL;
|
---|
32 |
|
---|
33 |
|
---|
34 | /* This is based on the hash algorithm from gdbm */
|
---|
35 | static unsigned int default_tdb_hash(TDB_DATA *key)
|
---|
36 | {
|
---|
37 | uint32_t value; /* Used to compute the hash value. */
|
---|
38 | uint32_t i; /* Used to cycle through random values. */
|
---|
39 |
|
---|
40 | /* Set the initial value from the key size. */
|
---|
41 | for (value = 0x238F13AF * key->dsize, i=0; i < key->dsize; i++)
|
---|
42 | value = (value + (key->dptr[i] << (i*5 % 24)));
|
---|
43 |
|
---|
44 | return (1103515243 * value + 12345);
|
---|
45 | }
|
---|
46 |
|
---|
47 |
|
---|
48 | /* initialise a new database with a specified hash size */
|
---|
49 | static int tdb_new_database(struct tdb_context *tdb, int hash_size)
|
---|
50 | {
|
---|
51 | struct tdb_header *newdb;
|
---|
52 | size_t size;
|
---|
53 | int ret = -1;
|
---|
54 | ssize_t written;
|
---|
55 |
|
---|
56 | /* We make it up in memory, then write it out if not internal */
|
---|
57 | size = sizeof(struct tdb_header) + (hash_size+1)*sizeof(tdb_off_t);
|
---|
58 | if (!(newdb = (struct tdb_header *)calloc(size, 1)))
|
---|
59 | return TDB_ERRCODE(TDB_ERR_OOM, -1);
|
---|
60 |
|
---|
61 | /* Fill in the header */
|
---|
62 | newdb->version = TDB_VERSION;
|
---|
63 | newdb->hash_size = hash_size;
|
---|
64 | if (tdb->flags & TDB_INTERNAL) {
|
---|
65 | tdb->map_size = size;
|
---|
66 | tdb->map_ptr = (char *)newdb;
|
---|
67 | memcpy(&tdb->header, newdb, sizeof(tdb->header));
|
---|
68 | /* Convert the `ondisk' version if asked. */
|
---|
69 | CONVERT(*newdb);
|
---|
70 | return 0;
|
---|
71 | }
|
---|
72 | if (lseek(tdb->fd, 0, SEEK_SET) == -1)
|
---|
73 | goto fail;
|
---|
74 |
|
---|
75 | if (ftruncate(tdb->fd, 0) == -1)
|
---|
76 | goto fail;
|
---|
77 |
|
---|
78 | /* This creates an endian-converted header, as if read from disk */
|
---|
79 | CONVERT(*newdb);
|
---|
80 | memcpy(&tdb->header, newdb, sizeof(tdb->header));
|
---|
81 | /* Don't endian-convert the magic food! */
|
---|
82 | memcpy(newdb->magic_food, TDB_MAGIC_FOOD, strlen(TDB_MAGIC_FOOD)+1);
|
---|
83 | /* we still have "ret == -1" here */
|
---|
84 | written = write(tdb->fd, newdb, size);
|
---|
85 | if (written == size) {
|
---|
86 | ret = 0;
|
---|
87 | } else if (written != -1) {
|
---|
88 | /* call write once again, this usually should return -1 and
|
---|
89 | * set errno appropriately */
|
---|
90 | size -= written;
|
---|
91 | written = write(tdb->fd, newdb+written, size);
|
---|
92 | if (written == size) {
|
---|
93 | ret = 0;
|
---|
94 | } else if (written >= 0) {
|
---|
95 | /* a second incomplete write - we give up.
|
---|
96 | * guessing the errno... */
|
---|
97 | errno = ENOSPC;
|
---|
98 | }
|
---|
99 | }
|
---|
100 |
|
---|
101 | fail:
|
---|
102 | SAFE_FREE(newdb);
|
---|
103 | return ret;
|
---|
104 | }
|
---|
105 |
|
---|
106 |
|
---|
107 |
|
---|
108 | static int tdb_already_open(dev_t device,
|
---|
109 | ino_t ino)
|
---|
110 | {
|
---|
111 | struct tdb_context *i;
|
---|
112 |
|
---|
113 | for (i = tdbs; i; i = i->next) {
|
---|
114 | if (i->device == device && i->inode == ino) {
|
---|
115 | return 1;
|
---|
116 | }
|
---|
117 | }
|
---|
118 |
|
---|
119 | return 0;
|
---|
120 | }
|
---|
121 |
|
---|
122 | /* open the database, creating it if necessary
|
---|
123 |
|
---|
124 | The open_flags and mode are passed straight to the open call on the
|
---|
125 | database file. A flags value of O_WRONLY is invalid. The hash size
|
---|
126 | is advisory, use zero for a default value.
|
---|
127 |
|
---|
128 | Return is NULL on error, in which case errno is also set. Don't
|
---|
129 | try to call tdb_error or tdb_errname, just do strerror(errno).
|
---|
130 |
|
---|
131 | @param name may be NULL for internal databases. */
|
---|
132 | struct tdb_context *tdb_open(const char *name, int hash_size, int tdb_flags,
|
---|
133 | int open_flags, mode_t mode)
|
---|
134 | {
|
---|
135 | return tdb_open_ex(name, hash_size, tdb_flags, open_flags, mode, NULL, NULL);
|
---|
136 | }
|
---|
137 |
|
---|
138 | /* a default logging function */
|
---|
139 | static void null_log_fn(struct tdb_context *tdb, enum tdb_debug_level level, const char *fmt, ...) PRINTF_ATTRIBUTE(3, 4);
|
---|
140 | static void null_log_fn(struct tdb_context *tdb, enum tdb_debug_level level, const char *fmt, ...)
|
---|
141 | {
|
---|
142 | }
|
---|
143 |
|
---|
144 |
|
---|
145 | struct tdb_context *tdb_open_ex(const char *name, int hash_size, int tdb_flags,
|
---|
146 | int open_flags, mode_t mode,
|
---|
147 | const struct tdb_logging_context *log_ctx,
|
---|
148 | tdb_hash_func hash_fn)
|
---|
149 | {
|
---|
150 | struct tdb_context *tdb;
|
---|
151 | struct stat st;
|
---|
152 | int rev = 0, locked = 0;
|
---|
153 | unsigned char *vp;
|
---|
154 | uint32_t vertest;
|
---|
155 | unsigned v;
|
---|
156 |
|
---|
157 | if (!(tdb = (struct tdb_context *)calloc(1, sizeof *tdb))) {
|
---|
158 | /* Can't log this */
|
---|
159 | errno = ENOMEM;
|
---|
160 | goto fail;
|
---|
161 | }
|
---|
162 | tdb_io_init(tdb);
|
---|
163 | tdb->fd = -1;
|
---|
164 | tdb->name = NULL;
|
---|
165 | tdb->map_ptr = NULL;
|
---|
166 | tdb->flags = tdb_flags;
|
---|
167 | tdb->open_flags = open_flags;
|
---|
168 | if (log_ctx) {
|
---|
169 | tdb->log = *log_ctx;
|
---|
170 | } else {
|
---|
171 | tdb->log.log_fn = null_log_fn;
|
---|
172 | tdb->log.log_private = NULL;
|
---|
173 | }
|
---|
174 | tdb->hash_fn = hash_fn ? hash_fn : default_tdb_hash;
|
---|
175 |
|
---|
176 | #ifdef __OS2__
|
---|
177 | if (!(tdb->flags & TDB_INTERNAL))
|
---|
178 | {
|
---|
179 | char szSem[_MAX_PATH];
|
---|
180 | char drive[_MAX_DRIVE], dir[_MAX_DIR];
|
---|
181 | char fname[_MAX_FNAME], ext[_MAX_EXT];
|
---|
182 | APIRET rc;
|
---|
183 | // extract path info
|
---|
184 | _splitpath( name, drive, dir, fname, ext);
|
---|
185 | sprintf( szSem, "\\SEM32\\TDB_GL_%s%s%s", dir, fname, ext);
|
---|
186 | rc = DosCreateMutexSem( szSem, &tdb->hGlobalLock, 0, FALSE);
|
---|
187 | if (rc == ERROR_DUPLICATE_NAME)
|
---|
188 | rc = DosOpenMutexSem( szSem, &tdb->hGlobalLock);
|
---|
189 | if (rc != NO_ERROR) {
|
---|
190 | printf( "cannot open %s %d\n", szSem, rc);
|
---|
191 | errno = EINVAL;
|
---|
192 | goto fail;
|
---|
193 | }
|
---|
194 | TDB_LOG((tdb, TDB_DEBUG_TRACE,"tdb_open_ex pid %d global handle %d\n", getpid(), tdb->hGlobalLock));
|
---|
195 | sprintf( szSem, "\\SEM32\\TDB_AL_%s%s%s", dir, fname, ext);
|
---|
196 | rc = DosCreateMutexSem( szSem, &tdb->hActiveLock, 0, FALSE);
|
---|
197 | if (rc == ERROR_DUPLICATE_NAME)
|
---|
198 | rc = DosOpenMutexSem( szSem, &tdb->hActiveLock);
|
---|
199 | if (rc != NO_ERROR) {
|
---|
200 | printf( "cannot open %s %d\n", szSem, rc);
|
---|
201 | errno = EINVAL;
|
---|
202 | goto fail;
|
---|
203 | }
|
---|
204 | TDB_LOG((tdb, TDB_DEBUG_TRACE,"tdb_open_ex pid %d active handle %d\n", getpid(), tdb->hActiveLock));
|
---|
205 | sprintf( szSem, "\\SEM32\\TDB_TL_%s%s%s", dir, fname, ext);
|
---|
206 | rc = DosCreateMutexSem( szSem, &tdb->hTransactionLock, 0, FALSE);
|
---|
207 | if (rc == ERROR_DUPLICATE_NAME)
|
---|
208 | rc = DosOpenMutexSem( szSem, &tdb->hTransactionLock);
|
---|
209 | if (rc != NO_ERROR) {
|
---|
210 | printf( "cannot open %s %d\n", szSem, rc);
|
---|
211 | errno = EINVAL;
|
---|
212 | goto fail;
|
---|
213 | }
|
---|
214 | TDB_LOG((tdb, TDB_DEBUG_TRACE,"tdb_open_ex pid %d transaction handle %d\n", getpid(), tdb->hTransactionLock));
|
---|
215 | }
|
---|
216 | #endif
|
---|
217 |
|
---|
218 | /* cache the page size */
|
---|
219 | tdb->page_size = getpagesize();
|
---|
220 | if (tdb->page_size <= 0) {
|
---|
221 | tdb->page_size = 0x2000;
|
---|
222 | }
|
---|
223 |
|
---|
224 | tdb->max_dead_records = (tdb_flags & TDB_VOLATILE) ? 5 : 0;
|
---|
225 |
|
---|
226 | if ((open_flags & O_ACCMODE) == O_WRONLY) {
|
---|
227 | TDB_LOG((tdb, TDB_DEBUG_ERROR, "tdb_open_ex: can't open tdb %s write-only\n",
|
---|
228 | name));
|
---|
229 | errno = EINVAL;
|
---|
230 | goto fail;
|
---|
231 | }
|
---|
232 |
|
---|
233 | if (hash_size == 0)
|
---|
234 | hash_size = DEFAULT_HASH_SIZE;
|
---|
235 | if ((open_flags & O_ACCMODE) == O_RDONLY) {
|
---|
236 | tdb->read_only = 1;
|
---|
237 | /* read only databases don't do locking or clear if first */
|
---|
238 | tdb->flags |= TDB_NOLOCK;
|
---|
239 | tdb->flags &= ~TDB_CLEAR_IF_FIRST;
|
---|
240 | }
|
---|
241 |
|
---|
242 | /* internal databases don't mmap or lock, and start off cleared */
|
---|
243 | if (tdb->flags & TDB_INTERNAL) {
|
---|
244 | tdb->flags |= (TDB_NOLOCK | TDB_NOMMAP);
|
---|
245 | tdb->flags &= ~TDB_CLEAR_IF_FIRST;
|
---|
246 | if (tdb_new_database(tdb, hash_size) != 0) {
|
---|
247 | TDB_LOG((tdb, TDB_DEBUG_ERROR, "tdb_open_ex: tdb_new_database failed!"));
|
---|
248 | goto fail;
|
---|
249 | }
|
---|
250 | goto internal;
|
---|
251 | }
|
---|
252 |
|
---|
253 | if ((tdb->fd = open(name, open_flags, mode)) == -1) {
|
---|
254 | TDB_LOG((tdb, TDB_DEBUG_WARNING, "tdb_open_ex: could not open file %s: %s\n",
|
---|
255 | name, strerror(errno)));
|
---|
256 | goto fail; /* errno set by open(2) */
|
---|
257 | }
|
---|
258 |
|
---|
259 | /* on exec, don't inherit the fd */
|
---|
260 | v = fcntl(tdb->fd, F_GETFD, 0);
|
---|
261 | fcntl(tdb->fd, F_SETFD, v | FD_CLOEXEC);
|
---|
262 |
|
---|
263 | /* ensure there is only one process initialising at once */
|
---|
264 | if (tdb->methods->tdb_brlock(tdb, GLOBAL_LOCK, F_WRLCK, F_SETLKW, 0, 1) == -1) {
|
---|
265 | TDB_LOG((tdb, TDB_DEBUG_ERROR, "tdb_open_ex: failed to get global lock on %s: %s\n",
|
---|
266 | name, strerror(errno)));
|
---|
267 | goto fail; /* errno set by tdb_brlock */
|
---|
268 | }
|
---|
269 |
|
---|
270 | /* we need to zero database if we are the only one with it open */
|
---|
271 | if ((tdb_flags & TDB_CLEAR_IF_FIRST)
|
---|
272 | #ifndef __OS2__ // we already have global lock
|
---|
273 | && (locked = (tdb->methods->tdb_brlock(tdb, ACTIVE_LOCK, F_WRLCK, F_SETLK, 0, 1) == 0))
|
---|
274 | #endif
|
---|
275 | ) {
|
---|
276 | open_flags |= O_CREAT;
|
---|
277 | if (ftruncate(tdb->fd, 0) == -1) {
|
---|
278 | TDB_LOG((tdb, TDB_DEBUG_FATAL, "tdb_open_ex: "
|
---|
279 | "failed to truncate %s: %s\n",
|
---|
280 | name, strerror(errno)));
|
---|
281 | goto fail; /* errno set by ftruncate */
|
---|
282 | }
|
---|
283 | }
|
---|
284 |
|
---|
285 | errno = 0;
|
---|
286 | if (read(tdb->fd, &tdb->header, sizeof(tdb->header)) != sizeof(tdb->header)
|
---|
287 | || strcmp(tdb->header.magic_food, TDB_MAGIC_FOOD) != 0
|
---|
288 | || (tdb->header.version != TDB_VERSION
|
---|
289 | && !(rev = (tdb->header.version==TDB_BYTEREV(TDB_VERSION))))) {
|
---|
290 | /* its not a valid database - possibly initialise it */
|
---|
291 | if (!(open_flags & O_CREAT) || tdb_new_database(tdb, hash_size) == -1) {
|
---|
292 | if (errno == 0) {
|
---|
293 | errno = EIO; /* ie bad format or something */
|
---|
294 | }
|
---|
295 | goto fail;
|
---|
296 | }
|
---|
297 | rev = (tdb->flags & TDB_CONVERT);
|
---|
298 | }
|
---|
299 | vp = (unsigned char *)&tdb->header.version;
|
---|
300 | vertest = (((uint32_t)vp[0]) << 24) | (((uint32_t)vp[1]) << 16) |
|
---|
301 | (((uint32_t)vp[2]) << 8) | (uint32_t)vp[3];
|
---|
302 | tdb->flags |= (vertest==TDB_VERSION) ? TDB_BIGENDIAN : 0;
|
---|
303 | if (!rev)
|
---|
304 | tdb->flags &= ~TDB_CONVERT;
|
---|
305 | else {
|
---|
306 | tdb->flags |= TDB_CONVERT;
|
---|
307 | tdb_convert(&tdb->header, sizeof(tdb->header));
|
---|
308 | }
|
---|
309 | if (fstat(tdb->fd, &st) == -1)
|
---|
310 | goto fail;
|
---|
311 |
|
---|
312 | if (tdb->header.rwlocks != 0) {
|
---|
313 | TDB_LOG((tdb, TDB_DEBUG_ERROR, "tdb_open_ex: spinlocks no longer supported\n"));
|
---|
314 | goto fail;
|
---|
315 | }
|
---|
316 |
|
---|
317 | /* Is it already in the open list? If so, fail. */
|
---|
318 | if (tdb_already_open(st.st_dev, st.st_ino)) {
|
---|
319 | TDB_LOG((tdb, TDB_DEBUG_ERROR, "tdb_open_ex: "
|
---|
320 | "%s (%d,%d) is already open in this process\n",
|
---|
321 | name, (int)st.st_dev, (int)st.st_ino));
|
---|
322 | errno = EBUSY;
|
---|
323 | goto fail;
|
---|
324 | }
|
---|
325 |
|
---|
326 | if (!(tdb->name = (char *)strdup(name))) {
|
---|
327 | errno = ENOMEM;
|
---|
328 | goto fail;
|
---|
329 | }
|
---|
330 |
|
---|
331 | tdb->map_size = st.st_size;
|
---|
332 | tdb->device = st.st_dev;
|
---|
333 | tdb->inode = st.st_ino;
|
---|
334 | tdb_mmap(tdb);
|
---|
335 | if (locked) {
|
---|
336 | #ifndef __OS2__
|
---|
337 | if (tdb->methods->tdb_brlock(tdb, ACTIVE_LOCK, F_UNLCK, F_SETLK, 0, 1) == -1) {
|
---|
338 | TDB_LOG((tdb, TDB_DEBUG_ERROR, "tdb_open_ex: "
|
---|
339 | "failed to take ACTIVE_LOCK on %s: %s\n",
|
---|
340 | name, strerror(errno)));
|
---|
341 | goto fail;
|
---|
342 | }
|
---|
343 | #endif
|
---|
344 | }
|
---|
345 |
|
---|
346 | /* We always need to do this if the CLEAR_IF_FIRST flag is set, even if
|
---|
347 | we didn't get the initial exclusive lock as we need to let all other
|
---|
348 | users know we're using it. */
|
---|
349 |
|
---|
350 | #ifndef __OS2__
|
---|
351 | if (tdb_flags & TDB_CLEAR_IF_FIRST) {
|
---|
352 | /* leave this lock in place to indicate it's in use */
|
---|
353 | if (tdb->methods->tdb_brlock(tdb, ACTIVE_LOCK, F_RDLCK, F_SETLKW, 0, 1) == -1)
|
---|
354 | goto fail;
|
---|
355 | }
|
---|
356 | #endif
|
---|
357 | /* if needed, run recovery */
|
---|
358 | if (tdb_transaction_recover(tdb) == -1) {
|
---|
359 | goto fail;
|
---|
360 | }
|
---|
361 |
|
---|
362 | // YD internal databases do not get global lock!
|
---|
363 | if (tdb->methods->tdb_brlock(tdb, GLOBAL_LOCK, F_UNLCK, F_SETLKW, 0, 1) == -1)
|
---|
364 | goto fail;
|
---|
365 |
|
---|
366 | internal:
|
---|
367 | /* Internal (memory-only) databases skip all the code above to
|
---|
368 | * do with disk files, and resume here by releasing their
|
---|
369 | * global lock and hooking into the active list. */
|
---|
370 | tdb->next = tdbs;
|
---|
371 | tdbs = tdb;
|
---|
372 | return tdb;
|
---|
373 |
|
---|
374 | fail:
|
---|
375 | { int save_errno = errno;
|
---|
376 | tdb->methods->tdb_brlock(tdb, GLOBAL_LOCK, F_UNLCK, F_SETLKW, 0, 1);
|
---|
377 |
|
---|
378 | if (!tdb)
|
---|
379 | return NULL;
|
---|
380 |
|
---|
381 | if (tdb->map_ptr) {
|
---|
382 | if (tdb->flags & TDB_INTERNAL)
|
---|
383 | SAFE_FREE(tdb->map_ptr);
|
---|
384 | else
|
---|
385 | tdb_munmap(tdb);
|
---|
386 | }
|
---|
387 | SAFE_FREE(tdb->name);
|
---|
388 | #ifdef __OS2__
|
---|
389 | DosCloseMutexSem( tdb->hGlobalLock);
|
---|
390 | tdb->hGlobalLock = 0;
|
---|
391 | DosCloseMutexSem( tdb->hActiveLock);
|
---|
392 | tdb->hActiveLock = 0;
|
---|
393 | DosCloseMutexSem( tdb->hTransactionLock);
|
---|
394 | tdb->hTransactionLock = 0;
|
---|
395 | #endif
|
---|
396 | if (tdb->fd != -1)
|
---|
397 | if (close(tdb->fd) != 0)
|
---|
398 | TDB_LOG((tdb, TDB_DEBUG_ERROR, "tdb_open_ex: failed to close tdb->fd on error!\n"));
|
---|
399 | SAFE_FREE(tdb);
|
---|
400 | errno = save_errno;
|
---|
401 | return NULL;
|
---|
402 | }
|
---|
403 | }
|
---|
404 |
|
---|
405 | /*
|
---|
406 | * Set the maximum number of dead records per hash chain
|
---|
407 | */
|
---|
408 |
|
---|
409 | void tdb_set_max_dead(struct tdb_context *tdb, int max_dead)
|
---|
410 | {
|
---|
411 | tdb->max_dead_records = max_dead;
|
---|
412 | }
|
---|
413 |
|
---|
414 | /**
|
---|
415 | * Close a database.
|
---|
416 | *
|
---|
417 | * @returns -1 for error; 0 for success.
|
---|
418 | **/
|
---|
419 | int tdb_close(struct tdb_context *tdb)
|
---|
420 | {
|
---|
421 | struct tdb_context **i;
|
---|
422 | int ret = 0;
|
---|
423 |
|
---|
424 | if (tdb->transaction) {
|
---|
425 | tdb_transaction_cancel(tdb);
|
---|
426 | }
|
---|
427 |
|
---|
428 | if (tdb->map_ptr) {
|
---|
429 | if (tdb->flags & TDB_INTERNAL)
|
---|
430 | SAFE_FREE(tdb->map_ptr);
|
---|
431 | else
|
---|
432 | tdb_munmap(tdb);
|
---|
433 | }
|
---|
434 | SAFE_FREE(tdb->name);
|
---|
435 | // YD internal databases do not have a global lock
|
---|
436 | if (!(tdb->flags & TDB_INTERNAL))
|
---|
437 | tdb->methods->tdb_brlock(tdb, GLOBAL_LOCK, F_UNLCK, F_SETLK, 0, 1);
|
---|
438 | if (tdb->fd != -1)
|
---|
439 | ret = close(tdb->fd);
|
---|
440 | SAFE_FREE(tdb->lockrecs);
|
---|
441 | #ifdef __OS2__
|
---|
442 | DosCloseMutexSem( tdb->hGlobalLock);
|
---|
443 | tdb->hGlobalLock = 0;
|
---|
444 | DosCloseMutexSem( tdb->hActiveLock);
|
---|
445 | tdb->hActiveLock = 0;
|
---|
446 | DosCloseMutexSem( tdb->hTransactionLock);
|
---|
447 | tdb->hTransactionLock = 0;
|
---|
448 | #endif
|
---|
449 |
|
---|
450 | /* Remove from contexts list */
|
---|
451 | for (i = &tdbs; *i; i = &(*i)->next) {
|
---|
452 | if (*i == tdb) {
|
---|
453 | *i = tdb->next;
|
---|
454 | break;
|
---|
455 | }
|
---|
456 | }
|
---|
457 |
|
---|
458 | memset(tdb, 0, sizeof(*tdb));
|
---|
459 | SAFE_FREE(tdb);
|
---|
460 |
|
---|
461 | return ret;
|
---|
462 | }
|
---|
463 |
|
---|
464 | /* register a loging function */
|
---|
465 | void tdb_set_logging_function(struct tdb_context *tdb,
|
---|
466 | const struct tdb_logging_context *log_ctx)
|
---|
467 | {
|
---|
468 | tdb->log = *log_ctx;
|
---|
469 | }
|
---|
470 |
|
---|
471 | void *tdb_get_logging_private(struct tdb_context *tdb)
|
---|
472 | {
|
---|
473 | return tdb->log.log_private;
|
---|
474 | }
|
---|
475 |
|
---|
476 | /* reopen a tdb - this can be used after a fork to ensure that we have an independent
|
---|
477 | seek pointer from our parent and to re-establish locks */
|
---|
478 | int tdb_reopen(struct tdb_context *tdb)
|
---|
479 | {
|
---|
480 | struct stat st;
|
---|
481 |
|
---|
482 | if (tdb->flags & TDB_INTERNAL) {
|
---|
483 | return 0; /* Nothing to do. */
|
---|
484 | }
|
---|
485 |
|
---|
486 | #ifdef __OS2__
|
---|
487 |
|
---|
488 | DosCloseMutexSem( tdb->hGlobalLock);
|
---|
489 | tdb->hGlobalLock = 0;
|
---|
490 | DosCloseMutexSem( tdb->hActiveLock);
|
---|
491 | tdb->hActiveLock = 0;
|
---|
492 | DosCloseMutexSem( tdb->hTransactionLock);
|
---|
493 | tdb->hTransactionLock = 0;
|
---|
494 |
|
---|
495 | if (!(tdb->flags & TDB_INTERNAL))
|
---|
496 | {
|
---|
497 | char szSem[_MAX_PATH];
|
---|
498 | char drive[_MAX_DRIVE], dir[_MAX_DIR];
|
---|
499 | char fname[_MAX_FNAME], ext[_MAX_EXT];
|
---|
500 | APIRET rc;
|
---|
501 | // extract path info
|
---|
502 | _splitpath( tdb->name, drive, dir, fname, ext);
|
---|
503 | sprintf( szSem, "\\SEM32\\TDB_GL_%s%s%s", dir, fname, ext);
|
---|
504 | rc = DosCreateMutexSem( szSem, &tdb->hGlobalLock, 0, FALSE);
|
---|
505 | if (rc == ERROR_DUPLICATE_NAME)
|
---|
506 | rc = DosOpenMutexSem( szSem, &tdb->hGlobalLock);
|
---|
507 | if (rc != NO_ERROR) {
|
---|
508 | printf( "cannot open %s %d\n", szSem, rc);
|
---|
509 | errno = EINVAL;
|
---|
510 | goto fail;
|
---|
511 | }
|
---|
512 | TDB_LOG((tdb, TDB_DEBUG_TRACE,"tdb_reopen pid %d global handle %d\n", getpid(), tdb->hGlobalLock));
|
---|
513 | sprintf( szSem, "\\SEM32\\TDB_AL_%s%s%s", dir, fname, ext);
|
---|
514 | rc = DosCreateMutexSem( szSem, &tdb->hActiveLock, 0, FALSE);
|
---|
515 | if (rc == ERROR_DUPLICATE_NAME)
|
---|
516 | rc = DosOpenMutexSem( szSem, &tdb->hActiveLock);
|
---|
517 | if (rc != NO_ERROR) {
|
---|
518 | printf( "cannot open %s %d\n", szSem, rc);
|
---|
519 | errno = EINVAL;
|
---|
520 | goto fail;
|
---|
521 | }
|
---|
522 | TDB_LOG((tdb, TDB_DEBUG_TRACE,"tdb_reopen pid %d active handle %d\n", getpid(), tdb->hActiveLock));
|
---|
523 | sprintf( szSem, "\\SEM32\\TDB_TL_%s%s%s", dir, fname, ext);
|
---|
524 | rc = DosCreateMutexSem( szSem, &tdb->hTransactionLock, 0, FALSE);
|
---|
525 | if (rc == ERROR_DUPLICATE_NAME)
|
---|
526 | rc = DosOpenMutexSem( szSem, &tdb->hTransactionLock);
|
---|
527 | if (rc != NO_ERROR) {
|
---|
528 | printf( "cannot open %s %d\n", szSem, rc);
|
---|
529 | errno = EINVAL;
|
---|
530 | goto fail;
|
---|
531 | }
|
---|
532 | TDB_LOG((tdb, TDB_DEBUG_TRACE,"tdb_reopen pid %d transaction handle %d\n", getpid(), tdb->hTransactionLock));
|
---|
533 | }
|
---|
534 | #endif
|
---|
535 | if (tdb->num_locks != 0 || tdb->global_lock.count) {
|
---|
536 | TDB_LOG((tdb, TDB_DEBUG_ERROR, "tdb_reopen: reopen not allowed with locks held\n"));
|
---|
537 | goto fail;
|
---|
538 | }
|
---|
539 |
|
---|
540 | if (tdb->transaction != 0) {
|
---|
541 | TDB_LOG((tdb, TDB_DEBUG_ERROR, "tdb_reopen: reopen not allowed inside a transaction\n"));
|
---|
542 | goto fail;
|
---|
543 | }
|
---|
544 |
|
---|
545 | if (tdb_munmap(tdb) != 0) {
|
---|
546 | TDB_LOG((tdb, TDB_DEBUG_FATAL, "tdb_reopen: munmap failed (%s)\n", strerror(errno)));
|
---|
547 | goto fail;
|
---|
548 | }
|
---|
549 | if (close(tdb->fd) != 0)
|
---|
550 | TDB_LOG((tdb, TDB_DEBUG_FATAL, "tdb_reopen: WARNING closing tdb->fd failed!\n"));
|
---|
551 | tdb->fd = open(tdb->name, tdb->open_flags & ~(O_CREAT|O_TRUNC), 0);
|
---|
552 | if (tdb->fd == -1) {
|
---|
553 | TDB_LOG((tdb, TDB_DEBUG_FATAL, "tdb_reopen: open failed (%s)\n", strerror(errno)));
|
---|
554 | goto fail;
|
---|
555 | }
|
---|
556 | if ((tdb->flags & TDB_CLEAR_IF_FIRST) &&
|
---|
557 | (tdb->methods->tdb_brlock(tdb, ACTIVE_LOCK, F_RDLCK, F_SETLKW, 0, 1) == -1)) {
|
---|
558 | TDB_LOG((tdb, TDB_DEBUG_FATAL, "tdb_reopen: failed to obtain active lock\n"));
|
---|
559 | goto fail;
|
---|
560 | }
|
---|
561 | if (fstat(tdb->fd, &st) != 0) {
|
---|
562 | TDB_LOG((tdb, TDB_DEBUG_FATAL, "tdb_reopen: fstat failed (%s)\n", strerror(errno)));
|
---|
563 | goto fail;
|
---|
564 | }
|
---|
565 | if (st.st_ino != tdb->inode || st.st_dev != tdb->device) {
|
---|
566 | TDB_LOG((tdb, TDB_DEBUG_FATAL, "tdb_reopen: file dev/inode has changed!\n"));
|
---|
567 | goto fail;
|
---|
568 | }
|
---|
569 | tdb_mmap(tdb);
|
---|
570 |
|
---|
571 | return 0;
|
---|
572 |
|
---|
573 | fail:
|
---|
574 | tdb_close(tdb);
|
---|
575 | return -1;
|
---|
576 | }
|
---|
577 |
|
---|
578 | /* reopen all tdb's */
|
---|
579 | int tdb_reopen_all(int parent_longlived)
|
---|
580 | {
|
---|
581 | struct tdb_context *tdb;
|
---|
582 |
|
---|
583 | for (tdb=tdbs; tdb; tdb = tdb->next) {
|
---|
584 | /*
|
---|
585 | * If the parent is longlived (ie. a
|
---|
586 | * parent daemon architecture), we know
|
---|
587 | * it will keep it's active lock on a
|
---|
588 | * tdb opened with CLEAR_IF_FIRST. Thus
|
---|
589 | * for child processes we don't have to
|
---|
590 | * add an active lock. This is essential
|
---|
591 | * to improve performance on systems that
|
---|
592 | * keep POSIX locks as a non-scalable data
|
---|
593 | * structure in the kernel.
|
---|
594 | */
|
---|
595 | if (parent_longlived) {
|
---|
596 | /* Ensure no clear-if-first. */
|
---|
597 | tdb->flags &= ~TDB_CLEAR_IF_FIRST;
|
---|
598 | }
|
---|
599 |
|
---|
600 | if (tdb_reopen(tdb) != 0)
|
---|
601 | return -1;
|
---|
602 | }
|
---|
603 |
|
---|
604 | return 0;
|
---|
605 | }
|
---|