bt_search.c revision 1.19 1 1.19 christos /* $NetBSD: bt_search.c,v 1.19 2016/09/24 21:31:25 christos Exp $ */
2 1.7 cgd
3 1.1 cgd /*-
4 1.8 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.13 agc * 3. Neither the name of the University nor the names of its contributors
19 1.1 cgd * may be used to endorse or promote products derived from this software
20 1.1 cgd * without specific prior written permission.
21 1.1 cgd *
22 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
23 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
24 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
25 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
26 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
27 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
28 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
29 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
31 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32 1.1 cgd * SUCH DAMAGE.
33 1.1 cgd */
34 1.1 cgd
35 1.17 joerg #if HAVE_NBTOOL_CONFIG_H
36 1.17 joerg #include "nbtool_config.h"
37 1.17 joerg #endif
38 1.17 joerg
39 1.9 christos #include <sys/cdefs.h>
40 1.19 christos __RCSID("$NetBSD: bt_search.c,v 1.19 2016/09/24 21:31:25 christos Exp $");
41 1.1 cgd
42 1.10 jtc #include "namespace.h"
43 1.1 cgd #include <sys/types.h>
44 1.1 cgd
45 1.14 christos #include <assert.h>
46 1.1 cgd #include <stdio.h>
47 1.1 cgd
48 1.1 cgd #include <db.h>
49 1.1 cgd #include "btree.h"
50 1.1 cgd
51 1.14 christos static int __bt_snext(BTREE *, PAGE *, const DBT *, int *);
52 1.14 christos static int __bt_sprev(BTREE *, PAGE *, const DBT *, int *);
53 1.5 cgd
54 1.1 cgd /*
55 1.8 cgd * __bt_search --
56 1.8 cgd * Search a btree for a key.
57 1.1 cgd *
58 1.1 cgd * Parameters:
59 1.1 cgd * t: tree to search
60 1.1 cgd * key: key to find
61 1.1 cgd * exactp: pointer to exact match flag
62 1.1 cgd *
63 1.1 cgd * Returns:
64 1.4 cgd * The EPG for matching record, if any, or the EPG for the location
65 1.4 cgd * of the key, if it were inserted into the tree, is entered into
66 1.4 cgd * the bt_cur field of the tree. A pointer to the field is returned.
67 1.1 cgd */
68 1.1 cgd EPG *
69 1.14 christos __bt_search(BTREE *t, const DBT *key, int *exactp)
70 1.1 cgd {
71 1.6 cgd PAGE *h;
72 1.12 thorpej indx_t base, idx, lim;
73 1.1 cgd pgno_t pg;
74 1.6 cgd int cmp;
75 1.1 cgd
76 1.1 cgd BT_CLR(t);
77 1.1 cgd for (pg = P_ROOT;;) {
78 1.19 christos if ((h = mpool_get(t->bt_mp, pg, 0)) == NULL)
79 1.1 cgd return (NULL);
80 1.1 cgd
81 1.1 cgd /* Do a binary search on the current page. */
82 1.4 cgd t->bt_cur.page = h;
83 1.1 cgd for (base = 0, lim = NEXTINDEX(h); lim; lim >>= 1) {
84 1.15 joerg t->bt_cur.index = idx = base + ((uint32_t)lim >> 1);
85 1.4 cgd if ((cmp = __bt_cmp(t, key, &t->bt_cur)) == 0) {
86 1.1 cgd if (h->flags & P_BLEAF) {
87 1.1 cgd *exactp = 1;
88 1.4 cgd return (&t->bt_cur);
89 1.1 cgd }
90 1.1 cgd goto next;
91 1.1 cgd }
92 1.1 cgd if (cmp > 0) {
93 1.12 thorpej base = idx + 1;
94 1.1 cgd --lim;
95 1.1 cgd }
96 1.1 cgd }
97 1.1 cgd
98 1.5 cgd /*
99 1.8 cgd * If it's a leaf page, we're almost done. If no duplicates
100 1.8 cgd * are allowed, or we have an exact match, we're done. Else,
101 1.8 cgd * it's possible that there were matching keys on this page,
102 1.8 cgd * which later deleted, and we're on a page with no matches
103 1.8 cgd * while there are matches on other pages. If at the start or
104 1.8 cgd * end of a page, check the adjacent page.
105 1.5 cgd */
106 1.1 cgd if (h->flags & P_BLEAF) {
107 1.8 cgd if (!F_ISSET(t, B_NODUPS)) {
108 1.5 cgd if (base == 0 &&
109 1.8 cgd h->prevpg != P_INVALID &&
110 1.8 cgd __bt_sprev(t, h, key, exactp))
111 1.5 cgd return (&t->bt_cur);
112 1.5 cgd if (base == NEXTINDEX(h) &&
113 1.8 cgd h->nextpg != P_INVALID &&
114 1.8 cgd __bt_snext(t, h, key, exactp))
115 1.5 cgd return (&t->bt_cur);
116 1.5 cgd }
117 1.8 cgd *exactp = 0;
118 1.8 cgd t->bt_cur.index = base;
119 1.4 cgd return (&t->bt_cur);
120 1.1 cgd }
121 1.1 cgd
122 1.1 cgd /*
123 1.1 cgd * No match found. Base is the smallest index greater than
124 1.1 cgd * key and may be zero or a last + 1 index. If it's non-zero,
125 1.1 cgd * decrement by one, and record the internal page which should
126 1.1 cgd * be a parent page for the key. If a split later occurs, the
127 1.1 cgd * inserted page will be to the right of the saved page.
128 1.1 cgd */
129 1.12 thorpej idx = base ? base - 1 : base;
130 1.1 cgd
131 1.12 thorpej next: BT_PUSH(t, h->pgno, idx);
132 1.12 thorpej pg = GETBINTERNAL(h, idx)->pgno;
133 1.1 cgd mpool_put(t->bt_mp, h, 0);
134 1.1 cgd }
135 1.5 cgd }
136 1.5 cgd
137 1.5 cgd /*
138 1.8 cgd * __bt_snext --
139 1.8 cgd * Check for an exact match after the key.
140 1.5 cgd *
141 1.5 cgd * Parameters:
142 1.8 cgd * t: tree
143 1.8 cgd * h: current page
144 1.8 cgd * key: key
145 1.5 cgd * exactp: pointer to exact match flag
146 1.5 cgd *
147 1.5 cgd * Returns:
148 1.5 cgd * If an exact match found.
149 1.5 cgd */
150 1.5 cgd static int
151 1.14 christos __bt_snext(BTREE *t, PAGE *h, const DBT *key, int *exactp)
152 1.5 cgd {
153 1.18 christos BINTERNAL *bi;
154 1.5 cgd EPG e;
155 1.18 christos EPGNO *parent;
156 1.18 christos indx_t idx = 0;
157 1.18 christos pgno_t pgno;
158 1.18 christos int level;
159 1.5 cgd
160 1.5 cgd /*
161 1.8 cgd * Get the next page. The key is either an exact
162 1.8 cgd * match, or not as good as the one we already have.
163 1.5 cgd */
164 1.19 christos if ((e.page = mpool_get(t->bt_mp, h->nextpg, 0)) == NULL)
165 1.18 christos return 0;
166 1.8 cgd e.index = 0;
167 1.18 christos if (__bt_cmp(t, key, &e) != 0) {
168 1.18 christos mpool_put(t->bt_mp, e.page, 0);
169 1.18 christos return 0;
170 1.18 christos }
171 1.18 christos mpool_put(t->bt_mp, h, 0);
172 1.18 christos t->bt_cur = e;
173 1.18 christos *exactp = 1;
174 1.18 christos
175 1.18 christos /*
176 1.18 christos * Adjust the stack for the movement.
177 1.18 christos *
178 1.18 christos * Move up the stack.
179 1.18 christos */
180 1.18 christos for (level = 0; (parent = BT_POP(t)) != NULL; ++level) {
181 1.18 christos /* Get the parent page. */
182 1.19 christos if ((h = mpool_get(t->bt_mp, parent->pgno, 0)) == NULL)
183 1.18 christos return 0;
184 1.18 christos
185 1.18 christos /* Move to the next index. */
186 1.18 christos if (parent->index != NEXTINDEX(h) - 1) {
187 1.18 christos idx = parent->index + 1;
188 1.18 christos BT_PUSH(t, h->pgno, idx);
189 1.18 christos break;
190 1.18 christos }
191 1.18 christos
192 1.8 cgd mpool_put(t->bt_mp, h, 0);
193 1.5 cgd }
194 1.18 christos
195 1.18 christos /* Restore the stack. */
196 1.18 christos while (level--) {
197 1.18 christos /* Push the next level down onto the stack. */
198 1.18 christos bi = GETBINTERNAL(h, idx);
199 1.18 christos pgno = bi->pgno;
200 1.18 christos BT_PUSH(t, pgno, 0);
201 1.18 christos
202 1.18 christos /* Lose the currently pinned page. */
203 1.18 christos mpool_put(t->bt_mp, h, 0);
204 1.18 christos
205 1.18 christos /* Get the next level down. */
206 1.19 christos if ((h = mpool_get(t->bt_mp, pgno, 0)) == NULL)
207 1.18 christos return 0;
208 1.18 christos idx = 0;
209 1.18 christos }
210 1.18 christos mpool_put(t->bt_mp, h, 0);
211 1.18 christos return 1;
212 1.5 cgd }
213 1.5 cgd
214 1.5 cgd /*
215 1.8 cgd * __bt_sprev --
216 1.8 cgd * Check for an exact match before the key.
217 1.5 cgd *
218 1.5 cgd * Parameters:
219 1.8 cgd * t: tree
220 1.8 cgd * h: current page
221 1.8 cgd * key: key
222 1.5 cgd * exactp: pointer to exact match flag
223 1.5 cgd *
224 1.5 cgd * Returns:
225 1.5 cgd * If an exact match found.
226 1.5 cgd */
227 1.5 cgd static int
228 1.14 christos __bt_sprev(BTREE *t, PAGE *h, const DBT *key, int *exactp)
229 1.5 cgd {
230 1.18 christos BINTERNAL *bi;
231 1.5 cgd EPG e;
232 1.18 christos EPGNO *parent;
233 1.18 christos indx_t idx = 0;
234 1.18 christos pgno_t pgno;
235 1.18 christos int level;
236 1.5 cgd
237 1.5 cgd /*
238 1.8 cgd * Get the previous page. The key is either an exact
239 1.8 cgd * match, or not as good as the one we already have.
240 1.5 cgd */
241 1.19 christos if ((e.page = mpool_get(t->bt_mp, h->prevpg, 0)) == NULL)
242 1.18 christos return 0;
243 1.8 cgd e.index = NEXTINDEX(e.page) - 1;
244 1.18 christos if (__bt_cmp(t, key, &e) != 0) {
245 1.18 christos mpool_put(t->bt_mp, e.page, 0);
246 1.18 christos return 0;
247 1.18 christos }
248 1.18 christos
249 1.18 christos mpool_put(t->bt_mp, h, 0);
250 1.18 christos t->bt_cur = e;
251 1.18 christos *exactp = 1;
252 1.18 christos
253 1.18 christos /*
254 1.18 christos * Adjust the stack for the movement.
255 1.18 christos *
256 1.18 christos * Move up the stack.
257 1.18 christos */
258 1.18 christos for (level = 0; (parent = BT_POP(t)) != NULL; ++level) {
259 1.18 christos /* Get the parent page. */
260 1.19 christos if ((h = mpool_get(t->bt_mp, parent->pgno, 0)) == NULL)
261 1.18 christos return 1;
262 1.18 christos
263 1.18 christos /* Move to the next index. */
264 1.18 christos if (parent->index != 0) {
265 1.18 christos idx = parent->index - 1;
266 1.18 christos BT_PUSH(t, h->pgno, idx);
267 1.18 christos break;
268 1.18 christos }
269 1.8 cgd mpool_put(t->bt_mp, h, 0);
270 1.5 cgd }
271 1.18 christos
272 1.18 christos /* Restore the stack. */
273 1.18 christos while (level--) {
274 1.18 christos /* Push the next level down onto the stack. */
275 1.18 christos bi = GETBINTERNAL(h, idx);
276 1.18 christos pgno = bi->pgno;
277 1.18 christos
278 1.18 christos /* Lose the currently pinned page. */
279 1.18 christos mpool_put(t->bt_mp, h, 0);
280 1.18 christos
281 1.18 christos /* Get the next level down. */
282 1.19 christos if ((h = mpool_get(t->bt_mp, pgno, 0)) == NULL)
283 1.18 christos return 1;
284 1.18 christos
285 1.18 christos idx = NEXTINDEX(h) - 1;
286 1.18 christos BT_PUSH(t, pgno, idx);
287 1.18 christos }
288 1.18 christos mpool_put(t->bt_mp, h, 0);
289 1.18 christos return 1;
290 1.1 cgd }
291