yplib.c revision 1.15 1 1.15 mycroft /* $NetBSD: yplib.c,v 1.15 1995/06/03 22:43:09 mycroft Exp $ */
2 1.14 cgd
3 1.3 deraadt /*
4 1.8 deraadt * Copyright (c) 1992, 1993 Theo de Raadt <deraadt (at) fsa.ca>
5 1.3 deraadt * All rights reserved.
6 1.3 deraadt *
7 1.3 deraadt * Redistribution and use in source and binary forms, with or without
8 1.3 deraadt * modification, are permitted provided that the following conditions
9 1.3 deraadt * are met:
10 1.3 deraadt * 1. Redistributions of source code must retain the above copyright
11 1.3 deraadt * notice, this list of conditions and the following disclaimer.
12 1.3 deraadt * 2. Redistributions in binary form must reproduce the above copyright
13 1.3 deraadt * notice, this list of conditions and the following disclaimer in the
14 1.3 deraadt * documentation and/or other materials provided with the distribution.
15 1.8 deraadt * 3. All advertising materials mentioning features or use of this software
16 1.8 deraadt * must display the following acknowledgement:
17 1.8 deraadt * This product includes software developed by Theo de Raadt.
18 1.8 deraadt * 4. The name of the author may not be used to endorse or promote products
19 1.8 deraadt * derived from this software without specific prior written permission.
20 1.3 deraadt *
21 1.3 deraadt * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
22 1.3 deraadt * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
23 1.3 deraadt * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
24 1.3 deraadt * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY
25 1.3 deraadt * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
26 1.3 deraadt * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
27 1.3 deraadt * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
28 1.3 deraadt * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
29 1.3 deraadt * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
30 1.3 deraadt * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31 1.3 deraadt * SUCH DAMAGE.
32 1.3 deraadt */
33 1.3 deraadt
34 1.3 deraadt #ifndef LINT
35 1.15 mycroft static char *rcsid = "$NetBSD: yplib.c,v 1.15 1995/06/03 22:43:09 mycroft Exp $";
36 1.3 deraadt #endif
37 1.3 deraadt
38 1.1 deraadt #include <sys/param.h>
39 1.1 deraadt #include <sys/types.h>
40 1.1 deraadt #include <sys/socket.h>
41 1.1 deraadt #include <sys/file.h>
42 1.7 deraadt #include <sys/uio.h>
43 1.1 deraadt #include <errno.h>
44 1.1 deraadt #include <stdio.h>
45 1.9 jtc #include <stdlib.h>
46 1.1 deraadt #include <string.h>
47 1.9 jtc #include <unistd.h>
48 1.1 deraadt #include <rpc/rpc.h>
49 1.1 deraadt #include <rpc/xdr.h>
50 1.1 deraadt #include <rpcsvc/yp_prot.h>
51 1.1 deraadt #include <rpcsvc/ypclnt.h>
52 1.1 deraadt
53 1.13 deraadt #define BINDINGDIR "/var/yp/binding"
54 1.13 deraadt #define YPBINDLOCK "/var/run/ypbind.lock"
55 1.1 deraadt #define YPMATCHCACHE
56 1.1 deraadt
57 1.1 deraadt extern bool_t xdr_domainname(), xdr_ypbind_resp();
58 1.1 deraadt extern bool_t xdr_ypreq_key(), xdr_ypresp_val();
59 1.1 deraadt extern bool_t xdr_ypreq_nokey(), xdr_ypresp_key_val();
60 1.1 deraadt extern bool_t xdr_ypresp_all(), xdr_ypresp_all_seq();
61 1.1 deraadt extern bool_t xdr_ypresp_master();
62 1.1 deraadt
63 1.1 deraadt int (*ypresp_allfn)();
64 1.1 deraadt void *ypresp_data;
65 1.1 deraadt
66 1.1 deraadt struct dom_binding *_ypbindlist;
67 1.1 deraadt static char _yp_domain[MAXHOSTNAMELEN];
68 1.1 deraadt int _yplib_timeout = 10;
69 1.1 deraadt
70 1.1 deraadt #ifdef YPMATCHCACHE
71 1.1 deraadt int _yplib_cache = 5;
72 1.1 deraadt
73 1.1 deraadt static struct ypmatch_ent {
74 1.1 deraadt struct ypmatch_ent *next;
75 1.1 deraadt char *map, *key, *val;
76 1.1 deraadt int keylen, vallen;
77 1.1 deraadt time_t expire_t;
78 1.1 deraadt } *ypmc;
79 1.1 deraadt
80 1.1 deraadt static void
81 1.1 deraadt ypmatch_add(map, key, keylen, val, vallen)
82 1.5 deraadt char *map;
83 1.5 deraadt char *key;
84 1.5 deraadt int keylen;
85 1.5 deraadt char *val;
86 1.5 deraadt int vallen;
87 1.1 deraadt {
88 1.1 deraadt struct ypmatch_ent *ep;
89 1.1 deraadt time_t t;
90 1.1 deraadt
91 1.1 deraadt time(&t);
92 1.1 deraadt
93 1.1 deraadt for(ep=ypmc; ep; ep=ep->next)
94 1.1 deraadt if(ep->expire_t < t)
95 1.1 deraadt break;
96 1.1 deraadt if(ep==NULL) {
97 1.1 deraadt ep = (struct ypmatch_ent *)malloc(sizeof *ep);
98 1.9 jtc memset(ep, 0, sizeof *ep);
99 1.1 deraadt if(ypmc)
100 1.1 deraadt ep->next = ypmc;
101 1.1 deraadt ypmc = ep;
102 1.1 deraadt }
103 1.1 deraadt
104 1.1 deraadt if(ep->key)
105 1.1 deraadt free(ep->key);
106 1.1 deraadt if(ep->val)
107 1.1 deraadt free(ep->val);
108 1.1 deraadt
109 1.1 deraadt ep->key = NULL;
110 1.1 deraadt ep->val = NULL;
111 1.1 deraadt
112 1.1 deraadt ep->key = (char *)malloc(keylen);
113 1.1 deraadt if(ep->key==NULL)
114 1.1 deraadt return;
115 1.1 deraadt
116 1.1 deraadt ep->val = (char *)malloc(vallen);
117 1.1 deraadt if(ep->key==NULL) {
118 1.1 deraadt free(ep->key);
119 1.1 deraadt ep->key = NULL;
120 1.1 deraadt return;
121 1.1 deraadt }
122 1.1 deraadt ep->keylen = keylen;
123 1.1 deraadt ep->vallen = vallen;
124 1.1 deraadt
125 1.9 jtc memcpy(ep->key, key, ep->keylen);
126 1.9 jtc memcpy(ep->val, val, ep->vallen);
127 1.1 deraadt
128 1.1 deraadt if(ep->map) {
129 1.1 deraadt if( strcmp(ep->map, map) ) {
130 1.1 deraadt free(ep->map);
131 1.1 deraadt ep->map = strdup(map);
132 1.1 deraadt }
133 1.1 deraadt } else {
134 1.1 deraadt ep->map = strdup(map);
135 1.1 deraadt }
136 1.1 deraadt
137 1.1 deraadt ep->expire_t = t + _yplib_cache;
138 1.1 deraadt }
139 1.1 deraadt
140 1.1 deraadt static bool_t
141 1.1 deraadt ypmatch_find(map, key, keylen, val, vallen)
142 1.5 deraadt char *map;
143 1.5 deraadt char *key;
144 1.1 deraadt int keylen;
145 1.1 deraadt char **val;
146 1.1 deraadt int *vallen;
147 1.1 deraadt {
148 1.1 deraadt struct ypmatch_ent *ep;
149 1.1 deraadt time_t t;
150 1.1 deraadt
151 1.1 deraadt if(ypmc==NULL)
152 1.1 deraadt return 0;
153 1.1 deraadt
154 1.1 deraadt time(&t);
155 1.1 deraadt
156 1.1 deraadt for(ep=ypmc; ep; ep=ep->next) {
157 1.1 deraadt if(ep->keylen != keylen)
158 1.1 deraadt continue;
159 1.1 deraadt if(strcmp(ep->map, map))
160 1.1 deraadt continue;
161 1.9 jtc if(memcmp(ep->key, key, keylen))
162 1.1 deraadt continue;
163 1.1 deraadt if(t > ep->expire_t)
164 1.1 deraadt continue;
165 1.1 deraadt
166 1.1 deraadt *val = ep->val;
167 1.1 deraadt *vallen = ep->vallen;
168 1.1 deraadt return 1;
169 1.1 deraadt }
170 1.1 deraadt return 0;
171 1.1 deraadt }
172 1.1 deraadt #endif
173 1.1 deraadt
174 1.1 deraadt int
175 1.1 deraadt _yp_dobind(dom, ypdb)
176 1.1 deraadt char *dom;
177 1.1 deraadt struct dom_binding **ypdb;
178 1.1 deraadt {
179 1.1 deraadt static int pid = -1;
180 1.1 deraadt char path[MAXPATHLEN];
181 1.1 deraadt struct dom_binding *ysd, *ysd2;
182 1.1 deraadt struct ypbind_resp ypbr;
183 1.1 deraadt struct timeval tv;
184 1.1 deraadt struct sockaddr_in clnt_sin;
185 1.1 deraadt int clnt_sock, fd, gpid;
186 1.1 deraadt CLIENT *client;
187 1.1 deraadt int new=0, r;
188 1.12 deraadt int count = 0;
189 1.1 deraadt
190 1.13 deraadt /*
191 1.13 deraadt * test if YP is running or not
192 1.13 deraadt */
193 1.13 deraadt if ((fd=open(YPBINDLOCK, O_RDONLY)) == -1)
194 1.13 deraadt return YPERR_YPBIND;
195 1.13 deraadt if( !(flock(fd, LOCK_EX|LOCK_NB) == -1 && errno==EWOULDBLOCK)) {
196 1.13 deraadt close(fd);
197 1.13 deraadt return YPERR_YPBIND;
198 1.13 deraadt }
199 1.13 deraadt close(fd);
200 1.13 deraadt
201 1.1 deraadt gpid = getpid();
202 1.1 deraadt if( !(pid==-1 || pid==gpid) ) {
203 1.1 deraadt ysd = _ypbindlist;
204 1.1 deraadt while(ysd) {
205 1.1 deraadt if(ysd->dom_client)
206 1.1 deraadt clnt_destroy(ysd->dom_client);
207 1.1 deraadt ysd2 = ysd->dom_pnext;
208 1.1 deraadt free(ysd);
209 1.1 deraadt ysd = ysd2;
210 1.1 deraadt }
211 1.1 deraadt _ypbindlist = NULL;
212 1.1 deraadt }
213 1.1 deraadt pid = gpid;
214 1.1 deraadt
215 1.1 deraadt if(ypdb!=NULL)
216 1.1 deraadt *ypdb = NULL;
217 1.1 deraadt
218 1.1 deraadt if(dom==NULL || strlen(dom)==0)
219 1.1 deraadt return YPERR_BADARGS;
220 1.1 deraadt
221 1.1 deraadt for(ysd = _ypbindlist; ysd; ysd = ysd->dom_pnext)
222 1.1 deraadt if( strcmp(dom, ysd->dom_domain) == 0)
223 1.1 deraadt break;
224 1.1 deraadt if(ysd==NULL) {
225 1.1 deraadt ysd = (struct dom_binding *)malloc(sizeof *ysd);
226 1.9 jtc memset(ysd, 0, sizeof *ysd);
227 1.1 deraadt ysd->dom_socket = -1;
228 1.1 deraadt ysd->dom_vers = 0;
229 1.1 deraadt new = 1;
230 1.1 deraadt }
231 1.1 deraadt again:
232 1.1 deraadt if(ysd->dom_vers==0) {
233 1.1 deraadt sprintf(path, "%s/%s.%d", BINDINGDIR, dom, 2);
234 1.1 deraadt if( (fd=open(path, O_RDONLY)) == -1) {
235 1.11 deraadt /* no binding file, YP is dead, or not yet fully alive. */
236 1.11 deraadt goto trynet;
237 1.1 deraadt }
238 1.1 deraadt if( flock(fd, LOCK_EX|LOCK_NB) == -1 && errno==EWOULDBLOCK) {
239 1.7 deraadt struct iovec iov[2];
240 1.7 deraadt struct ypbind_resp ybr;
241 1.7 deraadt u_short ypb_port;
242 1.7 deraadt
243 1.7 deraadt iov[0].iov_base = (caddr_t)&ypb_port;
244 1.7 deraadt iov[0].iov_len = sizeof ypb_port;
245 1.7 deraadt iov[1].iov_base = (caddr_t)&ybr;
246 1.7 deraadt iov[1].iov_len = sizeof ybr;
247 1.7 deraadt
248 1.7 deraadt r = readv(fd, iov, 2);
249 1.7 deraadt if(r != iov[0].iov_len + iov[1].iov_len) {
250 1.1 deraadt close(fd);
251 1.1 deraadt ysd->dom_vers = -1;
252 1.1 deraadt goto again;
253 1.1 deraadt }
254 1.7 deraadt
255 1.9 jtc memset(&ysd->dom_server_addr, 0, sizeof ysd->dom_server_addr);
256 1.15 mycroft ysd->dom_server_addr.sin_len = sizeof(struct sockaddr_in);
257 1.7 deraadt ysd->dom_server_addr.sin_family = AF_INET;
258 1.15 mycroft ysd->dom_server_addr.sin_port =
259 1.15 mycroft ybr.ypbind_respbody.ypbind_bindinfo.ypbind_binding_port;
260 1.7 deraadt ysd->dom_server_addr.sin_addr =
261 1.7 deraadt ybr.ypbind_respbody.ypbind_bindinfo.ypbind_binding_addr;
262 1.7 deraadt
263 1.1 deraadt ysd->dom_server_port = ysd->dom_server_addr.sin_port;
264 1.1 deraadt close(fd);
265 1.1 deraadt goto gotit;
266 1.1 deraadt } else {
267 1.1 deraadt /* no lock on binding file, YP is dead. */
268 1.1 deraadt close(fd);
269 1.1 deraadt if(new)
270 1.1 deraadt free(ysd);
271 1.1 deraadt return YPERR_YPBIND;
272 1.1 deraadt }
273 1.1 deraadt }
274 1.11 deraadt trynet:
275 1.1 deraadt if(ysd->dom_vers==-1 || ysd->dom_vers==0) {
276 1.9 jtc memset(&clnt_sin, 0, sizeof clnt_sin);
277 1.15 mycroft clnt_sin.sin_len = sizeof(struct sockaddr_in);
278 1.1 deraadt clnt_sin.sin_family = AF_INET;
279 1.1 deraadt clnt_sin.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
280 1.1 deraadt
281 1.1 deraadt clnt_sock = RPC_ANYSOCK;
282 1.1 deraadt client = clnttcp_create(&clnt_sin, YPBINDPROG, YPBINDVERS, &clnt_sock,
283 1.1 deraadt 0, 0);
284 1.1 deraadt if(client==NULL) {
285 1.1 deraadt clnt_pcreateerror("clnttcp_create");
286 1.1 deraadt if(new)
287 1.1 deraadt free(ysd);
288 1.1 deraadt return YPERR_YPBIND;
289 1.1 deraadt }
290 1.1 deraadt
291 1.1 deraadt tv.tv_sec = _yplib_timeout;
292 1.1 deraadt tv.tv_usec = 0;
293 1.1 deraadt r = clnt_call(client, YPBINDPROC_DOMAIN,
294 1.1 deraadt xdr_domainname, dom, xdr_ypbind_resp, &ypbr, tv);
295 1.1 deraadt if(r != RPC_SUCCESS) {
296 1.12 deraadt if (new==0 || count)
297 1.12 deraadt fprintf(stderr,
298 1.12 deraadt "YP server for domain %s not responding, still trying\n",
299 1.12 deraadt dom);
300 1.12 deraadt count++;
301 1.1 deraadt clnt_destroy(client);
302 1.1 deraadt ysd->dom_vers = -1;
303 1.1 deraadt goto again;
304 1.1 deraadt }
305 1.1 deraadt clnt_destroy(client);
306 1.1 deraadt
307 1.9 jtc memset(&ysd->dom_server_addr, 0, sizeof ysd->dom_server_addr);
308 1.15 mycroft ysd->dom_server_addr.sin_len = sizeof(struct sockaddr_in);
309 1.1 deraadt ysd->dom_server_addr.sin_family = AF_INET;
310 1.1 deraadt ysd->dom_server_addr.sin_port =
311 1.1 deraadt ypbr.ypbind_respbody.ypbind_bindinfo.ypbind_binding_port;
312 1.1 deraadt ysd->dom_server_addr.sin_addr.s_addr =
313 1.1 deraadt ypbr.ypbind_respbody.ypbind_bindinfo.ypbind_binding_addr.s_addr;
314 1.1 deraadt ysd->dom_server_port =
315 1.1 deraadt ypbr.ypbind_respbody.ypbind_bindinfo.ypbind_binding_port;
316 1.1 deraadt gotit:
317 1.1 deraadt ysd->dom_vers = YPVERS;
318 1.1 deraadt strcpy(ysd->dom_domain, dom);
319 1.1 deraadt }
320 1.1 deraadt
321 1.1 deraadt tv.tv_sec = _yplib_timeout/2;
322 1.1 deraadt tv.tv_usec = 0;
323 1.1 deraadt if(ysd->dom_client)
324 1.1 deraadt clnt_destroy(ysd->dom_client);
325 1.1 deraadt ysd->dom_socket = RPC_ANYSOCK;
326 1.1 deraadt ysd->dom_client = clntudp_create(&ysd->dom_server_addr,
327 1.1 deraadt YPPROG, YPVERS, tv, &ysd->dom_socket);
328 1.1 deraadt if(ysd->dom_client==NULL) {
329 1.1 deraadt clnt_pcreateerror("clntudp_create");
330 1.1 deraadt ysd->dom_vers = -1;
331 1.1 deraadt goto again;
332 1.1 deraadt }
333 1.1 deraadt if( fcntl(ysd->dom_socket, F_SETFD, 1) == -1)
334 1.1 deraadt perror("fcntl: F_SETFD");
335 1.1 deraadt
336 1.1 deraadt if(new) {
337 1.1 deraadt ysd->dom_pnext = _ypbindlist;
338 1.1 deraadt _ypbindlist = ysd;
339 1.1 deraadt }
340 1.1 deraadt
341 1.1 deraadt if(ypdb!=NULL)
342 1.1 deraadt *ypdb = ysd;
343 1.1 deraadt return 0;
344 1.1 deraadt }
345 1.1 deraadt
346 1.1 deraadt static void
347 1.1 deraadt _yp_unbind(ypb)
348 1.1 deraadt struct dom_binding *ypb;
349 1.1 deraadt {
350 1.1 deraadt clnt_destroy(ypb->dom_client);
351 1.1 deraadt ypb->dom_client = NULL;
352 1.1 deraadt ypb->dom_socket = -1;
353 1.1 deraadt }
354 1.1 deraadt
355 1.1 deraadt int
356 1.1 deraadt yp_bind(dom)
357 1.1 deraadt char *dom;
358 1.1 deraadt {
359 1.1 deraadt return _yp_dobind(dom, NULL);
360 1.1 deraadt }
361 1.1 deraadt
362 1.1 deraadt void
363 1.1 deraadt yp_unbind(dom)
364 1.1 deraadt char *dom;
365 1.1 deraadt {
366 1.1 deraadt struct dom_binding *ypb, *ypbp;
367 1.1 deraadt
368 1.1 deraadt ypbp = NULL;
369 1.1 deraadt for(ypb=_ypbindlist; ypb; ypb=ypb->dom_pnext) {
370 1.1 deraadt if( strcmp(dom, ypb->dom_domain) == 0) {
371 1.1 deraadt clnt_destroy(ypb->dom_client);
372 1.1 deraadt if(ypbp)
373 1.1 deraadt ypbp->dom_pnext = ypb->dom_pnext;
374 1.1 deraadt else
375 1.1 deraadt _ypbindlist = ypb->dom_pnext;
376 1.1 deraadt free(ypb);
377 1.1 deraadt return;
378 1.1 deraadt }
379 1.1 deraadt ypbp = ypb;
380 1.1 deraadt }
381 1.1 deraadt return;
382 1.1 deraadt }
383 1.1 deraadt
384 1.1 deraadt int
385 1.1 deraadt yp_match(indomain, inmap, inkey, inkeylen, outval, outvallen)
386 1.1 deraadt char *indomain;
387 1.1 deraadt char *inmap;
388 1.5 deraadt const char *inkey;
389 1.1 deraadt int inkeylen;
390 1.1 deraadt char **outval;
391 1.1 deraadt int *outvallen;
392 1.1 deraadt {
393 1.1 deraadt struct dom_binding *ysd;
394 1.1 deraadt struct ypresp_val yprv;
395 1.1 deraadt struct timeval tv;
396 1.1 deraadt struct ypreq_key yprk;
397 1.1 deraadt int r;
398 1.1 deraadt
399 1.1 deraadt *outval = NULL;
400 1.1 deraadt *outvallen = 0;
401 1.1 deraadt
402 1.1 deraadt again:
403 1.1 deraadt if( _yp_dobind(indomain, &ysd) != 0)
404 1.1 deraadt return YPERR_DOMAIN;
405 1.1 deraadt
406 1.1 deraadt #ifdef YPMATCHCACHE
407 1.1 deraadt if( !strcmp(_yp_domain, indomain) && ypmatch_find(inmap, inkey,
408 1.1 deraadt inkeylen, &yprv.valdat.dptr, &yprv.valdat.dsize)) {
409 1.1 deraadt *outvallen = yprv.valdat.dsize;
410 1.1 deraadt *outval = (char *)malloc(*outvallen+1);
411 1.9 jtc memcpy(*outval, yprv.valdat.dptr, *outvallen);
412 1.1 deraadt (*outval)[*outvallen] = '\0';
413 1.1 deraadt return 0;
414 1.1 deraadt }
415 1.1 deraadt #endif
416 1.1 deraadt
417 1.1 deraadt tv.tv_sec = _yplib_timeout;
418 1.1 deraadt tv.tv_usec = 0;
419 1.1 deraadt
420 1.1 deraadt yprk.domain = indomain;
421 1.1 deraadt yprk.map = inmap;
422 1.7 deraadt yprk.keydat.dptr = (char *)inkey;
423 1.1 deraadt yprk.keydat.dsize = inkeylen;
424 1.1 deraadt
425 1.9 jtc memset(&yprv, 0, sizeof yprv);
426 1.1 deraadt
427 1.1 deraadt r = clnt_call(ysd->dom_client, YPPROC_MATCH,
428 1.1 deraadt xdr_ypreq_key, &yprk, xdr_ypresp_val, &yprv, tv);
429 1.1 deraadt if(r != RPC_SUCCESS) {
430 1.1 deraadt clnt_perror(ysd->dom_client, "yp_match: clnt_call");
431 1.1 deraadt ysd->dom_vers = -1;
432 1.1 deraadt goto again;
433 1.1 deraadt }
434 1.1 deraadt if( !(r=ypprot_err(yprv.status)) ) {
435 1.1 deraadt *outvallen = yprv.valdat.dsize;
436 1.1 deraadt *outval = (char *)malloc(*outvallen+1);
437 1.9 jtc memcpy(*outval, yprv.valdat.dptr, *outvallen);
438 1.1 deraadt (*outval)[*outvallen] = '\0';
439 1.1 deraadt #ifdef YPMATCHCACHE
440 1.1 deraadt if( strcmp(_yp_domain, indomain)==0 )
441 1.1 deraadt ypmatch_add(inmap, inkey, inkeylen, *outval, *outvallen);
442 1.1 deraadt #endif
443 1.1 deraadt }
444 1.4 deraadt xdr_free(xdr_ypresp_val, (char *)&yprv);
445 1.1 deraadt _yp_unbind(ysd);
446 1.1 deraadt return r;
447 1.1 deraadt }
448 1.1 deraadt
449 1.1 deraadt int
450 1.1 deraadt yp_get_default_domain(domp)
451 1.1 deraadt char **domp;
452 1.1 deraadt {
453 1.1 deraadt *domp = NULL;
454 1.1 deraadt if(_yp_domain[0] == '\0')
455 1.1 deraadt if( getdomainname(_yp_domain, sizeof _yp_domain))
456 1.1 deraadt return YPERR_NODOM;
457 1.1 deraadt *domp = _yp_domain;
458 1.1 deraadt return 0;
459 1.1 deraadt }
460 1.1 deraadt
461 1.1 deraadt int
462 1.1 deraadt yp_first(indomain, inmap, outkey, outkeylen, outval, outvallen)
463 1.1 deraadt char *indomain;
464 1.1 deraadt char *inmap;
465 1.1 deraadt char **outkey;
466 1.1 deraadt int *outkeylen;
467 1.1 deraadt char **outval;
468 1.1 deraadt int *outvallen;
469 1.1 deraadt {
470 1.1 deraadt struct ypresp_key_val yprkv;
471 1.1 deraadt struct ypreq_nokey yprnk;
472 1.1 deraadt struct dom_binding *ysd;
473 1.1 deraadt struct timeval tv;
474 1.1 deraadt int r;
475 1.1 deraadt
476 1.1 deraadt *outkey = *outval = NULL;
477 1.1 deraadt *outkeylen = *outvallen = 0;
478 1.1 deraadt
479 1.1 deraadt again:
480 1.1 deraadt if( _yp_dobind(indomain, &ysd) != 0)
481 1.1 deraadt return YPERR_DOMAIN;
482 1.1 deraadt
483 1.1 deraadt tv.tv_sec = _yplib_timeout;
484 1.1 deraadt tv.tv_usec = 0;
485 1.1 deraadt
486 1.1 deraadt yprnk.domain = indomain;
487 1.1 deraadt yprnk.map = inmap;
488 1.9 jtc memset(&yprkv, 0, sizeof yprkv);
489 1.1 deraadt
490 1.1 deraadt r = clnt_call(ysd->dom_client, YPPROC_FIRST,
491 1.1 deraadt xdr_ypreq_nokey, &yprnk, xdr_ypresp_key_val, &yprkv, tv);
492 1.1 deraadt if(r != RPC_SUCCESS) {
493 1.1 deraadt clnt_perror(ysd->dom_client, "yp_first: clnt_call");
494 1.1 deraadt ysd->dom_vers = -1;
495 1.1 deraadt goto again;
496 1.1 deraadt }
497 1.1 deraadt if( !(r=ypprot_err(yprkv.status)) ) {
498 1.1 deraadt *outkeylen = yprkv.keydat.dsize;
499 1.1 deraadt *outkey = (char *)malloc(*outkeylen+1);
500 1.10 mycroft memcpy(*outkey, yprkv.keydat.dptr, *outkeylen);
501 1.1 deraadt (*outkey)[*outkeylen] = '\0';
502 1.1 deraadt *outvallen = yprkv.valdat.dsize;
503 1.1 deraadt *outval = (char *)malloc(*outvallen+1);
504 1.10 mycroft memcpy(*outval, yprkv.valdat.dptr, *outvallen);
505 1.1 deraadt (*outval)[*outvallen] = '\0';
506 1.1 deraadt }
507 1.4 deraadt xdr_free(xdr_ypresp_key_val, (char *)&yprkv);
508 1.1 deraadt _yp_unbind(ysd);
509 1.1 deraadt return r;
510 1.1 deraadt }
511 1.1 deraadt
512 1.1 deraadt int
513 1.1 deraadt yp_next(indomain, inmap, inkey, inkeylen, outkey, outkeylen, outval, outvallen)
514 1.1 deraadt char *indomain;
515 1.1 deraadt char *inmap;
516 1.1 deraadt char *inkey;
517 1.1 deraadt int inkeylen;
518 1.1 deraadt char **outkey;
519 1.1 deraadt int *outkeylen;
520 1.1 deraadt char **outval;
521 1.1 deraadt int *outvallen;
522 1.1 deraadt {
523 1.1 deraadt struct ypresp_key_val yprkv;
524 1.1 deraadt struct ypreq_key yprk;
525 1.1 deraadt struct dom_binding *ysd;
526 1.1 deraadt struct timeval tv;
527 1.1 deraadt int r;
528 1.1 deraadt
529 1.1 deraadt *outkey = *outval = NULL;
530 1.1 deraadt *outkeylen = *outvallen = 0;
531 1.1 deraadt
532 1.1 deraadt again:
533 1.1 deraadt if( _yp_dobind(indomain, &ysd) != 0)
534 1.1 deraadt return YPERR_DOMAIN;
535 1.1 deraadt
536 1.1 deraadt tv.tv_sec = _yplib_timeout;
537 1.1 deraadt tv.tv_usec = 0;
538 1.1 deraadt
539 1.1 deraadt yprk.domain = indomain;
540 1.1 deraadt yprk.map = inmap;
541 1.1 deraadt yprk.keydat.dptr = inkey;
542 1.1 deraadt yprk.keydat.dsize = inkeylen;
543 1.9 jtc memset(&yprkv, 0, sizeof yprkv);
544 1.1 deraadt
545 1.1 deraadt r = clnt_call(ysd->dom_client, YPPROC_NEXT,
546 1.1 deraadt xdr_ypreq_key, &yprk, xdr_ypresp_key_val, &yprkv, tv);
547 1.1 deraadt if(r != RPC_SUCCESS) {
548 1.1 deraadt clnt_perror(ysd->dom_client, "yp_next: clnt_call");
549 1.1 deraadt ysd->dom_vers = -1;
550 1.1 deraadt goto again;
551 1.1 deraadt }
552 1.1 deraadt if( !(r=ypprot_err(yprkv.status)) ) {
553 1.1 deraadt *outkeylen = yprkv.keydat.dsize;
554 1.1 deraadt *outkey = (char *)malloc(*outkeylen+1);
555 1.9 jtc memcpy(*outkey, yprkv.keydat.dptr, *outkeylen);
556 1.1 deraadt (*outkey)[*outkeylen] = '\0';
557 1.1 deraadt *outvallen = yprkv.valdat.dsize;
558 1.1 deraadt *outval = (char *)malloc(*outvallen+1);
559 1.9 jtc memcpy(*outval, yprkv.valdat.dptr, *outvallen);
560 1.1 deraadt (*outval)[*outvallen] = '\0';
561 1.1 deraadt }
562 1.4 deraadt xdr_free(xdr_ypresp_key_val, (char *)&yprkv);
563 1.1 deraadt _yp_unbind(ysd);
564 1.1 deraadt return r;
565 1.1 deraadt }
566 1.1 deraadt
567 1.1 deraadt int
568 1.1 deraadt yp_all(indomain, inmap, incallback)
569 1.1 deraadt char *indomain;
570 1.1 deraadt char *inmap;
571 1.1 deraadt struct ypall_callback *incallback;
572 1.1 deraadt {
573 1.1 deraadt struct ypreq_nokey yprnk;
574 1.1 deraadt struct dom_binding *ysd;
575 1.1 deraadt struct timeval tv;
576 1.1 deraadt struct sockaddr_in clnt_sin;
577 1.1 deraadt CLIENT *clnt;
578 1.1 deraadt u_long status;
579 1.1 deraadt int clnt_sock;
580 1.1 deraadt
581 1.1 deraadt if( _yp_dobind(indomain, &ysd) != 0)
582 1.1 deraadt return YPERR_DOMAIN;
583 1.1 deraadt
584 1.1 deraadt tv.tv_sec = _yplib_timeout;
585 1.1 deraadt tv.tv_usec = 0;
586 1.1 deraadt clnt_sock = RPC_ANYSOCK;
587 1.1 deraadt clnt_sin = ysd->dom_server_addr;
588 1.1 deraadt clnt_sin.sin_port = 0;
589 1.1 deraadt clnt = clnttcp_create(&clnt_sin, YPPROG, YPVERS, &clnt_sock, 0, 0);
590 1.1 deraadt if(clnt==NULL) {
591 1.1 deraadt printf("clnttcp_create failed\n");
592 1.1 deraadt return YPERR_PMAP;
593 1.1 deraadt }
594 1.1 deraadt
595 1.1 deraadt yprnk.domain = indomain;
596 1.1 deraadt yprnk.map = inmap;
597 1.1 deraadt ypresp_allfn = incallback->foreach;
598 1.1 deraadt ypresp_data = (void *)incallback->data;
599 1.1 deraadt
600 1.1 deraadt (void) clnt_call(clnt, YPPROC_ALL,
601 1.1 deraadt xdr_ypreq_nokey, &yprnk, xdr_ypresp_all_seq, &status, tv);
602 1.1 deraadt clnt_destroy(clnt);
603 1.4 deraadt xdr_free(xdr_ypresp_all_seq, (char *)&status); /* not really needed... */
604 1.1 deraadt _yp_unbind(ysd);
605 1.1 deraadt
606 1.1 deraadt if(status != YP_FALSE)
607 1.1 deraadt return ypprot_err(status);
608 1.1 deraadt return 0;
609 1.1 deraadt }
610 1.1 deraadt
611 1.1 deraadt int
612 1.1 deraadt yp_order(indomain, inmap, outorder)
613 1.1 deraadt char *indomain;
614 1.1 deraadt char *inmap;
615 1.1 deraadt int *outorder;
616 1.1 deraadt {
617 1.1 deraadt struct dom_binding *ysd;
618 1.1 deraadt struct ypresp_order ypro;
619 1.1 deraadt struct ypreq_nokey yprnk;
620 1.1 deraadt struct timeval tv;
621 1.1 deraadt int r;
622 1.1 deraadt
623 1.1 deraadt again:
624 1.1 deraadt if( _yp_dobind(indomain, &ysd) != 0)
625 1.1 deraadt return YPERR_DOMAIN;
626 1.1 deraadt
627 1.1 deraadt tv.tv_sec = _yplib_timeout;
628 1.1 deraadt tv.tv_usec = 0;
629 1.1 deraadt
630 1.1 deraadt yprnk.domain = indomain;
631 1.1 deraadt yprnk.map = inmap;
632 1.1 deraadt
633 1.9 jtc memset(&ypro, 0, sizeof ypro);
634 1.1 deraadt
635 1.1 deraadt r = clnt_call(ysd->dom_client, YPPROC_ORDER,
636 1.1 deraadt xdr_ypreq_nokey, &yprnk, xdr_ypresp_order, &ypro, tv);
637 1.1 deraadt if(r != RPC_SUCCESS) {
638 1.1 deraadt clnt_perror(ysd->dom_client, "yp_order: clnt_call");
639 1.1 deraadt ysd->dom_vers = -1;
640 1.1 deraadt goto again;
641 1.1 deraadt }
642 1.1 deraadt
643 1.1 deraadt *outorder = ypro.ordernum;
644 1.4 deraadt xdr_free(xdr_ypresp_order, (char *)&ypro);
645 1.1 deraadt _yp_unbind(ysd);
646 1.1 deraadt return ypprot_err(ypro.status);
647 1.1 deraadt }
648 1.1 deraadt
649 1.5 deraadt int
650 1.1 deraadt yp_master(indomain, inmap, outname)
651 1.1 deraadt char *indomain;
652 1.1 deraadt char *inmap;
653 1.1 deraadt char **outname;
654 1.1 deraadt {
655 1.1 deraadt struct dom_binding *ysd;
656 1.1 deraadt struct ypresp_master yprm;
657 1.1 deraadt struct ypreq_nokey yprnk;
658 1.1 deraadt struct timeval tv;
659 1.1 deraadt int r;
660 1.1 deraadt
661 1.1 deraadt again:
662 1.1 deraadt if( _yp_dobind(indomain, &ysd) != 0)
663 1.1 deraadt return YPERR_DOMAIN;
664 1.1 deraadt
665 1.1 deraadt tv.tv_sec = _yplib_timeout;
666 1.1 deraadt tv.tv_usec = 0;
667 1.1 deraadt
668 1.1 deraadt yprnk.domain = indomain;
669 1.1 deraadt yprnk.map = inmap;
670 1.1 deraadt
671 1.9 jtc memset(&yprm, 0, sizeof yprm);
672 1.1 deraadt
673 1.1 deraadt r = clnt_call(ysd->dom_client, YPPROC_MASTER,
674 1.1 deraadt xdr_ypreq_nokey, &yprnk, xdr_ypresp_master, &yprm, tv);
675 1.1 deraadt if(r != RPC_SUCCESS) {
676 1.1 deraadt clnt_perror(ysd->dom_client, "yp_master: clnt_call");
677 1.1 deraadt ysd->dom_vers = -1;
678 1.1 deraadt goto again;
679 1.1 deraadt }
680 1.1 deraadt if( !(r=ypprot_err(yprm.status)) ) {
681 1.1 deraadt *outname = (char *)strdup(yprm.master);
682 1.1 deraadt }
683 1.4 deraadt xdr_free(xdr_ypresp_master, (char *)&yprm);
684 1.1 deraadt _yp_unbind(ysd);
685 1.1 deraadt return r;
686 1.1 deraadt }
687 1.1 deraadt
688 1.1 deraadt yp_maplist(indomain, outmaplist)
689 1.1 deraadt char *indomain;
690 1.1 deraadt struct ypmaplist **outmaplist;
691 1.1 deraadt {
692 1.1 deraadt struct dom_binding *ysd;
693 1.1 deraadt struct ypresp_maplist ypml;
694 1.1 deraadt struct timeval tv;
695 1.1 deraadt int r;
696 1.1 deraadt
697 1.1 deraadt again:
698 1.1 deraadt if( _yp_dobind(indomain, &ysd) != 0)
699 1.1 deraadt return YPERR_DOMAIN;
700 1.1 deraadt
701 1.1 deraadt tv.tv_sec = _yplib_timeout;
702 1.1 deraadt tv.tv_usec = 0;
703 1.1 deraadt
704 1.9 jtc memset(&ypml, 0, sizeof ypml);
705 1.1 deraadt
706 1.1 deraadt r = clnt_call(ysd->dom_client, YPPROC_MAPLIST,
707 1.1 deraadt xdr_domainname, indomain, xdr_ypresp_maplist, &ypml, tv);
708 1.1 deraadt if (r != RPC_SUCCESS) {
709 1.1 deraadt clnt_perror(ysd->dom_client, "yp_maplist: clnt_call");
710 1.1 deraadt ysd->dom_vers = -1;
711 1.1 deraadt goto again;
712 1.1 deraadt }
713 1.1 deraadt *outmaplist = ypml.list;
714 1.1 deraadt /* NO: xdr_free(xdr_ypresp_maplist, &ypml);*/
715 1.1 deraadt _yp_unbind(ysd);
716 1.1 deraadt return ypprot_err(ypml.status);
717 1.1 deraadt }
718 1.1 deraadt
719 1.1 deraadt char *
720 1.1 deraadt yperr_string(incode)
721 1.1 deraadt int incode;
722 1.1 deraadt {
723 1.1 deraadt static char err[80];
724 1.1 deraadt
725 1.1 deraadt switch(incode) {
726 1.1 deraadt case 0:
727 1.1 deraadt return "Success";
728 1.1 deraadt case YPERR_BADARGS:
729 1.1 deraadt return "Request arguments bad";
730 1.1 deraadt case YPERR_RPC:
731 1.1 deraadt return "RPC failure";
732 1.1 deraadt case YPERR_DOMAIN:
733 1.1 deraadt return "Can't bind to server which serves this domain";
734 1.1 deraadt case YPERR_MAP:
735 1.1 deraadt return "No such map in server's domain";
736 1.1 deraadt case YPERR_KEY:
737 1.1 deraadt return "No such key in map";
738 1.1 deraadt case YPERR_YPERR:
739 1.1 deraadt return "YP server error";
740 1.1 deraadt case YPERR_RESRC:
741 1.1 deraadt return "Local resource allocation failure";
742 1.1 deraadt case YPERR_NOMORE:
743 1.1 deraadt return "No more records in map database";
744 1.1 deraadt case YPERR_PMAP:
745 1.1 deraadt return "Can't communicate with portmapper";
746 1.1 deraadt case YPERR_YPBIND:
747 1.1 deraadt return "Can't communicate with ypbind";
748 1.1 deraadt case YPERR_YPSERV:
749 1.1 deraadt return "Can't communicate with ypserv";
750 1.1 deraadt case YPERR_NODOM:
751 1.1 deraadt return "Local domain name not set";
752 1.1 deraadt case YPERR_BADDB:
753 1.1 deraadt return "Server data base is bad";
754 1.1 deraadt case YPERR_VERS:
755 1.1 deraadt return "YP server version mismatch - server can't supply service.";
756 1.1 deraadt case YPERR_ACCESS:
757 1.1 deraadt return "Access violation";
758 1.1 deraadt case YPERR_BUSY:
759 1.1 deraadt return "Database is busy";
760 1.1 deraadt }
761 1.1 deraadt sprintf(err, "YP unknown error %d\n", incode);
762 1.1 deraadt return err;
763 1.1 deraadt }
764 1.1 deraadt
765 1.1 deraadt int
766 1.1 deraadt ypprot_err(incode)
767 1.1 deraadt unsigned int incode;
768 1.1 deraadt {
769 1.1 deraadt switch(incode) {
770 1.1 deraadt case YP_TRUE:
771 1.1 deraadt return 0;
772 1.1 deraadt case YP_FALSE:
773 1.1 deraadt return YPERR_YPBIND;
774 1.1 deraadt case YP_NOMORE:
775 1.1 deraadt return YPERR_NOMORE;
776 1.1 deraadt case YP_NOMAP:
777 1.1 deraadt return YPERR_MAP;
778 1.1 deraadt case YP_NODOM:
779 1.1 deraadt return YPERR_NODOM;
780 1.1 deraadt case YP_NOKEY:
781 1.1 deraadt return YPERR_KEY;
782 1.1 deraadt case YP_BADOP:
783 1.1 deraadt return YPERR_YPERR;
784 1.1 deraadt case YP_BADDB:
785 1.1 deraadt return YPERR_BADDB;
786 1.1 deraadt case YP_YPERR:
787 1.1 deraadt return YPERR_YPERR;
788 1.1 deraadt case YP_BADARGS:
789 1.1 deraadt return YPERR_BADARGS;
790 1.1 deraadt case YP_VERS:
791 1.1 deraadt return YPERR_VERS;
792 1.1 deraadt }
793 1.1 deraadt return YPERR_YPERR;
794 1.1 deraadt }
795 1.1 deraadt
796 1.1 deraadt int
797 1.1 deraadt _yp_check(dom)
798 1.1 deraadt char **dom;
799 1.1 deraadt {
800 1.1 deraadt int use_yp = 0;
801 1.1 deraadt char *unused;
802 1.1 deraadt
803 1.1 deraadt if( _yp_domain[0]=='\0' )
804 1.1 deraadt if( yp_get_default_domain(&unused) )
805 1.1 deraadt return 0;
806 1.1 deraadt
807 1.1 deraadt if(dom)
808 1.1 deraadt *dom = _yp_domain;
809 1.1 deraadt
810 1.1 deraadt if( yp_bind(_yp_domain)==0 )
811 1.1 deraadt return 1;
812 1.1 deraadt return 0;
813 1.1 deraadt }
814