rec_utils.c revision 1.15 1 1.15 andvar /* $NetBSD: rec_utils.c,v 1.15 2024/05/14 19:00:43 andvar Exp $ */
2 1.6 cgd
3 1.1 cgd /*-
4 1.5 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 * Redistribution and use in source and binary forms, with or without
8 1.1 cgd * modification, are permitted provided that the following conditions
9 1.1 cgd * are met:
10 1.1 cgd * 1. Redistributions of source code must retain the above copyright
11 1.1 cgd * notice, this list of conditions and the following disclaimer.
12 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 cgd * notice, this list of conditions and the following disclaimer in the
14 1.1 cgd * documentation and/or other materials provided with the distribution.
15 1.9 agc * 3. Neither the name of the University nor the names of its contributors
16 1.1 cgd * may be used to endorse or promote products derived from this software
17 1.1 cgd * without specific prior written permission.
18 1.1 cgd *
19 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
20 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
21 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
22 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
23 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
24 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
25 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
26 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
27 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
28 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
29 1.1 cgd * SUCH DAMAGE.
30 1.1 cgd */
31 1.1 cgd
32 1.10 jmc #if HAVE_NBTOOL_CONFIG_H
33 1.10 jmc #include "nbtool_config.h"
34 1.10 jmc #endif
35 1.10 jmc
36 1.8 christos #include <sys/cdefs.h>
37 1.15 andvar __RCSID("$NetBSD: rec_utils.c,v 1.15 2024/05/14 19:00:43 andvar Exp $");
38 1.1 cgd
39 1.1 cgd #include <sys/param.h>
40 1.1 cgd
41 1.11 christos #include <assert.h>
42 1.1 cgd #include <stdio.h>
43 1.1 cgd #include <stdlib.h>
44 1.1 cgd #include <string.h>
45 1.1 cgd
46 1.1 cgd #include <db.h>
47 1.1 cgd #include "recno.h"
48 1.1 cgd
49 1.1 cgd /*
50 1.7 cgd * __rec_ret --
51 1.7 cgd * Build return data.
52 1.1 cgd *
53 1.1 cgd * Parameters:
54 1.1 cgd * t: tree
55 1.7 cgd * e: key/data pair to be returned
56 1.7 cgd * nrec: record number
57 1.7 cgd * key: user's key structure
58 1.1 cgd * data: user's data structure
59 1.1 cgd *
60 1.1 cgd * Returns:
61 1.1 cgd * RET_SUCCESS, RET_ERROR.
62 1.1 cgd */
63 1.1 cgd int
64 1.11 christos __rec_ret(BTREE *t, EPG *e, recno_t nrec, DBT *key, DBT *data)
65 1.1 cgd {
66 1.7 cgd RLEAF *rl;
67 1.7 cgd void *p;
68 1.1 cgd
69 1.7 cgd if (key == NULL)
70 1.7 cgd goto dataonly;
71 1.7 cgd
72 1.7 cgd /* We have to copy the key, it's not on the page. */
73 1.13 christos if (sizeof(nrec) > t->bt_rkey.size) {
74 1.14 christos p = realloc(t->bt_rkey.data, sizeof(nrec));
75 1.7 cgd if (p == NULL)
76 1.7 cgd return (RET_ERROR);
77 1.7 cgd t->bt_rkey.data = p;
78 1.13 christos t->bt_rkey.size = sizeof(nrec);
79 1.7 cgd }
80 1.13 christos memmove(t->bt_rkey.data, &nrec, sizeof(nrec));
81 1.13 christos key->size = sizeof(nrec);
82 1.7 cgd key->data = t->bt_rkey.data;
83 1.7 cgd
84 1.7 cgd dataonly:
85 1.1 cgd if (data == NULL)
86 1.7 cgd return (RET_SUCCESS);
87 1.1 cgd
88 1.4 cgd /*
89 1.15 andvar * We must copy big keys/data to make them contiguous. Otherwise,
90 1.4 cgd * leave the page pinned and don't copy unless the user specified
91 1.4 cgd * concurrent access.
92 1.4 cgd */
93 1.7 cgd rl = GETRLEAF(e->page, e->index);
94 1.1 cgd if (rl->flags & P_BIGDATA) {
95 1.1 cgd if (__ovfl_get(t, rl->bytes,
96 1.7 cgd &data->size, &t->bt_rdata.data, &t->bt_rdata.size))
97 1.1 cgd return (RET_ERROR);
98 1.7 cgd data->data = t->bt_rdata.data;
99 1.7 cgd } else if (F_ISSET(t, B_DB_LOCK)) {
100 1.1 cgd /* Use +1 in case the first record retrieved is 0 length. */
101 1.7 cgd if (rl->dsize + 1 > t->bt_rdata.size) {
102 1.14 christos p = realloc(t->bt_rdata.data, rl->dsize + 1);
103 1.5 cgd if (p == NULL)
104 1.1 cgd return (RET_ERROR);
105 1.7 cgd t->bt_rdata.data = p;
106 1.7 cgd t->bt_rdata.size = rl->dsize + 1;
107 1.1 cgd }
108 1.7 cgd memmove(t->bt_rdata.data, rl->bytes, rl->dsize);
109 1.1 cgd data->size = rl->dsize;
110 1.7 cgd data->data = t->bt_rdata.data;
111 1.4 cgd } else {
112 1.4 cgd data->size = rl->dsize;
113 1.4 cgd data->data = rl->bytes;
114 1.1 cgd }
115 1.1 cgd return (RET_SUCCESS);
116 1.1 cgd }
117