Home | History | Annotate | Line # | Download | only in btree
bt_close.c revision 1.9.14.1
      1  1.9.14.1   nathanw /*	$NetBSD: bt_close.c,v 1.9.14.1 2002/01/28 20:50:20 nathanw Exp $	*/
      2       1.6       cgd 
      3       1.1       cgd /*-
      4       1.7       cgd  * Copyright (c) 1990, 1993, 1994
      5       1.1       cgd  *	The Regents of the University of California.  All rights reserved.
      6       1.1       cgd  *
      7       1.1       cgd  * This code is derived from software contributed to Berkeley by
      8       1.1       cgd  * Mike Olson.
      9       1.1       cgd  *
     10       1.1       cgd  * Redistribution and use in source and binary forms, with or without
     11       1.1       cgd  * modification, are permitted provided that the following conditions
     12       1.1       cgd  * are met:
     13       1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     14       1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     15       1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     16       1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     17       1.1       cgd  *    documentation and/or other materials provided with the distribution.
     18       1.1       cgd  * 3. All advertising materials mentioning features or use of this software
     19       1.1       cgd  *    must display the following acknowledgement:
     20       1.1       cgd  *	This product includes software developed by the University of
     21       1.1       cgd  *	California, Berkeley and its contributors.
     22       1.1       cgd  * 4. Neither the name of the University nor the names of its contributors
     23       1.1       cgd  *    may be used to endorse or promote products derived from this software
     24       1.1       cgd  *    without specific prior written permission.
     25       1.1       cgd  *
     26       1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     27       1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     28       1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     29       1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     30       1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     31       1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     32       1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     33       1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     34       1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     35       1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     36       1.1       cgd  * SUCH DAMAGE.
     37       1.1       cgd  */
     38       1.1       cgd 
     39       1.8  christos #include <sys/cdefs.h>
     40       1.1       cgd #if defined(LIBC_SCCS) && !defined(lint)
     41       1.6       cgd #if 0
     42       1.7       cgd static char sccsid[] = "@(#)bt_close.c	8.7 (Berkeley) 8/17/94";
     43       1.6       cgd #else
     44  1.9.14.1   nathanw __RCSID("$NetBSD: bt_close.c,v 1.9.14.1 2002/01/28 20:50:20 nathanw Exp $");
     45       1.6       cgd #endif
     46       1.1       cgd #endif /* LIBC_SCCS and not lint */
     47       1.1       cgd 
     48       1.9       jtc #include "namespace.h"
     49       1.1       cgd 
     50       1.1       cgd #include <errno.h>
     51       1.1       cgd #include <stdio.h>
     52       1.1       cgd #include <stdlib.h>
     53       1.1       cgd #include <string.h>
     54       1.1       cgd #include <unistd.h>
     55       1.1       cgd 
     56       1.1       cgd #include <db.h>
     57       1.1       cgd #include "btree.h"
     58       1.1       cgd 
     59       1.1       cgd static int bt_meta __P((BTREE *));
     60       1.1       cgd 
     61       1.1       cgd /*
     62       1.1       cgd  * BT_CLOSE -- Close a btree.
     63       1.1       cgd  *
     64       1.1       cgd  * Parameters:
     65       1.1       cgd  *	dbp:	pointer to access method
     66       1.1       cgd  *
     67       1.1       cgd  * Returns:
     68       1.1       cgd  *	RET_ERROR, RET_SUCCESS
     69       1.1       cgd  */
     70       1.1       cgd int
     71       1.1       cgd __bt_close(dbp)
     72       1.1       cgd 	DB *dbp;
     73       1.1       cgd {
     74       1.1       cgd 	BTREE *t;
     75       1.1       cgd 	int fd;
     76       1.1       cgd 
     77       1.1       cgd 	t = dbp->internal;
     78       1.1       cgd 
     79       1.4       cgd 	/* Toss any page pinned across calls. */
     80       1.4       cgd 	if (t->bt_pinned != NULL) {
     81       1.4       cgd 		mpool_put(t->bt_mp, t->bt_pinned, 0);
     82       1.4       cgd 		t->bt_pinned = NULL;
     83       1.4       cgd 	}
     84       1.4       cgd 
     85       1.7       cgd 	/* Sync the tree. */
     86       1.1       cgd 	if (__bt_sync(dbp, 0) == RET_ERROR)
     87       1.1       cgd 		return (RET_ERROR);
     88       1.1       cgd 
     89       1.7       cgd 	/* Close the memory pool. */
     90       1.1       cgd 	if (mpool_close(t->bt_mp) == RET_ERROR)
     91       1.1       cgd 		return (RET_ERROR);
     92       1.1       cgd 
     93       1.7       cgd 	/* Free random memory. */
     94       1.7       cgd 	if (t->bt_cursor.key.data != NULL) {
     95       1.7       cgd 		free(t->bt_cursor.key.data);
     96       1.7       cgd 		t->bt_cursor.key.size = 0;
     97       1.7       cgd 		t->bt_cursor.key.data = NULL;
     98       1.7       cgd 	}
     99       1.7       cgd 	if (t->bt_rkey.data) {
    100       1.7       cgd 		free(t->bt_rkey.data);
    101       1.7       cgd 		t->bt_rkey.size = 0;
    102       1.7       cgd 		t->bt_rkey.data = NULL;
    103       1.7       cgd 	}
    104       1.7       cgd 	if (t->bt_rdata.data) {
    105       1.7       cgd 		free(t->bt_rdata.data);
    106       1.7       cgd 		t->bt_rdata.size = 0;
    107       1.7       cgd 		t->bt_rdata.data = NULL;
    108       1.7       cgd 	}
    109       1.1       cgd 
    110       1.1       cgd 	fd = t->bt_fd;
    111       1.1       cgd 	free(t);
    112       1.1       cgd 	free(dbp);
    113       1.1       cgd 	return (close(fd) ? RET_ERROR : RET_SUCCESS);
    114       1.1       cgd }
    115       1.1       cgd 
    116       1.1       cgd /*
    117       1.1       cgd  * BT_SYNC -- sync the btree to disk.
    118       1.1       cgd  *
    119       1.1       cgd  * Parameters:
    120       1.1       cgd  *	dbp:	pointer to access method
    121       1.1       cgd  *
    122       1.1       cgd  * Returns:
    123       1.1       cgd  *	RET_SUCCESS, RET_ERROR.
    124       1.1       cgd  */
    125       1.1       cgd int
    126       1.1       cgd __bt_sync(dbp, flags)
    127       1.1       cgd 	const DB *dbp;
    128       1.1       cgd 	u_int flags;
    129       1.1       cgd {
    130       1.1       cgd 	BTREE *t;
    131       1.1       cgd 	int status;
    132       1.1       cgd 
    133       1.4       cgd 	t = dbp->internal;
    134       1.4       cgd 
    135       1.4       cgd 	/* Toss any page pinned across calls. */
    136       1.4       cgd 	if (t->bt_pinned != NULL) {
    137       1.4       cgd 		mpool_put(t->bt_mp, t->bt_pinned, 0);
    138       1.4       cgd 		t->bt_pinned = NULL;
    139       1.4       cgd 	}
    140       1.4       cgd 
    141       1.4       cgd 	/* Sync doesn't currently take any flags. */
    142       1.1       cgd 	if (flags != 0) {
    143       1.1       cgd 		errno = EINVAL;
    144       1.1       cgd 		return (RET_ERROR);
    145       1.1       cgd 	}
    146       1.1       cgd 
    147       1.7       cgd 	if (F_ISSET(t, B_INMEM | B_RDONLY) || !F_ISSET(t, B_MODIFIED))
    148       1.1       cgd 		return (RET_SUCCESS);
    149       1.1       cgd 
    150       1.7       cgd 	if (F_ISSET(t, B_METADIRTY) && bt_meta(t) == RET_ERROR)
    151       1.1       cgd 		return (RET_ERROR);
    152       1.1       cgd 
    153       1.1       cgd 	if ((status = mpool_sync(t->bt_mp)) == RET_SUCCESS)
    154       1.7       cgd 		F_CLR(t, B_MODIFIED);
    155       1.1       cgd 
    156       1.1       cgd 	return (status);
    157       1.1       cgd }
    158       1.1       cgd 
    159       1.1       cgd /*
    160       1.1       cgd  * BT_META -- write the tree meta data to disk.
    161       1.1       cgd  *
    162       1.1       cgd  * Parameters:
    163       1.1       cgd  *	t:	tree
    164       1.1       cgd  *
    165       1.1       cgd  * Returns:
    166       1.1       cgd  *	RET_ERROR, RET_SUCCESS
    167       1.1       cgd  */
    168       1.1       cgd static int
    169       1.1       cgd bt_meta(t)
    170       1.1       cgd 	BTREE *t;
    171       1.1       cgd {
    172       1.1       cgd 	BTMETA m;
    173       1.1       cgd 	void *p;
    174       1.1       cgd 
    175       1.1       cgd 	if ((p = mpool_get(t->bt_mp, P_META, 0)) == NULL)
    176       1.1       cgd 		return (RET_ERROR);
    177       1.1       cgd 
    178       1.1       cgd 	/* Fill in metadata. */
    179       1.7       cgd 	m.magic = BTREEMAGIC;
    180       1.7       cgd 	m.version = BTREEVERSION;
    181       1.7       cgd 	m.psize = t->bt_psize;
    182       1.7       cgd 	m.free = t->bt_free;
    183       1.7       cgd 	m.nrecs = t->bt_nrecs;
    184       1.7       cgd 	m.flags = F_ISSET(t, SAVEMETA);
    185       1.1       cgd 
    186       1.1       cgd 	memmove(p, &m, sizeof(BTMETA));
    187       1.1       cgd 	mpool_put(t->bt_mp, p, MPOOL_DIRTY);
    188       1.1       cgd 	return (RET_SUCCESS);
    189       1.1       cgd }
    190