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