1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 1998, 2012 Oracle and/or its affiliates. All rights reserved.
*
* $Id$
*/
#include "db_config.h"
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/btree.h"
#include "dbinc/lock.h"
/*
* __bam_reclaim --
* Free a database.
*
* PUBLIC: int __bam_reclaim __P((DB *, DB_THREAD_INFO *, DB_TXN *, u_int32_t));
*/
int
__bam_reclaim(dbp, ip, txn, flags)
DB *dbp;
DB_THREAD_INFO *ip;
DB_TXN *txn;
u_int32_t flags;
{
DBC *dbc;
DB_LOCK meta_lock;
int ret, t_ret;
/* Acquire a cursor. */
if ((ret = __db_cursor(dbp, ip, txn, &dbc, 0)) != 0)
return (ret);
/* Write lock the metapage for deallocations. */
if ((ret = __db_lget(dbc,
0, PGNO_BASE_MD, DB_LOCK_WRITE, 0, &meta_lock)) != 0)
goto err;
/* Avoid locking every page, we have the handle locked exclusive. */
F_SET(dbc, DBC_DONTLOCK);
/* Walk the tree, freeing pages. */
ret = __bam_traverse(dbc, DB_LOCK_WRITE,
PGNO_INVALID, __db_reclaim_callback, &flags);
if ((t_ret = __TLPUT(dbc, meta_lock)) != 0 && ret == 0)
ret = t_ret;
/* Discard the cursor. */
err: if ((t_ret = __dbc_close(dbc)) != 0 && ret == 0)
ret = t_ret;
return (ret);
}
/*
* __bam_truncate --
* Truncate a database.
*
* PUBLIC: int __bam_truncate __P((DBC *, u_int32_t *));
*/
int
__bam_truncate(dbc, countp)
DBC *dbc;
u_int32_t *countp;
{
u_int32_t count;
int ret;
#ifdef HAVE_COMPRESSION
u_int32_t comp_count;
comp_count = 0;
if (DB_IS_COMPRESSED(dbc->dbp) &&
(ret = __bam_compress_count(dbc, NULL, &comp_count)) != 0)
return (ret);
#endif
count = 0;
/* Walk the tree, freeing pages. */
ret = __bam_traverse(dbc,
DB_LOCK_WRITE, PGNO_INVALID, __db_truncate_callback, &count);
#ifdef HAVE_COMPRESSION
if (DB_IS_COMPRESSED(dbc->dbp)) {
if (countp != NULL)
*countp = comp_count;
} else
#endif
if (countp != NULL)
*countp = count;
return (ret);
}
|
