Home | History | Annotate | Line # | Download | only in ypbind
ypbind.c revision 1.2
      1 /*
      2  * Copyright (c) 1992/3 Theo de Raadt <deraadt (at) fsa.ca>
      3  * All rights reserved.
      4  *
      5  * Redistribution and use in source and binary forms, with or without
      6  * modification, are permitted provided that the following conditions
      7  * are met:
      8  * 1. Redistributions of source code must retain the above copyright
      9  *    notice, this list of conditions and the following disclaimer.
     10  * 2. Redistributions in binary form must reproduce the above copyright
     11  *    notice, this list of conditions and the following disclaimer in the
     12  *    documentation and/or other materials provided with the distribution.
     13  * 3. The name of the author may not be used to endorse or promote
     14  *    products derived from this software without specific prior written
     15  *    permission.
     16  *
     17  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
     18  * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
     19  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     20  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY
     21  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     22  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     23  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     24  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     25  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     26  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     27  * SUCH DAMAGE.
     28  */
     29 
     30 #ifndef LINT
     31 static char rcsid[] = "$Id: ypbind.c,v 1.2 1993/05/16 02:48:49 deraadt Exp $";
     32 #endif
     33 
     34 #include <sys/param.h>
     35 #include <sys/types.h>
     36 #include <sys/ioctl.h>
     37 #include <sys/signal.h>
     38 #include <sys/socket.h>
     39 #include <sys/file.h>
     40 #include <sys/fcntl.h>
     41 #include <sys/syslog.h>
     42 #include <stdio.h>
     43 #include <errno.h>
     44 #include <ctype.h>
     45 #include <dirent.h>
     46 #include <netdb.h>
     47 #include <string.h>
     48 #include <rpc/rpc.h>
     49 #include <rpc/xdr.h>
     50 #include <net/if.h>
     51 #include <arpa/inet.h>
     52 #include <rpc/pmap_clnt.h>
     53 #include <rpc/pmap_prot.h>
     54 #include <rpc/pmap_rmt.h>
     55 #include <unistd.h>
     56 #include <rpcsvc/yp_prot.h>
     57 #include <rpcsvc/ypclnt.h>
     58 
     59 #ifndef BINDINGDIR
     60 #define BINDINGDIR "/var/yp/binding"
     61 #endif
     62 
     63 struct _dom_binding {
     64 	struct _dom_binding *dom_pnext;
     65 	char dom_domain[YPMAXDOMAIN + 1];
     66 	struct sockaddr_in dom_server_addr;
     67 	unsigned short int dom_server_port;
     68 	int dom_socket;
     69 	CLIENT *dom_client;
     70 	long int dom_vers;
     71 	time_t dom_check_t;
     72 	int dom_lockfd;
     73 	int dom_alive;
     74 };
     75 
     76 extern bool_t xdr_domainname(), xdr_ypbind_resp();
     77 extern bool_t xdr_ypreq_key(), xdr_ypresp_val();
     78 extern bool_t xdr_ypbind_setdom();
     79 
     80 char *domainname;
     81 
     82 struct _dom_binding *ypbindlist;
     83 int check;
     84 
     85 #define YPSET_NO	0
     86 #define YPSET_LOCAL	1
     87 #define YPSET_ALL	2
     88 int ypsetmode = YPSET_NO;
     89 
     90 int rpcsock;
     91 struct rmtcallargs rmtca;
     92 struct rmtcallres rmtcr;
     93 char rmtcr_outval;
     94 u_long rmtcr_port;
     95 
     96 void *
     97 ypbindproc_null_2(transp, argp, clnt)
     98 SVCXPRT *transp;
     99 void *argp;
    100 CLIENT *clnt;
    101 {
    102 	static char res;
    103 
    104 	bzero((char *)&res, sizeof(res));
    105 	return (void *)&res;
    106 }
    107 
    108 struct ypbind_resp *
    109 ypbindproc_domain_2(transp, argp, clnt)
    110 SVCXPRT *transp;
    111 char *argp;
    112 CLIENT *clnt;
    113 {
    114 	static struct ypbind_resp res;
    115 	struct _dom_binding *ypdb;
    116 	char path[MAXPATHLEN];
    117 
    118 	bzero((char *)&res, sizeof res);
    119 	res.ypbind_status = YPBIND_FAIL_VAL;
    120 
    121 	for(ypdb=ypbindlist; ypdb; ypdb=ypdb->dom_pnext)
    122 		if( strcmp(ypdb->dom_domain, argp) == 0)
    123 			break;
    124 
    125 	if(ypdb==NULL) {
    126 		ypdb = (struct _dom_binding *)malloc(sizeof *ypdb);
    127 		bzero((char *)ypdb, sizeof *ypdb);
    128 		strncpy(ypdb->dom_domain, argp, sizeof ypdb->dom_domain);
    129 		ypdb->dom_vers = YPVERS;
    130 		ypdb->dom_alive = 0;
    131 		ypdb->dom_lockfd = -1;
    132 		sprintf(path, "%s/%s.%d", BINDINGDIR, ypdb->dom_domain, ypdb->dom_vers);
    133 		unlink(path);
    134 		ypdb->dom_pnext = ypbindlist;
    135 		ypbindlist = ypdb;
    136 		check++;
    137 		return NULL;
    138 	}
    139 
    140 	if(ypdb->dom_alive==0)
    141 		return NULL;
    142 
    143 #if 0
    144 	delta = ypdb->dom_check_t - ypdb->dom_ask_t;
    145 	if( !(ypdb->dom_ask_t==0 || delta > 5)) {
    146 		ypdb->dom_ask_t = time(NULL);
    147 		/*
    148 		 * Hmm. More than 2 requests in 5 seconds have indicated that my
    149 		 * binding is possibly incorrect. Ok, make myself unalive, and
    150 		 * find out what the actual state is.
    151 		 */
    152 		if(ypdb->dom_lockfd!=-1)
    153 			close(ypdb->dom_lockfd);
    154 		ypdb->dom_lockfd = -1;
    155 		ypdb->dom_alive = 0;
    156 		ypdb->dom_lockfd = -1;
    157 		sprintf(path, "%s/%s.%d", BINDINGDIR, ypdb->dom_domain, ypdb->dom_vers);
    158 		unlink(path);
    159 		check++;
    160 		return NULL;
    161 	}
    162 #endif
    163 
    164 answer:
    165 	res.ypbind_status = YPBIND_SUCC_VAL;
    166 	res.ypbind_respbody.ypbind_bindinfo.ypbind_binding_addr.s_addr =
    167 		ypdb->dom_server_addr.sin_addr.s_addr;
    168 	res.ypbind_respbody.ypbind_bindinfo.ypbind_binding_port =
    169 		ypdb->dom_server_port;
    170 	/*printf("domain %s at %s/%d\n", ypdb->dom_domain,
    171 		inet_ntoa(ypdb->dom_server_addr.sin_addr),
    172 		ntohs(ypdb->dom_server_addr.sin_port));*/
    173 	return &res;
    174 }
    175 
    176 bool_t *
    177 ypbindproc_setdom_2(transp, argp, clnt)
    178 SVCXPRT *transp;
    179 struct ypbind_setdom *argp;
    180 CLIENT *clnt;
    181 {
    182 	struct sockaddr_in *fromsin, bindsin;
    183 	char res;
    184 
    185 	bzero((char *)&res, sizeof(res));
    186 	fromsin = svc_getcaller(transp);
    187 
    188 	switch(ypsetmode) {
    189 	case YPSET_LOCAL:
    190 		if( fromsin->sin_addr.s_addr != htonl(INADDR_LOOPBACK))
    191 			return (void *)NULL;
    192 		break;
    193 	case YPSET_ALL:
    194 		break;
    195 	case YPSET_NO:
    196 	default:
    197 		return (void *)NULL;
    198 	}
    199 
    200 	if(argp->ypsetdom_vers != YPVERS)
    201 		return (void *)&res;
    202 
    203 	bzero((char *)&bindsin, sizeof bindsin);
    204 	bindsin.sin_family = AF_INET;
    205 	bindsin.sin_addr.s_addr = argp->ypsetdom_addr.s_addr;
    206 	bindsin.sin_port = argp->ypsetdom_port;
    207 	rpc_received(argp->ypsetdom_domain, &bindsin, 1);
    208 
    209 	res = 1;
    210 	return (void *)&res;
    211 }
    212 
    213 static void
    214 ypbindprog_2(rqstp, transp)
    215 struct svc_req *rqstp;
    216 register SVCXPRT *transp;
    217 {
    218 	union {
    219 		char ypbindproc_domain_2_arg[MAXHOSTNAMELEN];
    220 		struct ypbind_setdom ypbindproc_setdom_2_arg;
    221 	} argument;
    222 	struct authunix_parms *creds;
    223 	char *result;
    224 	bool_t (*xdr_argument)(), (*xdr_result)();
    225 	char *(*local)();
    226 
    227 	switch (rqstp->rq_proc) {
    228 	case YPBINDPROC_NULL:
    229 		xdr_argument = xdr_void;
    230 		xdr_result = xdr_void;
    231 		local = (char *(*)()) ypbindproc_null_2;
    232 		break;
    233 
    234 	case YPBINDPROC_DOMAIN:
    235 		xdr_argument = xdr_domainname;
    236 		xdr_result = xdr_ypbind_resp;
    237 		local = (char *(*)()) ypbindproc_domain_2;
    238 		break;
    239 
    240 	case YPBINDPROC_SETDOM:
    241 		switch(rqstp->rq_cred.oa_flavor) {
    242 		case AUTH_UNIX:
    243 			creds = (struct authunix_parms *)rqstp->rq_clntcred;
    244 			if( creds->aup_uid != 0) {
    245 				svcerr_auth(transp, AUTH_BADCRED);
    246 				return;
    247 			}
    248 			break;
    249 		default:
    250 			svcerr_auth(transp, AUTH_TOOWEAK);
    251 			return;
    252 		}
    253 
    254 		xdr_argument = xdr_ypbind_setdom;
    255 		xdr_result = xdr_void;
    256 		local = (char *(*)()) ypbindproc_setdom_2;
    257 		break;
    258 
    259 	default:
    260 		svcerr_noproc(transp);
    261 		return;
    262 	}
    263 	bzero((char *)&argument, sizeof(argument));
    264 	if (!svc_getargs(transp, xdr_argument, &argument)) {
    265 		svcerr_decode(transp);
    266 		return;
    267 	}
    268 	result = (*local)(transp, &argument, rqstp);
    269 	if (result != NULL && !svc_sendreply(transp, xdr_result, result)) {
    270 		svcerr_systemerr(transp);
    271 	}
    272 	return;
    273 }
    274 
    275 main(argc, argv)
    276 char **argv;
    277 {
    278 	char path[MAXPATHLEN];
    279 	struct timeval tv;
    280 	SVCXPRT *transp;
    281 	fd_set fdsr;
    282 	int width;
    283 	int i;
    284 
    285 	yp_get_default_domain(&domainname);
    286 	if( domainname[0] == '\0') {
    287 		fprintf(stderr, "domainname not set. Aborting.\n");
    288 		exit(1);
    289 	}
    290 
    291 	for(i=1; i<argc; i++) {
    292 		if( strcmp("-ypset", argv[i]) == 0)
    293 			ypsetmode = YPSET_ALL;
    294 		else if (strcmp("-ypsetme", argv[i]) == 0)
    295 			ypsetmode = YPSET_LOCAL;
    296 	}
    297 
    298 	/* blow away everything in BINDINGDIR */
    299 
    300 
    301 
    302 #ifdef DAEMON
    303 	switch(fork()) {
    304 	case 0:
    305 		break;
    306 	case -1:
    307 		perror("fork");
    308 		exit(1);
    309 	default:
    310 		exit(0);
    311 	}
    312 	setsid();
    313 #endif
    314 
    315 	pmap_unset(YPBINDPROG, YPBINDVERS);
    316 
    317 	transp = svcudp_create(RPC_ANYSOCK);
    318 	if (transp == NULL) {
    319 		fprintf(stderr, "cannot create udp service.");
    320 		exit(1);
    321 	}
    322 	if (!svc_register(transp, YPBINDPROG, YPBINDVERS, ypbindprog_2, IPPROTO_UDP)) {
    323 		fprintf(stderr, "unable to register (YPBINDPROG, YPBINDVERS, udp).");
    324 		exit(1);
    325 	}
    326 
    327 	transp = svctcp_create(RPC_ANYSOCK, 0, 0);
    328 	if (transp == NULL) {
    329 		fprintf(stderr, "cannot create tcp service.");
    330 		exit(1);
    331 	}
    332 
    333 	if (!svc_register(transp, YPBINDPROG, YPBINDVERS, ypbindprog_2, IPPROTO_TCP)) {
    334 		fprintf(stderr, "unable to register (YPBINDPROG, YPBINDVERS, tcp).");
    335 		exit(1);
    336 	}
    337 
    338 	if( (rpcsock=socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0) {
    339 		perror("socket");
    340 		return -1;
    341 	}
    342 	fcntl(rpcsock, F_SETFL, fcntl(rpcsock, F_GETFL, 0) | FNDELAY);
    343 	i = 1;
    344 	setsockopt(rpcsock, SOL_SOCKET, SO_BROADCAST, &i, sizeof(i));
    345 	rmtca.prog = YPPROG;
    346 	rmtca.vers = YPVERS;
    347 	rmtca.proc = YPPROC_DOMAIN_NONACK;
    348 	rmtca.xdr_args = NULL;		/* set at call time */
    349 	rmtca.args_ptr = NULL;		/* set at call time */
    350 	rmtcr.port_ptr = &rmtcr_port;
    351 	rmtcr.xdr_results = xdr_bool;
    352 	rmtcr.results_ptr = (caddr_t)&rmtcr_outval;
    353 
    354 	/* build initial domain binding, make it "unsuccessful" */
    355 	ypbindlist = (struct _dom_binding *)malloc(sizeof *ypbindlist);
    356 	bzero((char *)ypbindlist, sizeof *ypbindlist);
    357 	strncpy(ypbindlist->dom_domain, domainname, sizeof ypbindlist->dom_domain);
    358 	ypbindlist->dom_vers = YPVERS;
    359 	ypbindlist->dom_alive = 0;
    360 	ypbindlist->dom_lockfd = -1;
    361 	sprintf(path, "%s/%s.%d", BINDINGDIR, ypbindlist->dom_domain,
    362 		ypbindlist->dom_vers);
    363 	(void)unlink(path);
    364 
    365 	width = getdtablesize();
    366 	while(1) {
    367 		fdsr = svc_fdset;
    368 		FD_SET(rpcsock, &fdsr);
    369 		tv.tv_sec = 1;
    370 		tv.tv_usec = 0;
    371 
    372 		switch(select(width, &fdsr, NULL, NULL, &tv)) {
    373 		case 0:
    374 			checkwork();
    375 			break;
    376 		case -1:
    377 			perror("select\n");
    378 			break;
    379 		default:
    380 			if(FD_ISSET(rpcsock, &fdsr)) {
    381 				FD_CLR(rpcsock, &fdsr);
    382 				handle_replies();
    383 			}
    384 			svc_getreqset(&fdsr);
    385 			if(check)
    386 				checkwork();
    387 			break;
    388 		}
    389 	}
    390 }
    391 
    392 /*
    393  * change to do something like this:
    394  *
    395  * STATE	TIME		ACTION		NEWTIME	NEWSTATE
    396  * no binding	t==*		broadcast 	t=2	no binding
    397  * binding	t==60		check server	t=10	binding
    398  * binding	t=10		broadcast	t=2	no binding
    399  */
    400 checkwork()
    401 {
    402 	struct _dom_binding *ypdb;
    403 	time_t t;
    404 
    405 	check = 0;
    406 
    407 	time(&t);
    408 	for(ypdb=ypbindlist; ypdb; ypdb=ypdb->dom_pnext) {
    409 		if(ypdb->dom_alive==0 || ypdb->dom_check_t < t) {
    410 			broadcast(ypdb->dom_domain);
    411 			time(&t);
    412 			ypdb->dom_check_t = t + 5;
    413 		}
    414 	}
    415 }
    416 
    417 broadcast(dom)
    418 char *dom;
    419 {
    420 	struct rpc_msg rpcmsg;
    421 	char buf[1400], inbuf[8192];
    422 	enum clnt_stat st;
    423 	struct timeval tv;
    424 	int outlen, i, sock, len;
    425 	struct sockaddr_in bsin;
    426 	struct ifconf ifc;
    427 	struct ifreq ifreq, *ifr;
    428 	struct in_addr in;
    429 	AUTH *rpcua;
    430 	XDR rpcxdr;
    431 
    432 	rmtca.xdr_args = xdr_domainname;
    433 	rmtca.args_ptr = dom;
    434 
    435 	bzero((char *)&bsin, sizeof bsin);
    436 	bsin.sin_family = AF_INET;
    437 	bsin.sin_port = htons(PMAPPORT);
    438 
    439 	bzero((char *)&rpcxdr, sizeof rpcxdr);
    440 	bzero((char *)&rpcmsg, sizeof rpcmsg);
    441 
    442 	rpcua = authunix_create_default();
    443 	if( rpcua == (AUTH *)NULL) {
    444 		/*printf("cannot get unix auth\n");*/
    445 		return RPC_SYSTEMERROR;
    446 	}
    447 	rpcmsg.rm_direction = CALL;
    448 	rpcmsg.rm_call.cb_rpcvers = RPC_MSG_VERSION;
    449 	rpcmsg.rm_call.cb_prog = PMAPPROG;
    450 	rpcmsg.rm_call.cb_vers = PMAPVERS;
    451 	rpcmsg.rm_call.cb_proc = PMAPPROC_CALLIT;
    452 	rpcmsg.rm_call.cb_cred = rpcua->ah_cred;
    453 	rpcmsg.rm_call.cb_verf = rpcua->ah_verf;
    454 
    455 	gettimeofday(&tv, (struct timezone *)0);
    456 	rpcmsg.rm_xid = (int)dom;
    457 	tv.tv_usec = 0;
    458 	xdrmem_create(&rpcxdr, buf, sizeof buf, XDR_ENCODE);
    459 	if( (!xdr_callmsg(&rpcxdr, &rpcmsg)) ) {
    460 		st = RPC_CANTENCODEARGS;
    461 		AUTH_DESTROY(rpcua);
    462 		return st;
    463 	}
    464 	if( (!xdr_rmtcall_args(&rpcxdr, &rmtca)) ) {
    465 		st = RPC_CANTENCODEARGS;
    466 		AUTH_DESTROY(rpcua);
    467 		return st;
    468 	}
    469 	outlen = (int)xdr_getpos(&rpcxdr);
    470 	xdr_destroy(&rpcxdr);
    471 	if(outlen<1) {
    472 		AUTH_DESTROY(rpcua);
    473 		return st;
    474 	}
    475 	AUTH_DESTROY(rpcua);
    476 
    477 	/* find all networks and send the RPC packet out them all */
    478 	if( (sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0) {
    479 		perror("socket");
    480 		return -1;
    481 	}
    482 
    483 	ifc.ifc_len = sizeof inbuf;
    484 	ifc.ifc_buf = inbuf;
    485 	if( ioctl(sock, SIOCGIFCONF, &ifc) < 0) {
    486 		close(sock);
    487 		perror("ioctl(SIOCGIFCONF)");
    488 		return -1;
    489 	}
    490 	ifr = ifc.ifc_req;
    491 	ifreq.ifr_name[0] = '\0';
    492 	for(i=0; i<ifc.ifc_len; i+=len, ifr=(struct ifreq *)((caddr_t)ifr+len)) {
    493 #if defined(BSD) && BSD >= 199103
    494 		len = sizeof ifr->ifr_name + ifr->ifr_addr.sa_len;
    495 #else
    496 		len = sizeof ifc.ifc_len / sizeof(struct ifreq);
    497 #endif
    498 		ifreq = *ifr;
    499 		if( ifreq.ifr_addr.sa_family != AF_INET)
    500 			continue;
    501 		if( ioctl(sock, SIOCGIFFLAGS, &ifreq) < 0) {
    502 			perror("ioctl(SIOCGIFFLAGS)");
    503 			continue;
    504 		}
    505 		if( (ifreq.ifr_flags & IFF_UP) == 0)
    506 			continue;
    507 
    508 		ifreq.ifr_flags &= (IFF_LOOPBACK | IFF_BROADCAST);
    509 		if( ifreq.ifr_flags==IFF_BROADCAST ) {
    510 			if( ioctl(sock, SIOCGIFBRDADDR, &ifreq) < 0 ) {
    511 				perror("ioctl(SIOCGIFBRDADDR)");
    512 				continue;
    513 			}
    514 		} else if( ifreq.ifr_flags==IFF_LOOPBACK ) {
    515 			if( ioctl(sock, SIOCGIFADDR, &ifreq) < 0 ) {
    516 				perror("ioctl(SIOCGIFADDR)");
    517 				continue;
    518 			}
    519 		} else
    520 			continue;
    521 
    522 		in = ((struct sockaddr_in *)&ifreq.ifr_addr)->sin_addr;
    523 		bsin.sin_addr = in;
    524 		if( sendto(rpcsock, buf, outlen, 0, (struct sockaddr *)&bsin,
    525 		   sizeof bsin) < 0 )
    526 			perror("sendto");
    527 	}
    528 	close(sock);
    529 	return 0;
    530 }
    531 
    532 /*enum clnt_stat*/
    533 handle_replies()
    534 {
    535 	char buf[1400];
    536 	int fromlen, inlen;
    537 	struct sockaddr_in raddr;
    538 	struct rpc_msg msg;
    539 	XDR xdr;
    540 
    541 recv_again:
    542 	bzero((char *)&xdr, sizeof(xdr));
    543 	bzero((char *)&msg, sizeof(msg));
    544 	msg.acpted_rply.ar_verf = _null_auth;
    545 	msg.acpted_rply.ar_results.where = (caddr_t)&rmtcr;
    546 	msg.acpted_rply.ar_results.proc = xdr_rmtcallres;
    547 
    548 try_again:
    549 	fromlen = sizeof (struct sockaddr);
    550 	inlen = recvfrom(rpcsock, buf, sizeof buf, 0,
    551 		(struct sockaddr *)&raddr, &fromlen);
    552 	if(inlen<0) {
    553 		if(errno==EINTR)
    554 			goto try_again;
    555 		return RPC_CANTRECV;
    556 	}
    557 	if(inlen<sizeof(u_long))
    558 		goto recv_again;
    559 
    560 	/*
    561 	 * see if reply transaction id matches sent id.
    562 	 * If so, decode the results.
    563 	 */
    564 	xdrmem_create(&xdr, buf, (u_int)inlen, XDR_DECODE);
    565 	if( xdr_replymsg(&xdr, &msg)) {
    566 		if( (msg.rm_reply.rp_stat == MSG_ACCEPTED) &&
    567 		   (msg.acpted_rply.ar_stat == SUCCESS)) {
    568 			raddr.sin_port = htons((u_short)rmtcr_port);
    569 			rpc_received(msg.rm_xid, &raddr, 0);
    570 		}
    571 	}
    572 	xdr.x_op = XDR_FREE;
    573 	msg.acpted_rply.ar_results.proc = xdr_void;
    574 	xdr_destroy(&xdr);
    575 
    576 	return RPC_SUCCESS;
    577 }
    578 
    579 /*
    580  * LOOPBACK IS MORE IMPORTANT: PUT IN HACK
    581  */
    582 rpc_received(dom, raddrp, force)
    583 char *dom;
    584 struct sockaddr_in *raddrp;
    585 int force;
    586 {
    587 	struct _dom_binding *ypdb;
    588 	char path[MAXPATHLEN];
    589 	int fd;
    590 
    591 	/*printf("returned from %s about %s\n", inet_ntoa(raddrp->sin_addr), dom);*/
    592 
    593 	if(dom==NULL)
    594 		return;
    595 
    596 	for(ypdb=ypbindlist; ypdb; ypdb=ypdb->dom_pnext)
    597 		if( strcmp(ypdb->dom_domain, dom) == 0)
    598 			break;
    599 
    600 	if(ypdb==NULL) {
    601 		if(force==0)
    602 			return;
    603 		ypdb = (struct _dom_binding *)malloc(sizeof *ypdb);
    604 		bzero((char *)ypdb, sizeof *ypdb);
    605 		strncpy(ypdb->dom_domain, dom, sizeof ypdb->dom_domain);
    606 		ypdb->dom_lockfd = -1;
    607 		ypdb->dom_pnext = ypbindlist;
    608 		ypbindlist = ypdb;
    609 	}
    610 
    611 	/* soft update, alive, less than 30 seconds old */
    612 	if(ypdb->dom_alive==1 && force==0 && ypdb->dom_check_t<time(NULL)+30)
    613 		return;
    614 
    615 	bcopy((char *)raddrp, (char *)&ypdb->dom_server_addr,
    616 		sizeof ypdb->dom_server_addr);
    617 	ypdb->dom_check_t = time(NULL) + 60;	/* recheck binding in 60 seconds */
    618 	ypdb->dom_vers = YPVERS;
    619 	ypdb->dom_alive = 1;
    620 
    621 	if(ypdb->dom_lockfd != -1)
    622 		close(ypdb->dom_lockfd);
    623 
    624 	sprintf(path, "%s/%s.%d", BINDINGDIR,
    625 		ypdb->dom_domain, ypdb->dom_vers);
    626 #ifdef O_SHLOCK
    627 	if( (fd=open(path, O_CREAT|O_SHLOCK|O_RDWR|O_TRUNC, 0644)) == -1) {
    628 		(void)mkdir(BINDINGDIR, 0755);
    629 		if( (fd=open(path, O_CREAT|O_SHLOCK|O_RDWR|O_TRUNC, 0644)) == -1)
    630 			return;
    631 	}
    632 #else
    633 	if( (fd=open(path, O_CREAT|O_RDWR|O_TRUNC, 0644)) == -1) {
    634 		(void)mkdir(BINDINGDIR, 0755);
    635 		if( (fd=open(path, O_CREAT|O_RDWR|O_TRUNC, 0644)) == -1)
    636 			return;
    637 	}
    638 	flock(fd, LOCK_SH);
    639 
    640 	/*
    641 	 * ok, if BINDINGDIR exists, and we can create the binding file,
    642 	 * then write to it..
    643 	 */
    644 	ypdb->dom_lockfd = fd;
    645 	if( write(ypdb->dom_lockfd, raddrp, sizeof *raddrp) != sizeof *raddrp) {
    646 		perror("write");
    647 		close(ypdb->dom_lockfd);
    648 		ypdb->dom_lockfd = -1;
    649 		return;
    650 	}
    651 #endif
    652 }
    653