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