diff options
Diffstat (limited to 'storage/bdb/hash/hash_reclaim.c')
-rw-r--r-- | storage/bdb/hash/hash_reclaim.c | 111 |
1 files changed, 111 insertions, 0 deletions
diff --git a/storage/bdb/hash/hash_reclaim.c b/storage/bdb/hash/hash_reclaim.c new file mode 100644 index 00000000000..ac90ffff08a --- /dev/null +++ b/storage/bdb/hash/hash_reclaim.c @@ -0,0 +1,111 @@ +/*- + * 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: hash_reclaim.c,v 11.12 2002/03/28 19:49:43 bostic Exp $"; +#endif /* not lint */ + +#ifndef NO_SYSTEM_INCLUDES +#include <sys/types.h> + +#include <string.h> +#endif + +#include "db_int.h" +#include "dbinc/db_page.h" +#include "dbinc/hash.h" + +/* + * __ham_reclaim -- + * Reclaim the pages from a subdatabase and return them to the + * parent free list. For now, we link each freed page on the list + * separately. If people really store hash databases in subdatabases + * and do a lot of creates and deletes, this is going to be a problem, + * because hash needs chunks of contiguous storage. We may eventually + * need to go to a model where we maintain the free list with chunks of + * contiguous pages as well. + * + * PUBLIC: int __ham_reclaim __P((DB *, DB_TXN *txn)); + */ +int +__ham_reclaim(dbp, txn) + DB *dbp; + DB_TXN *txn; +{ + DBC *dbc; + HASH_CURSOR *hcp; + int ret; + + /* Open up a cursor that we'll use for traversing. */ + if ((ret = dbp->cursor(dbp, txn, &dbc, 0)) != 0) + return (ret); + hcp = (HASH_CURSOR *)dbc->internal; + + if ((ret = __ham_get_meta(dbc)) != 0) + goto err; + + if ((ret = __ham_traverse(dbc, + DB_LOCK_WRITE, __db_reclaim_callback, dbc, 1)) != 0) + goto err; + if ((ret = dbc->c_close(dbc)) != 0) + goto err; + if ((ret = __ham_release_meta(dbc)) != 0) + goto err; + return (0); + +err: if (hcp->hdr != NULL) + (void)__ham_release_meta(dbc); + (void)dbc->c_close(dbc); + return (ret); +} + +/* + * __ham_truncate -- + * Reclaim the pages from a subdatabase and return them to the + * parent free list. + * + * PUBLIC: int __ham_truncate __P((DB *, DB_TXN *txn, u_int32_t *)); + */ +int +__ham_truncate(dbp, txn, countp) + DB *dbp; + DB_TXN *txn; + u_int32_t *countp; +{ + DBC *dbc; + HASH_CURSOR *hcp; + db_trunc_param trunc; + int ret; + + /* Open up a cursor that we'll use for traversing. */ + if ((ret = dbp->cursor(dbp, txn, &dbc, 0)) != 0) + return (ret); + hcp = (HASH_CURSOR *)dbc->internal; + + if ((ret = __ham_get_meta(dbc)) != 0) + goto err; + + trunc.count = 0; + trunc.dbc = dbc; + + if ((ret = __ham_traverse(dbc, + DB_LOCK_WRITE, __db_truncate_callback, &trunc, 1)) != 0) + goto err; + if ((ret = __ham_release_meta(dbc)) != 0) + goto err; + if ((ret = dbc->c_close(dbc)) != 0) + goto err; + *countp = trunc.count; + return (0); + +err: if (hcp->hdr != NULL) + (void)__ham_release_meta(dbc); + (void)dbc->c_close(dbc); + return (ret); +} |