diff options
Diffstat (limited to 'usr.sbin/ypserv/ypxfr')
| -rw-r--r-- | usr.sbin/ypserv/ypxfr/Makefile | 10 | ||||
| -rw-r--r-- | usr.sbin/ypserv/ypxfr/ypxfr.8 | 74 | ||||
| -rw-r--r-- | usr.sbin/ypserv/ypxfr/ypxfr.c | 624 | ||||
| -rw-r--r-- | usr.sbin/ypserv/ypxfr/ypxfr_xdr.c | 88 |
4 files changed, 796 insertions, 0 deletions
diff --git a/usr.sbin/ypserv/ypxfr/Makefile b/usr.sbin/ypserv/ypxfr/Makefile new file mode 100644 index 00000000000..46640a89201 --- /dev/null +++ b/usr.sbin/ypserv/ypxfr/Makefile @@ -0,0 +1,10 @@ +# from: @(#)Makefile 5.8 (Berkeley) 7/28/90 +# $Id: Makefile,v 1.1 1995/11/01 16:56:42 deraadt Exp $ + +PROG= ypxfr +SRCS= ypxfr.c ypdb.c yplog.c yplib_host.c ypxfr_xdr.c +MAN= ypxfr.8 +.PATH: ${.CURDIR}/../common +CFLAGS+=-I${.CURDIR}/../common + +.include <bsd.prog.mk> diff --git a/usr.sbin/ypserv/ypxfr/ypxfr.8 b/usr.sbin/ypserv/ypxfr/ypxfr.8 new file mode 100644 index 00000000000..efe6c7b8a24 --- /dev/null +++ b/usr.sbin/ypserv/ypxfr/ypxfr.8 @@ -0,0 +1,74 @@ +.\" Copyright (c) 1994 Mats O Jansson <moj@stacken.kth.se> +.\" All rights reserved. +.\" +.\" Redistribution and use in source and binary forms, with or without +.\" modification, are permitted provided that the following conditions +.\" are met: +.\" 1. Redistributions of source code must retain the above copyright +.\" notice, this list of conditions and the following disclaimer. +.\" 2. Redistributions in binary form must reproduce the above copyright +.\" notice, this list of conditions and the following disclaimer in the +.\" documentation and/or other materials provided with the distribution. +.\" 3. The name of the author may not be used to endorse or promote +.\" products derived from this software without specific prior written +.\" permission. +.\" +.\" THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS +.\" OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED +.\" WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE +.\" ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY +.\" DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL +.\" DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS +.\" OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) +.\" HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT +.\" LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY +.\" OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF +.\" SUCH DAMAGE. +.\" +.\" $Id: ypxfr.8,v 1.1 1995/11/01 16:56:42 deraadt Exp $ +.\" +.Dd August 18, 1994 +.Dt YPXFR 8 +.Os NetBSD 1.0 +.Sh NAME +.Nm ypxfr +.Nd get a YP map from YP server +.Sh SYNOPSIS +.Nm /usr/sbin/ypxfr +.Op Fl bcf +.Op Fl d Ar domain +.Op Fl h Ar host +.Op Fl s Ar domain +.Op Fl C Ar tid prog ipadd port +.Ar mapname +.Sh DESCRIPTION +.Nm ypxfr +is the utiliy in YP that transfers maps to the local host. +.Pp +.Pp +The options are as follows: +.Bl -tag -width indent +.It Fl b +Preserve the entry in the database informing a YP server to use +DNS to get information about unknown hosts. This option will only have +effect on the two maps hosts.byname and hosts.byaddr. +.It Fl c +Don't send a "Clear current map" to local ypserv process. Useful if ypserv +isn't running localy to avoid timeout message. +.It Fl f +Force map transfer, even if version of master is older than local copy. +.It Fl d Ar domain +Don't use default domain, use the specifiyed domain. +.It Fl h Ar host +Get map from host insteed of the maps master host. +.It Fl s Ar domain +Specify a source domain other than the target domain. +.It Fl C Ar tid prog ipadd port +This option is only used by ypserv. This is to open communication with +an yppush on another host. +.El +.Sh SEE ALSO +.Xr yppush 8 , +.Xr ypserv 8 +.Sh AUTHOR +Mats O Jansson <moj@stacken.kth.se> diff --git a/usr.sbin/ypserv/ypxfr/ypxfr.c b/usr.sbin/ypserv/ypxfr/ypxfr.c new file mode 100644 index 00000000000..7e7c92cb5dc --- /dev/null +++ b/usr.sbin/ypserv/ypxfr/ypxfr.c @@ -0,0 +1,624 @@ +/* + * Copyright (c) 1994 Mats O Jansson <moj@stacken.kth.se> + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * 3. The name of the author may not be used to endorse or promote + * products derived from this software without specific prior written + * permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS + * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED + * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY + * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS + * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) + * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT + * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY + * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + */ + +#ifndef LINT +static char rcsid[] = "$Id: ypxfr.c,v 1.1 1995/11/01 16:56:43 deraadt Exp $"; +#endif + +#include <stdio.h> +#include <stdlib.h> +#include <unistd.h> +#include <sys/stat.h> +#include <fcntl.h> +#include <string.h> +#include <netinet/in.h> +#include <arpa/inet.h> +#include <sys/socket.h> +#include <netdb.h> + +#include <rpc/rpc.h> +#include <rpc/xdr.h> +/* #include <rpcsvc/yp_prot.h> */ +#include <rpcsvc/ypclnt.h> +#include <rpcsvc/yp.h> + +#include "yplib_host.h" +#include "yplog.h" +#include "ypdb.h" +#include "ypdef.h" + +char *progname = "ypxfr"; +DBM *db; + +extern bool_t xdr_ypresp_all_seq(); + +extern int (*ypresp_allfn)(); +extern void *ypresp_data; + +static int +ypxfr_foreach(status,keystr,keylen,valstr,vallen,data) +int status,keylen,vallen,*data; +char *keystr,*valstr; +{ + datum key,val; + + if (status == 2) + return(0); + + keystr[keylen] = '\0'; + valstr[vallen] = '\0'; + + key.dptr = keystr; + key.dsize = strlen(keystr) + 1; + + val.dptr = valstr; + val.dsize = strlen(valstr) + 1; + + ypdb_store(db, key, val, YPDB_INSERT); + + return 0; +} + +int +get_local_ordernum(domain,map,lordernum) +char *domain; +char *map; +u_long *lordernum; +{ + char map_path[1024]; + char order_key[YP_LAST_LEN] = YP_LAST_KEY; + char order[MAX_LAST_LEN+1]; + struct stat finfo; + DBM *db; + datum k,v; + int status; + + /* This routine returns YPPUSH_SUCC or YPPUSH_NODOM */ + + status = YPPUSH_SUCC; + + sprintf(map_path,"%s/%s",YP_DB_PATH,domain); + if (!((stat(map_path, &finfo) == 0) && + ((finfo.st_mode & S_IFMT) == S_IFDIR))) { + fprintf(stderr, "%s: domain %s not found locally\n", + progname, domain); + status = YPPUSH_NODOM; + } + + if(status > 0) { + + sprintf(map_path,"%s/%s/%s%s",YP_DB_PATH,domain,map,YPDB_SUFFIX); + if(!(stat(map_path, &finfo) == 0)) { + status = YPPUSH_NOMAP; + } + } + + if(status > 0) { + + sprintf(map_path,"%s/%s/%s",YP_DB_PATH,domain,map); + db = ypdb_open(map_path, O_RDONLY, 0444); + if(db == NULL) { + status = YPPUSH_DBM; + } + + } + + if(status > 0) { + + k.dptr = (char *) &order_key; + k.dsize = YP_LAST_LEN; + + v = ypdb_fetch(db,k); + ypdb_close(db); + + if (v.dptr == NULL) { + *lordernum = 0; + } else { + strncpy(order, v.dptr, v.dsize); + order[v.dsize] = '\0'; + *lordernum = (u_long) atol((char *) &order); + } + } + + if((status == YPPUSH_NOMAP) || (status == YPPUSH_DBM)) { + *lordernum = 0; + status = YPPUSH_SUCC; + } + + return(status); + +} + +int +get_remote_ordernum(client,domain,map,lordernum,rordernum) +CLIENT *client; +char *domain; +char *map; +u_long lordernum; +u_long *rordernum; +{ + int status; + + status = yp_order_host(client, domain, map,(int *)rordernum); + + if (status == 0) { + if(*rordernum <= lordernum) { + status = YPPUSH_AGE; + } else { + status = YPPUSH_SUCC; + } + } + + return status; +} + +void +get_map(client,domain,map,incallback) +CLIENT *client; +char *domain; +char *map; +struct ypall_callback *incallback; +{ + u_long status; + + status = yp_all_host(client, domain, map, incallback); + +} + +DBM * +create_db(domain,map,temp_map) +char *domain; +char *map; +char *temp_map; +{ + DBM *db; + char db_temp[255]; + + sprintf(db_temp,"%s/%s/%s",YP_DB_PATH,domain,temp_map); + + db = ypdb_open(db_temp, O_RDWR|O_CREAT, 0444); + + return db; + + yplog_str("Open DB "); yplog_cat(db_temp); yplog_cat("\n"); +} + +int +install_db(domain,map,temp_map) +char *domain; +char *map; +char *temp_map; +{ + char db_name[255],db_temp[255]; + + sprintf(db_name,"%s/%s/%s%s",YP_DB_PATH,domain,map,YPDB_SUFFIX); + sprintf(db_temp,"%s/%s/%s%s",YP_DB_PATH,domain,temp_map,YPDB_SUFFIX); + rename(db_temp,db_name); + + return YPPUSH_SUCC; +} + +int +add_order(db, ordernum) +DBM *db; +u_long ordernum; +{ + char datestr[10]; + datum key,val; + char keystr[YP_LAST_LEN] = YP_LAST_KEY; + int status; + + sprintf(datestr, "%010d", ordernum); + + key.dptr = keystr; + key.dsize = strlen(keystr) + 1; + + val.dptr = datestr; + val.dsize = strlen(datestr) + 1; + + status = ypdb_store(db, key, val, YPDB_INSERT); + if(status >= 0) { + status = YPPUSH_SUCC; + } else { + status = YPPUSH_DBM; + } + return(status); +} + +int +add_master(client, domain, map, db) +CLIENT *client; +char *domain; +char *map; +DBM *db; +{ + char keystr[YP_MASTER_LEN] = YP_MASTER_KEY; + char *master; + int status; + datum key,val; + + master = NULL; + + /* Get MASTER */ + + status = yp_master_host(client, domain, map, &master); + + if(master != NULL) { + key.dptr = keystr; + key.dsize = strlen(keystr) + 1; + + val.dptr = master; + val.dsize = strlen(master) + 1; + + status = ypdb_store(db, key, val, YPDB_INSERT); + if(status >= 0) { + status = YPPUSH_SUCC; + } else { + status = YPPUSH_DBM; + } + } + + return status; +} + +int +add_interdomain(client, domain, map, db) +CLIENT *client; +char *domain; +char *map; +DBM *db; +{ + char keystr[YP_INTERDOMAIN_LEN] = YP_INTERDOMAIN_KEY; + char *value; + int vallen; + int status; + datum k,v; + + /* Get INTERDOMAIN */ + + k.dptr = keystr; + k.dsize = strlen(keystr) + 1; + + status = yp_match_host(client, domain, map, + k.dptr, k.dsize, &value, &vallen); + + if(status > 0) { + v.dptr = value; + v.dsize = vallen; + + if(v.dptr != NULL) { + status = ypdb_store(db,k,v,YPDB_INSERT); + if(status >= 0) { + status = YPPUSH_SUCC; + } else { + status = YPPUSH_DBM; + } + } + } + + return status; +} + +int +add_secure(client, domain, map, db) +CLIENT *client; +char *domain; +char *map; +DBM *db; +{ + char keystr[YP_SECURE_LEN] = YP_SECURE_KEY; + char *value; + int vallen; + int status; + datum k,v; + + /* Get SECURE */ + + k.dptr = keystr; + k.dsize = strlen(keystr) + 1; + + status = yp_match_host(client, domain, map, + k.dptr, k.dsize, &value, &vallen); + + if(status > 0) { + v.dptr = value; + v.dsize = vallen; + + if(v.dptr != NULL) { + status = ypdb_store(db,k,v,YPDB_INSERT); + if(status >= 0) { + status = YPPUSH_SUCC; + } else { + status = YPPUSH_DBM; + } + } + } + + return status; + +} + +int +send_clear(client) +CLIENT *client; +{ + struct timeval tv; + int r; + int status; + + status = YPPUSH_SUCC; + + tv.tv_sec = 10; + tv.tv_usec = 0; + + /* Send CLEAR */ + + r = clnt_call(client, YPPROC_CLEAR, + xdr_void, 0, xdr_void, 0, tv); + if(r != RPC_SUCCESS) { + clnt_perror(client, "yp_clear: clnt_call"); + } + + return status; + +} + +int +send_reply(client,status,tid) +CLIENT *client; +u_long status; +u_long tid; +{ + struct timeval tv; + struct ypresp_xfr resp; + int r; + + tv.tv_sec = 10; + tv.tv_usec = 0; + + resp.transid = tid; + resp.xfrstat = status; + + /* Send CLEAR */ + + r = clnt_call(client, 1, + xdr_ypresp_xfr, &resp, xdr_void, 0, tv); + if(r != RPC_SUCCESS) { + clnt_perror(client, "yppushresp_xdr: clnt_call"); + } + + return status; + +} + +int +main (argc,argv) +int argc; +char *argv[]; +{ + int usage = 0; + int cflag = 0; + int fflag = 0; + int Cflag = 0; + char ch; + extern char *optarg; + char *domain; + char *host = NULL; + char *srcdomain = NULL; + char *tid = NULL; + char *prog = NULL; + char *ipadd = NULL; + char *port = NULL; + char *map = NULL; + u_long ordernum,new_ordernum; + struct ypall_callback callback; + CLIENT *client; + char mapname[] = "ypdbXXXXXX"; + int status,xfr_status; + + status = YPPUSH_SUCC; + client = NULL; + + yp_get_default_domain(&domain); + + while ((ch = getopt(argc, argv, "cd:fh:s:C:")) != EOF) + switch (ch) { + case 'c': + cflag++; + break; + case 'd': + domain = optarg; + break; + case 'f': + fflag++; + break; + case 'h': + host = optarg; + break; + case 's': + srcdomain = optarg; + break; + case 'C': + Cflag++; + tid = optarg; + prog = argv[optind++]; + ipadd = argv[optind++]; + port = argv[optind++]; + break; + default: + usage++; + break; + } + + if(optind + 1 != argc) { + usage++; + } else { + map = argv[optind]; + } + + if (usage) { + status = YPPUSH_BADARGS; + (void)fprintf(stderr,"usage: %s [-cf] [-d domain] [-h host] [-s domain] [-C tid prog ipadd port] mapname\n",progname); + } + + if (status > 0) { + yplog_init(progname); + + yplog_date("Arguments:"); + yplog_str("YP clear to local: "); + if (cflag) { + yplog_cat("no\n"); + } else { + yplog_cat("yes\n"); + } + yplog_str(" Force transfer: "); + if (fflag) { + yplog_cat("yes\n"); + } else { + yplog_cat("no\n"); + } + yplog_str(" domain: "); yplog_cat(domain); yplog_cat("\n"); + yplog_str(" host: "); yplog_cat(host); yplog_cat("\n"); + yplog_str(" source domain: "); yplog_cat(srcdomain); yplog_cat("\n"); + yplog_str(" transid: "); yplog_cat(tid); yplog_cat("\n"); + yplog_str(" prog: "); yplog_cat(prog); yplog_cat("\n"); + yplog_str(" port: "); yplog_cat(port); yplog_cat("\n"); + yplog_str(" ipadd: "); yplog_cat(ipadd); yplog_cat("\n"); + yplog_str(" map: "); yplog_cat(map); yplog_cat("\n\n"); + + if(fflag != 0) { + ordernum = 0; + } else { + status = get_local_ordernum(domain,map,&ordernum); + } + } + + if (status > 0) { + + yplog_str("Get Master\n"); + + if (host == NULL) { + if (srcdomain == NULL) { + status = yp_master(domain,map,&host); + } else { + status = yp_master(srcdomain,map,&host); + } + if(status == 0) { + status = YPPUSH_SUCC; + } else { + status = -status; + } + } + }; + + if (status > 0) { + + yplog_str("Connect host: "); yplog_cat(host); yplog_cat("\n"); + + client = yp_bind_host(host,YPPROG,YPVERS,0); + + status = get_remote_ordernum(client,domain,map, + ordernum,&new_ordernum); + + } + + if (status == YPPUSH_SUCC) { + + /* Create temporary db */ + mktemp(mapname); + db = create_db(domain,map,mapname); + if(db == NULL) { + status = YPPUSH_DBM; + } + + /* Add ORDER */ + if(status > 0) { + status = add_order(db, new_ordernum); + } + + /* Add MASTER */ + if(status > 0) { + status = add_master(client,domain,map,db); + } + + /* Add INTERDOMAIN */ + if(status > 0) { + status = add_interdomain(client,domain,map,db); + } + + /* Add SECURE */ + if(status > 0) { + status = add_secure(client,domain,map,db); + } + + if(status > 0) { + callback.foreach=ypxfr_foreach; + get_map(client,domain,map,&callback); + } + + /* Close db */ + if(db != NULL) { + ypdb_close(db); + } + + /* Rename db */ + if(status > 0) { + status = install_db(domain,map,mapname); + } + + } + + xfr_status = status; + + if(client != NULL) { + clnt_destroy(client); + } + + /* YP_CLEAR */ + + if(!cflag) { + client = yp_bind_local(YPPROG,YPVERS); + status = send_clear(client); + clnt_destroy(client); + } + + if(Cflag > 0) { + /* Send Response */ + client = yp_bind_host(ipadd, + atoi(prog), + 1, + atoi(port)); + status = send_reply(client,xfr_status,atoi(tid)); + clnt_destroy(client); + } + + return(0); + +} + diff --git a/usr.sbin/ypserv/ypxfr/ypxfr_xdr.c b/usr.sbin/ypserv/ypxfr/ypxfr_xdr.c new file mode 100644 index 00000000000..848bbc0b1ad --- /dev/null +++ b/usr.sbin/ypserv/ypxfr/ypxfr_xdr.c @@ -0,0 +1,88 @@ +/* + * Copyright (c) 1995 Mats O Jansson <moj@stacken.kth.se> + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * 3. The name of the author may not be used to endorse or promote + * products derived from this software without specific prior written + * permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS + * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED + * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY + * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS + * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) + * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT + * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY + * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + */ + +#ifndef LINT +static char rcsid[] = "$Id: ypxfr_xdr.c,v 1.1 1995/11/01 16:56:43 deraadt Exp $"; +#endif + + + +#include <rpc/rpc.h> +#include <rpcsvc/yp.h> + +bool_t +xdr_ypxfrstat(xdrs, objp) + XDR *xdrs; + ypxfrstat *objp; +{ + if (!xdr_enum(xdrs, (enum_t *)objp)) { + return (FALSE); + } + return (TRUE); +} + +#ifdef notdef +bool_t +xdr_ypreq_xfr(xdrs, objp) + XDR *xdrs; + ypreq_xfr *objp; +{ + if (!xdr_ypmap_parms(xdrs, &objp->map_parms)) { + return (FALSE); + } + if (!xdr_u_int(xdrs, &objp->transid)) { + return (FALSE); + } + if (!xdr_u_int(xdrs, &objp->prog)) { + return (FALSE); + } + if (!xdr_u_int(xdrs, &objp->port)) { + return (FALSE); + } + return (TRUE); +} +#endif + +bool_t +xdr_ypresp_xfr(xdrs, objp) + XDR *xdrs; + ypresp_xfr *objp; +{ + if (!xdr_u_int(xdrs, &objp->transid)) { + return (FALSE); + } + if (!xdr_ypxfrstat(xdrs, &objp->xfrstat)) { + return (FALSE); + } + return (TRUE); +} + + + + |