ypdb.c revision 1.7 1 1.7 lukem /* $NetBSD: ypdb.c,v 1.7 1999/07/26 03:01:09 lukem Exp $ */
2 1.1 thorpej
3 1.1 thorpej /*
4 1.1 thorpej * Copyright (c) 1990, 1993
5 1.1 thorpej * The Regents of the University of California. All rights reserved.
6 1.1 thorpej * All rights reserved.
7 1.1 thorpej *
8 1.1 thorpej * This code is derived from software contributed to Berkeley by
9 1.1 thorpej * Margo Seltzer.
10 1.1 thorpej *
11 1.1 thorpej * This code is derived from ndbm module of BSD4.4 db (hash) by
12 1.1 thorpej * Mats O Jansson
13 1.1 thorpej *
14 1.1 thorpej * Redistribution and use in source and binary forms, with or without
15 1.1 thorpej * modification, are permitted provided that the following conditions
16 1.1 thorpej * are met:
17 1.1 thorpej * 1. Redistributions of source code must retain the above copyright
18 1.1 thorpej * notice, this list of conditions and the following disclaimer.
19 1.1 thorpej * 2. Redistributions in binary form must reproduce the above copyright
20 1.1 thorpej * notice, this list of conditions and the following disclaimer in the
21 1.1 thorpej * documentation and/or other materials provided with the distribution.
22 1.1 thorpej * 3. All advertising materials mentioning features or use of this software
23 1.1 thorpej * must display the following acknowledgement:
24 1.1 thorpej * This product includes software developed by the University of
25 1.1 thorpej * California, Berkeley and its contributors.
26 1.1 thorpej * 4. Neither the name of the University nor the names of its contributors
27 1.1 thorpej * may be used to endorse or promote products derived from this software
28 1.1 thorpej * without specific prior written permission.
29 1.1 thorpej *
30 1.1 thorpej * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
31 1.1 thorpej * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
32 1.1 thorpej * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
33 1.1 thorpej * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY
34 1.1 thorpej * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
35 1.1 thorpej * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
36 1.1 thorpej * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
37 1.1 thorpej * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
38 1.1 thorpej * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
39 1.1 thorpej * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
40 1.1 thorpej * SUCH DAMAGE.
41 1.1 thorpej */
42 1.1 thorpej
43 1.4 lukem #include <sys/cdefs.h>
44 1.4 lukem #ifndef lint
45 1.7 lukem __RCSID("$NetBSD: ypdb.c,v 1.7 1999/07/26 03:01:09 lukem Exp $");
46 1.4 lukem #endif
47 1.4 lukem
48 1.1 thorpej #include <sys/param.h>
49 1.1 thorpej #include <sys/types.h>
50 1.4 lukem
51 1.4 lukem #include <db.h>
52 1.4 lukem #include <errno.h>
53 1.1 thorpej #include <stdio.h>
54 1.1 thorpej #include <string.h>
55 1.1 thorpej
56 1.5 lukem #include <rpcsvc/yp.h>
57 1.5 lukem
58 1.1 thorpej #include "ypdb.h"
59 1.1 thorpej
60 1.1 thorpej /*
61 1.1 thorpej * Returns:
62 1.1 thorpej * *DBM on success
63 1.1 thorpej * NULL on failure
64 1.1 thorpej */
65 1.1 thorpej
66 1.3 lukem DBM *
67 1.1 thorpej ypdb_open(file, flags, mode)
68 1.1 thorpej const char *file;
69 1.1 thorpej int flags, mode;
70 1.1 thorpej {
71 1.4 lukem char path[MAXPATHLEN], *cp;
72 1.4 lukem DBM *db;
73 1.1 thorpej BTREEINFO info;
74 1.1 thorpej
75 1.4 lukem cp = strrchr(file, '.');
76 1.4 lukem snprintf(path, sizeof(path), "%s%s", file,
77 1.4 lukem (cp != NULL && strcmp(cp, ".db") == 0) ? "" : YPDB_SUFFIX);
78 1.4 lukem
79 1.4 lukem /* try our btree format first */
80 1.1 thorpej info.flags = 0;
81 1.1 thorpej info.cachesize = 0;
82 1.1 thorpej info.maxkeypage = 0;
83 1.1 thorpej info.minkeypage = 0;
84 1.1 thorpej info.psize = 0;
85 1.1 thorpej info.compare = NULL;
86 1.1 thorpej info.prefix = NULL;
87 1.1 thorpej info.lorder = 0;
88 1.4 lukem db = (DBM *)dbopen(path, flags, mode, DB_BTREE, (void *)&info);
89 1.4 lukem if (db != NULL || errno != EFTYPE)
90 1.4 lukem return (db);
91 1.4 lukem
92 1.4 lukem /* fallback to standard hash (for sendmail's aliases.db) */
93 1.4 lukem db = (DBM *)dbopen(path, flags, mode, DB_HASH, NULL);
94 1.4 lukem return (db);
95 1.1 thorpej }
96 1.1 thorpej
97 1.3 lukem void
98 1.1 thorpej ypdb_close(db)
99 1.1 thorpej DBM *db;
100 1.1 thorpej {
101 1.1 thorpej (void)(db->close)(db);
102 1.1 thorpej }
103 1.1 thorpej
104 1.1 thorpej /*
105 1.1 thorpej * Returns:
106 1.1 thorpej * DATUM on success
107 1.1 thorpej * NULL on failure
108 1.1 thorpej */
109 1.1 thorpej
110 1.3 lukem datum
111 1.1 thorpej ypdb_fetch(db, key)
112 1.1 thorpej DBM *db;
113 1.1 thorpej datum key;
114 1.1 thorpej {
115 1.6 lukem datum retkey;
116 1.6 lukem DBT nk, nd;
117 1.1 thorpej int status;
118 1.1 thorpej
119 1.6 lukem nk.data = key.dptr;
120 1.7 lukem nk.size = key.dsize;
121 1.6 lukem status = (db->get)(db, &nk, &nd, 0);
122 1.1 thorpej if (status) {
123 1.6 lukem retkey.dptr = NULL;
124 1.6 lukem retkey.dsize = 0;
125 1.6 lukem } else {
126 1.6 lukem retkey.dptr = nd.data;
127 1.7 lukem retkey.dsize = nd.size;
128 1.1 thorpej }
129 1.6 lukem return (retkey);
130 1.1 thorpej }
131 1.1 thorpej
132 1.1 thorpej /*
133 1.1 thorpej * Returns:
134 1.1 thorpej * DATUM on success
135 1.1 thorpej * NULL on failure
136 1.1 thorpej */
137 1.1 thorpej
138 1.3 lukem datum
139 1.1 thorpej ypdb_firstkey(db)
140 1.1 thorpej DBM *db;
141 1.1 thorpej {
142 1.1 thorpej int status;
143 1.6 lukem datum retkey;
144 1.6 lukem DBT nk, nd;
145 1.1 thorpej
146 1.6 lukem status = (db->seq)(db, &nk, &nd, R_FIRST);
147 1.6 lukem if (status) {
148 1.1 thorpej retkey.dptr = NULL;
149 1.6 lukem retkey.dsize = 0;
150 1.6 lukem } else {
151 1.6 lukem retkey.dptr = nk.data;
152 1.7 lukem retkey.dsize = nk.size;
153 1.6 lukem }
154 1.1 thorpej return (retkey);
155 1.1 thorpej }
156 1.1 thorpej
157 1.1 thorpej /*
158 1.1 thorpej * Returns:
159 1.1 thorpej * DATUM on success
160 1.1 thorpej * NULL on failure
161 1.1 thorpej */
162 1.1 thorpej
163 1.3 lukem datum
164 1.1 thorpej ypdb_nextkey(db)
165 1.1 thorpej DBM *db;
166 1.1 thorpej {
167 1.1 thorpej int status;
168 1.6 lukem datum retkey;
169 1.6 lukem DBT nk, nd;
170 1.1 thorpej
171 1.6 lukem status = (db->seq)(db, &nk, &nd, R_NEXT);
172 1.6 lukem if (status) {
173 1.1 thorpej retkey.dptr = NULL;
174 1.6 lukem retkey.dsize = 0;
175 1.6 lukem } else {
176 1.6 lukem retkey.dptr = nk.data;
177 1.7 lukem retkey.dsize = nk.size;
178 1.6 lukem }
179 1.1 thorpej return (retkey);
180 1.1 thorpej }
181 1.1 thorpej
182 1.1 thorpej /*
183 1.1 thorpej * Returns:
184 1.1 thorpej * DATUM on success
185 1.1 thorpej * NULL on failure
186 1.1 thorpej */
187 1.1 thorpej
188 1.3 lukem datum
189 1.1 thorpej ypdb_setkey(db, key)
190 1.1 thorpej DBM *db;
191 1.1 thorpej datum key;
192 1.1 thorpej {
193 1.1 thorpej int status;
194 1.6 lukem DBT nk, nd;
195 1.6 lukem
196 1.6 lukem nk.data = key.dptr;
197 1.7 lukem nk.size = key.dsize;
198 1.6 lukem status = (db->seq)(db, &nk, &nd, R_CURSOR);
199 1.6 lukem if (status) {
200 1.1 thorpej key.dptr = NULL;
201 1.6 lukem key.dsize = 0;
202 1.6 lukem }
203 1.1 thorpej return (key);
204 1.1 thorpej }
205 1.1 thorpej
206 1.1 thorpej /*
207 1.1 thorpej * Returns:
208 1.1 thorpej * 0 on success
209 1.1 thorpej * <0 failure
210 1.1 thorpej */
211 1.1 thorpej
212 1.1 thorpej int
213 1.1 thorpej ypdb_delete(db, key)
214 1.1 thorpej DBM *db;
215 1.1 thorpej datum key;
216 1.1 thorpej {
217 1.1 thorpej int status;
218 1.6 lukem DBT nk;
219 1.1 thorpej
220 1.6 lukem nk.data = key.dptr;
221 1.7 lukem nk.size = key.dsize;
222 1.6 lukem status = (db->del)(db, &nk, 0);
223 1.1 thorpej if (status)
224 1.1 thorpej return (-1);
225 1.1 thorpej else
226 1.1 thorpej return (0);
227 1.1 thorpej }
228 1.1 thorpej
229 1.1 thorpej /*
230 1.1 thorpej * Returns:
231 1.1 thorpej * 0 on success
232 1.1 thorpej * <0 failure
233 1.1 thorpej * 1 if YPDB_INSERT and entry exists
234 1.1 thorpej */
235 1.1 thorpej
236 1.1 thorpej int
237 1.1 thorpej ypdb_store(db, key, content, flags)
238 1.1 thorpej DBM *db;
239 1.1 thorpej datum key, content;
240 1.1 thorpej int flags;
241 1.1 thorpej {
242 1.6 lukem DBT nk, nd;
243 1.6 lukem
244 1.5 lukem if (key.dsize > YPMAXRECORD || content.dsize > YPMAXRECORD)
245 1.5 lukem return -1;
246 1.6 lukem nk.data = key.dptr;
247 1.7 lukem nk.size = key.dsize;
248 1.6 lukem nd.data = content.dptr;
249 1.7 lukem nd.size = content.dsize;
250 1.6 lukem return ((db->put)(db, &nk, &nd,
251 1.1 thorpej (flags == YPDB_INSERT) ? R_NOOVERWRITE : 0));
252 1.1 thorpej }
253