rec_utils.c revision 1.11 1 1.11 christos /* $NetBSD: rec_utils.c,v 1.11 2007/02/03 23:46:09 christos 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.1 cgd #if defined(LIBC_SCCS) && !defined(lint)
38 1.6 cgd #if 0
39 1.7 cgd static char sccsid[] = "@(#)rec_utils.c 8.6 (Berkeley) 7/16/94";
40 1.6 cgd #else
41 1.11 christos __RCSID("$NetBSD: rec_utils.c,v 1.11 2007/02/03 23:46:09 christos Exp $");
42 1.6 cgd #endif
43 1.1 cgd #endif /* LIBC_SCCS and not lint */
44 1.1 cgd
45 1.1 cgd #include <sys/param.h>
46 1.1 cgd
47 1.11 christos #include <assert.h>
48 1.1 cgd #include <stdio.h>
49 1.1 cgd #include <stdlib.h>
50 1.1 cgd #include <string.h>
51 1.1 cgd
52 1.1 cgd #include <db.h>
53 1.1 cgd #include "recno.h"
54 1.1 cgd
55 1.1 cgd /*
56 1.7 cgd * __rec_ret --
57 1.7 cgd * Build return data.
58 1.1 cgd *
59 1.1 cgd * Parameters:
60 1.1 cgd * t: tree
61 1.7 cgd * e: key/data pair to be returned
62 1.7 cgd * nrec: record number
63 1.7 cgd * key: user's key structure
64 1.1 cgd * data: user's data structure
65 1.1 cgd *
66 1.1 cgd * Returns:
67 1.1 cgd * RET_SUCCESS, RET_ERROR.
68 1.1 cgd */
69 1.1 cgd int
70 1.11 christos __rec_ret(BTREE *t, EPG *e, recno_t nrec, DBT *key, DBT *data)
71 1.1 cgd {
72 1.7 cgd RLEAF *rl;
73 1.7 cgd void *p;
74 1.1 cgd
75 1.7 cgd if (key == NULL)
76 1.7 cgd goto dataonly;
77 1.7 cgd
78 1.7 cgd /* We have to copy the key, it's not on the page. */
79 1.7 cgd if (sizeof(recno_t) > t->bt_rkey.size) {
80 1.7 cgd p = (void *)(t->bt_rkey.data == NULL ?
81 1.7 cgd malloc(sizeof(recno_t)) :
82 1.7 cgd realloc(t->bt_rkey.data, sizeof(recno_t)));
83 1.7 cgd if (p == NULL)
84 1.7 cgd return (RET_ERROR);
85 1.7 cgd t->bt_rkey.data = p;
86 1.7 cgd t->bt_rkey.size = sizeof(recno_t);
87 1.7 cgd }
88 1.7 cgd memmove(t->bt_rkey.data, &nrec, sizeof(recno_t));
89 1.7 cgd key->size = sizeof(recno_t);
90 1.7 cgd key->data = t->bt_rkey.data;
91 1.7 cgd
92 1.7 cgd dataonly:
93 1.1 cgd if (data == NULL)
94 1.7 cgd return (RET_SUCCESS);
95 1.1 cgd
96 1.4 cgd /*
97 1.7 cgd * We must copy big keys/data to make them contigous. Otherwise,
98 1.4 cgd * leave the page pinned and don't copy unless the user specified
99 1.4 cgd * concurrent access.
100 1.4 cgd */
101 1.7 cgd rl = GETRLEAF(e->page, e->index);
102 1.1 cgd if (rl->flags & P_BIGDATA) {
103 1.1 cgd if (__ovfl_get(t, rl->bytes,
104 1.7 cgd &data->size, &t->bt_rdata.data, &t->bt_rdata.size))
105 1.1 cgd return (RET_ERROR);
106 1.7 cgd data->data = t->bt_rdata.data;
107 1.7 cgd } else if (F_ISSET(t, B_DB_LOCK)) {
108 1.1 cgd /* Use +1 in case the first record retrieved is 0 length. */
109 1.7 cgd if (rl->dsize + 1 > t->bt_rdata.size) {
110 1.7 cgd p = (void *)(t->bt_rdata.data == NULL ?
111 1.5 cgd malloc(rl->dsize + 1) :
112 1.7 cgd realloc(t->bt_rdata.data, rl->dsize + 1));
113 1.5 cgd if (p == NULL)
114 1.1 cgd return (RET_ERROR);
115 1.7 cgd t->bt_rdata.data = p;
116 1.7 cgd t->bt_rdata.size = rl->dsize + 1;
117 1.1 cgd }
118 1.7 cgd memmove(t->bt_rdata.data, rl->bytes, rl->dsize);
119 1.1 cgd data->size = rl->dsize;
120 1.7 cgd data->data = t->bt_rdata.data;
121 1.4 cgd } else {
122 1.4 cgd data->size = rl->dsize;
123 1.4 cgd data->data = rl->bytes;
124 1.1 cgd }
125 1.1 cgd return (RET_SUCCESS);
126 1.1 cgd }
127