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