Home | History | Annotate | Line # | Download | only in ypbind
ypbind.c revision 1.5
      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.5 1993/11/15 21:51:30 cgd 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(ntohs(fromsin->sin_port) >= IPPORT_RESERVED)
    201 		return (void *)&res;
    202 
    203 	if(argp->ypsetdom_vers != YPVERS)
    204 		return (void *)&res;
    205 
    206 	bzero((char *)&bindsin, sizeof bindsin);
    207 	bindsin.sin_family = AF_INET;
    208 	bindsin.sin_addr.s_addr = argp->ypsetdom_addr.s_addr;
    209 	bindsin.sin_port = argp->ypsetdom_port;
    210 	rpc_received(argp->ypsetdom_domain, &bindsin, 1);
    211 
    212 	res = 1;
    213 	return (void *)&res;
    214 }
    215 
    216 static void
    217 ypbindprog_2(rqstp, transp)
    218 struct svc_req *rqstp;
    219 register SVCXPRT *transp;
    220 {
    221 	union {
    222 		char ypbindproc_domain_2_arg[MAXHOSTNAMELEN];
    223 		struct ypbind_setdom ypbindproc_setdom_2_arg;
    224 	} argument;
    225 	struct authunix_parms *creds;
    226 	char *result;
    227 	bool_t (*xdr_argument)(), (*xdr_result)();
    228 	char *(*local)();
    229 
    230 	switch (rqstp->rq_proc) {
    231 	case YPBINDPROC_NULL:
    232 		xdr_argument = xdr_void;
    233 		xdr_result = xdr_void;
    234 		local = (char *(*)()) ypbindproc_null_2;
    235 		break;
    236 
    237 	case YPBINDPROC_DOMAIN:
    238 		xdr_argument = xdr_domainname;
    239 		xdr_result = xdr_ypbind_resp;
    240 		local = (char *(*)()) ypbindproc_domain_2;
    241 		break;
    242 
    243 	case YPBINDPROC_SETDOM:
    244 		switch(rqstp->rq_cred.oa_flavor) {
    245 		case AUTH_UNIX:
    246 			creds = (struct authunix_parms *)rqstp->rq_clntcred;
    247 			if( creds->aup_uid != 0) {
    248 				svcerr_auth(transp, AUTH_BADCRED);
    249 				return;
    250 			}
    251 			break;
    252 		default:
    253 			svcerr_auth(transp, AUTH_TOOWEAK);
    254 			return;
    255 		}
    256 
    257 		xdr_argument = xdr_ypbind_setdom;
    258 		xdr_result = xdr_void;
    259 		local = (char *(*)()) ypbindproc_setdom_2;
    260 		break;
    261 
    262 	default:
    263 		svcerr_noproc(transp);
    264 		return;
    265 	}
    266 	bzero((char *)&argument, sizeof(argument));
    267 	if (!svc_getargs(transp, xdr_argument, &argument)) {
    268 		svcerr_decode(transp);
    269 		return;
    270 	}
    271 	result = (*local)(transp, &argument, rqstp);
    272 	if (result != NULL && !svc_sendreply(transp, xdr_result, result)) {
    273 		svcerr_systemerr(transp);
    274 	}
    275 	return;
    276 }
    277 
    278 main(argc, argv)
    279 char **argv;
    280 {
    281 	char path[MAXPATHLEN];
    282 	struct timeval tv;
    283 	SVCXPRT *transp;
    284 	fd_set fdsr;
    285 	int width;
    286 	int i;
    287 
    288 	yp_get_default_domain(&domainname);
    289 	if( domainname[0] == '\0') {
    290 		fprintf(stderr, "domainname not set. Aborting.\n");
    291 		exit(1);
    292 	}
    293 
    294 	for(i=1; i<argc; i++) {
    295 		if( strcmp("-ypset", argv[i]) == 0)
    296 			ypsetmode = YPSET_ALL;
    297 		else if (strcmp("-ypsetme", argv[i]) == 0)
    298 			ypsetmode = YPSET_LOCAL;
    299 	}
    300 
    301 	/* blow away everything in BINDINGDIR */
    302 
    303 
    304 
    305 #ifdef DAEMON
    306 	switch(fork()) {
    307 	case 0:
    308 		break;
    309 	case -1:
    310 		perror("fork");
    311 		exit(1);
    312 	default:
    313 		exit(0);
    314 	}
    315 	setsid();
    316 #endif
    317 
    318 	pmap_unset(YPBINDPROG, YPBINDVERS);
    319 
    320 	transp = svcudp_create(RPC_ANYSOCK);
    321 	if (transp == NULL) {
    322 		fprintf(stderr, "cannot create udp service.");
    323 		exit(1);
    324 	}
    325 	if (!svc_register(transp, YPBINDPROG, YPBINDVERS, ypbindprog_2, IPPROTO_UDP)) {
    326 		fprintf(stderr, "unable to register (YPBINDPROG, YPBINDVERS, udp).");
    327 		exit(1);
    328 	}
    329 
    330 	transp = svctcp_create(RPC_ANYSOCK, 0, 0);
    331 	if (transp == NULL) {
    332 		fprintf(stderr, "cannot create tcp service.");
    333 		exit(1);
    334 	}
    335 
    336 	if (!svc_register(transp, YPBINDPROG, YPBINDVERS, ypbindprog_2, IPPROTO_TCP)) {
    337 		fprintf(stderr, "unable to register (YPBINDPROG, YPBINDVERS, tcp).");
    338 		exit(1);
    339 	}
    340 
    341 	if( (rpcsock=socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0) {
    342 		perror("socket");
    343 		return -1;
    344 	}
    345 	fcntl(rpcsock, F_SETFL, fcntl(rpcsock, F_GETFL, 0) | FNDELAY);
    346 	i = 1;
    347 	setsockopt(rpcsock, SOL_SOCKET, SO_BROADCAST, &i, sizeof(i));
    348 	rmtca.prog = YPPROG;
    349 	rmtca.vers = YPVERS;
    350 	rmtca.proc = YPPROC_DOMAIN_NONACK;
    351 	rmtca.xdr_args = NULL;		/* set at call time */
    352 	rmtca.args_ptr = NULL;		/* set at call time */
    353 	rmtcr.port_ptr = &rmtcr_port;
    354 	rmtcr.xdr_results = xdr_bool;
    355 	rmtcr.results_ptr = (caddr_t)&rmtcr_outval;
    356 
    357 	/* build initial domain binding, make it "unsuccessful" */
    358 	ypbindlist = (struct _dom_binding *)malloc(sizeof *ypbindlist);
    359 	bzero((char *)ypbindlist, sizeof *ypbindlist);
    360 	strncpy(ypbindlist->dom_domain, domainname, sizeof ypbindlist->dom_domain);
    361 	ypbindlist->dom_vers = YPVERS;
    362 	ypbindlist->dom_alive = 0;
    363 	ypbindlist->dom_lockfd = -1;
    364 	sprintf(path, "%s/%s.%d", BINDINGDIR, ypbindlist->dom_domain,
    365 		ypbindlist->dom_vers);
    366 	(void)unlink(path);
    367 
    368 	width = getdtablesize();
    369 	while(1) {
    370 		fdsr = svc_fdset;
    371 		FD_SET(rpcsock, &fdsr);
    372 		tv.tv_sec = 1;
    373 		tv.tv_usec = 0;
    374 
    375 		switch(select(width, &fdsr, NULL, NULL, &tv)) {
    376 		case 0:
    377 			checkwork();
    378 			break;
    379 		case -1:
    380 			perror("select\n");
    381 			break;
    382 		default:
    383 			if(FD_ISSET(rpcsock, &fdsr)) {
    384 				FD_CLR(rpcsock, &fdsr);
    385 				handle_replies();
    386 			}
    387 			svc_getreqset(&fdsr);
    388 			if(check)
    389 				checkwork();
    390 			break;
    391 		}
    392 	}
    393 }
    394 
    395 /*
    396  * change to do something like this:
    397  *
    398  * STATE	TIME		ACTION		NEWTIME	NEWSTATE
    399  * no binding	t==*		broadcast 	t=2	no binding
    400  * binding	t==60		check server	t=10	binding
    401  * binding	t=10		broadcast	t=2	no binding
    402  */
    403 checkwork()
    404 {
    405 	struct _dom_binding *ypdb;
    406 	time_t t;
    407 
    408 	check = 0;
    409 
    410 	time(&t);
    411 	for(ypdb=ypbindlist; ypdb; ypdb=ypdb->dom_pnext) {
    412 		if(ypdb->dom_alive==0 || ypdb->dom_check_t < t) {
    413 			broadcast(ypdb->dom_domain);
    414 			time(&t);
    415 			ypdb->dom_check_t = t + 5;
    416 		}
    417 	}
    418 }
    419 
    420 broadcast(dom)
    421 char *dom;
    422 {
    423 	struct rpc_msg rpcmsg;
    424 	char buf[1400], inbuf[8192];
    425 	enum clnt_stat st;
    426 	struct timeval tv;
    427 	int outlen, i, sock, len;
    428 	struct sockaddr_in bsin;
    429 	struct ifconf ifc;
    430 	struct ifreq ifreq, *ifr;
    431 	struct in_addr in;
    432 	AUTH *rpcua;
    433 	XDR rpcxdr;
    434 
    435 	rmtca.xdr_args = xdr_domainname;
    436 	rmtca.args_ptr = dom;
    437 
    438 	bzero((char *)&bsin, sizeof bsin);
    439 	bsin.sin_family = AF_INET;
    440 	bsin.sin_port = htons(PMAPPORT);
    441 
    442 	bzero((char *)&rpcxdr, sizeof rpcxdr);
    443 	bzero((char *)&rpcmsg, sizeof rpcmsg);
    444 
    445 	rpcua = authunix_create_default();
    446 	if( rpcua == (AUTH *)NULL) {
    447 		/*printf("cannot get unix auth\n");*/
    448 		return RPC_SYSTEMERROR;
    449 	}
    450 	rpcmsg.rm_direction = CALL;
    451 	rpcmsg.rm_call.cb_rpcvers = RPC_MSG_VERSION;
    452 	rpcmsg.rm_call.cb_prog = PMAPPROG;
    453 	rpcmsg.rm_call.cb_vers = PMAPVERS;
    454 	rpcmsg.rm_call.cb_proc = PMAPPROC_CALLIT;
    455 	rpcmsg.rm_call.cb_cred = rpcua->ah_cred;
    456 	rpcmsg.rm_call.cb_verf = rpcua->ah_verf;
    457 
    458 	gettimeofday(&tv, (struct timezone *)0);
    459 	rpcmsg.rm_xid = (int)dom;
    460 	tv.tv_usec = 0;
    461 	xdrmem_create(&rpcxdr, buf, sizeof buf, XDR_ENCODE);
    462 	if( (!xdr_callmsg(&rpcxdr, &rpcmsg)) ) {
    463 		st = RPC_CANTENCODEARGS;
    464 		AUTH_DESTROY(rpcua);
    465 		return st;
    466 	}
    467 	if( (!xdr_rmtcall_args(&rpcxdr, &rmtca)) ) {
    468 		st = RPC_CANTENCODEARGS;
    469 		AUTH_DESTROY(rpcua);
    470 		return st;
    471 	}
    472 	outlen = (int)xdr_getpos(&rpcxdr);
    473 	xdr_destroy(&rpcxdr);
    474 	if(outlen<1) {
    475 		AUTH_DESTROY(rpcua);
    476 		return st;
    477 	}
    478 	AUTH_DESTROY(rpcua);
    479 
    480 	/* find all networks and send the RPC packet out them all */
    481 	if( (sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0) {
    482 		perror("socket");
    483 		return -1;
    484 	}
    485 
    486 	ifc.ifc_len = sizeof inbuf;
    487 	ifc.ifc_buf = inbuf;
    488 	if( ioctl(sock, SIOCGIFCONF, &ifc) < 0) {
    489 		close(sock);
    490 		perror("ioctl(SIOCGIFCONF)");
    491 		return -1;
    492 	}
    493 	ifr = ifc.ifc_req;
    494 	ifreq.ifr_name[0] = '\0';
    495 	for(i=0; i<ifc.ifc_len; i+=len, ifr=(struct ifreq *)((caddr_t)ifr+len)) {
    496 #if defined(BSD) && BSD >= 199103
    497 		len = sizeof ifr->ifr_name + ifr->ifr_addr.sa_len;
    498 #else
    499 		len = sizeof ifc.ifc_len / sizeof(struct ifreq);
    500 #endif
    501 		ifreq = *ifr;
    502 		if( ifreq.ifr_addr.sa_family != AF_INET)
    503 			continue;
    504 		if( ioctl(sock, SIOCGIFFLAGS, &ifreq) < 0) {
    505 			perror("ioctl(SIOCGIFFLAGS)");
    506 			continue;
    507 		}
    508 		if( (ifreq.ifr_flags & IFF_UP) == 0)
    509 			continue;
    510 
    511 		ifreq.ifr_flags &= (IFF_LOOPBACK | IFF_BROADCAST);
    512 		if( ifreq.ifr_flags==IFF_BROADCAST ) {
    513 			if( ioctl(sock, SIOCGIFBRDADDR, &ifreq) < 0 ) {
    514 				perror("ioctl(SIOCGIFBRDADDR)");
    515 				continue;
    516 			}
    517 		} else if( ifreq.ifr_flags==IFF_LOOPBACK ) {
    518 			if( ioctl(sock, SIOCGIFADDR, &ifreq) < 0 ) {
    519 				perror("ioctl(SIOCGIFADDR)");
    520 				continue;
    521 			}
    522 		} else
    523 			continue;
    524 
    525 		in = ((struct sockaddr_in *)&ifreq.ifr_addr)->sin_addr;
    526 		bsin.sin_addr = in;
    527 		if( sendto(rpcsock, buf, outlen, 0, (struct sockaddr *)&bsin,
    528 		   sizeof bsin) < 0 )
    529 			perror("sendto");
    530 	}
    531 	close(sock);
    532 	return 0;
    533 }
    534 
    535 /*enum clnt_stat*/
    536 handle_replies()
    537 {
    538 	char buf[1400];
    539 	int fromlen, inlen;
    540 	struct sockaddr_in raddr;
    541 	struct rpc_msg msg;
    542 	XDR xdr;
    543 
    544 recv_again:
    545 	bzero((char *)&xdr, sizeof(xdr));
    546 	bzero((char *)&msg, sizeof(msg));
    547 	msg.acpted_rply.ar_verf = _null_auth;
    548 	msg.acpted_rply.ar_results.where = (caddr_t)&rmtcr;
    549 	msg.acpted_rply.ar_results.proc = xdr_rmtcallres;
    550 
    551 try_again:
    552 	fromlen = sizeof (struct sockaddr);
    553 	inlen = recvfrom(rpcsock, buf, sizeof buf, 0,
    554 		(struct sockaddr *)&raddr, &fromlen);
    555 	if(inlen<0) {
    556 		if(errno==EINTR)
    557 			goto try_again;
    558 		return RPC_CANTRECV;
    559 	}
    560 	if(inlen<sizeof(u_long))
    561 		goto recv_again;
    562 
    563 	/*
    564 	 * see if reply transaction id matches sent id.
    565 	 * If so, decode the results.
    566 	 */
    567 	xdrmem_create(&xdr, buf, (u_int)inlen, XDR_DECODE);
    568 	if( xdr_replymsg(&xdr, &msg)) {
    569 		if( (msg.rm_reply.rp_stat == MSG_ACCEPTED) &&
    570 		   (msg.acpted_rply.ar_stat == SUCCESS)) {
    571 			raddr.sin_port = htons((u_short)rmtcr_port);
    572 			rpc_received(msg.rm_xid, &raddr, 0);
    573 		}
    574 	}
    575 	xdr.x_op = XDR_FREE;
    576 	msg.acpted_rply.ar_results.proc = xdr_void;
    577 	xdr_destroy(&xdr);
    578 
    579 	return RPC_SUCCESS;
    580 }
    581 
    582 /*
    583  * LOOPBACK IS MORE IMPORTANT: PUT IN HACK
    584  */
    585 rpc_received(dom, raddrp, force)
    586 char *dom;
    587 struct sockaddr_in *raddrp;
    588 int force;
    589 {
    590 	struct _dom_binding *ypdb;
    591 	char path[MAXPATHLEN];
    592 	int fd;
    593 
    594 	/*printf("returned from %s about %s\n", inet_ntoa(raddrp->sin_addr), dom);*/
    595 
    596 	if(dom==NULL)
    597 		return;
    598 
    599 	for(ypdb=ypbindlist; ypdb; ypdb=ypdb->dom_pnext)
    600 		if( strcmp(ypdb->dom_domain, dom) == 0)
    601 			break;
    602 
    603 	if(ypdb==NULL) {
    604 		if(force==0)
    605 			return;
    606 		ypdb = (struct _dom_binding *)malloc(sizeof *ypdb);
    607 		bzero((char *)ypdb, sizeof *ypdb);
    608 		strncpy(ypdb->dom_domain, dom, sizeof ypdb->dom_domain);
    609 		ypdb->dom_lockfd = -1;
    610 		ypdb->dom_pnext = ypbindlist;
    611 		ypbindlist = ypdb;
    612 	}
    613 
    614 	/* soft update, alive, less than 30 seconds old */
    615 	if(ypdb->dom_alive==1 && force==0 && ypdb->dom_check_t<time(NULL)+30)
    616 		return;
    617 
    618 	bcopy((char *)raddrp, (char *)&ypdb->dom_server_addr,
    619 		sizeof ypdb->dom_server_addr);
    620 	ypdb->dom_check_t = time(NULL) + 60;	/* recheck binding in 60 seconds */
    621 	ypdb->dom_vers = YPVERS;
    622 	ypdb->dom_alive = 1;
    623 
    624 	if(ypdb->dom_lockfd != -1)
    625 		close(ypdb->dom_lockfd);
    626 
    627 	sprintf(path, "%s/%s.%d", BINDINGDIR,
    628 		ypdb->dom_domain, ypdb->dom_vers);
    629 #ifdef O_SHLOCK
    630 	if( (fd=open(path, O_CREAT|O_SHLOCK|O_RDWR|O_TRUNC, 0644)) == -1) {
    631 		(void)mkdir(BINDINGDIR, 0755);
    632 		if( (fd=open(path, O_CREAT|O_SHLOCK|O_RDWR|O_TRUNC, 0644)) == -1)
    633 			return;
    634 	}
    635 #else
    636 	if( (fd=open(path, O_CREAT|O_RDWR|O_TRUNC, 0644)) == -1) {
    637 		(void)mkdir(BINDINGDIR, 0755);
    638 		if( (fd=open(path, O_CREAT|O_RDWR|O_TRUNC, 0644)) == -1)
    639 			return;
    640 	}
    641 	flock(fd, LOCK_SH);
    642 #endif
    643 
    644 	/*
    645 	 * ok, if BINDINGDIR exists, and we can create the binding file,
    646 	 * then write to it..
    647 	 */
    648 	ypdb->dom_lockfd = fd;
    649 	if( write(ypdb->dom_lockfd, raddrp, sizeof *raddrp) != sizeof *raddrp) {
    650 		perror("write");
    651 		close(ypdb->dom_lockfd);
    652 		ypdb->dom_lockfd = -1;
    653 		return;
    654 	}
    655 }
    656