mirror of
https://sourceware.org/git/glibc.git
synced 2024-11-24 22:10:13 +00:00
bf7997b65c
1998-06-09 Ulrich Drepper <drepper@cygnus.com> * sysdeps/unix/sysv/linux/netinet/ip.h (struct ip_options): Define __data member only for gcc. Reported by ak@muc.de. * misc/mntent.h: Undo last patch. * sysdeps/unix/sysv/linux/fstatvfs.c (fstatvfs): Undo last patch. * misc/tst/mntent.c: Adjust code for this change. * io/fts.c: Updated from a slightly more recent BSD version. * io/fts.h: Likewise. * libc.map: Add __libc_stack_end. * db2/Makefile (routines): Add lock_region. * db2/config.h: Update from db-2.4.14. * db2/db.h: Likewise. * db2/db_185.h: Likewise. * db2/db_int.h: Likewise. * db2/bt_close.c: Likewise. * db2/bt_compare.c: Likewise. * db2/bt_conv.c: Likewise. * db2/bt_cursor.c: Likewise. * db2/bt_delete.c: Likewise. * db2/bt_open.c: Likewise. * db2/bt_page.c: Likewise. * db2/bt_put.c: Likewise. * db2/bt_rec.c: Likewise. * db2/bt_recno.c: Likewise. * db2/bt_rsearch.c: Likewise. * db2/bt_search.c: Likewise. * db2/bt_split.c: Likewise. * db2/bt_stat.c: Likewise. * db2/btree.src: Likewise. * db2/btree_auto.c: Likewise. * db2/getlong.c: Likewise. * db2/db_appinit.c: Likewise. * db2/db_apprec.c: Likewise. * db2/db_byteorder.c: Likewise. * db2/db_err.c: Likewise. * db2/db_log2.c: Likewise. * db2/db_region.c: Likewise. * db2/db_salloc.c: Likewise. * db2/db_shash.c: Likewise. * db2/db.c: Likewise. * db2/db.src: Likewise. * db2/db_auto.c: Likewise. * db2/db_conv.c: Likewise. * db2/db_dispatch.c: Likewise. * db2/db_dup.c: Likewise. * db2/db_overflow.c: Likewise. * db2/db_pr.c: Likewise. * db2/db_rec.c: Likewise. * db2/db_ret.c: Likewise. * db2/db_thread.c: Likewise. * db2/db185.c: Likewise. * db2/db185_int.h: Likewise. * db2/dbm.c: Likewise. * db2/hash.c: Likewise. * db2/hash.src: Likewise. * db2/hash_auto.c: Likewise. * db2/hash_conv.c: Likewise. * db2/hash_debug.c: Likewise. * db2/hash_dup.c: Likewise. * db2/hash_func.c: Likewise. * db2/hash_page.c: Likewise. * db2/hash_rec.c: Likewise. * db2/hash_stat.c: Likewise. * db2/btree.h: Likewise. * db2/btree_ext.h: Likewise. * db2/clib_ext.h: Likewise. * db2/common_ext.h: Likewise. * db2/cxx_int.h: Likewise. * db2/db.h.src: Likewise. * db2/db_185.h.src: Likewise. * db2/db_am.h: Likewise. * db2/db_auto.h: Likewise. * db2/db_cxx.h: Likewise. * db2/db_dispatch.h: Likewise. * db2/db_ext.h: Likewise. * db2/db_int.h.src: Likewise. * db2/db_page.h: Likewise. * db2/db_shash.h: Likewise. * db2/db_swap.h: Likewise. * db2/hash.h: Likewise. * db2/hash_ext.h: Likewise. * db2/lock.h: Likewise. * db2/lock_ext.h: Likewise. * db2/log.h: Likewise. * db2/log_ext.h: Likewise. * db2/mp.h: Likewise. * db2/mp_ext.h: Likewise. * db2/mutex_ext.h: Likewise. * db2/os_ext.h: Likewise. * db2/os_func.h: Likewise. * db2/queue.h: Likewise. * db2/shqueue.h: Likewise. * db2/txn.h: Likewise. * db2/lock.c: Likewise. * db2/lock_conflict.c: Likewise. * db2/lock_deadlock.c: Likewise. * db2/lock_region.c: Likewise. * db2/lock_util.c: Likewise. * db2/log.c: Likewise. * db2/log.src: Likewise. * db2/log_archive.c: Likewise. * db2/log_auto.c: Likewise. * db2/log_compare.c: Likewise. * db2/log_findckp.c: Likewise. * db2/log_get.c: Likewise. * db2/log_put.c: Likewise. * db2/log_rec.c: Likewise. * db2/log_register.c: Likewise. * db2/mp_bh.c: Likewise. * db2/mp_fget.c: Likewise. * db2/mp_fopen.c: Likewise. * db2/mp_fput.c: Likewise. * db2/mp_fset.c: Likewise. * db2/mp_open.c: Likewise. * db2/mp_pr.c: Likewise. * db2/mp_region.c: Likewise. * db2/mp_sync.c: Likewise. * db2/68020.gcc: Likewise. * db2/mutex.c: Likewise. * db2/parisc.gcc: Likewise. * db2/parisc.hp: Likewise. * db2/sco.cc: Likewise. * db2/os_abs.c: Likewise. * db2/os_alloc.c: Likewise. * db2/os_config.c: Likewise. * db2/os_dir.c: Likewise. * db2/os_fid.c: Likewise. * db2/os_fsync.c: Likewise. * db2/os_map.c: Likewise. * db2/os_oflags.c: Likewise. * db2/os_open.c: Likewise. * db2/os_rpath.c: Likewise. * db2/os_rw.c: Likewise. * db2/os_seek.c: Likewise. * db2/os_sleep.c: Likewise. * db2/os_spin.c: Likewise. * db2/os_stat.c: Likewise. * db2/os_unlink.c: Likewise. * db2/db_archive.c: Likewise. * db2/db_checkpoint.c: Likewise. * db2/db_deadlock.c: Likewise. * db2/db_dump.c: Likewise. * db2/db_dump185.c: Likewise. * db2/db_load.c: Likewise. * db2/db_printlog.c: Likewise. * db2/db_recover.c: Likewise. * db2/db_stat.c: Likewise. * db2/txn.c: Likewise. * db2/txn.src: Likewise. * db2/txn_auto.c: Likewise. * db2/txn_rec.c: Likewise. * elf/rtld.c: Move definition of __libc_stack_end to ... * sysdeps/generic/dl-sysdep.h: ...here. * sysdeps/unix/sysv/linux/fstatvfs.c: Handle nodiratime option. * sysdeps/unix/sysv/linux/bits/statvfs.h: Define ST_NODIRATIME. * sysdeps/unix/sysv/linux/sys/mount.h: Define MS_NODIRATIME. 1998-06-08 21:44 Ulrich Drepper <drepper@cygnus.com> * sysdeps/unix/sysv/linux/fstatvfs.c: Handle constant option string from mntent correctly. 1998-06-06 Andreas Jaeger <aj@arthur.rhein-neckar.de> * sunrpc/Makefile (generated): Correct typo. 1998-06-04 Philip Blundell <philb@gnu.org> * elf/elf.h (EM_ARM, et al.): New definitions. * sysdeps/arm/dl-machine.h: Update for new draft ARM ELF ABI.
506 lines
13 KiB
C
506 lines
13 KiB
C
/*-
|
|
* See the file LICENSE for redistribution information.
|
|
*
|
|
* Copyright (c) 1996, 1997, 1998
|
|
* Sleepycat Software. All rights reserved.
|
|
*/
|
|
#include "config.h"
|
|
|
|
#ifndef lint
|
|
static const char sccsid[] = "@(#)mp_fopen.c 10.47 (Sleepycat) 5/4/98";
|
|
#endif /* not lint */
|
|
|
|
#ifndef NO_SYSTEM_INCLUDES
|
|
#include <sys/types.h>
|
|
|
|
#include <errno.h>
|
|
#include <string.h>
|
|
#endif
|
|
|
|
#include "db_int.h"
|
|
#include "shqueue.h"
|
|
#include "db_shash.h"
|
|
#include "mp.h"
|
|
#include "common_ext.h"
|
|
|
|
static int __memp_mf_close __P((DB_MPOOL *, DB_MPOOLFILE *));
|
|
static int __memp_mf_open __P((DB_MPOOL *,
|
|
const char *, size_t, db_pgno_t, DB_MPOOL_FINFO *, MPOOLFILE **));
|
|
|
|
/*
|
|
* memp_fopen --
|
|
* Open a backing file for the memory pool.
|
|
*/
|
|
int
|
|
memp_fopen(dbmp, path, flags, mode, pagesize, finfop, retp)
|
|
DB_MPOOL *dbmp;
|
|
const char *path;
|
|
u_int32_t flags;
|
|
int mode;
|
|
size_t pagesize;
|
|
DB_MPOOL_FINFO *finfop;
|
|
DB_MPOOLFILE **retp;
|
|
{
|
|
int ret;
|
|
|
|
/* Validate arguments. */
|
|
if ((ret = __db_fchk(dbmp->dbenv,
|
|
"memp_fopen", flags, DB_CREATE | DB_NOMMAP | DB_RDONLY)) != 0)
|
|
return (ret);
|
|
|
|
/* Require a non-zero pagesize. */
|
|
if (pagesize == 0) {
|
|
__db_err(dbmp->dbenv, "memp_fopen: pagesize not specified");
|
|
return (EINVAL);
|
|
}
|
|
|
|
return (__memp_fopen(dbmp,
|
|
NULL, path, flags, mode, pagesize, 1, finfop, retp));
|
|
}
|
|
|
|
/*
|
|
* __memp_fopen --
|
|
* Open a backing file for the memory pool; internal version.
|
|
*
|
|
* PUBLIC: int __memp_fopen __P((DB_MPOOL *, MPOOLFILE *, const char *,
|
|
* PUBLIC: u_int32_t, int, size_t, int, DB_MPOOL_FINFO *, DB_MPOOLFILE **));
|
|
*/
|
|
int
|
|
__memp_fopen(dbmp, mfp, path, flags, mode, pagesize, needlock, finfop, retp)
|
|
DB_MPOOL *dbmp;
|
|
MPOOLFILE *mfp;
|
|
const char *path;
|
|
u_int32_t flags;
|
|
int mode, needlock;
|
|
size_t pagesize;
|
|
DB_MPOOL_FINFO *finfop;
|
|
DB_MPOOLFILE **retp;
|
|
{
|
|
DB_ENV *dbenv;
|
|
DB_MPOOLFILE *dbmfp;
|
|
DB_MPOOL_FINFO finfo;
|
|
db_pgno_t last_pgno;
|
|
size_t size;
|
|
u_int32_t mbytes, bytes;
|
|
int ret;
|
|
u_int8_t idbuf[DB_FILE_ID_LEN];
|
|
char *rpath;
|
|
|
|
dbenv = dbmp->dbenv;
|
|
ret = 0;
|
|
rpath = NULL;
|
|
|
|
/*
|
|
* If mfp is provided, we take the DB_MPOOL_FINFO information from
|
|
* the mfp. We don't bother initializing everything, because some
|
|
* of them are expensive to acquire. If no mfp is provided and the
|
|
* finfop argument is NULL, we default the values.
|
|
*/
|
|
if (finfop == NULL) {
|
|
memset(&finfo, 0, sizeof(finfo));
|
|
if (mfp != NULL) {
|
|
finfo.ftype = mfp->ftype;
|
|
finfo.pgcookie = NULL;
|
|
finfo.fileid = NULL;
|
|
finfo.lsn_offset = mfp->lsn_off;
|
|
finfo.clear_len = mfp->clear_len;
|
|
} else {
|
|
finfo.ftype = 0;
|
|
finfo.pgcookie = NULL;
|
|
finfo.fileid = NULL;
|
|
finfo.lsn_offset = -1;
|
|
finfo.clear_len = 0;
|
|
}
|
|
finfop = &finfo;
|
|
}
|
|
|
|
/* Allocate and initialize the per-process structure. */
|
|
if ((dbmfp =
|
|
(DB_MPOOLFILE *)__db_calloc(1, sizeof(DB_MPOOLFILE))) == NULL) {
|
|
__db_err(dbenv, "memp_fopen: %s", strerror(ENOMEM));
|
|
return (ENOMEM);
|
|
}
|
|
dbmfp->dbmp = dbmp;
|
|
dbmfp->fd = -1;
|
|
if (LF_ISSET(DB_RDONLY))
|
|
F_SET(dbmfp, MP_READONLY);
|
|
|
|
if (path == NULL) {
|
|
if (LF_ISSET(DB_RDONLY)) {
|
|
__db_err(dbenv,
|
|
"memp_fopen: temporary files can't be readonly");
|
|
ret = EINVAL;
|
|
goto err;
|
|
}
|
|
size = 0;
|
|
last_pgno = 0;
|
|
} else {
|
|
/* Get the real name for this file and open it. */
|
|
if ((ret = __db_appname(dbenv,
|
|
DB_APP_DATA, NULL, path, 0, NULL, &rpath)) != 0)
|
|
goto err;
|
|
if ((ret = __db_open(rpath,
|
|
LF_ISSET(DB_CREATE | DB_RDONLY),
|
|
DB_CREATE | DB_RDONLY, mode, &dbmfp->fd)) != 0) {
|
|
__db_err(dbenv, "%s: %s", rpath, strerror(ret));
|
|
goto err;
|
|
}
|
|
|
|
/* Don't permit files that aren't a multiple of the pagesize. */
|
|
if ((ret = __db_ioinfo(rpath,
|
|
dbmfp->fd, &mbytes, &bytes, NULL)) != 0) {
|
|
__db_err(dbenv, "%s: %s", rpath, strerror(ret));
|
|
goto err;
|
|
}
|
|
if (bytes % pagesize) {
|
|
__db_err(dbenv,
|
|
"%s: file size not a multiple of the pagesize",
|
|
rpath);
|
|
ret = EINVAL;
|
|
goto err;
|
|
}
|
|
size = mbytes * MEGABYTE + bytes;
|
|
last_pgno = size == 0 ? 0 : (size - 1) / pagesize;
|
|
|
|
/*
|
|
* Get the file id if we weren't given one. Generated file id's
|
|
* don't use timestamps, otherwise there'd be no chance of any
|
|
* other process joining the party.
|
|
*/
|
|
if (finfop->fileid == NULL) {
|
|
if ((ret = __db_fileid(dbenv, rpath, 0, idbuf)) != 0)
|
|
goto err;
|
|
finfop->fileid = idbuf;
|
|
}
|
|
}
|
|
|
|
/*
|
|
* If we weren't provided an underlying shared object to join with,
|
|
* find/allocate the shared file objects. Also allocate space for
|
|
* for the per-process thread lock.
|
|
*/
|
|
if (needlock)
|
|
LOCKREGION(dbmp);
|
|
|
|
if (mfp == NULL)
|
|
ret = __memp_mf_open(dbmp,
|
|
path, pagesize, last_pgno, finfop, &mfp);
|
|
else {
|
|
++mfp->ref;
|
|
ret = 0;
|
|
}
|
|
if (ret == 0 &&
|
|
F_ISSET(dbmp, MP_LOCKHANDLE) && (ret =
|
|
__memp_ralloc(dbmp, sizeof(db_mutex_t), NULL, &dbmfp->mutexp)) == 0)
|
|
LOCKINIT(dbmp, dbmfp->mutexp);
|
|
|
|
if (needlock)
|
|
UNLOCKREGION(dbmp);
|
|
if (ret != 0)
|
|
goto err;
|
|
|
|
dbmfp->mfp = mfp;
|
|
|
|
/*
|
|
* If a file:
|
|
* + is read-only
|
|
* + isn't temporary
|
|
* + doesn't require any pgin/pgout support
|
|
* + the DB_NOMMAP flag wasn't set
|
|
* + and is less than mp_mmapsize bytes in size
|
|
*
|
|
* we can mmap it instead of reading/writing buffers. Don't do error
|
|
* checking based on the mmap call failure. We want to do normal I/O
|
|
* on the file if the reason we failed was because the file was on an
|
|
* NFS mounted partition, and we can fail in buffer I/O just as easily
|
|
* as here.
|
|
*
|
|
* XXX
|
|
* We'd like to test to see if the file is too big to mmap. Since we
|
|
* don't know what size or type off_t's or size_t's are, or the largest
|
|
* unsigned integral type is, or what random insanity the local C
|
|
* compiler will perpetrate, doing the comparison in a portable way is
|
|
* flatly impossible. Hope that mmap fails if the file is too large.
|
|
*/
|
|
#define DB_MAXMMAPSIZE (10 * 1024 * 1024) /* 10 Mb. */
|
|
if (F_ISSET(mfp, MP_CAN_MMAP)) {
|
|
if (!F_ISSET(dbmfp, MP_READONLY))
|
|
F_CLR(mfp, MP_CAN_MMAP);
|
|
if (path == NULL)
|
|
F_CLR(mfp, MP_CAN_MMAP);
|
|
if (finfop->ftype != 0)
|
|
F_CLR(mfp, MP_CAN_MMAP);
|
|
if (LF_ISSET(DB_NOMMAP))
|
|
F_CLR(mfp, MP_CAN_MMAP);
|
|
if (size > (dbenv == NULL || dbenv->mp_mmapsize == 0 ?
|
|
DB_MAXMMAPSIZE : dbenv->mp_mmapsize))
|
|
F_CLR(mfp, MP_CAN_MMAP);
|
|
}
|
|
dbmfp->addr = NULL;
|
|
if (F_ISSET(mfp, MP_CAN_MMAP)) {
|
|
dbmfp->len = size;
|
|
if (__db_mapfile(rpath,
|
|
dbmfp->fd, dbmfp->len, 1, &dbmfp->addr) != 0) {
|
|
dbmfp->addr = NULL;
|
|
F_CLR(mfp, MP_CAN_MMAP);
|
|
}
|
|
}
|
|
if (rpath != NULL)
|
|
FREES(rpath);
|
|
|
|
LOCKHANDLE(dbmp, dbmp->mutexp);
|
|
TAILQ_INSERT_TAIL(&dbmp->dbmfq, dbmfp, q);
|
|
UNLOCKHANDLE(dbmp, dbmp->mutexp);
|
|
|
|
*retp = dbmfp;
|
|
return (0);
|
|
|
|
err: /*
|
|
* Note that we do not have to free the thread mutex, because we
|
|
* never get to here after we have successfully allocated it.
|
|
*/
|
|
if (rpath != NULL)
|
|
FREES(rpath);
|
|
if (dbmfp->fd != -1)
|
|
(void)__db_close(dbmfp->fd);
|
|
if (dbmfp != NULL)
|
|
FREE(dbmfp, sizeof(DB_MPOOLFILE));
|
|
return (ret);
|
|
}
|
|
|
|
/*
|
|
* __memp_mf_open --
|
|
* Open an MPOOLFILE.
|
|
*/
|
|
static int
|
|
__memp_mf_open(dbmp, path, pagesize, last_pgno, finfop, retp)
|
|
DB_MPOOL *dbmp;
|
|
const char *path;
|
|
size_t pagesize;
|
|
db_pgno_t last_pgno;
|
|
DB_MPOOL_FINFO *finfop;
|
|
MPOOLFILE **retp;
|
|
{
|
|
MPOOLFILE *mfp;
|
|
int ret;
|
|
void *p;
|
|
|
|
#define ISTEMPORARY (path == NULL)
|
|
|
|
/*
|
|
* Walk the list of MPOOLFILE's, looking for a matching file.
|
|
* Temporary files can't match previous files.
|
|
*/
|
|
if (!ISTEMPORARY)
|
|
for (mfp = SH_TAILQ_FIRST(&dbmp->mp->mpfq, __mpoolfile);
|
|
mfp != NULL; mfp = SH_TAILQ_NEXT(mfp, q, __mpoolfile)) {
|
|
if (F_ISSET(mfp, MP_TEMP))
|
|
continue;
|
|
if (!memcmp(finfop->fileid,
|
|
R_ADDR(dbmp, mfp->fileid_off), DB_FILE_ID_LEN)) {
|
|
if (finfop->clear_len != mfp->clear_len ||
|
|
finfop->ftype != mfp->ftype ||
|
|
pagesize != mfp->stat.st_pagesize) {
|
|
__db_err(dbmp->dbenv,
|
|
"%s: ftype, clear length or pagesize changed",
|
|
path);
|
|
return (EINVAL);
|
|
}
|
|
|
|
/* Found it: increment the reference count. */
|
|
++mfp->ref;
|
|
*retp = mfp;
|
|
return (0);
|
|
}
|
|
}
|
|
|
|
/* Allocate a new MPOOLFILE. */
|
|
if ((ret = __memp_ralloc(dbmp, sizeof(MPOOLFILE), NULL, &mfp)) != 0)
|
|
return (ret);
|
|
*retp = mfp;
|
|
|
|
/* Initialize the structure. */
|
|
memset(mfp, 0, sizeof(MPOOLFILE));
|
|
mfp->ref = 1;
|
|
mfp->ftype = finfop->ftype;
|
|
mfp->lsn_off = finfop->lsn_offset;
|
|
mfp->clear_len = finfop->clear_len;
|
|
|
|
/*
|
|
* If the user specifies DB_MPOOL_LAST or DB_MPOOL_NEW on a memp_fget,
|
|
* we have to know the last page in the file. Figure it out and save
|
|
* it away.
|
|
*/
|
|
mfp->stat.st_pagesize = pagesize;
|
|
mfp->orig_last_pgno = mfp->last_pgno = last_pgno;
|
|
|
|
F_SET(mfp, MP_CAN_MMAP);
|
|
if (ISTEMPORARY)
|
|
F_SET(mfp, MP_TEMP);
|
|
else {
|
|
/* Copy the file path into shared memory. */
|
|
if ((ret = __memp_ralloc(dbmp,
|
|
strlen(path) + 1, &mfp->path_off, &p)) != 0)
|
|
goto err;
|
|
memcpy(p, path, strlen(path) + 1);
|
|
|
|
/* Copy the file identification string into shared memory. */
|
|
if ((ret = __memp_ralloc(dbmp,
|
|
DB_FILE_ID_LEN, &mfp->fileid_off, &p)) != 0)
|
|
goto err;
|
|
memcpy(p, finfop->fileid, DB_FILE_ID_LEN);
|
|
}
|
|
|
|
/* Copy the page cookie into shared memory. */
|
|
if (finfop->pgcookie == NULL || finfop->pgcookie->size == 0) {
|
|
mfp->pgcookie_len = 0;
|
|
mfp->pgcookie_off = 0;
|
|
} else {
|
|
if ((ret = __memp_ralloc(dbmp,
|
|
finfop->pgcookie->size, &mfp->pgcookie_off, &p)) != 0)
|
|
goto err;
|
|
memcpy(p, finfop->pgcookie->data, finfop->pgcookie->size);
|
|
mfp->pgcookie_len = finfop->pgcookie->size;
|
|
}
|
|
|
|
/* Prepend the MPOOLFILE to the list of MPOOLFILE's. */
|
|
SH_TAILQ_INSERT_HEAD(&dbmp->mp->mpfq, mfp, q, __mpoolfile);
|
|
|
|
if (0) {
|
|
err: if (mfp->path_off != 0)
|
|
__db_shalloc_free(dbmp->addr,
|
|
R_ADDR(dbmp, mfp->path_off));
|
|
if (mfp->fileid_off != 0)
|
|
__db_shalloc_free(dbmp->addr,
|
|
R_ADDR(dbmp, mfp->fileid_off));
|
|
if (mfp != NULL)
|
|
__db_shalloc_free(dbmp->addr, mfp);
|
|
mfp = NULL;
|
|
}
|
|
return (0);
|
|
}
|
|
|
|
/*
|
|
* memp_fclose --
|
|
* Close a backing file for the memory pool.
|
|
*/
|
|
int
|
|
memp_fclose(dbmfp)
|
|
DB_MPOOLFILE *dbmfp;
|
|
{
|
|
DB_MPOOL *dbmp;
|
|
int ret, t_ret;
|
|
|
|
dbmp = dbmfp->dbmp;
|
|
ret = 0;
|
|
|
|
/* Complain if pinned blocks never returned. */
|
|
if (dbmfp->pinref != 0)
|
|
__db_err(dbmp->dbenv, "%s: close: %lu blocks left pinned",
|
|
__memp_fn(dbmfp), (u_long)dbmfp->pinref);
|
|
|
|
/* Remove the DB_MPOOLFILE structure from the list. */
|
|
LOCKHANDLE(dbmp, dbmp->mutexp);
|
|
TAILQ_REMOVE(&dbmp->dbmfq, dbmfp, q);
|
|
UNLOCKHANDLE(dbmp, dbmp->mutexp);
|
|
|
|
/* Close the underlying MPOOLFILE. */
|
|
(void)__memp_mf_close(dbmp, dbmfp);
|
|
|
|
/* Discard any mmap information. */
|
|
if (dbmfp->addr != NULL &&
|
|
(ret = __db_unmapfile(dbmfp->addr, dbmfp->len)) != 0)
|
|
__db_err(dbmp->dbenv,
|
|
"%s: %s", __memp_fn(dbmfp), strerror(ret));
|
|
|
|
/* Close the file; temporary files may not yet have been created. */
|
|
if (dbmfp->fd != -1 && (t_ret = __db_close(dbmfp->fd)) != 0) {
|
|
__db_err(dbmp->dbenv,
|
|
"%s: %s", __memp_fn(dbmfp), strerror(t_ret));
|
|
if (ret != 0)
|
|
t_ret = ret;
|
|
}
|
|
|
|
/* Free memory. */
|
|
if (dbmfp->mutexp != NULL) {
|
|
LOCKREGION(dbmp);
|
|
__db_shalloc_free(dbmp->addr, dbmfp->mutexp);
|
|
UNLOCKREGION(dbmp);
|
|
}
|
|
|
|
/* Discard the DB_MPOOLFILE structure. */
|
|
FREE(dbmfp, sizeof(DB_MPOOLFILE));
|
|
|
|
return (ret);
|
|
}
|
|
|
|
/*
|
|
* __memp_mf_close --
|
|
* Close down an MPOOLFILE.
|
|
*/
|
|
static int
|
|
__memp_mf_close(dbmp, dbmfp)
|
|
DB_MPOOL *dbmp;
|
|
DB_MPOOLFILE *dbmfp;
|
|
{
|
|
BH *bhp, *nbhp;
|
|
MPOOL *mp;
|
|
MPOOLFILE *mfp;
|
|
size_t mf_offset;
|
|
|
|
mp = dbmp->mp;
|
|
mfp = dbmfp->mfp;
|
|
|
|
LOCKREGION(dbmp);
|
|
|
|
/* If more than a single reference, simply decrement. */
|
|
if (mfp->ref > 1) {
|
|
--mfp->ref;
|
|
goto ret1;
|
|
}
|
|
|
|
/*
|
|
* Move any BH's held by the file to the free list. We don't free the
|
|
* memory itself because we may be discarding the memory pool, and it's
|
|
* fairly expensive to reintegrate the buffers back into the region for
|
|
* no purpose.
|
|
*/
|
|
mf_offset = R_OFFSET(dbmp, mfp);
|
|
for (bhp = SH_TAILQ_FIRST(&mp->bhq, __bh); bhp != NULL; bhp = nbhp) {
|
|
nbhp = SH_TAILQ_NEXT(bhp, q, __bh);
|
|
|
|
#ifdef DEBUG_NO_DIRTY
|
|
/* Complain if we find any blocks that were left dirty. */
|
|
if (F_ISSET(bhp, BH_DIRTY))
|
|
__db_err(dbmp->dbenv,
|
|
"%s: close: pgno %lu left dirty; ref %lu",
|
|
__memp_fn(dbmfp),
|
|
(u_long)bhp->pgno, (u_long)bhp->ref);
|
|
#endif
|
|
|
|
if (bhp->mf_offset == mf_offset) {
|
|
if (F_ISSET(bhp, BH_DIRTY)) {
|
|
++mp->stat.st_page_clean;
|
|
--mp->stat.st_page_dirty;
|
|
}
|
|
__memp_bhfree(dbmp, mfp, bhp, 0);
|
|
SH_TAILQ_INSERT_HEAD(&mp->bhfq, bhp, q, __bh);
|
|
}
|
|
}
|
|
|
|
/* Delete from the list of MPOOLFILEs. */
|
|
SH_TAILQ_REMOVE(&mp->mpfq, mfp, q, __mpoolfile);
|
|
|
|
/* Free the space. */
|
|
if (mfp->path_off != 0)
|
|
__db_shalloc_free(dbmp->addr, R_ADDR(dbmp, mfp->path_off));
|
|
if (mfp->fileid_off != 0)
|
|
__db_shalloc_free(dbmp->addr, R_ADDR(dbmp, mfp->fileid_off));
|
|
if (mfp->pgcookie_off != 0)
|
|
__db_shalloc_free(dbmp->addr, R_ADDR(dbmp, mfp->pgcookie_off));
|
|
__db_shalloc_free(dbmp->addr, mfp);
|
|
|
|
ret1: UNLOCKREGION(dbmp);
|
|
return (0);
|
|
}
|