diff options
Diffstat (limited to 'bdb/os')
| -rw-r--r-- | bdb/os/os_abs.c | 31 | ||||
| -rw-r--r-- | bdb/os/os_alloc.c | 458 | ||||
| -rw-r--r-- | bdb/os/os_clock.c | 92 | ||||
| -rw-r--r-- | bdb/os/os_config.c | 31 | ||||
| -rw-r--r-- | bdb/os/os_dir.c | 108 | ||||
| -rw-r--r-- | bdb/os/os_errno.c | 64 | ||||
| -rw-r--r-- | bdb/os/os_fid.c | 148 | ||||
| -rw-r--r-- | bdb/os/os_fsync.c | 89 | ||||
| -rw-r--r-- | bdb/os/os_handle.c | 185 | ||||
| -rw-r--r-- | bdb/os/os_id.c | 47 | ||||
| -rw-r--r-- | bdb/os/os_map.c | 443 | ||||
| -rw-r--r-- | bdb/os/os_method.c | 234 | ||||
| -rw-r--r-- | bdb/os/os_oflags.c | 118 | ||||
| -rw-r--r-- | bdb/os/os_open.c | 257 | ||||
| -rw-r--r-- | bdb/os/os_region.c | 115 | ||||
| -rw-r--r-- | bdb/os/os_rename.c | 47 | ||||
| -rw-r--r-- | bdb/os/os_root.c | 36 | ||||
| -rw-r--r-- | bdb/os/os_rpath.c | 69 | ||||
| -rw-r--r-- | bdb/os/os_rw.c | 148 | ||||
| -rw-r--r-- | bdb/os/os_seek.c | 77 | ||||
| -rw-r--r-- | bdb/os/os_sleep.c | 80 | ||||
| -rw-r--r-- | bdb/os/os_spin.c | 113 | ||||
| -rw-r--r-- | bdb/os/os_stat.c | 119 | ||||
| -rw-r--r-- | bdb/os/os_tmpdir.c | 121 | ||||
| -rw-r--r-- | bdb/os/os_unlink.c | 109 |
25 files changed, 0 insertions, 3339 deletions
diff --git a/bdb/os/os_abs.c b/bdb/os/os_abs.c deleted file mode 100644 index cd7d0a5d2be..00000000000 --- a/bdb/os/os_abs.c +++ /dev/null @@ -1,31 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_abs.c,v 11.5 2002/01/11 15:52:58 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> -#endif - -#include "db_int.h" - -/* - * __os_abspath -- - * Return if a path is an absolute path. - * - * PUBLIC: int __os_abspath __P((const char *)); - */ -int -__os_abspath(path) - const char *path; -{ - return (path[0] == '/'); -} diff --git a/bdb/os/os_alloc.c b/bdb/os/os_alloc.c deleted file mode 100644 index 5b38cc7d6f1..00000000000 --- a/bdb/os/os_alloc.c +++ /dev/null @@ -1,458 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_alloc.c,v 11.32 2002/08/06 04:57:07 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#include <stdlib.h> -#include <string.h> -#endif - -#include "db_int.h" - -#ifdef DIAGNOSTIC -static void __os_guard __P((DB_ENV *)); - -union __db_alloc { - size_t size; - double align; -}; -#endif - -/* - * !!! - * Correct for systems that return NULL when you allocate 0 bytes of memory. - * There are several places in DB where we allocate the number of bytes held - * by the key/data item, and it can be 0. Correct here so that malloc never - * returns a NULL for that reason (which behavior is permitted by ANSI). We - * could make these calls macros on non-Alpha architectures (that's where we - * saw the problem), but it's probably not worth the autoconf complexity. - * - * !!! - * Correct for systems that don't set errno when malloc and friends fail. - * - * !!! - * There is no circumstance in which we can call __os_umalloc, __os_urealloc - * or __os_ufree without an environment handle, as we need one to determine - * whether or not to use an application-specified malloc function. If we - * don't have an environment handle, we should be calling __os_XXX instead. - * Make DIAGNOSTIC blow up if we get this wrong. - * - * Out of memory. - * We wish to hold the whole sky, - * But we never will. - */ - -/* - * __os_umalloc -- - * A malloc(3) function that will use, in order of preference, - * the allocation function specified to the DB handle, the DB_ENV - * handle, or __os_malloc. - * - * PUBLIC: int __os_umalloc __P((DB_ENV *, size_t, void *)); - */ -int -__os_umalloc(dbenv, size, storep) - DB_ENV *dbenv; - size_t size; - void *storep; -{ - int ret; - - /* Require an environment handle. */ - DB_ASSERT(dbenv != NULL); - - /* Never allocate 0 bytes -- some C libraries don't like it. */ - if (size == 0) - ++size; - - if (dbenv == NULL || dbenv->db_malloc == NULL) { - if (DB_GLOBAL(j_malloc) != NULL) - *(void **)storep = DB_GLOBAL(j_malloc)(size); - else - *(void **)storep = malloc(size); - if (*(void **)storep == NULL) { - /* - * Correct error return, see __os_malloc. - */ - if ((ret = __os_get_errno()) == 0) { - ret = ENOMEM; - __os_set_errno(ENOMEM); - } - __db_err(dbenv, - "malloc: %s: %lu", strerror(ret), (u_long)size); - return (ret); - } - return (0); - } - - if ((*(void **)storep = dbenv->db_malloc(size)) == NULL) { - __db_err(dbenv, "User-specified malloc function returned NULL"); - return (ENOMEM); - } - - return (0); -} - -/* - * __os_urealloc -- - * realloc(3) counterpart to __os_umalloc. - * - * PUBLIC: int __os_urealloc __P((DB_ENV *, size_t, void *)); - */ -int -__os_urealloc(dbenv, size, storep) - DB_ENV *dbenv; - size_t size; - void *storep; -{ - int ret; - void *ptr; - - ptr = *(void **)storep; - - /* Require an environment handle. */ - DB_ASSERT(dbenv != NULL); - - /* Never allocate 0 bytes -- some C libraries don't like it. */ - if (size == 0) - ++size; - - if (dbenv == NULL || dbenv->db_realloc == NULL) { - if (ptr == NULL) - return (__os_umalloc(dbenv, size, storep)); - - if (DB_GLOBAL(j_realloc) != NULL) - *(void **)storep = DB_GLOBAL(j_realloc)(ptr, size); - else - *(void **)storep = realloc(ptr, size); - if (*(void **)storep == NULL) { - /* - * Correct errno, see __os_realloc. - */ - if ((ret = __os_get_errno()) == 0) { - ret = ENOMEM; - __os_set_errno(ENOMEM); - } - __db_err(dbenv, - "realloc: %s: %lu", strerror(ret), (u_long)size); - return (ret); - } - return (0); - } - - if ((*(void **)storep = dbenv->db_realloc(ptr, size)) == NULL) { - __db_err(dbenv, - "User-specified realloc function returned NULL"); - return (ENOMEM); - } - - return (0); -} - -/* - * __os_ufree -- - * free(3) counterpart to __os_umalloc. - * - * PUBLIC: int __os_ufree __P((DB_ENV *, void *)); - */ -int -__os_ufree(dbenv, ptr) - DB_ENV *dbenv; - void *ptr; -{ - /* Require an environment handle. */ - DB_ASSERT(dbenv != NULL); - - if (dbenv != NULL && dbenv->db_free != NULL) - dbenv->db_free(ptr); - else if (DB_GLOBAL(j_free) != NULL) - DB_GLOBAL(j_free)(ptr); - else - free(ptr); - - return (0); -} - -/* - * __os_strdup -- - * The strdup(3) function for DB. - * - * PUBLIC: int __os_strdup __P((DB_ENV *, const char *, void *)); - */ -int -__os_strdup(dbenv, str, storep) - DB_ENV *dbenv; - const char *str; - void *storep; -{ - size_t size; - int ret; - void *p; - - *(void **)storep = NULL; - - size = strlen(str) + 1; - if ((ret = __os_malloc(dbenv, size, &p)) != 0) - return (ret); - - memcpy(p, str, size); - - *(void **)storep = p; - return (0); -} - -/* - * __os_calloc -- - * The calloc(3) function for DB. - * - * PUBLIC: int __os_calloc __P((DB_ENV *, size_t, size_t, void *)); - */ -int -__os_calloc(dbenv, num, size, storep) - DB_ENV *dbenv; - size_t num, size; - void *storep; -{ - void *p; - int ret; - - size *= num; - if ((ret = __os_malloc(dbenv, size, &p)) != 0) - return (ret); - - memset(p, 0, size); - - *(void **)storep = p; - return (0); -} - -/* - * __os_malloc -- - * The malloc(3) function for DB. - * - * PUBLIC: int __os_malloc __P((DB_ENV *, size_t, void *)); - */ -int -__os_malloc(dbenv, size, storep) - DB_ENV *dbenv; - size_t size; - void *storep; -{ - int ret; - void *p; - - *(void **)storep = NULL; - - /* Never allocate 0 bytes -- some C libraries don't like it. */ - if (size == 0) - ++size; - -#ifdef DIAGNOSTIC - /* Add room for size and a guard byte. */ - size += sizeof(union __db_alloc) + 1; -#endif - - if (DB_GLOBAL(j_malloc) != NULL) - p = DB_GLOBAL(j_malloc)(size); - else - p = malloc(size); - if (p == NULL) { - /* - * Some C libraries don't correctly set errno when malloc(3) - * fails. We'd like to 0 out errno before calling malloc, - * but it turns out that setting errno is quite expensive on - * Windows/NT in an MT environment. - */ - if ((ret = __os_get_errno()) == 0) { - ret = ENOMEM; - __os_set_errno(ENOMEM); - } - __db_err(dbenv, - "malloc: %s: %lu", strerror(ret), (u_long)size); - return (ret); - } - -#ifdef DIAGNOSTIC - /* - * Guard bytes: if #DIAGNOSTIC is defined, we allocate an additional - * byte after the memory and set it to a special value that we check - * for when the memory is free'd. - */ - ((u_int8_t *)p)[size - 1] = CLEAR_BYTE; - - ((union __db_alloc *)p)->size = size; - p = &((union __db_alloc *)p)[1]; -#endif - *(void **)storep = p; - - return (0); -} - -/* - * __os_realloc -- - * The realloc(3) function for DB. - * - * PUBLIC: int __os_realloc __P((DB_ENV *, size_t, void *)); - */ -int -__os_realloc(dbenv, size, storep) - DB_ENV *dbenv; - size_t size; - void *storep; -{ - int ret; - void *p, *ptr; - - ptr = *(void **)storep; - - /* Never allocate 0 bytes -- some C libraries don't like it. */ - if (size == 0) - ++size; - - /* If we haven't yet allocated anything yet, simply call malloc. */ - if (ptr == NULL) - return (__os_malloc(dbenv, size, storep)); - -#ifdef DIAGNOSTIC - /* Add room for size and a guard byte. */ - size += sizeof(union __db_alloc) + 1; - - /* Back up to the real begining */ - ptr = &((union __db_alloc *)ptr)[-1]; -#endif - - /* - * Don't overwrite the original pointer, there are places in DB we - * try to continue after realloc fails. - */ - if (DB_GLOBAL(j_realloc) != NULL) - p = DB_GLOBAL(j_realloc)(ptr, size); - else - p = realloc(ptr, size); - if (p == NULL) { - /* - * Some C libraries don't correctly set errno when malloc(3) - * fails. We'd like to 0 out errno before calling malloc, - * but it turns out that setting errno is quite expensive on - * Windows/NT in an MT environment. - */ - if ((ret = __os_get_errno()) == 0) { - ret = ENOMEM; - __os_set_errno(ENOMEM); - } - __db_err(dbenv, - "realloc: %s: %lu", strerror(ret), (u_long)size); - return (ret); - } -#ifdef DIAGNOSTIC - ((u_int8_t *)p)[size - 1] = CLEAR_BYTE; /* Initialize guard byte. */ - - ((union __db_alloc *)p)->size = size; - p = &((union __db_alloc *)p)[1]; -#endif - - *(void **)storep = p; - - return (0); -} - -/* - * __os_free -- - * The free(3) function for DB. - * - * PUBLIC: void __os_free __P((DB_ENV *, void *)); - */ -void -__os_free(dbenv, ptr) - DB_ENV *dbenv; - void *ptr; -{ -#ifdef DIAGNOSTIC - int size; - /* - * Check that the guard byte (one past the end of the memory) is - * still CLEAR_BYTE. - */ - if (ptr == NULL) - return; - - ptr = &((union __db_alloc *)ptr)[-1]; - size = ((union __db_alloc *)ptr)->size; - if (((u_int8_t *)ptr)[size - 1] != CLEAR_BYTE) - __os_guard(dbenv); - - /* Clear memory. */ - if (size != 0) - memset(ptr, CLEAR_BYTE, size); -#endif - COMPQUIET(dbenv, NULL); - - if (DB_GLOBAL(j_free) != NULL) - DB_GLOBAL(j_free)(ptr); - else - free(ptr); -} - -#ifdef DIAGNOSTIC -/* - * __os_guard -- - * Complain and abort. - */ -static void -__os_guard(dbenv) - DB_ENV *dbenv; -{ - __db_err(dbenv, "Guard byte incorrect during free"); - abort(); - /* NOTREACHED */ -} -#endif - -/* - * __ua_memcpy -- - * Copy memory to memory without relying on any kind of alignment. - * - * There are places in DB that we have unaligned data, for example, - * when we've stored a structure in a log record as a DBT, and now - * we want to look at it. Unfortunately, if you have code like: - * - * struct a { - * int x; - * } *p; - * - * void *func_argument; - * int local; - * - * p = (struct a *)func_argument; - * memcpy(&local, p->x, sizeof(local)); - * - * compilers optimize to use inline instructions requiring alignment, - * and records in the log don't have any particular alignment. (This - * isn't a compiler bug, because it's a structure they're allowed to - * assume alignment.) - * - * Casting the memcpy arguments to (u_int8_t *) appears to work most - * of the time, but we've seen examples where it wasn't sufficient - * and there's nothing in ANSI C that requires that work. - * - * PUBLIC: void *__ua_memcpy __P((void *, const void *, size_t)); - */ -void * -__ua_memcpy(dst, src, len) - void *dst; - const void *src; - size_t len; -{ - return ((void *)memcpy(dst, src, len)); -} diff --git a/bdb/os/os_clock.c b/bdb/os/os_clock.c deleted file mode 100644 index 8da02cf6f9c..00000000000 --- a/bdb/os/os_clock.c +++ /dev/null @@ -1,92 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 2001-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_clock.c,v 1.9 2002/03/29 20:46:44 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#if TIME_WITH_SYS_TIME -#include <sys/time.h> -#include <time.h> -#else -#if HAVE_SYS_TIME_H -#include <sys/time.h> -#else -#include <time.h> -#endif /* HAVE_SYS_TIME_H */ -#endif /* TIME_WITH SYS_TIME */ - -#include <string.h> -#endif - -#include "db_int.h" - -/* - * __os_clock -- - * Return the current time-of-day clock in seconds and microseconds. - * - * PUBLIC: int __os_clock __P((DB_ENV *, u_int32_t *, u_int32_t *)); - */ -int -__os_clock(dbenv, secsp, usecsp) - DB_ENV *dbenv; - u_int32_t *secsp, *usecsp; /* Seconds and microseconds. */ -{ -#if defined(HAVE_GETTIMEOFDAY) - struct timeval tp; - int ret; - -retry: if (gettimeofday(&tp, NULL) != 0) { - if ((ret = __os_get_errno()) == EINTR) - goto retry; - __db_err(dbenv, "gettimeofday: %s", strerror(ret)); - return (ret); - } - - if (secsp != NULL) - *secsp = tp.tv_sec; - if (usecsp != NULL) - *usecsp = tp.tv_usec; -#endif -#if !defined(HAVE_GETTIMEOFDAY) && defined(HAVE_CLOCK_GETTIME) - struct timespec tp; - int ret; - -retry: if (clock_gettime(CLOCK_REALTIME, &tp) != 0) { - if ((ret = __os_get_errno()) == EINTR) - goto retry; - __db_err(dbenv, "clock_gettime: %s", strerror(ret)); - return (ret); - } - - if (secsp != NULL) - *secsp = tp.tv_sec; - if (usecsp != NULL) - *usecsp = tp.tv_nsec / 1000; -#endif -#if !defined(HAVE_GETTIMEOFDAY) && !defined(HAVE_CLOCK_GETTIME) - time_t now; - int ret; - - if (time(&now) == (time_t)-1) { - ret = __os_get_errno(); - __db_err(dbenv, "time: %s", strerror(ret)); - return (ret); - } - - if (secsp != NULL) - *secsp = now; - if (usecsp != NULL) - *usecsp = 0; -#endif - return (0); -} diff --git a/bdb/os/os_config.c b/bdb/os/os_config.c deleted file mode 100644 index b64952a8302..00000000000 --- a/bdb/os/os_config.c +++ /dev/null @@ -1,31 +0,0 @@ -/*- - * 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_config.c,v 11.13 2002/01/31 19:54:12 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> -#endif - -#include "db_int.h" - -/* - * __os_fs_notzero -- - * Return 1 if allocated filesystem blocks are not zeroed. - * - * PUBLIC: int __os_fs_notzero __P((void)); - */ -int -__os_fs_notzero() -{ - /* Most filesystems zero out implicitly created pages. */ - return (0); -} diff --git a/bdb/os/os_dir.c b/bdb/os/os_dir.c deleted file mode 100644 index 3f59a23d963..00000000000 --- a/bdb/os/os_dir.c +++ /dev/null @@ -1,108 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_dir.c,v 11.14 2002/07/12 18:56:50 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#if HAVE_DIRENT_H -# include <dirent.h> -# define NAMLEN(dirent) strlen((dirent)->d_name) -#else -# define dirent direct -# define NAMLEN(dirent) (dirent)->d_namlen -# if HAVE_SYS_NDIR_H -# include <sys/ndir.h> -# endif -# if HAVE_SYS_DIR_H -# include <sys/dir.h> -# endif -# if HAVE_NDIR_H -# include <ndir.h> -# endif -#endif - -#endif - -#include "db_int.h" - -/* - * __os_dirlist -- - * Return a list of the files in a directory. - * - * PUBLIC: int __os_dirlist __P((DB_ENV *, const char *, char ***, int *)); - */ -int -__os_dirlist(dbenv, dir, namesp, cntp) - DB_ENV *dbenv; - const char *dir; - char ***namesp; - int *cntp; -{ - struct dirent *dp; - DIR *dirp; - int arraysz, cnt, ret; - char **names; - - if (DB_GLOBAL(j_dirlist) != NULL) - return (DB_GLOBAL(j_dirlist)(dir, namesp, cntp)); - -#ifdef HAVE_VXWORKS - if ((dirp = opendir((char *)dir)) == NULL) -#else - if ((dirp = opendir(dir)) == NULL) -#endif - return (__os_get_errno()); - names = NULL; - for (arraysz = cnt = 0; (dp = readdir(dirp)) != NULL; ++cnt) { - if (cnt >= arraysz) { - arraysz += 100; - if ((ret = __os_realloc(dbenv, - arraysz * sizeof(names[0]), &names)) != 0) - goto nomem; - } - if ((ret = __os_strdup(dbenv, dp->d_name, &names[cnt])) != 0) - goto nomem; - } - (void)closedir(dirp); - - *namesp = names; - *cntp = cnt; - return (0); - -nomem: if (names != NULL) - __os_dirfree(dbenv, names, cnt); - if (dirp != NULL) - (void)closedir(dirp); - return (ret); -} - -/* - * __os_dirfree -- - * Free the list of files. - * - * PUBLIC: void __os_dirfree __P((DB_ENV *, char **, int)); - */ -void -__os_dirfree(dbenv, names, cnt) - DB_ENV *dbenv; - char **names; - int cnt; -{ - if (DB_GLOBAL(j_dirfree) != NULL) - DB_GLOBAL(j_dirfree)(names, cnt); - else { - while (cnt > 0) - __os_free(dbenv, names[--cnt]); - __os_free(dbenv, names); - } -} diff --git a/bdb/os/os_errno.c b/bdb/os/os_errno.c deleted file mode 100644 index 4b40f88d177..00000000000 --- a/bdb/os/os_errno.c +++ /dev/null @@ -1,64 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1999-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_errno.c,v 11.8 2002/01/11 15:52:59 bostic Exp $"; -#endif /* not lint */ - -#include "db_int.h" - -/* - * __os_get_errno_ret_zero -- - * Return the value of errno, even if it's zero. - * - * PUBLIC: int __os_get_errno_ret_zero __P((void)); - */ -int -__os_get_errno_ret_zero() -{ - /* This routine must be able to return the same value repeatedly. */ - return (errno); -} - -/* - * __os_get_errno -- - * Return the value of errno, or EAGAIN if errno is zero. - * - * PUBLIC: int __os_get_errno __P((void)); - */ -int -__os_get_errno() -{ - /* - * This routine must be able to return the same value repeatedly. - * - * We've seen cases where system calls failed but errno was never set. - * This version of __os_get_errno() sets errno to EAGAIN if it's not - * already set, to work around that problem. For obvious reasons, we - * can only call this function if we know an error has occurred, that - * is, we can't test errno for a non-zero value after this call. - */ - if (errno == 0) - __os_set_errno(EAGAIN); - - return (errno); -} - -/* - * __os_set_errno -- - * Set the value of errno. - * - * PUBLIC: void __os_set_errno __P((int)); - */ -void -__os_set_errno(evalue) - int evalue; -{ - errno = evalue; -} diff --git a/bdb/os/os_fid.c b/bdb/os/os_fid.c deleted file mode 100644 index 125e6f0712c..00000000000 --- a/bdb/os/os_fid.c +++ /dev/null @@ -1,148 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1996-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_fid.c,v 11.14 2002/08/26 14:37:38 margo Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> -#include <sys/stat.h> - -#if TIME_WITH_SYS_TIME -#include <sys/time.h> -#include <time.h> -#else -#if HAVE_SYS_TIME_H -#include <sys/time.h> -#else -#include <time.h> -#endif -#endif - -#include <stdlib.h> -#include <string.h> -#include <unistd.h> -#endif - -#include "db_int.h" - -#define SERIAL_INIT 0 -static u_int32_t fid_serial = SERIAL_INIT; - -/* - * __os_fileid -- - * Return a unique identifier for a file. The structure - * of a fileid is: ino(4) dev(4) time(4) pid(4) extra(4). - * For real files, which have a backing inode and device, the first - * 16 bytes are filled in and the extra bytes are left 0. For - * temporary files, the inode and device fields are left blank and - * the extra four bytes are filled in with a random value. - * - * PUBLIC: int __os_fileid __P((DB_ENV *, const char *, int, u_int8_t *)); - */ -int -__os_fileid(dbenv, fname, unique_okay, fidp) - DB_ENV *dbenv; - const char *fname; - int unique_okay; - u_int8_t *fidp; -{ - struct stat sb; - size_t i; - int ret; - u_int32_t tmp; - u_int8_t *p; - - /* Clear the buffer. */ - memset(fidp, 0, DB_FILE_ID_LEN); - - /* On POSIX/UNIX, use a dev/inode pair. */ -retry: -#ifdef HAVE_VXWORKS - if (stat((char *)fname, &sb) != 0) { -#else - if (stat(fname, &sb) != 0) { -#endif - if ((ret = __os_get_errno()) == EINTR) - goto retry; - __db_err(dbenv, "%s: %s", fname, strerror(ret)); - return (ret); - } - - /* - * Initialize/increment the serial number we use to help avoid - * fileid collisions. Note that we don't bother with locking; - * it's unpleasant to do from down in here, and if we race on - * this no real harm will be done, since the finished fileid - * has so many other components. - * - * We increment by 100000 on each call as a simple way of - * randomizing; simply incrementing seems potentially less useful - * if pids are also simply incremented, since this is process-local - * and we may be one of a set of processes starting up. 100000 - * pushes us out of pid space on most platforms, and has few - * interesting properties in base 2. - */ - if (fid_serial == SERIAL_INIT) - __os_id(&fid_serial); - else - fid_serial += 100000; - - /* - * !!! - * Nothing is ever big enough -- on Sparc V9, st_ino, st_dev and the - * time_t types are all 8 bytes. As DB_FILE_ID_LEN is only 20 bytes, - * we convert to a (potentially) smaller fixed-size type and use it. - * - * We don't worry about byte sexing or the actual variable sizes. - * - * When this routine is called from the DB access methods, it's only - * called once -- whatever ID is generated when a database is created - * is stored in the database file's metadata, and that is what is - * saved in the mpool region's information to uniquely identify the - * file. - * - * When called from the mpool layer this routine will be called each - * time a new thread of control wants to share the file, which makes - * things tougher. As far as byte sexing goes, since the mpool region - * lives on a single host, there's no issue of that -- the entire - * region is byte sex dependent. As far as variable sizes go, we make - * the simplifying assumption that 32-bit and 64-bit processes will - * get the same 32-bit values if we truncate any returned 64-bit value - * to a 32-bit value. When we're called from the mpool layer, though, - * we need to be careful not to include anything that isn't - * reproducible for a given file, such as the timestamp or serial - * number. - */ - tmp = (u_int32_t)sb.st_ino; - for (p = (u_int8_t *)&tmp, i = sizeof(u_int32_t); i > 0; --i) - *fidp++ = *p++; - - tmp = (u_int32_t)sb.st_dev; - for (p = (u_int8_t *)&tmp, i = sizeof(u_int32_t); i > 0; --i) - *fidp++ = *p++; - - if (unique_okay) { - /* - * We want the number of seconds, not the high-order 0 bits, - * so convert the returned time_t to a (potentially) smaller - * fixed-size type. - */ - tmp = (u_int32_t)time(NULL); - for (p = (u_int8_t *)&tmp, i = sizeof(u_int32_t); i > 0; --i) - *fidp++ = *p++; - - for (p = (u_int8_t *)&fid_serial, i = sizeof(u_int32_t); - i > 0; --i) - *fidp++ = *p++; - } - - return (0); -} diff --git a/bdb/os/os_fsync.c b/bdb/os/os_fsync.c deleted file mode 100644 index 46ab4885a16..00000000000 --- a/bdb/os/os_fsync.c +++ /dev/null @@ -1,89 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_fsync.c,v 11.14 2002/07/12 18:56:50 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#include <fcntl.h> /* XXX: Required by __hp3000s900 */ -#include <unistd.h> -#include <string.h> -#endif - -#include "db_int.h" - -#ifdef HAVE_VXWORKS -#include "ioLib.h" - -#define fsync(fd) __vx_fsync(fd); - -int -__vx_fsync(fd) - int fd; -{ - int ret; - - /* - * The results of ioctl are driver dependent. Some will return the - * number of bytes sync'ed. Only if it returns 'ERROR' should we - * flag it. - */ - if ((ret = ioctl(fd, FIOSYNC, 0)) != ERROR) - return (0); - return (ret); -} -#endif - -#ifdef __hp3000s900 -#define fsync(fd) __mpe_fsync(fd); - -int -__mpe_fsync(fd) - int fd; -{ - extern FCONTROL(short, short, void *); - - FCONTROL(_MPE_FILENO(fd), 2, NULL); /* Flush the buffers */ - FCONTROL(_MPE_FILENO(fd), 6, NULL); /* Write the EOF */ - return (0); -} -#endif - -/* - * __os_fsync -- - * Flush a file descriptor. - * - * PUBLIC: int __os_fsync __P((DB_ENV *, DB_FH *)); - */ -int -__os_fsync(dbenv, fhp) - DB_ENV *dbenv; - DB_FH *fhp; -{ - int ret; - - /* - * Do nothing if the file descriptor has been marked as not requiring - * any sync to disk. - */ - if (F_ISSET(fhp, DB_FH_NOSYNC)) - return (0); - - do { - ret = DB_GLOBAL(j_fsync) != NULL ? - DB_GLOBAL(j_fsync)(fhp->fd) : fsync(fhp->fd); - } while (ret != 0 && (ret = __os_get_errno()) == EINTR); - - if (ret != 0) - __db_err(dbenv, "fsync %s", strerror(ret)); - return (ret); -} diff --git a/bdb/os/os_handle.c b/bdb/os/os_handle.c deleted file mode 100644 index 5f617085e5d..00000000000 --- a/bdb/os/os_handle.c +++ /dev/null @@ -1,185 +0,0 @@ -/*- - * 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 11.28 2002/07/12 18:56:50 bostic 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, FD_CLOEXEC) == -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); -} diff --git a/bdb/os/os_id.c b/bdb/os/os_id.c deleted file mode 100644 index c242bb12e23..00000000000 --- a/bdb/os/os_id.c +++ /dev/null @@ -1,47 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 2001-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_id.c,v 1.2 2002/01/11 15:52:59 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#include <unistd.h> -#endif - -#include "db_int.h" - -/* - * __os_id -- - * Return a 32-bit value identifying the current thread of control. - * - * PUBLIC: void __os_id __P((u_int32_t *)); - */ -void -__os_id(idp) - u_int32_t *idp; -{ - /* - * By default, use the process ID. - * - * getpid() returns a pid_t which we convert to a u_int32_t. I have - * not yet seen a system where a pid_t has 64-bits, but I'm sure they - * exist. Since we're returning only the bottom 32-bits, you cannot - * use the return of __os_id to reference a process (for example, you - * cannot send a signal to the value returned by __os_id). To send a - * signal to the current process, use raise(3) instead. - */ -#ifdef HAVE_VXWORKS - *idp = taskIdSelf(); -#else - *idp = getpid(); -#endif -} diff --git a/bdb/os/os_map.c b/bdb/os/os_map.c deleted file mode 100644 index 6d385b6a84d..00000000000 --- a/bdb/os/os_map.c +++ /dev/null @@ -1,443 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1996-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_map.c,v 11.44 2002/07/12 18:56:51 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> -#ifdef HAVE_MMAP -#include <sys/mman.h> -#endif - -#ifdef HAVE_SHMGET -#include <sys/ipc.h> -#include <sys/shm.h> -#endif - -#include <string.h> -#endif - -#include "db_int.h" - -#ifdef HAVE_MMAP -static int __os_map __P((DB_ENV *, char *, DB_FH *, size_t, int, int, void **)); -#endif -#ifndef HAVE_SHMGET -static int __db_nosystemmem __P((DB_ENV *)); -#endif - -/* - * __os_r_sysattach -- - * Create/join a shared memory region. - * - * PUBLIC: int __os_r_sysattach __P((DB_ENV *, REGINFO *, REGION *)); - */ -int -__os_r_sysattach(dbenv, infop, rp) - DB_ENV *dbenv; - REGINFO *infop; - REGION *rp; -{ - if (F_ISSET(dbenv, DB_ENV_SYSTEM_MEM)) { - /* - * If the region is in system memory on UNIX, we use shmget(2). - * - * !!! - * There exist spinlocks that don't work in shmget memory, e.g., - * the HP/UX msemaphore interface. If we don't have locks that - * will work in shmget memory, we better be private and not be - * threaded. If we reach this point, we know we're public, so - * it's an error. - */ -#if defined(MUTEX_NO_SHMGET_LOCKS) - __db_err(dbenv, - "architecture does not support locks inside system shared memory"); - return (EINVAL); -#endif -#if defined(HAVE_SHMGET) - { - key_t segid; - int id, ret; - - /* - * We could potentially create based on REGION_CREATE_OK, but - * that's dangerous -- we might get crammed in sideways if - * some of the expected regions exist but others do not. Also, - * if the requested size differs from an existing region's - * actual size, then all sorts of nasty things can happen. - * Basing create solely on REGION_CREATE is much safer -- a - * recovery will get us straightened out. - */ - if (F_ISSET(infop, REGION_CREATE)) { - /* - * The application must give us a base System V IPC key - * value. Adjust that value based on the region's ID, - * and correct so the user's original value appears in - * the ipcs output. - */ - if (dbenv->shm_key == INVALID_REGION_SEGID) { - __db_err(dbenv, - "no base system shared memory ID specified"); - return (EINVAL); - } - segid = (key_t)(dbenv->shm_key + (infop->id - 1)); - - /* - * If map to an existing region, assume the application - * crashed and we're restarting. Delete the old region - * and re-try. If that fails, return an error, the - * application will have to select a different segment - * ID or clean up some other way. - */ - if ((id = shmget(segid, 0, 0)) != -1) { - (void)shmctl(id, IPC_RMID, NULL); - if ((id = shmget(segid, 0, 0)) != -1) { - __db_err(dbenv, - "shmget: key: %ld: shared system memory region already exists", - (long)segid); - return (EAGAIN); - } - } - if ((id = - shmget(segid, rp->size, IPC_CREAT | 0600)) == -1) { - ret = __os_get_errno(); - __db_err(dbenv, - "shmget: key: %ld: unable to create shared system memory region: %s", - (long)segid, strerror(ret)); - return (ret); - } - rp->segid = id; - } else - id = rp->segid; - - if ((infop->addr = shmat(id, NULL, 0)) == (void *)-1) { - infop->addr = NULL; - ret = __os_get_errno(); - __db_err(dbenv, - "shmat: id %d: unable to attach to shared system memory region: %s", - id, strerror(ret)); - return (ret); - } - - return (0); - } -#else - return (__db_nosystemmem(dbenv)); -#endif - } - -#ifdef HAVE_MMAP - { - DB_FH fh; - int ret; - - /* - * Try to open/create the shared region file. We DO NOT need to ensure - * that multiple threads/processes attempting to simultaneously create - * the region are properly ordered, our caller has already taken care - * of that. - */ - if ((ret = __os_open(dbenv, infop->name, - DB_OSO_REGION | DB_OSO_DIRECT | - (F_ISSET(infop, REGION_CREATE_OK) ? DB_OSO_CREATE : 0), - infop->mode, &fh)) != 0) - __db_err(dbenv, "%s: %s", infop->name, db_strerror(ret)); - - /* - * If we created the file, grow it to its full size before mapping - * it in. We really want to avoid touching the buffer cache after - * mmap(2) is called, doing anything else confuses the hell out of - * systems without merged VM/buffer cache systems, or, more to the - * point, *badly* merged VM/buffer cache systems. - */ - if (ret == 0 && F_ISSET(infop, REGION_CREATE)) - ret = __db_fileinit(dbenv, - &fh, rp->size, F_ISSET(dbenv, DB_ENV_REGION_INIT) ? 1 : 0); - - /* Map the file in. */ - if (ret == 0) - ret = __os_map(dbenv, - infop->name, &fh, rp->size, 1, 0, &infop->addr); - - if (F_ISSET(&fh, DB_FH_VALID)) - (void)__os_closehandle(dbenv, &fh); - - return (ret); - } -#else - COMPQUIET(infop, NULL); - COMPQUIET(rp, NULL); - __db_err(dbenv, - "architecture lacks mmap(2), shared environments not possible"); - return (__db_eopnotsup(dbenv)); -#endif -} - -/* - * __os_r_sysdetach -- - * Detach from a shared memory region. - * - * PUBLIC: int __os_r_sysdetach __P((DB_ENV *, REGINFO *, int)); - */ -int -__os_r_sysdetach(dbenv, infop, destroy) - DB_ENV *dbenv; - REGINFO *infop; - int destroy; -{ - REGION *rp; - - rp = infop->rp; - - if (F_ISSET(dbenv, DB_ENV_SYSTEM_MEM)) { -#ifdef HAVE_SHMGET - int ret, segid; - - /* - * We may be about to remove the memory referenced by rp, - * save the segment ID, and (optionally) wipe the original. - */ - segid = rp->segid; - if (destroy) - rp->segid = INVALID_REGION_SEGID; - - if (shmdt(infop->addr) != 0) { - ret = __os_get_errno(); - __db_err(dbenv, "shmdt: %s", strerror(ret)); - return (ret); - } - - if (destroy && shmctl(segid, IPC_RMID, - NULL) != 0 && (ret = __os_get_errno()) != EINVAL) { - __db_err(dbenv, - "shmctl: id %ld: unable to delete system shared memory region: %s", - segid, strerror(ret)); - return (ret); - } - - return (0); -#else - return (__db_nosystemmem(dbenv)); -#endif - } - -#ifdef HAVE_MMAP -#ifdef HAVE_MUNLOCK - if (F_ISSET(dbenv, DB_ENV_LOCKDOWN)) - (void)munlock(infop->addr, rp->size); -#endif - if (munmap(infop->addr, rp->size) != 0) { - int ret; - - ret = __os_get_errno(); - __db_err(dbenv, "munmap: %s", strerror(ret)); - return (ret); - } - - if (destroy && __os_region_unlink(dbenv, infop->name) != 0) - return (__os_get_errno()); - - return (0); -#else - COMPQUIET(destroy, 0); - return (EINVAL); -#endif -} - -/* - * __os_mapfile -- - * Map in a shared memory file. - * - * PUBLIC: int __os_mapfile __P((DB_ENV *, - * PUBLIC: char *, DB_FH *, size_t, int, void **)); - */ -int -__os_mapfile(dbenv, path, fhp, len, is_rdonly, addrp) - DB_ENV *dbenv; - char *path; - DB_FH *fhp; - int is_rdonly; - size_t len; - void **addrp; -{ -#if defined(HAVE_MMAP) && !defined(HAVE_QNX) - return (__os_map(dbenv, path, fhp, len, 0, is_rdonly, addrp)); -#else - COMPQUIET(dbenv, NULL); - COMPQUIET(path, NULL); - COMPQUIET(fhp, NULL); - COMPQUIET(is_rdonly, 0); - COMPQUIET(len, 0); - COMPQUIET(addrp, NULL); - return (EINVAL); -#endif -} - -/* - * __os_unmapfile -- - * Unmap the shared memory file. - * - * PUBLIC: int __os_unmapfile __P((DB_ENV *, void *, size_t)); - */ -int -__os_unmapfile(dbenv, addr, len) - DB_ENV *dbenv; - void *addr; - size_t len; -{ - /* If the user replaced the map call, call through their interface. */ - if (DB_GLOBAL(j_unmap) != NULL) - return (DB_GLOBAL(j_unmap)(addr, len)); - -#ifdef HAVE_MMAP -#ifdef HAVE_MUNLOCK - if (F_ISSET(dbenv, DB_ENV_LOCKDOWN)) - while (munlock(addr, len) != 0 && __os_get_errno() == EINTR) - ; -#else - COMPQUIET(dbenv, NULL); -#endif - { - int ret; - - while ((ret = munmap(addr, len)) != 0 && - __os_get_errno() == EINTR) - ; - return (ret ? __os_get_errno() : 0); - } -#else - COMPQUIET(dbenv, NULL); - - return (EINVAL); -#endif -} - -#ifdef HAVE_MMAP -/* - * __os_map -- - * Call the mmap(2) function. - */ -static int -__os_map(dbenv, path, fhp, len, is_region, is_rdonly, addrp) - DB_ENV *dbenv; - char *path; - DB_FH *fhp; - int is_region, is_rdonly; - size_t len; - void **addrp; -{ - void *p; - int flags, prot, ret; - - /* If the user replaced the map call, call through their interface. */ - if (DB_GLOBAL(j_map) != NULL) - return (DB_GLOBAL(j_map) - (path, len, is_region, is_rdonly, addrp)); - - /* - * If it's read-only, it's private, and if it's not, it's shared. - * Don't bother with an additional parameter. - */ - flags = is_rdonly ? MAP_PRIVATE : MAP_SHARED; - -#ifdef MAP_FILE - /* - * Historically, MAP_FILE was required for mapping regular files, - * even though it was the default. Some systems have it, some - * don't, some that have it set it to 0. - */ - flags |= MAP_FILE; -#endif - - /* - * I know of no systems that implement the flag to tell the system - * that the region contains semaphores, but it's not an unreasonable - * thing to do, and has been part of the design since forever. I - * don't think anyone will object, but don't set it for read-only - * files, it doesn't make sense. - */ -#ifdef MAP_HASSEMAPHORE - if (is_region && !is_rdonly) - flags |= MAP_HASSEMAPHORE; -#else - COMPQUIET(is_region, 0); -#endif - - prot = PROT_READ | (is_rdonly ? 0 : PROT_WRITE); - - /* - * XXX - * Work around a bug in the VMS V7.1 mmap() implementation. To map - * a file into memory on VMS it needs to be opened in a certain way, - * originally. To get the file opened in that certain way, the VMS - * mmap() closes the file and re-opens it. When it does this, it - * doesn't flush any caches out to disk before closing. The problem - * this causes us is that when the memory cache doesn't get written - * out, the file isn't big enough to match the memory chunk and the - * mmap() call fails. This call to fsync() fixes the problem. DEC - * thinks this isn't a bug because of language in XPG5 discussing user - * responsibility for on-disk and in-memory synchronization. - */ -#ifdef VMS - if (__os_fsync(dbenv, fhp) == -1) - return (__os_get_errno()); -#endif - - /* MAP_FAILED was not defined in early mmap implementations. */ -#ifndef MAP_FAILED -#define MAP_FAILED -1 -#endif - if ((p = mmap(NULL, - len, prot, flags, fhp->fd, (off_t)0)) == (void *)MAP_FAILED) { - ret = __os_get_errno(); - __db_err(dbenv, "mmap: %s", strerror(ret)); - return (ret); - } - -#ifdef HAVE_MLOCK - /* - * If it's a region, we want to make sure that the memory isn't paged. - * For example, Solaris will page large mpools because it thinks that - * I/O buffer memory is more important than we are. The mlock system - * call may or may not succeed (mlock is restricted to the super-user - * on some systems). Currently, the only other use of mmap in DB is - * to map read-only databases -- we don't want them paged, either, so - * the call isn't conditional. - */ - if (F_ISSET(dbenv, DB_ENV_LOCKDOWN) && mlock(p, len) != 0) { - ret = __os_get_errno(); - (void)munmap(p, len); - __db_err(dbenv, "mlock: %s", strerror(ret)); - return (ret); - } -#else - COMPQUIET(dbenv, NULL); -#endif - - *addrp = p; - return (0); -} -#endif - -#ifndef HAVE_SHMGET -/* - * __db_nosystemmem -- - * No system memory environments error message. - */ -static int -__db_nosystemmem(dbenv) - DB_ENV *dbenv; -{ - __db_err(dbenv, - "architecture doesn't support environments in system memory"); - return (__db_eopnotsup(dbenv)); -} -#endif diff --git a/bdb/os/os_method.c b/bdb/os/os_method.c deleted file mode 100644 index 04367654efa..00000000000 --- a/bdb/os/os_method.c +++ /dev/null @@ -1,234 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1999-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_method.c,v 11.15 2002/07/12 18:56:51 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> -#endif - -#include "db_int.h" - -/* - * EXTERN: int db_env_set_func_close __P((int (*)(int))); - */ -int -db_env_set_func_close(func_close) - int (*func_close) __P((int)); -{ - DB_GLOBAL(j_close) = func_close; - return (0); -} - -/* - * EXTERN: int db_env_set_func_dirfree __P((void (*)(char **, int))); - */ -int -db_env_set_func_dirfree(func_dirfree) - void (*func_dirfree) __P((char **, int)); -{ - DB_GLOBAL(j_dirfree) = func_dirfree; - return (0); -} - -/* - * EXTERN: int db_env_set_func_dirlist - * EXTERN: __P((int (*)(const char *, char ***, int *))); - */ -int -db_env_set_func_dirlist(func_dirlist) - int (*func_dirlist) __P((const char *, char ***, int *)); -{ - DB_GLOBAL(j_dirlist) = func_dirlist; - return (0); -} - -/* - * EXTERN: int db_env_set_func_exists __P((int (*)(const char *, int *))); - */ -int -db_env_set_func_exists(func_exists) - int (*func_exists) __P((const char *, int *)); -{ - DB_GLOBAL(j_exists) = func_exists; - return (0); -} - -/* - * EXTERN: int db_env_set_func_free __P((void (*)(void *))); - */ -int -db_env_set_func_free(func_free) - void (*func_free) __P((void *)); -{ - DB_GLOBAL(j_free) = func_free; - return (0); -} - -/* - * EXTERN: int db_env_set_func_fsync __P((int (*)(int))); - */ -int -db_env_set_func_fsync(func_fsync) - int (*func_fsync) __P((int)); -{ - DB_GLOBAL(j_fsync) = func_fsync; - return (0); -} - -/* - * EXTERN: int db_env_set_func_ioinfo __P((int (*)(const char *, - * EXTERN: int, u_int32_t *, u_int32_t *, u_int32_t *))); - */ -int -db_env_set_func_ioinfo(func_ioinfo) - int (*func_ioinfo) - __P((const char *, int, u_int32_t *, u_int32_t *, u_int32_t *)); -{ - DB_GLOBAL(j_ioinfo) = func_ioinfo; - return (0); -} - -/* - * EXTERN: int db_env_set_func_malloc __P((void *(*)(size_t))); - */ -int -db_env_set_func_malloc(func_malloc) - void *(*func_malloc) __P((size_t)); -{ - DB_GLOBAL(j_malloc) = func_malloc; - return (0); -} - -/* - * EXTERN: int db_env_set_func_map - * EXTERN: __P((int (*)(char *, size_t, int, int, void **))); - */ -int -db_env_set_func_map(func_map) - int (*func_map) __P((char *, size_t, int, int, void **)); -{ - DB_GLOBAL(j_map) = func_map; - return (0); -} - -/* - * EXTERN: int db_env_set_func_open __P((int (*)(const char *, int, ...))); - */ -int -db_env_set_func_open(func_open) - int (*func_open) __P((const char *, int, ...)); -{ - DB_GLOBAL(j_open) = func_open; - return (0); -} - -/* - * EXTERN: int db_env_set_func_read __P((ssize_t (*)(int, void *, size_t))); - */ -int -db_env_set_func_read(func_read) - ssize_t (*func_read) __P((int, void *, size_t)); -{ - DB_GLOBAL(j_read) = func_read; - return (0); -} - -/* - * EXTERN: int db_env_set_func_realloc __P((void *(*)(void *, size_t))); - */ -int -db_env_set_func_realloc(func_realloc) - void *(*func_realloc) __P((void *, size_t)); -{ - DB_GLOBAL(j_realloc) = func_realloc; - return (0); -} - -/* - * EXTERN: int db_env_set_func_rename - * EXTERN: __P((int (*)(const char *, const char *))); - */ -int -db_env_set_func_rename(func_rename) - int (*func_rename) __P((const char *, const char *)); -{ - DB_GLOBAL(j_rename) = func_rename; - return (0); -} - -/* - * EXTERN: int db_env_set_func_seek - * EXTERN: __P((int (*)(int, size_t, db_pgno_t, u_int32_t, int, int))); - */ -int -db_env_set_func_seek(func_seek) - int (*func_seek) __P((int, size_t, db_pgno_t, u_int32_t, int, int)); -{ - DB_GLOBAL(j_seek) = func_seek; - return (0); -} - -/* - * EXTERN: int db_env_set_func_sleep __P((int (*)(u_long, u_long))); - */ -int -db_env_set_func_sleep(func_sleep) - int (*func_sleep) __P((u_long, u_long)); -{ - DB_GLOBAL(j_sleep) = func_sleep; - return (0); -} - -/* - * EXTERN: int db_env_set_func_unlink __P((int (*)(const char *))); - */ -int -db_env_set_func_unlink(func_unlink) - int (*func_unlink) __P((const char *)); -{ - DB_GLOBAL(j_unlink) = func_unlink; - return (0); -} - -/* - * EXTERN: int db_env_set_func_unmap __P((int (*)(void *, size_t))); - */ -int -db_env_set_func_unmap(func_unmap) - int (*func_unmap) __P((void *, size_t)); -{ - DB_GLOBAL(j_unmap) = func_unmap; - return (0); -} - -/* - * EXTERN: int db_env_set_func_write - * EXTERN: __P((ssize_t (*)(int, const void *, size_t))); - */ -int -db_env_set_func_write(func_write) - ssize_t (*func_write) __P((int, const void *, size_t)); -{ - DB_GLOBAL(j_write) = func_write; - return (0); -} - -/* - * EXTERN: int db_env_set_func_yield __P((int (*)(void))); - */ -int -db_env_set_func_yield(func_yield) - int (*func_yield) __P((void)); -{ - DB_GLOBAL(j_yield) = func_yield; - return (0); -} diff --git a/bdb/os/os_oflags.c b/bdb/os/os_oflags.c deleted file mode 100644 index f75178de75e..00000000000 --- a/bdb/os/os_oflags.c +++ /dev/null @@ -1,118 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_oflags.c,v 11.9 2002/01/11 15:53:00 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> -#include <sys/stat.h> - -#include <fcntl.h> -#endif - -#include "db_int.h" - -/* - * __db_oflags -- - * Convert open(2) flags to DB flags. - * - * PUBLIC: u_int32_t __db_oflags __P((int)); - */ -u_int32_t -__db_oflags(oflags) - int oflags; -{ - u_int32_t dbflags; - - dbflags = 0; - - if (oflags & O_CREAT) - dbflags |= DB_CREATE; - - if (oflags & O_TRUNC) - dbflags |= DB_TRUNCATE; - - /* - * !!! - * Convert POSIX 1003.1 open(2) mode flags to DB flags. This isn't - * an exact science as few POSIX implementations have a flag value - * for O_RDONLY, it's simply the lack of a write flag. - */ -#ifndef O_ACCMODE -#define O_ACCMODE (O_RDONLY | O_RDWR | O_WRONLY) -#endif - switch (oflags & O_ACCMODE) { - case O_RDWR: - case O_WRONLY: - break; - default: - dbflags |= DB_RDONLY; - break; - } - return (dbflags); -} - -/* - * __db_omode -- - * Convert a permission string to the correct open(2) flags. - * - * PUBLIC: int __db_omode __P((const char *)); - */ -int -__db_omode(perm) - const char *perm; -{ - int mode; - -#ifdef DB_WIN32 -#ifndef S_IRUSR -#define S_IRUSR S_IREAD /* R for owner */ -#endif -#ifndef S_IWUSR -#define S_IWUSR S_IWRITE /* W for owner */ -#endif -#ifndef S_IRGRP -#define S_IRGRP 0 /* R for group */ -#endif -#ifndef S_IWGRP -#define S_IWGRP 0 /* W for group */ -#endif -#ifndef S_IROTH -#define S_IROTH 0 /* R for other */ -#endif -#ifndef S_IWOTH -#define S_IWOTH 0 /* W for other */ -#endif -#else -#ifndef S_IRUSR -#define S_IRUSR 0000400 /* R for owner */ -#define S_IWUSR 0000200 /* W for owner */ -#define S_IRGRP 0000040 /* R for group */ -#define S_IWGRP 0000020 /* W for group */ -#define S_IROTH 0000004 /* R for other */ -#define S_IWOTH 0000002 /* W for other */ -#endif -#endif /* DB_WIN32 */ - mode = 0; - if (perm[0] == 'r') - mode |= S_IRUSR; - if (perm[1] == 'w') - mode |= S_IWUSR; - if (perm[2] == 'r') - mode |= S_IRGRP; - if (perm[3] == 'w') - mode |= S_IWGRP; - if (perm[4] == 'r') - mode |= S_IROTH; - if (perm[5] == 'w') - mode |= S_IWOTH; - return (mode); -} diff --git a/bdb/os/os_open.c b/bdb/os/os_open.c deleted file mode 100644 index 0a4dbadc6e8..00000000000 --- a/bdb/os/os_open.c +++ /dev/null @@ -1,257 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_open.c,v 11.37 2002/06/21 20:35:16 sandstro Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#include <fcntl.h> -#include <string.h> -#endif - -#include "db_int.h" - -#ifdef HAVE_QNX -static int __os_region_open __P((DB_ENV *, const char *, int, int, DB_FH *)); -#endif - -/* - * __os_open -- - * Open a file. - * - * PUBLIC: int __os_open __P((DB_ENV *, const char *, u_int32_t, int, DB_FH *)); - */ -int -__os_open(dbenv, name, flags, mode, fhp) - DB_ENV *dbenv; - const char *name; - u_int32_t flags; - int mode; - DB_FH *fhp; -{ - int oflags, ret; - - oflags = 0; - -#ifdef DIAGNOSTIC -#define OKFLAGS \ - (DB_OSO_CREATE | DB_OSO_DIRECT | DB_OSO_EXCL | DB_OSO_LOG | \ - DB_OSO_RDONLY | DB_OSO_REGION | DB_OSO_SEQ | DB_OSO_TEMP | \ - DB_OSO_TRUNC) - if ((ret = __db_fchk(dbenv, "__os_open", flags, OKFLAGS)) != 0) - return (ret); -#endif - -#if defined(O_BINARY) - /* - * If there's a binary-mode open flag, set it, we never want any - * kind of translation. Some systems do translations by default, - * e.g., with Cygwin, the default mode for an open() is set by the - * mode of the mount that underlies the file. - */ - oflags |= O_BINARY; -#endif - - /* - * DB requires the POSIX 1003.1 semantic that two files opened at the - * same time with DB_OSO_CREATE/O_CREAT and DB_OSO_EXCL/O_EXCL flags - * set return an EEXIST failure in at least one. - */ - if (LF_ISSET(DB_OSO_CREATE)) - oflags |= O_CREAT; - - if (LF_ISSET(DB_OSO_EXCL)) - oflags |= O_EXCL; - -#if defined(O_DSYNC) && defined(XXX_NEVER_SET) - /* - * !!! - * We should get better performance if we push the log files to disk - * immediately instead of waiting for the sync. However, Solaris - * (and likely any other system based on the 4BSD filesystem releases), - * doesn't implement O_DSYNC correctly, only flushing data blocks and - * not inode or indirect blocks. - */ - if (LF_ISSET(DB_OSO_LOG)) - oflags |= O_DSYNC; -#endif - - if (LF_ISSET(DB_OSO_RDONLY)) - oflags |= O_RDONLY; - else - oflags |= O_RDWR; - - if (LF_ISSET(DB_OSO_TRUNC)) - oflags |= O_TRUNC; - -#ifdef HAVE_O_DIRECT - if (LF_ISSET(DB_OSO_DIRECT)) - oflags |= O_DIRECT; -#endif - -#ifdef HAVE_QNX - if (LF_ISSET(DB_OSO_REGION)) - return (__os_region_open(dbenv, name, oflags, mode, fhp)); -#endif - /* Open the file. */ - if ((ret = __os_openhandle(dbenv, name, oflags, mode, fhp)) != 0) - return (ret); - -#ifdef HAVE_DIRECTIO - if (LF_ISSET(DB_OSO_DIRECT)) - (void)directio(fhp->fd, DIRECTIO_ON); -#endif - - /* - * Delete any temporary file. - * - * !!! - * There's a race here, where we've created a file and we crash before - * we can unlink it. Temporary files aren't common in DB, regardless, - * it's not a security problem because the file is empty. There's no - * reasonable way to avoid the race (playing signal games isn't worth - * the portability nightmare), so we just live with it. - */ - if (LF_ISSET(DB_OSO_TEMP)) { -#if defined(HAVE_UNLINK_WITH_OPEN_FAILURE) || defined(CONFIG_TEST) - if ((ret = __os_strdup(dbenv, name, &fhp->name)) != 0) { - (void)__os_closehandle(dbenv, fhp); - (void)__os_unlink(dbenv, name); - return (ret); - } - F_SET(fhp, DB_FH_UNLINK); -#else - (void)__os_unlink(dbenv, name); -#endif - } - - return (0); -} - -#ifdef HAVE_QNX -/* - * __os_region_open -- - * Open a shared memory region file using POSIX shm_open. - */ -static int -__os_region_open(dbenv, name, oflags, mode, fhp) - DB_ENV *dbenv; - const char *name; - int oflags; - int mode; - DB_FH *fhp; -{ - int ret; - char *newname; - - if ((ret = __os_shmname(dbenv, name, &newname)) != 0) - goto err; - memset(fhp, 0, sizeof(*fhp)); - fhp->fd = shm_open(newname, oflags, mode); - if (fhp->fd == -1) - ret = __os_get_errno(); - else { -#ifdef HAVE_FCNTL_F_SETFD - /* Deny file descriptor acces 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)); - __os_closehandle(dbenv, fhp); - } else -#endif - F_SET(fhp, DB_FH_VALID); - } - /* - * Once we have created the object, we don't need the name - * anymore. Other callers of this will convert themselves. - */ -err: - if (newname != NULL) - __os_free(dbenv, newname); - return (ret); -} - -/* - * __os_shmname -- - * Translate a pathname into a shm_open memory object name. - * - * PUBLIC: #ifdef HAVE_QNX - * PUBLIC: int __os_shmname __P((DB_ENV *, const char *, char **)); - * PUBLIC: #endif - */ -int -__os_shmname(dbenv, name, newnamep) - DB_ENV *dbenv; - const char *name; - char **newnamep; -{ - int ret; - size_t size; - char *p, *q, *tmpname; - - *newnamep = NULL; - - /* - * POSIX states that the name for a shared memory object - * may begin with a slash '/' and support for subsequent - * slashes is implementation-dependent. The one implementation - * we know of right now, QNX, forbids subsequent slashes. - * We don't want to be parsing pathnames for '.' and '..' in - * the middle. In order to allow easy conversion, just take - * the last component as the shared memory name. This limits - * the namespace a bit, but makes our job a lot easier. - * - * We should not be modifying user memory, so we use our own. - * Caller is responsible for freeing the memory we give them. - */ - if ((ret = __os_strdup(dbenv, name, &tmpname)) != 0) - return (ret); - /* - * Skip over filename component. - * We set that separator to '\0' so that we can do another - * __db_rpath. However, we immediately set it then to ':' - * so that we end up with the tailing directory:filename. - * We require a home directory component. Return an error - * if there isn't one. - */ - p = __db_rpath(tmpname); - if (p == NULL) - return (EINVAL); - if (p != tmpname) { - *p = '\0'; - q = p; - p = __db_rpath(tmpname); - *q = ':'; - } - if (p != NULL) { - /* - * If we have a path component, copy and return it. - */ - ret = __os_strdup(dbenv, p, newnamep); - __os_free(dbenv, tmpname); - return (ret); - } - - /* - * We were given just a directory name with no path components. - * Add a leading slash, and copy the remainder. - */ - size = strlen(tmpname) + 2; - if ((ret = __os_malloc(dbenv, size, &p)) != 0) - return (ret); - p[0] = '/'; - memcpy(&p[1], tmpname, size-1); - __os_free(dbenv, tmpname); - *newnamep = p; - return (0); -} -#endif diff --git a/bdb/os/os_region.c b/bdb/os/os_region.c deleted file mode 100644 index 6529f708b2c..00000000000 --- a/bdb/os/os_region.c +++ /dev/null @@ -1,115 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1996-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_region.c,v 11.15 2002/07/12 18:56:51 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#endif - -#include "db_int.h" - -/* - * __os_r_attach -- - * Attach to a shared memory region. - * - * PUBLIC: int __os_r_attach __P((DB_ENV *, REGINFO *, REGION *)); - */ -int -__os_r_attach(dbenv, infop, rp) - DB_ENV *dbenv; - REGINFO *infop; - REGION *rp; -{ - int ret; - /* Round off the requested size for the underlying VM. */ - OS_VMROUNDOFF(rp->size); - -#ifdef DB_REGIONSIZE_MAX - /* Some architectures have hard limits on the maximum region size. */ - if (rp->size > DB_REGIONSIZE_MAX) { - __db_err(dbenv, "region size %lu is too large; maximum is %lu", - (u_long)rp->size, (u_long)DB_REGIONSIZE_MAX); - return (EINVAL); - } -#endif - - /* - * If a region is private, malloc the memory. - * - * !!! - * If this fails because the region is too large to malloc, mmap(2) - * using the MAP_ANON or MAP_ANONYMOUS flags would be an alternative. - * I don't know of any architectures (yet!) where malloc is a problem. - */ - if (F_ISSET(dbenv, DB_ENV_PRIVATE)) { -#if defined(MUTEX_NO_MALLOC_LOCKS) - /* - * !!! - * There exist spinlocks that don't work in malloc memory, e.g., - * the HP/UX msemaphore interface. If we don't have locks that - * will work in malloc memory, we better not be private or not - * be threaded. - */ - if (F_ISSET(dbenv, DB_ENV_THREAD)) { - __db_err(dbenv, "%s", - "architecture does not support locks inside process-local (malloc) memory"); - __db_err(dbenv, "%s", - "application may not specify both DB_PRIVATE and DB_THREAD"); - return (EINVAL); - } -#endif - if ((ret = - __os_malloc(dbenv, rp->size, &infop->addr)) != 0) - return (ret); -#if defined(UMRW) && !defined(DIAGNOSTIC) - memset(infop->addr, CLEAR_BYTE, rp->size); -#endif - return (0); - } - - /* If the user replaced the map call, call through their interface. */ - if (DB_GLOBAL(j_map) != NULL) - return (DB_GLOBAL(j_map)(infop->name, - rp->size, 1, 0, &infop->addr)); - - return (__os_r_sysattach(dbenv, infop, rp)); -} - -/* - * __os_r_detach -- - * Detach from a shared memory region. - * - * PUBLIC: int __os_r_detach __P((DB_ENV *, REGINFO *, int)); - */ -int -__os_r_detach(dbenv, infop, destroy) - DB_ENV *dbenv; - REGINFO *infop; - int destroy; -{ - REGION *rp; - - rp = infop->rp; - - /* If a region is private, free the memory. */ - if (F_ISSET(dbenv, DB_ENV_PRIVATE)) { - __os_free(dbenv, infop->addr); - return (0); - } - - /* If the user replaced the map call, call through their interface. */ - if (DB_GLOBAL(j_unmap) != NULL) - return (DB_GLOBAL(j_unmap)(infop->addr, rp->size)); - - return (__os_r_sysdetach(dbenv, infop, destroy)); -} diff --git a/bdb/os/os_rename.c b/bdb/os/os_rename.c deleted file mode 100644 index 2569a9c3186..00000000000 --- a/bdb/os/os_rename.c +++ /dev/null @@ -1,47 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_rename.c,v 11.12 2002/07/12 18:56:52 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#include <string.h> -#include <unistd.h> -#endif - -#include "db_int.h" - -/* - * __os_rename -- - * Rename a file. If flags is non-zero, then errors are OK and we - * should not output an error message. - * - * PUBLIC: int __os_rename __P((DB_ENV *, - * PUBLIC: const char *, const char *, u_int32_t)); - */ -int -__os_rename(dbenv, old, new, flags) - DB_ENV *dbenv; - const char *old, *new; - u_int32_t flags; -{ - int ret; - - do { - ret = DB_GLOBAL(j_rename) != NULL ? - DB_GLOBAL(j_rename)(old, new) : rename(old, new); - } while (ret != 0 && (ret = __os_get_errno()) == EINTR); - - if (ret != 0 && flags == 0) - __db_err(dbenv, "rename %s %s: %s", old, new, strerror(ret)); - return (ret); -} diff --git a/bdb/os/os_root.c b/bdb/os/os_root.c deleted file mode 100644 index cd5bfc352e9..00000000000 --- a/bdb/os/os_root.c +++ /dev/null @@ -1,36 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1999-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_root.c,v 11.6 2002/01/11 15:53:01 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#include <unistd.h> -#endif - -#include "db_int.h" - -/* - * __os_isroot -- - * Return if user has special permissions. - * - * PUBLIC: int __os_isroot __P((void)); - */ -int -__os_isroot() -{ -#ifdef HAVE_GETUID - return (getuid() == 0); -#else - return (0); -#endif -} diff --git a/bdb/os/os_rpath.c b/bdb/os/os_rpath.c deleted file mode 100644 index b9ccba01bd5..00000000000 --- a/bdb/os/os_rpath.c +++ /dev/null @@ -1,69 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_rpath.c,v 11.7 2002/01/11 15:53:01 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <string.h> -#endif - -#include "db_int.h" -#ifdef HAVE_VXWORKS -#include "iosLib.h" -#endif - -/* - * __db_rpath -- - * Return the last path separator in the path or NULL if none found. - * - * PUBLIC: char *__db_rpath __P((const char *)); - */ -char * -__db_rpath(path) - const char *path; -{ - const char *s, *last; -#ifdef HAVE_VXWORKS - DEV_HDR *dummy; - char *ptail; - - /* - * VxWorks devices can be rooted at any name. We want to - * skip over the device name and not take into account any - * PATH_SEPARATOR characters that might be in that name. - * - * XXX [#2393] - * VxWorks supports having a filename directly follow a device - * name with no separator. I.e. to access a file 'xxx' in - * the top level directory of a device mounted at "mydrive" - * you could say "mydrivexxx" or "mydrive/xxx" or "mydrive\xxx". - * We do not support the first usage here. - * XXX - */ - if ((dummy = iosDevFind((char *)path, &ptail)) == NULL) - s = path; - else - s = ptail; -#else - s = path; -#endif - - last = NULL; - if (PATH_SEPARATOR[1] != '\0') { - for (; s[0] != '\0'; ++s) - if (strchr(PATH_SEPARATOR, s[0]) != NULL) - last = s; - } else - for (; s[0] != '\0'; ++s) - if (s[0] == PATH_SEPARATOR[0]) - last = s; - return ((char *)last); -} diff --git a/bdb/os/os_rw.c b/bdb/os/os_rw.c deleted file mode 100644 index 9a79342c7b8..00000000000 --- a/bdb/os/os_rw.c +++ /dev/null @@ -1,148 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_rw.c,v 11.24 2002/07/12 18:56:52 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#include <string.h> -#include <unistd.h> -#endif - -#include "db_int.h" - -/* - * __os_io -- - * Do an I/O. - * - * PUBLIC: int __os_io __P((DB_ENV *, DB_IO *, int, size_t *)); - */ -int -__os_io(dbenv, db_iop, op, niop) - DB_ENV *dbenv; - DB_IO *db_iop; - int op; - size_t *niop; -{ - int ret; - -#if defined(HAVE_PREAD) && defined(HAVE_PWRITE) - switch (op) { - case DB_IO_READ: - if (DB_GLOBAL(j_read) != NULL) - goto slow; - *niop = pread(db_iop->fhp->fd, db_iop->buf, - db_iop->bytes, (off_t)db_iop->pgno * db_iop->pagesize); - break; - case DB_IO_WRITE: - if (DB_GLOBAL(j_write) != NULL) - goto slow; - *niop = pwrite(db_iop->fhp->fd, db_iop->buf, - db_iop->bytes, (off_t)db_iop->pgno * db_iop->pagesize); - break; - } - if (*niop == (size_t)db_iop->bytes) - return (0); -slow: -#endif - MUTEX_THREAD_LOCK(dbenv, db_iop->mutexp); - - if ((ret = __os_seek(dbenv, db_iop->fhp, - db_iop->pagesize, db_iop->pgno, 0, 0, DB_OS_SEEK_SET)) != 0) - goto err; - switch (op) { - case DB_IO_READ: - ret = __os_read(dbenv, - db_iop->fhp, db_iop->buf, db_iop->bytes, niop); - break; - case DB_IO_WRITE: - ret = __os_write(dbenv, - db_iop->fhp, db_iop->buf, db_iop->bytes, niop); - break; - } - -err: MUTEX_THREAD_UNLOCK(dbenv, db_iop->mutexp); - - return (ret); - -} - -/* - * __os_read -- - * Read from a file handle. - * - * PUBLIC: int __os_read __P((DB_ENV *, DB_FH *, void *, size_t, size_t *)); - */ -int -__os_read(dbenv, fhp, addr, len, nrp) - DB_ENV *dbenv; - DB_FH *fhp; - void *addr; - size_t len; - size_t *nrp; -{ - size_t offset; - ssize_t nr; - int ret; - u_int8_t *taddr; - - for (taddr = addr, - offset = 0; offset < len; taddr += nr, offset += nr) { -retry: if ((nr = DB_GLOBAL(j_read) != NULL ? - DB_GLOBAL(j_read)(fhp->fd, taddr, len - offset) : - read(fhp->fd, taddr, len - offset)) < 0) { - if ((ret = __os_get_errno()) == EINTR) - goto retry; - __db_err(dbenv, "read: 0x%x, %lu: %s", taddr, - (u_long)len-offset, strerror(ret)); - return (ret); - } - if (nr == 0) - break; - } - *nrp = taddr - (u_int8_t *)addr; - return (0); -} - -/* - * __os_write -- - * Write to a file handle. - * - * PUBLIC: int __os_write __P((DB_ENV *, DB_FH *, void *, size_t, size_t *)); - */ -int -__os_write(dbenv, fhp, addr, len, nwp) - DB_ENV *dbenv; - DB_FH *fhp; - void *addr; - size_t len; - size_t *nwp; -{ - size_t offset; - ssize_t nw; - int ret; - u_int8_t *taddr; - - for (taddr = addr, - offset = 0; offset < len; taddr += nw, offset += nw) -retry: if ((nw = DB_GLOBAL(j_write) != NULL ? - DB_GLOBAL(j_write)(fhp->fd, taddr, len - offset) : - write(fhp->fd, taddr, len - offset)) < 0) { - if ((ret = __os_get_errno()) == EINTR) - goto retry; - __db_err(dbenv, "write: 0x%x, %lu: %s", taddr, - (u_long)len-offset, strerror(ret)); - return (ret); - } - *nwp = len; - return (0); -} diff --git a/bdb/os/os_seek.c b/bdb/os/os_seek.c deleted file mode 100644 index 5b2aa45d5dd..00000000000 --- a/bdb/os/os_seek.c +++ /dev/null @@ -1,77 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_seek.c,v 11.18 2002/07/12 18:56:52 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#include <stdlib.h> -#include <string.h> -#include <unistd.h> -#endif - -#include "db_int.h" - -/* - * __os_seek -- - * Seek to a page/byte offset in the file. - * - * PUBLIC: int __os_seek __P((DB_ENV *, - * PUBLIC: DB_FH *, size_t, db_pgno_t, u_int32_t, int, DB_OS_SEEK)); - */ -int -__os_seek(dbenv, fhp, pgsize, pageno, relative, isrewind, db_whence) - DB_ENV *dbenv; - DB_FH *fhp; - size_t pgsize; - db_pgno_t pageno; - u_int32_t relative; - int isrewind; - DB_OS_SEEK db_whence; -{ - off_t offset; - int ret, whence; - - switch (db_whence) { - case DB_OS_SEEK_CUR: - whence = SEEK_CUR; - break; - case DB_OS_SEEK_END: - whence = SEEK_END; - break; - case DB_OS_SEEK_SET: - whence = SEEK_SET; - break; - default: - return (EINVAL); - } - - if (DB_GLOBAL(j_seek) != NULL) - ret = DB_GLOBAL(j_seek)(fhp->fd, - pgsize, pageno, relative, isrewind, whence); - else { - offset = (off_t)pgsize * pageno + relative; - if (isrewind) - offset = -offset; - do { - ret = lseek(fhp->fd, offset, whence) == -1 ? - __os_get_errno() : 0; - } while (ret == EINTR); - } - - if (ret != 0) - __db_err(dbenv, "seek: %lu %d %d: %s", - (u_long)pgsize * pageno + relative, - isrewind, db_whence, strerror(ret)); - - return (ret); -} diff --git a/bdb/os/os_sleep.c b/bdb/os/os_sleep.c deleted file mode 100644 index 42d496dbae7..00000000000 --- a/bdb/os/os_sleep.c +++ /dev/null @@ -1,80 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_sleep.c,v 11.15 2002/07/12 18:56:52 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#ifdef HAVE_SYS_SELECT_H -#include <sys/select.h> -#endif - -#ifdef HAVE_VXWORKS -#include <sys/times.h> -#include <time.h> -#include <selectLib.h> -#else -#if TIME_WITH_SYS_TIME -#include <sys/time.h> -#include <time.h> -#else -#if HAVE_SYS_TIME_H -#include <sys/time.h> -#else -#include <time.h> -#endif /* HAVE_SYS_TIME_H */ -#endif /* TIME_WITH SYS_TIME */ -#endif /* HAVE_VXWORKS */ - -#include <string.h> -#include <unistd.h> -#endif - -#include "db_int.h" - -/* - * __os_sleep -- - * Yield the processor for a period of time. - * - * PUBLIC: int __os_sleep __P((DB_ENV *, u_long, u_long)); - */ -int -__os_sleep(dbenv, secs, usecs) - DB_ENV *dbenv; - u_long secs, usecs; /* Seconds and microseconds. */ -{ - struct timeval t; - int ret; - - /* Don't require that the values be normalized. */ - for (; usecs >= 1000000; usecs -= 1000000) - ++secs; - - if (DB_GLOBAL(j_sleep) != NULL) - return (DB_GLOBAL(j_sleep)(secs, usecs)); - - /* - * It's important that we yield the processor here so that other - * processes or threads are permitted to run. - */ - t.tv_sec = secs; - t.tv_usec = usecs; - do { - ret = select(0, NULL, NULL, NULL, &t) == -1 ? - __os_get_errno() : 0; - } while (ret == EINTR); - - if (ret != 0) - __db_err(dbenv, "select: %s", strerror(ret)); - - return (ret); -} diff --git a/bdb/os/os_spin.c b/bdb/os/os_spin.c deleted file mode 100644 index fb36977cb44..00000000000 --- a/bdb/os/os_spin.c +++ /dev/null @@ -1,113 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_spin.c,v 11.13 2002/08/07 02:02:07 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> -#if defined(HAVE_PSTAT_GETDYNAMIC) -#include <sys/pstat.h> -#endif - -#include <limits.h> -#include <unistd.h> -#endif - -#include "db_int.h" - -#if defined(HAVE_PSTAT_GETDYNAMIC) -static int __os_pstat_getdynamic __P((void)); - -/* - * __os_pstat_getdynamic -- - * HP/UX. - */ -static int -__os_pstat_getdynamic() -{ - struct pst_dynamic psd; - - return (pstat_getdynamic(&psd, - sizeof(psd), (size_t)1, 0) == -1 ? 1 : psd.psd_proc_cnt); -} -#endif - -#if defined(HAVE_SYSCONF) && defined(_SC_NPROCESSORS_ONLN) -static int __os_sysconf __P((void)); - -/* - * __os_sysconf -- - * Solaris, Linux. - */ -static int -__os_sysconf() -{ - long nproc; - - return ((nproc = sysconf(_SC_NPROCESSORS_ONLN)) > 1 ? (int)nproc : 1); -} -#endif - -/* - * __os_spin -- - * Return the number of default spins before blocking. - * - * PUBLIC: int __os_spin __P((DB_ENV *)); - */ -int -__os_spin(dbenv) - DB_ENV *dbenv; -{ - /* - * If the application specified a value or we've already figured it - * out, return it. - * - * XXX - * We don't want to repeatedly call the underlying function because - * it can be expensive (e.g., requiring multiple filesystem accesses - * under Debian Linux). - */ - if (dbenv->tas_spins != 0) - return (dbenv->tas_spins); - - dbenv->tas_spins = 1; -#if defined(HAVE_PSTAT_GETDYNAMIC) - dbenv->tas_spins = __os_pstat_getdynamic(); -#endif -#if defined(HAVE_SYSCONF) && defined(_SC_NPROCESSORS_ONLN) - dbenv->tas_spins = __os_sysconf(); -#endif - - /* - * Spin 50 times per processor, we have anecdotal evidence that this - * is a reasonable value. - */ - if (dbenv->tas_spins != 1) - dbenv->tas_spins *= 50; - - return (dbenv->tas_spins); -} - -/* - * __os_yield -- - * Yield the processor. - * - * PUBLIC: void __os_yield __P((DB_ENV*, u_long)); - */ -void -__os_yield(dbenv, usecs) - DB_ENV *dbenv; - u_long usecs; -{ - if (DB_GLOBAL(j_yield) != NULL && DB_GLOBAL(j_yield)() == 0) - return; - (void)__os_sleep(dbenv, 0, usecs); -} diff --git a/bdb/os/os_stat.c b/bdb/os/os_stat.c deleted file mode 100644 index c3510e36f5d..00000000000 --- a/bdb/os/os_stat.c +++ /dev/null @@ -1,119 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_stat.c,v 11.20 2002/07/12 18:56:53 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> -#include <sys/stat.h> - -#include <string.h> -#endif - -#include "db_int.h" - -/* - * __os_exists -- - * Return if the file exists. - * - * PUBLIC: int __os_exists __P((const char *, int *)); - */ -int -__os_exists(path, isdirp) - const char *path; - int *isdirp; -{ - int ret; - struct stat sb; - - if (DB_GLOBAL(j_exists) != NULL) - return (DB_GLOBAL(j_exists)(path, isdirp)); - - do { - ret = -#ifdef HAVE_VXWORKS - stat((char *)path, &sb); -#else - stat(path, &sb); -#endif - if (ret != 0) - ret = __os_get_errno(); - } while (ret == EINTR); - - if (ret != 0) - return (ret); - -#if !defined(S_ISDIR) || defined(STAT_MACROS_BROKEN) -#undef S_ISDIR -#ifdef _S_IFDIR -#define S_ISDIR(m) (_S_IFDIR & (m)) -#else -#define S_ISDIR(m) (((m) & 0170000) == 0040000) -#endif -#endif - if (isdirp != NULL) - *isdirp = S_ISDIR(sb.st_mode); - - return (0); -} - -/* - * __os_ioinfo -- - * Return file size and I/O size; abstracted to make it easier - * to replace. - * - * PUBLIC: int __os_ioinfo __P((DB_ENV *, const char *, - * PUBLIC: DB_FH *, u_int32_t *, u_int32_t *, u_int32_t *)); - */ -int -__os_ioinfo(dbenv, path, fhp, mbytesp, bytesp, iosizep) - DB_ENV *dbenv; - const char *path; - DB_FH *fhp; - u_int32_t *mbytesp, *bytesp, *iosizep; -{ - int ret; - struct stat sb; - - if (DB_GLOBAL(j_ioinfo) != NULL) - return (DB_GLOBAL(j_ioinfo)(path, - fhp->fd, mbytesp, bytesp, iosizep)); - -retry: - if (fstat(fhp->fd, &sb) == -1) { - if ((ret = __os_get_errno()) == EINTR) - goto retry; - __db_err(dbenv, "fstat: %s", strerror(ret)); - return (ret); - } - - /* Return the size of the file. */ - if (mbytesp != NULL) - *mbytesp = (u_int32_t)(sb.st_size / MEGABYTE); - if (bytesp != NULL) - *bytesp = (u_int32_t)(sb.st_size % MEGABYTE); - - /* - * Return the underlying filesystem blocksize, if available. - * - * XXX - * Check for a 0 size -- the HP MPE/iX architecture has st_blksize, - * but it's always 0. - */ -#ifdef HAVE_STRUCT_STAT_ST_BLKSIZE - if (iosizep != NULL && (*iosizep = sb.st_blksize) == 0) - *iosizep = DB_DEF_IOSIZE; -#else - if (iosizep != NULL) - *iosizep = DB_DEF_IOSIZE; -#endif - return (0); -} diff --git a/bdb/os/os_tmpdir.c b/bdb/os/os_tmpdir.c deleted file mode 100644 index 94645af5e71..00000000000 --- a/bdb/os/os_tmpdir.c +++ /dev/null @@ -1,121 +0,0 @@ -/*- - * 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_tmpdir.c,v 11.19 2002/01/11 15:53:02 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#include <stdlib.h> -#endif - -#include "db_int.h" - -#ifdef macintosh -#include <TFileSpec.h> -#endif - -/* - * __os_tmpdir -- - * Set the temporary directory path. - * - * The order of items in the list structure and the order of checks in - * the environment are documented. - * - * PUBLIC: int __os_tmpdir __P((DB_ENV *, u_int32_t)); - */ -int -__os_tmpdir(dbenv, flags) - DB_ENV *dbenv; - u_int32_t flags; -{ - int isdir; - - /* - * !!! - * Don't change this to: - * - * static const char * const list[] - * - * because it creates a text relocation in position independent code. - */ - static const char * list[] = { - "/var/tmp", - "/usr/tmp", - "/temp", /* Windows. */ - "/tmp", - "C:/temp", /* Windows. */ - "C:/tmp", /* Windows. */ - NULL - }; - const char * const *lp, *p; - - /* Use the environment if it's permitted and initialized. */ - if (LF_ISSET(DB_USE_ENVIRON) || - (LF_ISSET(DB_USE_ENVIRON_ROOT) && __os_isroot())) { - if ((p = getenv("TMPDIR")) != NULL && p[0] == '\0') { - __db_err(dbenv, "illegal TMPDIR environment variable"); - return (EINVAL); - } - /* Windows */ - if (p == NULL && (p = getenv("TEMP")) != NULL && p[0] == '\0') { - __db_err(dbenv, "illegal TEMP environment variable"); - return (EINVAL); - } - /* Windows */ - if (p == NULL && (p = getenv("TMP")) != NULL && p[0] == '\0') { - __db_err(dbenv, "illegal TMP environment variable"); - return (EINVAL); - } - /* Macintosh */ - if (p == NULL && - (p = getenv("TempFolder")) != NULL && p[0] == '\0') { - __db_err(dbenv, - "illegal TempFolder environment variable"); - return (EINVAL); - } - if (p != NULL) - return (__os_strdup(dbenv, p, &dbenv->db_tmp_dir)); - } - -#ifdef macintosh - /* Get the path to the temporary folder. */ - {FSSpec spec; - - if (!Special2FSSpec(kTemporaryFolderType, - kOnSystemDisk, 0, &spec)) - return (__os_strdup(dbenv, - FSp2FullPath(&spec), &dbenv->db_tmp_dir)); - } -#endif -#ifdef DB_WIN32 - /* Get the path to the temporary directory. */ - {int len; - char *eos, temp[MAXPATHLEN + 1]; - - if ((len = GetTempPath(sizeof(temp) - 1, temp)) > 2) { - eos = &temp[len]; - *eos-- = '\0'; - if (*eos == '\\' || *eos == '/') - *eos = '\0'; - if (__os_exists(temp, &isdir) == 0 && isdir != 0) - return (__os_strdup(dbenv, - temp, &dbenv->db_tmp_dir)); - } - } -#endif - - /* Step through the static list looking for a possibility. */ - for (lp = list; *lp != NULL; ++lp) - if (__os_exists(*lp, &isdir) == 0 && isdir != 0) - return (__os_strdup(dbenv, *lp, &dbenv->db_tmp_dir)); - return (0); -} diff --git a/bdb/os/os_unlink.c b/bdb/os/os_unlink.c deleted file mode 100644 index 28b03afd1aa..00000000000 --- a/bdb/os/os_unlink.c +++ /dev/null @@ -1,109 +0,0 @@ -/*- - * See the file LICENSE for redistribution information. - * - * Copyright (c) 1997-2002 - * Sleepycat Software. All rights reserved. - */ - -#include "db_config.h" - -#ifndef lint -static const char revid[] = "$Id: os_unlink.c,v 11.24 2002/07/12 18:56:53 bostic Exp $"; -#endif /* not lint */ - -#ifndef NO_SYSTEM_INCLUDES -#include <sys/types.h> - -#include <string.h> -#include <unistd.h> -#endif - -#include "db_int.h" - -/* - * __os_region_unlink -- - * Remove a shared memory object file. - * - * PUBLIC: int __os_region_unlink __P((DB_ENV *, const char *)); - */ -int -__os_region_unlink(dbenv, path) - DB_ENV *dbenv; - const char *path; -{ -#ifdef HAVE_QNX - int ret; - char *newname; - - if ((ret = __os_shmname(dbenv, path, &newname)) != 0) - goto err; - - if ((ret = shm_unlink(newname)) != 0) { - ret = __os_get_errno(); - if (ret != ENOENT) - __db_err(dbenv, "shm_unlink: %s: %s", - newname, strerror(ret)); - } -err: - if (newname != NULL) - __os_free(dbenv, newname); - return (ret); -#else - if (F_ISSET(dbenv, DB_ENV_OVERWRITE)) - (void)__db_overwrite(dbenv, path); - - return (__os_unlink(dbenv, path)); -#endif -} - -/* - * __os_unlink -- - * Remove a file. - * - * PUBLIC: int __os_unlink __P((DB_ENV *, const char *)); - */ -int -__os_unlink(dbenv, path) - DB_ENV *dbenv; - const char *path; -{ - int ret; - -retry: ret = DB_GLOBAL(j_unlink) != NULL ? - DB_GLOBAL(j_unlink)(path) : -#ifdef HAVE_VXWORKS - unlink((char *)path); -#else - unlink(path); -#endif - if (ret == -1) { - if ((ret = __os_get_errno()) == EINTR) - goto retry; - /* - * XXX - * We really shouldn't be looking at this value ourselves, - * but ENOENT usually signals that a file is missing, and - * we attempt to unlink things (such as v. 2.x environment - * regions, in DB_ENV->remove) that we're expecting not to - * be there. Reporting errors in these cases is annoying. - */ -#ifdef HAVE_VXWORKS - /* - * XXX - * The results of unlink are file system driver specific - * on VxWorks. In the case of removing a file that did - * not exist, some, at least, return an error, but with - * an errno of 0, not ENOENT. - * - * Code below falls through to original if-statement only - * we didn't get a "successful" error. - */ - if (ret != 0) - /* FALLTHROUGH */ -#endif - if (ret != ENOENT) - __db_err(dbenv, "unlink: %s: %s", path, strerror(ret)); - } - - return (ret); -} |