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