Home | History | Annotate | Line # | Download | only in yp
yplib.c revision 1.9
      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.9      jtc static char *rcsid = "$Id: yplib.c,v 1.9 1994/08/06 23:07:50 jtc Exp $";
     34  1.3  deraadt #endif
     35  1.3  deraadt 
     36  1.1  deraadt #include <sys/param.h>
     37  1.1  deraadt #include <sys/types.h>
     38  1.1  deraadt #include <sys/socket.h>
     39  1.1  deraadt #include <sys/file.h>
     40  1.7  deraadt #include <sys/uio.h>
     41  1.1  deraadt #include <errno.h>
     42  1.1  deraadt #include <stdio.h>
     43  1.9      jtc #include <stdlib.h>
     44  1.1  deraadt #include <string.h>
     45  1.9      jtc #include <unistd.h>
     46  1.1  deraadt #include <rpc/rpc.h>
     47  1.1  deraadt #include <rpc/xdr.h>
     48  1.1  deraadt #include <rpcsvc/yp_prot.h>
     49  1.1  deraadt #include <rpcsvc/ypclnt.h>
     50  1.1  deraadt 
     51  1.1  deraadt #ifndef BINDINGDIR
     52  1.1  deraadt #define BINDINGDIR "/var/yp/binding"
     53  1.1  deraadt #endif
     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.1  deraadt 
    188  1.1  deraadt 	gpid = getpid();
    189  1.1  deraadt 	if( !(pid==-1 || pid==gpid) ) {
    190  1.1  deraadt 		ysd = _ypbindlist;
    191  1.1  deraadt 		while(ysd) {
    192  1.1  deraadt 			if(ysd->dom_client)
    193  1.1  deraadt 				clnt_destroy(ysd->dom_client);
    194  1.1  deraadt 			ysd2 = ysd->dom_pnext;
    195  1.1  deraadt 			free(ysd);
    196  1.1  deraadt 			ysd = ysd2;
    197  1.1  deraadt 		}
    198  1.1  deraadt 		_ypbindlist = NULL;
    199  1.1  deraadt 	}
    200  1.1  deraadt 	pid = gpid;
    201  1.1  deraadt 
    202  1.1  deraadt 	if(ypdb!=NULL)
    203  1.1  deraadt 		*ypdb = NULL;
    204  1.1  deraadt 
    205  1.1  deraadt 	if(dom==NULL || strlen(dom)==0)
    206  1.1  deraadt 		return YPERR_BADARGS;
    207  1.1  deraadt 
    208  1.1  deraadt 	for(ysd = _ypbindlist; ysd; ysd = ysd->dom_pnext)
    209  1.1  deraadt 		if( strcmp(dom, ysd->dom_domain) == 0)
    210  1.1  deraadt 			break;
    211  1.1  deraadt 	if(ysd==NULL) {
    212  1.1  deraadt 		ysd = (struct dom_binding *)malloc(sizeof *ysd);
    213  1.9      jtc 		memset(ysd, 0, sizeof *ysd);
    214  1.1  deraadt 		ysd->dom_socket = -1;
    215  1.1  deraadt 		ysd->dom_vers = 0;
    216  1.1  deraadt 		new = 1;
    217  1.1  deraadt 	}
    218  1.1  deraadt again:
    219  1.1  deraadt #ifdef BINDINGDIR
    220  1.1  deraadt 	if(ysd->dom_vers==0) {
    221  1.1  deraadt 		sprintf(path, "%s/%s.%d", BINDINGDIR, dom, 2);
    222  1.1  deraadt 		if( (fd=open(path, O_RDONLY)) == -1) {
    223  1.1  deraadt 			/* no binding file, YP is dead. */
    224  1.1  deraadt 			if(new)
    225  1.1  deraadt 				free(ysd);
    226  1.1  deraadt 			return YPERR_YPBIND;
    227  1.1  deraadt 		}
    228  1.1  deraadt 		if( flock(fd, LOCK_EX|LOCK_NB) == -1 && errno==EWOULDBLOCK) {
    229  1.7  deraadt 			struct iovec iov[2];
    230  1.7  deraadt 			struct ypbind_resp ybr;
    231  1.7  deraadt 			u_short	ypb_port;
    232  1.7  deraadt 
    233  1.7  deraadt 			iov[0].iov_base = (caddr_t)&ypb_port;
    234  1.7  deraadt 			iov[0].iov_len = sizeof ypb_port;
    235  1.7  deraadt 			iov[1].iov_base = (caddr_t)&ybr;
    236  1.7  deraadt 			iov[1].iov_len = sizeof ybr;
    237  1.7  deraadt 
    238  1.7  deraadt 			r = readv(fd, iov, 2);
    239  1.7  deraadt 			if(r != iov[0].iov_len + iov[1].iov_len) {
    240  1.1  deraadt 				close(fd);
    241  1.1  deraadt 				ysd->dom_vers = -1;
    242  1.1  deraadt 				goto again;
    243  1.1  deraadt 			}
    244  1.7  deraadt 
    245  1.9      jtc 			memset(&ysd->dom_server_addr, 0, sizeof ysd->dom_server_addr);
    246  1.7  deraadt 			ysd->dom_server_addr.sin_family = AF_INET;
    247  1.7  deraadt 			ysd->dom_server_addr.sin_len = sizeof(struct sockaddr_in);
    248  1.7  deraadt 			ysd->dom_server_addr.sin_addr =
    249  1.7  deraadt 			    ybr.ypbind_respbody.ypbind_bindinfo.ypbind_binding_addr;
    250  1.7  deraadt 			ysd->dom_server_addr.sin_port =
    251  1.7  deraadt 			    ybr.ypbind_respbody.ypbind_bindinfo.ypbind_binding_port;
    252  1.7  deraadt 
    253  1.1  deraadt 			ysd->dom_server_port = ysd->dom_server_addr.sin_port;
    254  1.1  deraadt 			close(fd);
    255  1.1  deraadt 			goto gotit;
    256  1.1  deraadt 		} else {
    257  1.1  deraadt 			/* no lock on binding file, YP is dead. */
    258  1.1  deraadt 			close(fd);
    259  1.1  deraadt 			if(new)
    260  1.1  deraadt 				free(ysd);
    261  1.1  deraadt 			return YPERR_YPBIND;
    262  1.1  deraadt 		}
    263  1.1  deraadt 	}
    264  1.1  deraadt #endif
    265  1.1  deraadt 	if(ysd->dom_vers==-1 || ysd->dom_vers==0) {
    266  1.9      jtc 		memset(&clnt_sin, 0, sizeof clnt_sin);
    267  1.1  deraadt 		clnt_sin.sin_family = AF_INET;
    268  1.1  deraadt 		clnt_sin.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
    269  1.1  deraadt 
    270  1.1  deraadt 		clnt_sock = RPC_ANYSOCK;
    271  1.1  deraadt 		client = clnttcp_create(&clnt_sin, YPBINDPROG, YPBINDVERS, &clnt_sock,
    272  1.1  deraadt 			0, 0);
    273  1.1  deraadt 		if(client==NULL) {
    274  1.1  deraadt 			clnt_pcreateerror("clnttcp_create");
    275  1.1  deraadt 			if(new)
    276  1.1  deraadt 				free(ysd);
    277  1.1  deraadt 			return YPERR_YPBIND;
    278  1.1  deraadt 		}
    279  1.1  deraadt 
    280  1.1  deraadt 		tv.tv_sec = _yplib_timeout;
    281  1.1  deraadt 		tv.tv_usec = 0;
    282  1.1  deraadt 		r = clnt_call(client, YPBINDPROC_DOMAIN,
    283  1.1  deraadt 			xdr_domainname, dom, xdr_ypbind_resp, &ypbr, tv);
    284  1.1  deraadt 		if(r != RPC_SUCCESS) {
    285  1.1  deraadt 			fprintf(stderr,
    286  1.1  deraadt 			"YP: server for domain %s not responding, still trying\n", dom);
    287  1.1  deraadt 			clnt_destroy(client);
    288  1.1  deraadt 			ysd->dom_vers = -1;
    289  1.1  deraadt 			goto again;
    290  1.1  deraadt 		}
    291  1.1  deraadt 		clnt_destroy(client);
    292  1.1  deraadt 
    293  1.9      jtc 		memset(&ysd->dom_server_addr, 0, sizeof ysd->dom_server_addr);
    294  1.1  deraadt 		ysd->dom_server_addr.sin_family = AF_INET;
    295  1.1  deraadt 		ysd->dom_server_addr.sin_port =
    296  1.1  deraadt 			ypbr.ypbind_respbody.ypbind_bindinfo.ypbind_binding_port;
    297  1.1  deraadt 		ysd->dom_server_addr.sin_addr.s_addr =
    298  1.1  deraadt 			ypbr.ypbind_respbody.ypbind_bindinfo.ypbind_binding_addr.s_addr;
    299  1.1  deraadt 		ysd->dom_server_port =
    300  1.1  deraadt 			ypbr.ypbind_respbody.ypbind_bindinfo.ypbind_binding_port;
    301  1.1  deraadt gotit:
    302  1.1  deraadt 		ysd->dom_vers = YPVERS;
    303  1.1  deraadt 		strcpy(ysd->dom_domain, dom);
    304  1.1  deraadt 	}
    305  1.1  deraadt 
    306  1.1  deraadt 	tv.tv_sec = _yplib_timeout/2;
    307  1.1  deraadt 	tv.tv_usec = 0;
    308  1.1  deraadt 	if(ysd->dom_client)
    309  1.1  deraadt 		clnt_destroy(ysd->dom_client);
    310  1.1  deraadt 	ysd->dom_socket = RPC_ANYSOCK;
    311  1.1  deraadt 	ysd->dom_client = clntudp_create(&ysd->dom_server_addr,
    312  1.1  deraadt 		YPPROG, YPVERS, tv, &ysd->dom_socket);
    313  1.1  deraadt 	if(ysd->dom_client==NULL) {
    314  1.1  deraadt 		clnt_pcreateerror("clntudp_create");
    315  1.1  deraadt 		ysd->dom_vers = -1;
    316  1.1  deraadt 		goto again;
    317  1.1  deraadt 	}
    318  1.1  deraadt 	if( fcntl(ysd->dom_socket, F_SETFD, 1) == -1)
    319  1.1  deraadt 		perror("fcntl: F_SETFD");
    320  1.1  deraadt 
    321  1.1  deraadt 	if(new) {
    322  1.1  deraadt 		ysd->dom_pnext = _ypbindlist;
    323  1.1  deraadt 		_ypbindlist = ysd;
    324  1.1  deraadt 	}
    325  1.1  deraadt 
    326  1.1  deraadt 	if(ypdb!=NULL)
    327  1.1  deraadt 		*ypdb = ysd;
    328  1.1  deraadt 	return 0;
    329  1.1  deraadt }
    330  1.1  deraadt 
    331  1.1  deraadt static void
    332  1.1  deraadt _yp_unbind(ypb)
    333  1.1  deraadt struct dom_binding *ypb;
    334  1.1  deraadt {
    335  1.1  deraadt 	clnt_destroy(ypb->dom_client);
    336  1.1  deraadt 	ypb->dom_client = NULL;
    337  1.1  deraadt 	ypb->dom_socket = -1;
    338  1.1  deraadt }
    339  1.1  deraadt 
    340  1.1  deraadt int
    341  1.1  deraadt yp_bind(dom)
    342  1.1  deraadt char *dom;
    343  1.1  deraadt {
    344  1.1  deraadt 	return _yp_dobind(dom, NULL);
    345  1.1  deraadt }
    346  1.1  deraadt 
    347  1.1  deraadt void
    348  1.1  deraadt yp_unbind(dom)
    349  1.1  deraadt char *dom;
    350  1.1  deraadt {
    351  1.1  deraadt 	struct dom_binding *ypb, *ypbp;
    352  1.1  deraadt 
    353  1.1  deraadt 	ypbp = NULL;
    354  1.1  deraadt 	for(ypb=_ypbindlist; ypb; ypb=ypb->dom_pnext) {
    355  1.1  deraadt 		if( strcmp(dom, ypb->dom_domain) == 0) {
    356  1.1  deraadt 			clnt_destroy(ypb->dom_client);
    357  1.1  deraadt 			if(ypbp)
    358  1.1  deraadt 				ypbp->dom_pnext = ypb->dom_pnext;
    359  1.1  deraadt 			else
    360  1.1  deraadt 				_ypbindlist = ypb->dom_pnext;
    361  1.1  deraadt 			free(ypb);
    362  1.1  deraadt 			return;
    363  1.1  deraadt 		}
    364  1.1  deraadt 		ypbp = ypb;
    365  1.1  deraadt 	}
    366  1.1  deraadt 	return;
    367  1.1  deraadt }
    368  1.1  deraadt 
    369  1.1  deraadt int
    370  1.1  deraadt yp_match(indomain, inmap, inkey, inkeylen, outval, outvallen)
    371  1.1  deraadt char *indomain;
    372  1.1  deraadt char *inmap;
    373  1.5  deraadt const char *inkey;
    374  1.1  deraadt int inkeylen;
    375  1.1  deraadt char **outval;
    376  1.1  deraadt int *outvallen;
    377  1.1  deraadt {
    378  1.1  deraadt 	struct dom_binding *ysd;
    379  1.1  deraadt 	struct ypresp_val yprv;
    380  1.1  deraadt 	struct timeval tv;
    381  1.1  deraadt 	struct ypreq_key yprk;
    382  1.1  deraadt 	int r;
    383  1.1  deraadt 
    384  1.1  deraadt 	*outval = NULL;
    385  1.1  deraadt 	*outvallen = 0;
    386  1.1  deraadt 
    387  1.1  deraadt again:
    388  1.1  deraadt 	if( _yp_dobind(indomain, &ysd) != 0)
    389  1.1  deraadt 		return YPERR_DOMAIN;
    390  1.1  deraadt 
    391  1.1  deraadt #ifdef YPMATCHCACHE
    392  1.1  deraadt 	if( !strcmp(_yp_domain, indomain) && ypmatch_find(inmap, inkey,
    393  1.1  deraadt 	    inkeylen, &yprv.valdat.dptr, &yprv.valdat.dsize)) {
    394  1.1  deraadt 		*outvallen = yprv.valdat.dsize;
    395  1.1  deraadt 		*outval = (char *)malloc(*outvallen+1);
    396  1.9      jtc 		memcpy(*outval, yprv.valdat.dptr, *outvallen);
    397  1.1  deraadt 		(*outval)[*outvallen] = '\0';
    398  1.1  deraadt 		return 0;
    399  1.1  deraadt 	}
    400  1.1  deraadt #endif
    401  1.1  deraadt 
    402  1.1  deraadt 	tv.tv_sec = _yplib_timeout;
    403  1.1  deraadt 	tv.tv_usec = 0;
    404  1.1  deraadt 
    405  1.1  deraadt 	yprk.domain = indomain;
    406  1.1  deraadt 	yprk.map = inmap;
    407  1.7  deraadt 	yprk.keydat.dptr = (char *)inkey;
    408  1.1  deraadt 	yprk.keydat.dsize = inkeylen;
    409  1.1  deraadt 
    410  1.9      jtc 	memset(&yprv, 0, sizeof yprv);
    411  1.1  deraadt 
    412  1.1  deraadt 	r = clnt_call(ysd->dom_client, YPPROC_MATCH,
    413  1.1  deraadt 		xdr_ypreq_key, &yprk, xdr_ypresp_val, &yprv, tv);
    414  1.1  deraadt 	if(r != RPC_SUCCESS) {
    415  1.1  deraadt 		clnt_perror(ysd->dom_client, "yp_match: clnt_call");
    416  1.1  deraadt 		ysd->dom_vers = -1;
    417  1.1  deraadt 		goto again;
    418  1.1  deraadt 	}
    419  1.1  deraadt 	if( !(r=ypprot_err(yprv.status)) ) {
    420  1.1  deraadt 		*outvallen = yprv.valdat.dsize;
    421  1.1  deraadt 		*outval = (char *)malloc(*outvallen+1);
    422  1.9      jtc 		memcpy(*outval, yprv.valdat.dptr, *outvallen);
    423  1.1  deraadt 		(*outval)[*outvallen] = '\0';
    424  1.1  deraadt #ifdef YPMATCHCACHE
    425  1.1  deraadt 		if( strcmp(_yp_domain, indomain)==0 )
    426  1.1  deraadt 			 ypmatch_add(inmap, inkey, inkeylen, *outval, *outvallen);
    427  1.1  deraadt #endif
    428  1.1  deraadt 	}
    429  1.4  deraadt 	xdr_free(xdr_ypresp_val, (char *)&yprv);
    430  1.1  deraadt 	_yp_unbind(ysd);
    431  1.1  deraadt 	return r;
    432  1.1  deraadt }
    433  1.1  deraadt 
    434  1.1  deraadt int
    435  1.1  deraadt yp_get_default_domain(domp)
    436  1.1  deraadt char **domp;
    437  1.1  deraadt {
    438  1.1  deraadt 	*domp = NULL;
    439  1.1  deraadt 	if(_yp_domain[0] == '\0')
    440  1.1  deraadt 		if( getdomainname(_yp_domain, sizeof _yp_domain))
    441  1.1  deraadt 			return YPERR_NODOM;
    442  1.1  deraadt 	*domp = _yp_domain;
    443  1.1  deraadt 	return 0;
    444  1.1  deraadt }
    445  1.1  deraadt 
    446  1.1  deraadt int
    447  1.1  deraadt yp_first(indomain, inmap, outkey, outkeylen, outval, outvallen)
    448  1.1  deraadt char *indomain;
    449  1.1  deraadt char *inmap;
    450  1.1  deraadt char **outkey;
    451  1.1  deraadt int *outkeylen;
    452  1.1  deraadt char **outval;
    453  1.1  deraadt int *outvallen;
    454  1.1  deraadt {
    455  1.1  deraadt 	struct ypresp_key_val yprkv;
    456  1.1  deraadt 	struct ypreq_nokey yprnk;
    457  1.1  deraadt 	struct dom_binding *ysd;
    458  1.1  deraadt 	struct timeval tv;
    459  1.1  deraadt 	int r;
    460  1.1  deraadt 
    461  1.1  deraadt 	*outkey = *outval = NULL;
    462  1.1  deraadt 	*outkeylen = *outvallen = 0;
    463  1.1  deraadt 
    464  1.1  deraadt again:
    465  1.1  deraadt 	if( _yp_dobind(indomain, &ysd) != 0)
    466  1.1  deraadt 		return YPERR_DOMAIN;
    467  1.1  deraadt 
    468  1.1  deraadt 	tv.tv_sec = _yplib_timeout;
    469  1.1  deraadt 	tv.tv_usec = 0;
    470  1.1  deraadt 
    471  1.1  deraadt 	yprnk.domain = indomain;
    472  1.1  deraadt 	yprnk.map = inmap;
    473  1.9      jtc 	memset(&yprkv, 0, sizeof yprkv);
    474  1.1  deraadt 
    475  1.1  deraadt 	r = clnt_call(ysd->dom_client, YPPROC_FIRST,
    476  1.1  deraadt 		xdr_ypreq_nokey, &yprnk, xdr_ypresp_key_val, &yprkv, tv);
    477  1.1  deraadt 	if(r != RPC_SUCCESS) {
    478  1.1  deraadt 		clnt_perror(ysd->dom_client, "yp_first: clnt_call");
    479  1.1  deraadt 		ysd->dom_vers = -1;
    480  1.1  deraadt 		goto again;
    481  1.1  deraadt 	}
    482  1.1  deraadt 	if( !(r=ypprot_err(yprkv.status)) ) {
    483  1.1  deraadt 		*outkeylen = yprkv.keydat.dsize;
    484  1.1  deraadt 		*outkey = (char *)malloc(*outkeylen+1);
    485  1.9      jtc 		memcpy (*outkey, yprkv.keydat.dptr, *outkeylen);
    486  1.1  deraadt 		(*outkey)[*outkeylen] = '\0';
    487  1.1  deraadt 		*outvallen = yprkv.valdat.dsize;
    488  1.1  deraadt 		*outval = (char *)malloc(*outvallen+1);
    489  1.9      jtc 		memcpy (*outval, yprkv.valdat.dptr, *outvallen);
    490  1.1  deraadt 		(*outval)[*outvallen] = '\0';
    491  1.1  deraadt 	}
    492  1.4  deraadt 	xdr_free(xdr_ypresp_key_val, (char *)&yprkv);
    493  1.1  deraadt 	_yp_unbind(ysd);
    494  1.1  deraadt 	return r;
    495  1.1  deraadt }
    496  1.1  deraadt 
    497  1.1  deraadt int
    498  1.1  deraadt yp_next(indomain, inmap, inkey, inkeylen, outkey, outkeylen, outval, outvallen)
    499  1.1  deraadt char *indomain;
    500  1.1  deraadt char *inmap;
    501  1.1  deraadt char *inkey;
    502  1.1  deraadt int inkeylen;
    503  1.1  deraadt char **outkey;
    504  1.1  deraadt int *outkeylen;
    505  1.1  deraadt char **outval;
    506  1.1  deraadt int *outvallen;
    507  1.1  deraadt {
    508  1.1  deraadt 	struct ypresp_key_val yprkv;
    509  1.1  deraadt 	struct ypreq_key yprk;
    510  1.1  deraadt 	struct dom_binding *ysd;
    511  1.1  deraadt 	struct timeval tv;
    512  1.1  deraadt 	int r;
    513  1.1  deraadt 
    514  1.1  deraadt 	*outkey = *outval = NULL;
    515  1.1  deraadt 	*outkeylen = *outvallen = 0;
    516  1.1  deraadt 
    517  1.1  deraadt again:
    518  1.1  deraadt 	if( _yp_dobind(indomain, &ysd) != 0)
    519  1.1  deraadt 		return YPERR_DOMAIN;
    520  1.1  deraadt 
    521  1.1  deraadt 	tv.tv_sec = _yplib_timeout;
    522  1.1  deraadt 	tv.tv_usec = 0;
    523  1.1  deraadt 
    524  1.1  deraadt 	yprk.domain = indomain;
    525  1.1  deraadt 	yprk.map = inmap;
    526  1.1  deraadt 	yprk.keydat.dptr = inkey;
    527  1.1  deraadt 	yprk.keydat.dsize = inkeylen;
    528  1.9      jtc 	memset(&yprkv, 0, sizeof yprkv);
    529  1.1  deraadt 
    530  1.1  deraadt 	r = clnt_call(ysd->dom_client, YPPROC_NEXT,
    531  1.1  deraadt 		xdr_ypreq_key, &yprk, xdr_ypresp_key_val, &yprkv, tv);
    532  1.1  deraadt 	if(r != RPC_SUCCESS) {
    533  1.1  deraadt 		clnt_perror(ysd->dom_client, "yp_next: clnt_call");
    534  1.1  deraadt 		ysd->dom_vers = -1;
    535  1.1  deraadt 		goto again;
    536  1.1  deraadt 	}
    537  1.1  deraadt 	if( !(r=ypprot_err(yprkv.status)) ) {
    538  1.1  deraadt 		*outkeylen = yprkv.keydat.dsize;
    539  1.1  deraadt 		*outkey = (char *)malloc(*outkeylen+1);
    540  1.9      jtc 		memcpy(*outkey, yprkv.keydat.dptr, *outkeylen);
    541  1.1  deraadt 		(*outkey)[*outkeylen] = '\0';
    542  1.1  deraadt 		*outvallen = yprkv.valdat.dsize;
    543  1.1  deraadt 		*outval = (char *)malloc(*outvallen+1);
    544  1.9      jtc 		memcpy(*outval, yprkv.valdat.dptr, *outvallen);
    545  1.1  deraadt 		(*outval)[*outvallen] = '\0';
    546  1.1  deraadt 	}
    547  1.4  deraadt 	xdr_free(xdr_ypresp_key_val, (char *)&yprkv);
    548  1.1  deraadt 	_yp_unbind(ysd);
    549  1.1  deraadt 	return r;
    550  1.1  deraadt }
    551  1.1  deraadt 
    552  1.1  deraadt int
    553  1.1  deraadt yp_all(indomain, inmap, incallback)
    554  1.1  deraadt char *indomain;
    555  1.1  deraadt char *inmap;
    556  1.1  deraadt struct ypall_callback *incallback;
    557  1.1  deraadt {
    558  1.1  deraadt 	struct ypreq_nokey yprnk;
    559  1.1  deraadt 	struct dom_binding *ysd;
    560  1.1  deraadt 	struct timeval tv;
    561  1.1  deraadt 	struct sockaddr_in clnt_sin;
    562  1.1  deraadt 	CLIENT *clnt;
    563  1.1  deraadt 	u_long status;
    564  1.1  deraadt 	int clnt_sock;
    565  1.1  deraadt 
    566  1.1  deraadt 	if( _yp_dobind(indomain, &ysd) != 0)
    567  1.1  deraadt 		return YPERR_DOMAIN;
    568  1.1  deraadt 
    569  1.1  deraadt 	tv.tv_sec = _yplib_timeout;
    570  1.1  deraadt 	tv.tv_usec = 0;
    571  1.1  deraadt 	clnt_sock = RPC_ANYSOCK;
    572  1.1  deraadt 	clnt_sin = ysd->dom_server_addr;
    573  1.1  deraadt 	clnt_sin.sin_port = 0;
    574  1.1  deraadt 	clnt = clnttcp_create(&clnt_sin, YPPROG, YPVERS, &clnt_sock, 0, 0);
    575  1.1  deraadt 	if(clnt==NULL) {
    576  1.1  deraadt 		printf("clnttcp_create failed\n");
    577  1.1  deraadt 		return YPERR_PMAP;
    578  1.1  deraadt 	}
    579  1.1  deraadt 
    580  1.1  deraadt 	yprnk.domain = indomain;
    581  1.1  deraadt 	yprnk.map = inmap;
    582  1.1  deraadt 	ypresp_allfn = incallback->foreach;
    583  1.1  deraadt 	ypresp_data = (void *)incallback->data;
    584  1.1  deraadt 
    585  1.1  deraadt 	(void) clnt_call(clnt, YPPROC_ALL,
    586  1.1  deraadt 		xdr_ypreq_nokey, &yprnk, xdr_ypresp_all_seq, &status, tv);
    587  1.1  deraadt 	clnt_destroy(clnt);
    588  1.4  deraadt 	xdr_free(xdr_ypresp_all_seq, (char *)&status);	/* not really needed... */
    589  1.1  deraadt 	_yp_unbind(ysd);
    590  1.1  deraadt 
    591  1.1  deraadt 	if(status != YP_FALSE)
    592  1.1  deraadt 		return ypprot_err(status);
    593  1.1  deraadt 	return 0;
    594  1.1  deraadt }
    595  1.1  deraadt 
    596  1.1  deraadt int
    597  1.1  deraadt yp_order(indomain, inmap, outorder)
    598  1.1  deraadt char *indomain;
    599  1.1  deraadt char *inmap;
    600  1.1  deraadt int *outorder;
    601  1.1  deraadt {
    602  1.1  deraadt  	struct dom_binding *ysd;
    603  1.1  deraadt 	struct ypresp_order ypro;
    604  1.1  deraadt 	struct ypreq_nokey yprnk;
    605  1.1  deraadt 	struct timeval tv;
    606  1.1  deraadt 	int r;
    607  1.1  deraadt 
    608  1.1  deraadt again:
    609  1.1  deraadt 	if( _yp_dobind(indomain, &ysd) != 0)
    610  1.1  deraadt 		return YPERR_DOMAIN;
    611  1.1  deraadt 
    612  1.1  deraadt 	tv.tv_sec = _yplib_timeout;
    613  1.1  deraadt 	tv.tv_usec = 0;
    614  1.1  deraadt 
    615  1.1  deraadt 	yprnk.domain = indomain;
    616  1.1  deraadt 	yprnk.map = inmap;
    617  1.1  deraadt 
    618  1.9      jtc 	memset(&ypro, 0, sizeof ypro);
    619  1.1  deraadt 
    620  1.1  deraadt 	r = clnt_call(ysd->dom_client, YPPROC_ORDER,
    621  1.1  deraadt 		xdr_ypreq_nokey, &yprnk, xdr_ypresp_order, &ypro, tv);
    622  1.1  deraadt 	if(r != RPC_SUCCESS) {
    623  1.1  deraadt 		clnt_perror(ysd->dom_client, "yp_order: clnt_call");
    624  1.1  deraadt 		ysd->dom_vers = -1;
    625  1.1  deraadt 		goto again;
    626  1.1  deraadt 	}
    627  1.1  deraadt 
    628  1.1  deraadt 	*outorder = ypro.ordernum;
    629  1.4  deraadt 	xdr_free(xdr_ypresp_order, (char *)&ypro);
    630  1.1  deraadt 	_yp_unbind(ysd);
    631  1.1  deraadt 	return ypprot_err(ypro.status);
    632  1.1  deraadt }
    633  1.1  deraadt 
    634  1.5  deraadt int
    635  1.1  deraadt yp_master(indomain, inmap, outname)
    636  1.1  deraadt char *indomain;
    637  1.1  deraadt char *inmap;
    638  1.1  deraadt char **outname;
    639  1.1  deraadt {
    640  1.1  deraadt 	struct dom_binding *ysd;
    641  1.1  deraadt 	struct ypresp_master yprm;
    642  1.1  deraadt 	struct ypreq_nokey yprnk;
    643  1.1  deraadt 	struct timeval tv;
    644  1.1  deraadt 	int r;
    645  1.1  deraadt 
    646  1.1  deraadt again:
    647  1.1  deraadt 	if( _yp_dobind(indomain, &ysd) != 0)
    648  1.1  deraadt 		return YPERR_DOMAIN;
    649  1.1  deraadt 
    650  1.1  deraadt 	tv.tv_sec = _yplib_timeout;
    651  1.1  deraadt 	tv.tv_usec = 0;
    652  1.1  deraadt 
    653  1.1  deraadt 	yprnk.domain = indomain;
    654  1.1  deraadt 	yprnk.map = inmap;
    655  1.1  deraadt 
    656  1.9      jtc 	memset(&yprm, 0, sizeof yprm);
    657  1.1  deraadt 
    658  1.1  deraadt 	r = clnt_call(ysd->dom_client, YPPROC_MASTER,
    659  1.1  deraadt 		xdr_ypreq_nokey, &yprnk, xdr_ypresp_master, &yprm, tv);
    660  1.1  deraadt 	if(r != RPC_SUCCESS) {
    661  1.1  deraadt 		clnt_perror(ysd->dom_client, "yp_master: clnt_call");
    662  1.1  deraadt 		ysd->dom_vers = -1;
    663  1.1  deraadt 		goto again;
    664  1.1  deraadt 	}
    665  1.1  deraadt 	if( !(r=ypprot_err(yprm.status)) ) {
    666  1.1  deraadt 		*outname = (char *)strdup(yprm.master);
    667  1.1  deraadt 	}
    668  1.4  deraadt 	xdr_free(xdr_ypresp_master, (char *)&yprm);
    669  1.1  deraadt 	_yp_unbind(ysd);
    670  1.1  deraadt 	return r;
    671  1.1  deraadt }
    672  1.1  deraadt 
    673  1.1  deraadt yp_maplist(indomain, outmaplist)
    674  1.1  deraadt char *indomain;
    675  1.1  deraadt struct ypmaplist **outmaplist;
    676  1.1  deraadt {
    677  1.1  deraadt 	struct dom_binding *ysd;
    678  1.1  deraadt 	struct ypresp_maplist ypml;
    679  1.1  deraadt 	struct timeval tv;
    680  1.1  deraadt 	int r;
    681  1.1  deraadt 
    682  1.1  deraadt again:
    683  1.1  deraadt 	if( _yp_dobind(indomain, &ysd) != 0)
    684  1.1  deraadt 		return YPERR_DOMAIN;
    685  1.1  deraadt 
    686  1.1  deraadt 	tv.tv_sec = _yplib_timeout;
    687  1.1  deraadt 	tv.tv_usec = 0;
    688  1.1  deraadt 
    689  1.9      jtc 	memset(&ypml, 0, sizeof ypml);
    690  1.1  deraadt 
    691  1.1  deraadt 	r = clnt_call(ysd->dom_client, YPPROC_MAPLIST,
    692  1.1  deraadt 		xdr_domainname, indomain, xdr_ypresp_maplist, &ypml, tv);
    693  1.1  deraadt 	if (r != RPC_SUCCESS) {
    694  1.1  deraadt 		clnt_perror(ysd->dom_client, "yp_maplist: clnt_call");
    695  1.1  deraadt 		ysd->dom_vers = -1;
    696  1.1  deraadt 		goto again;
    697  1.1  deraadt 	}
    698  1.1  deraadt 	*outmaplist = ypml.list;
    699  1.1  deraadt 	/* NO: xdr_free(xdr_ypresp_maplist, &ypml);*/
    700  1.1  deraadt 	_yp_unbind(ysd);
    701  1.1  deraadt 	return ypprot_err(ypml.status);
    702  1.1  deraadt }
    703  1.1  deraadt 
    704  1.1  deraadt char *
    705  1.1  deraadt yperr_string(incode)
    706  1.1  deraadt int incode;
    707  1.1  deraadt {
    708  1.1  deraadt 	static char err[80];
    709  1.1  deraadt 
    710  1.1  deraadt 	switch(incode) {
    711  1.1  deraadt 	case 0:
    712  1.1  deraadt 		return "Success";
    713  1.1  deraadt 	case YPERR_BADARGS:
    714  1.1  deraadt 		return "Request arguments bad";
    715  1.1  deraadt 	case YPERR_RPC:
    716  1.1  deraadt 		return "RPC failure";
    717  1.1  deraadt 	case YPERR_DOMAIN:
    718  1.1  deraadt 		return "Can't bind to server which serves this domain";
    719  1.1  deraadt 	case YPERR_MAP:
    720  1.1  deraadt 		return "No such map in server's domain";
    721  1.1  deraadt 	case YPERR_KEY:
    722  1.1  deraadt 		return "No such key in map";
    723  1.1  deraadt 	case YPERR_YPERR:
    724  1.1  deraadt 		return "YP server error";
    725  1.1  deraadt 	case YPERR_RESRC:
    726  1.1  deraadt 		return "Local resource allocation failure";
    727  1.1  deraadt 	case YPERR_NOMORE:
    728  1.1  deraadt 		return "No more records in map database";
    729  1.1  deraadt 	case YPERR_PMAP:
    730  1.1  deraadt 		return "Can't communicate with portmapper";
    731  1.1  deraadt 	case YPERR_YPBIND:
    732  1.1  deraadt 		return "Can't communicate with ypbind";
    733  1.1  deraadt 	case YPERR_YPSERV:
    734  1.1  deraadt 		return "Can't communicate with ypserv";
    735  1.1  deraadt 	case YPERR_NODOM:
    736  1.1  deraadt 		return "Local domain name not set";
    737  1.1  deraadt 	case YPERR_BADDB:
    738  1.1  deraadt 		return "Server data base is bad";
    739  1.1  deraadt 	case YPERR_VERS:
    740  1.1  deraadt 		return "YP server version mismatch - server can't supply service.";
    741  1.1  deraadt 	case YPERR_ACCESS:
    742  1.1  deraadt 		return "Access violation";
    743  1.1  deraadt 	case YPERR_BUSY:
    744  1.1  deraadt 		return "Database is busy";
    745  1.1  deraadt 	}
    746  1.1  deraadt 	sprintf(err, "YP unknown error %d\n", incode);
    747  1.1  deraadt 	return err;
    748  1.1  deraadt }
    749  1.1  deraadt 
    750  1.1  deraadt int
    751  1.1  deraadt ypprot_err(incode)
    752  1.1  deraadt unsigned int incode;
    753  1.1  deraadt {
    754  1.1  deraadt 	switch(incode) {
    755  1.1  deraadt 	case YP_TRUE:
    756  1.1  deraadt 		return 0;
    757  1.1  deraadt 	case YP_FALSE:
    758  1.1  deraadt 		return YPERR_YPBIND;
    759  1.1  deraadt 	case YP_NOMORE:
    760  1.1  deraadt 		return YPERR_NOMORE;
    761  1.1  deraadt 	case YP_NOMAP:
    762  1.1  deraadt 		return YPERR_MAP;
    763  1.1  deraadt 	case YP_NODOM:
    764  1.1  deraadt 		return YPERR_NODOM;
    765  1.1  deraadt 	case YP_NOKEY:
    766  1.1  deraadt 		return YPERR_KEY;
    767  1.1  deraadt 	case YP_BADOP:
    768  1.1  deraadt 		return YPERR_YPERR;
    769  1.1  deraadt 	case YP_BADDB:
    770  1.1  deraadt 		return YPERR_BADDB;
    771  1.1  deraadt 	case YP_YPERR:
    772  1.1  deraadt 		return YPERR_YPERR;
    773  1.1  deraadt 	case YP_BADARGS:
    774  1.1  deraadt 		return YPERR_BADARGS;
    775  1.1  deraadt 	case YP_VERS:
    776  1.1  deraadt 		return YPERR_VERS;
    777  1.1  deraadt 	}
    778  1.1  deraadt 	return YPERR_YPERR;
    779  1.1  deraadt }
    780  1.1  deraadt 
    781  1.1  deraadt int
    782  1.1  deraadt _yp_check(dom)
    783  1.1  deraadt char **dom;
    784  1.1  deraadt {
    785  1.1  deraadt 	int use_yp = 0;
    786  1.1  deraadt 	char *unused;
    787  1.1  deraadt 
    788  1.1  deraadt 	if( _yp_domain[0]=='\0' )
    789  1.1  deraadt 		if( yp_get_default_domain(&unused) )
    790  1.1  deraadt 			return 0;
    791  1.1  deraadt 
    792  1.1  deraadt 	if(dom)
    793  1.1  deraadt 		*dom = _yp_domain;
    794  1.1  deraadt 
    795  1.1  deraadt 	if( yp_bind(_yp_domain)==0 )
    796  1.1  deraadt 		return 1;
    797  1.1  deraadt 	return 0;
    798  1.1  deraadt }
    799