Home | History | Annotate | Line # | Download | only in ftpd
ftpd.c revision 1.24
      1  1.24    lukem /*	$NetBSD: ftpd.c,v 1.24 1997/06/14 08:43:31 lukem Exp $	*/
      2  1.13      cgd 
      3   1.1      cgd /*
      4   1.8  deraadt  * Copyright (c) 1985, 1988, 1990, 1992, 1993, 1994
      5   1.8  deraadt  *	The Regents of the University of California.  All rights reserved.
      6   1.1      cgd  *
      7   1.1      cgd  * Redistribution and use in source and binary forms, with or without
      8   1.1      cgd  * modification, are permitted provided that the following conditions
      9   1.1      cgd  * are met:
     10   1.1      cgd  * 1. Redistributions of source code must retain the above copyright
     11   1.1      cgd  *    notice, this list of conditions and the following disclaimer.
     12   1.1      cgd  * 2. Redistributions in binary form must reproduce the above copyright
     13   1.1      cgd  *    notice, this list of conditions and the following disclaimer in the
     14   1.1      cgd  *    documentation and/or other materials provided with the distribution.
     15   1.1      cgd  * 3. All advertising materials mentioning features or use of this software
     16   1.1      cgd  *    must display the following acknowledgement:
     17   1.1      cgd  *	This product includes software developed by the University of
     18   1.1      cgd  *	California, Berkeley and its contributors.
     19   1.1      cgd  * 4. Neither the name of the University nor the names of its contributors
     20   1.1      cgd  *    may be used to endorse or promote products derived from this software
     21   1.1      cgd  *    without specific prior written permission.
     22   1.1      cgd  *
     23   1.1      cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     24   1.1      cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     25   1.1      cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     26   1.1      cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     27   1.1      cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     28   1.1      cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     29   1.1      cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     30   1.1      cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     31   1.1      cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     32   1.1      cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     33   1.1      cgd  * SUCH DAMAGE.
     34   1.1      cgd  */
     35   1.1      cgd 
     36   1.1      cgd #ifndef lint
     37   1.8  deraadt static char copyright[] =
     38   1.8  deraadt "@(#) Copyright (c) 1985, 1988, 1990, 1992, 1993, 1994\n\
     39   1.8  deraadt 	The Regents of the University of California.  All rights reserved.\n";
     40   1.1      cgd #endif /* not lint */
     41   1.1      cgd 
     42   1.1      cgd #ifndef lint
     43  1.13      cgd #if 0
     44  1.17      cjs static char sccsid[] = "@(#)ftpd.c	8.5 (Berkeley) 4/28/95";
     45  1.13      cgd #else
     46  1.24    lukem static char rcsid[] = "$NetBSD: ftpd.c,v 1.24 1997/06/14 08:43:31 lukem Exp $";
     47  1.13      cgd #endif
     48   1.1      cgd #endif /* not lint */
     49   1.1      cgd 
     50   1.1      cgd /*
     51   1.1      cgd  * FTP server.
     52   1.1      cgd  */
     53   1.1      cgd #include <sys/param.h>
     54   1.1      cgd #include <sys/stat.h>
     55   1.1      cgd #include <sys/ioctl.h>
     56   1.1      cgd #include <sys/socket.h>
     57   1.1      cgd #include <sys/wait.h>
     58   1.1      cgd 
     59   1.1      cgd #include <netinet/in.h>
     60   1.1      cgd #include <netinet/in_systm.h>
     61   1.1      cgd #include <netinet/ip.h>
     62   1.1      cgd 
     63   1.1      cgd #define	FTP_NAMES
     64   1.1      cgd #include <arpa/ftp.h>
     65   1.1      cgd #include <arpa/inet.h>
     66   1.1      cgd #include <arpa/telnet.h>
     67   1.1      cgd 
     68   1.8  deraadt #include <ctype.h>
     69   1.1      cgd #include <dirent.h>
     70   1.8  deraadt #include <err.h>
     71   1.8  deraadt #include <errno.h>
     72   1.1      cgd #include <fcntl.h>
     73  1.21      cjs #include <fnmatch.h>
     74   1.8  deraadt #include <glob.h>
     75   1.8  deraadt #include <limits.h>
     76   1.8  deraadt #include <netdb.h>
     77   1.1      cgd #include <pwd.h>
     78   1.1      cgd #include <setjmp.h>
     79   1.8  deraadt #include <signal.h>
     80   1.1      cgd #include <stdio.h>
     81   1.1      cgd #include <stdlib.h>
     82   1.1      cgd #include <string.h>
     83   1.8  deraadt #include <syslog.h>
     84   1.8  deraadt #include <time.h>
     85   1.8  deraadt #include <unistd.h>
     86   1.8  deraadt 
     87  1.24    lukem #include "extern.h"
     88   1.1      cgd #include "pathnames.h"
     89   1.1      cgd 
     90   1.8  deraadt #if __STDC__
     91   1.8  deraadt #include <stdarg.h>
     92   1.8  deraadt #else
     93   1.8  deraadt #include <varargs.h>
     94   1.8  deraadt #endif
     95   1.8  deraadt 
     96  1.24    lukem static char version[] = "Version 7.00";
     97   1.8  deraadt 
     98   1.8  deraadt extern	off_t restart_point;
     99   1.1      cgd extern	char cbuf[];
    100   1.1      cgd 
    101   1.1      cgd struct	sockaddr_in ctrl_addr;
    102   1.1      cgd struct	sockaddr_in data_source;
    103   1.1      cgd struct	sockaddr_in data_dest;
    104   1.1      cgd struct	sockaddr_in his_addr;
    105   1.1      cgd struct	sockaddr_in pasv_addr;
    106   1.1      cgd 
    107   1.1      cgd int	data;
    108   1.1      cgd jmp_buf	errcatch, urgcatch;
    109   1.1      cgd int	logged_in;
    110   1.1      cgd struct	passwd *pw;
    111   1.1      cgd int	debug;
    112   1.1      cgd int	logging;
    113   1.1      cgd int	guest;
    114   1.5      cgd int	dochroot;
    115   1.1      cgd int	type;
    116   1.1      cgd int	form;
    117   1.1      cgd int	stru;			/* avoid C keyword */
    118   1.1      cgd int	mode;
    119   1.1      cgd int	usedefault = 1;		/* for data transfers */
    120   1.1      cgd int	pdata = -1;		/* for passive mode */
    121   1.8  deraadt sig_atomic_t transflag;
    122   1.1      cgd off_t	file_size;
    123   1.1      cgd off_t	byte_count;
    124   1.1      cgd char	tmpline[7];
    125   1.1      cgd char	hostname[MAXHOSTNAMELEN];
    126   1.1      cgd char	remotehost[MAXHOSTNAMELEN];
    127  1.13      cgd static char ttyline[20];
    128  1.13      cgd char	*tty = ttyline;		/* for klogin */
    129  1.22      cjs static char *anondir = NULL;
    130  1.24    lukem static struct timeval lastt;
    131  1.24    lukem 
    132  1.24    lukem extern struct ftpclass curclass;
    133   1.1      cgd 
    134   1.4      cgd #if defined(KERBEROS)
    135  1.13      cgd int	notickets = 1;
    136  1.13      cgd char	*krbtkfile_env = NULL;
    137   1.4      cgd #endif
    138   1.4      cgd 
    139   1.1      cgd /*
    140   1.1      cgd  * Timeout intervals for retrying connections
    141   1.1      cgd  * to hosts that don't accept PORT cmds.  This
    142   1.1      cgd  * is a kludge, but given the problems with TCP...
    143   1.1      cgd  */
    144   1.1      cgd #define	SWAITMAX	90	/* wait at most 90 seconds */
    145   1.1      cgd #define	SWAITINT	5	/* interval between retries */
    146   1.1      cgd 
    147   1.1      cgd int	swaitmax = SWAITMAX;
    148   1.1      cgd int	swaitint = SWAITINT;
    149   1.1      cgd 
    150   1.6      cgd #ifdef HASSETPROCTITLE
    151   1.1      cgd char	proctitle[BUFSIZ];	/* initial part of title */
    152   1.6      cgd #endif /* HASSETPROCTITLE */
    153   1.1      cgd 
    154   1.8  deraadt #define LOGCMD(cmd, file) \
    155   1.8  deraadt 	if (logging > 1) \
    156   1.8  deraadt 	    syslog(LOG_INFO,"%s %s%s", cmd, \
    157   1.8  deraadt 		*(file) == '/' ? "" : curdir(), file);
    158   1.8  deraadt #define LOGCMD2(cmd, file1, file2) \
    159   1.8  deraadt 	 if (logging > 1) \
    160   1.8  deraadt 	    syslog(LOG_INFO,"%s %s%s %s%s", cmd, \
    161   1.8  deraadt 		*(file1) == '/' ? "" : curdir(), file1, \
    162   1.8  deraadt 		*(file2) == '/' ? "" : curdir(), file2);
    163   1.8  deraadt #define LOGBYTES(cmd, file, cnt) \
    164   1.8  deraadt 	if (logging > 1) { \
    165   1.8  deraadt 		if (cnt == (off_t)-1) \
    166   1.8  deraadt 		    syslog(LOG_INFO,"%s %s%s", cmd, \
    167   1.8  deraadt 			*(file) == '/' ? "" : curdir(), file); \
    168   1.8  deraadt 		else \
    169   1.8  deraadt 		    syslog(LOG_INFO, "%s %s%s = %qd bytes", \
    170   1.8  deraadt 			cmd, (*(file) == '/') ? "" : curdir(), file, cnt); \
    171   1.8  deraadt 	}
    172   1.8  deraadt 
    173   1.8  deraadt static void	 ack __P((char *));
    174   1.8  deraadt static void	 myoob __P((int));
    175   1.8  deraadt static int	 checkuser __P((char *, char *));
    176  1.19      cjs static int	 checkaccess __P((char *));
    177   1.8  deraadt static FILE	*dataconn __P((char *, off_t, char *));
    178   1.8  deraadt static void	 dolog __P((struct sockaddr_in *));
    179   1.8  deraadt static char	*curdir __P((void));
    180   1.8  deraadt static void	 end_login __P((void));
    181   1.8  deraadt static FILE	*getdatasock __P((char *));
    182   1.8  deraadt static char	*gunique __P((char *));
    183   1.8  deraadt static void	 lostconn __P((int));
    184   1.8  deraadt static int	 receive_data __P((FILE *, FILE *));
    185   1.8  deraadt static void	 send_data __P((FILE *, FILE *, off_t));
    186   1.8  deraadt static struct passwd *
    187   1.8  deraadt 		 sgetpwnam __P((char *));
    188   1.8  deraadt static char	*sgetsave __P((char *));
    189   1.8  deraadt 
    190   1.8  deraadt static char *
    191   1.8  deraadt curdir()
    192   1.8  deraadt {
    193   1.8  deraadt 	static char path[MAXPATHLEN+1+1];	/* path + '/' + '\0' */
    194   1.8  deraadt 
    195   1.8  deraadt 	if (getcwd(path, sizeof(path)-2) == NULL)
    196   1.8  deraadt 		return ("");
    197   1.8  deraadt 	if (path[1] != '\0')		/* special case for root dir. */
    198   1.8  deraadt 		strcat(path, "/");
    199   1.8  deraadt 	/* For guest account, skip / since it's chrooted */
    200   1.8  deraadt 	return (guest ? path+1 : path);
    201   1.8  deraadt }
    202   1.8  deraadt 
    203   1.8  deraadt int
    204   1.1      cgd main(argc, argv, envp)
    205   1.1      cgd 	int argc;
    206   1.1      cgd 	char *argv[];
    207   1.1      cgd 	char **envp;
    208   1.1      cgd {
    209   1.8  deraadt 	int addrlen, ch, on = 1, tos;
    210   1.8  deraadt 	char *cp, line[LINE_MAX];
    211   1.8  deraadt 	FILE *fd;
    212   1.1      cgd 
    213   1.1      cgd 	/*
    214   1.1      cgd 	 * LOG_NDELAY sets up the logging connection immediately,
    215   1.1      cgd 	 * necessary for anonymous ftp's that chroot and can't do it later.
    216   1.1      cgd 	 */
    217   1.8  deraadt 	openlog("ftpd", LOG_PID | LOG_NDELAY, LOG_FTP);
    218   1.8  deraadt 	addrlen = sizeof(his_addr);
    219   1.1      cgd 	if (getpeername(0, (struct sockaddr *)&his_addr, &addrlen) < 0) {
    220   1.1      cgd 		syslog(LOG_ERR, "getpeername (%s): %m",argv[0]);
    221   1.1      cgd 		exit(1);
    222   1.1      cgd 	}
    223   1.8  deraadt 	addrlen = sizeof(ctrl_addr);
    224   1.1      cgd 	if (getsockname(0, (struct sockaddr *)&ctrl_addr, &addrlen) < 0) {
    225   1.1      cgd 		syslog(LOG_ERR, "getsockname (%s): %m",argv[0]);
    226   1.1      cgd 		exit(1);
    227   1.1      cgd 	}
    228   1.1      cgd #ifdef IP_TOS
    229   1.1      cgd 	tos = IPTOS_LOWDELAY;
    230   1.1      cgd 	if (setsockopt(0, IPPROTO_IP, IP_TOS, (char *)&tos, sizeof(int)) < 0)
    231   1.1      cgd 		syslog(LOG_WARNING, "setsockopt (IP_TOS): %m");
    232   1.1      cgd #endif
    233   1.1      cgd 	data_source.sin_port = htons(ntohs(ctrl_addr.sin_port) - 1);
    234   1.1      cgd 	debug = 0;
    235   1.1      cgd 
    236  1.11   brezak 	/* set this here so klogin can use it... */
    237  1.11   brezak 	(void)sprintf(ttyline, "ftp%d", getpid());
    238  1.11   brezak 
    239  1.22      cjs 	while ((ch = getopt(argc, argv, "a:dlt:T:u:v")) != EOF) {
    240   1.8  deraadt 		switch (ch) {
    241  1.22      cjs 		case 'a':
    242  1.22      cjs 			anondir = optarg;
    243  1.22      cjs 			break;
    244  1.22      cjs 
    245   1.1      cgd 		case 'd':
    246  1.22      cjs 		case 'v':		/* deprecated */
    247   1.1      cgd 			debug = 1;
    248   1.1      cgd 			break;
    249   1.1      cgd 
    250   1.1      cgd 		case 'l':
    251   1.8  deraadt 			logging++;	/* > 1 == extra logging */
    252   1.1      cgd 			break;
    253   1.1      cgd 
    254   1.1      cgd 		case 't':
    255   1.1      cgd 		case 'T':
    256   1.1      cgd 		case 'u':
    257  1.24    lukem 			warnx("-%c has be deprecated in favour of ftpd.conf",
    258  1.24    lukem 			    ch);
    259   1.8  deraadt 			break;
    260   1.1      cgd 
    261   1.1      cgd 		default:
    262   1.8  deraadt 			warnx("unknown flag -%c ignored", optopt);
    263   1.1      cgd 			break;
    264   1.1      cgd 		}
    265   1.1      cgd 	}
    266   1.1      cgd 	(void) freopen(_PATH_DEVNULL, "w", stderr);
    267   1.1      cgd 	(void) signal(SIGPIPE, lostconn);
    268   1.1      cgd 	(void) signal(SIGCHLD, SIG_IGN);
    269  1.10      cgd 	if ((long)signal(SIGURG, myoob) < 0)
    270   1.1      cgd 		syslog(LOG_ERR, "signal: %m");
    271   1.1      cgd 
    272   1.1      cgd 	/* Try to handle urgent data inline */
    273   1.1      cgd #ifdef SO_OOBINLINE
    274   1.1      cgd 	if (setsockopt(0, SOL_SOCKET, SO_OOBINLINE, (char *)&on, sizeof(on)) < 0)
    275   1.1      cgd 		syslog(LOG_ERR, "setsockopt: %m");
    276   1.1      cgd #endif
    277   1.1      cgd 
    278   1.1      cgd #ifdef	F_SETOWN
    279   1.1      cgd 	if (fcntl(fileno(stdin), F_SETOWN, getpid()) == -1)
    280   1.1      cgd 		syslog(LOG_ERR, "fcntl F_SETOWN: %m");
    281   1.1      cgd #endif
    282   1.1      cgd 	dolog(&his_addr);
    283   1.1      cgd 	/*
    284   1.1      cgd 	 * Set up default state
    285   1.1      cgd 	 */
    286   1.1      cgd 	data = -1;
    287   1.1      cgd 	type = TYPE_A;
    288   1.1      cgd 	form = FORM_N;
    289   1.1      cgd 	stru = STRU_F;
    290   1.1      cgd 	mode = MODE_S;
    291   1.1      cgd 	tmpline[0] = '\0';
    292   1.8  deraadt 
    293   1.8  deraadt 	/* If logins are disabled, print out the message. */
    294   1.8  deraadt 	if ((fd = fopen(_PATH_NOLOGIN,"r")) != NULL) {
    295   1.8  deraadt 		while (fgets(line, sizeof(line), fd) != NULL) {
    296   1.8  deraadt 			if ((cp = strchr(line, '\n')) != NULL)
    297   1.8  deraadt 				*cp = '\0';
    298   1.8  deraadt 			lreply(530, "%s", line);
    299   1.8  deraadt 		}
    300   1.8  deraadt 		(void) fflush(stdout);
    301   1.8  deraadt 		(void) fclose(fd);
    302   1.8  deraadt 		reply(530, "System not available.");
    303   1.8  deraadt 		exit(0);
    304   1.8  deraadt 	}
    305   1.8  deraadt 	if ((fd = fopen(_PATH_FTPWELCOME, "r")) != NULL) {
    306   1.8  deraadt 		while (fgets(line, sizeof(line), fd) != NULL) {
    307   1.8  deraadt 			if ((cp = strchr(line, '\n')) != NULL)
    308   1.8  deraadt 				*cp = '\0';
    309   1.8  deraadt 			lreply(220, "%s", line);
    310   1.8  deraadt 		}
    311   1.8  deraadt 		(void) fflush(stdout);
    312   1.8  deraadt 		(void) fclose(fd);
    313   1.8  deraadt 		/* reply(220,) must follow */
    314   1.8  deraadt 	}
    315   1.8  deraadt 	(void) gethostname(hostname, sizeof(hostname));
    316   1.1      cgd 	reply(220, "%s FTP server (%s) ready.", hostname, version);
    317   1.1      cgd 	(void) setjmp(errcatch);
    318   1.1      cgd 	for (;;)
    319   1.1      cgd 		(void) yyparse();
    320   1.1      cgd 	/* NOTREACHED */
    321   1.1      cgd }
    322   1.1      cgd 
    323   1.8  deraadt static void
    324   1.8  deraadt lostconn(signo)
    325   1.8  deraadt 	int signo;
    326   1.1      cgd {
    327   1.8  deraadt 
    328   1.1      cgd 	if (debug)
    329   1.1      cgd 		syslog(LOG_DEBUG, "lost connection");
    330   1.1      cgd 	dologout(-1);
    331   1.1      cgd }
    332   1.1      cgd 
    333   1.1      cgd /*
    334   1.1      cgd  * Helper function for sgetpwnam().
    335   1.1      cgd  */
    336   1.8  deraadt static char *
    337   1.1      cgd sgetsave(s)
    338   1.1      cgd 	char *s;
    339   1.1      cgd {
    340   1.1      cgd 	char *new = malloc((unsigned) strlen(s) + 1);
    341   1.1      cgd 
    342   1.1      cgd 	if (new == NULL) {
    343   1.1      cgd 		perror_reply(421, "Local resource failure: malloc");
    344   1.1      cgd 		dologout(1);
    345   1.1      cgd 		/* NOTREACHED */
    346   1.1      cgd 	}
    347   1.1      cgd 	(void) strcpy(new, s);
    348   1.1      cgd 	return (new);
    349   1.1      cgd }
    350   1.1      cgd 
    351   1.1      cgd /*
    352   1.1      cgd  * Save the result of a getpwnam.  Used for USER command, since
    353   1.1      cgd  * the data returned must not be clobbered by any other command
    354   1.1      cgd  * (e.g., globbing).
    355   1.1      cgd  */
    356   1.8  deraadt static struct passwd *
    357   1.1      cgd sgetpwnam(name)
    358   1.1      cgd 	char *name;
    359   1.1      cgd {
    360   1.1      cgd 	static struct passwd save;
    361   1.8  deraadt 	struct passwd *p;
    362   1.1      cgd 
    363   1.1      cgd 	if ((p = getpwnam(name)) == NULL)
    364   1.1      cgd 		return (p);
    365   1.1      cgd 	if (save.pw_name) {
    366   1.1      cgd 		free(save.pw_name);
    367   1.1      cgd 		free(save.pw_passwd);
    368   1.1      cgd 		free(save.pw_gecos);
    369   1.1      cgd 		free(save.pw_dir);
    370   1.1      cgd 		free(save.pw_shell);
    371   1.1      cgd 	}
    372   1.1      cgd 	save = *p;
    373   1.1      cgd 	save.pw_name = sgetsave(p->pw_name);
    374   1.1      cgd 	save.pw_passwd = sgetsave(p->pw_passwd);
    375   1.1      cgd 	save.pw_gecos = sgetsave(p->pw_gecos);
    376   1.1      cgd 	save.pw_dir = sgetsave(p->pw_dir);
    377   1.1      cgd 	save.pw_shell = sgetsave(p->pw_shell);
    378   1.1      cgd 	return (&save);
    379   1.1      cgd }
    380   1.1      cgd 
    381   1.8  deraadt static int login_attempts;	/* number of failed login attempts */
    382   1.8  deraadt static int askpasswd;		/* had user command, ask for passwd */
    383   1.8  deraadt static char curname[10];	/* current USER name */
    384   1.1      cgd 
    385   1.1      cgd /*
    386   1.1      cgd  * USER command.
    387   1.1      cgd  * Sets global passwd pointer pw if named account exists and is acceptable;
    388   1.1      cgd  * sets askpasswd if a PASS command is expected.  If logged in previously,
    389   1.1      cgd  * need to reset state.  If name is "ftp" or "anonymous", the name is not in
    390   1.1      cgd  * _PATH_FTPUSERS, and ftp account exists, set guest and pw, then just return.
    391   1.1      cgd  * If account doesn't exist, ask for passwd anyway.  Otherwise, check user
    392   1.1      cgd  * requesting login privileges.  Disallow anyone who does not have a standard
    393   1.1      cgd  * shell as returned by getusershell().  Disallow anyone mentioned in the file
    394   1.1      cgd  * _PATH_FTPUSERS to allow people such as root and uucp to be avoided.
    395   1.1      cgd  */
    396   1.8  deraadt void
    397   1.1      cgd user(name)
    398   1.1      cgd 	char *name;
    399   1.1      cgd {
    400   1.1      cgd 	if (logged_in) {
    401   1.1      cgd 		if (guest) {
    402   1.1      cgd 			reply(530, "Can't change user from guest login.");
    403   1.1      cgd 			return;
    404   1.5      cgd 		} else if (dochroot) {
    405   1.5      cgd 			reply(530, "Can't change user from chroot user.");
    406   1.5      cgd 			return;
    407   1.1      cgd 		}
    408   1.1      cgd 		end_login();
    409   1.1      cgd 	}
    410   1.1      cgd 
    411   1.1      cgd 	guest = 0;
    412   1.1      cgd 	if (strcmp(name, "ftp") == 0 || strcmp(name, "anonymous") == 0) {
    413  1.19      cjs 		if (checkaccess("ftp") || checkaccess("anonymous"))
    414   1.1      cgd 			reply(530, "User %s access denied.", name);
    415   1.1      cgd 		else if ((pw = sgetpwnam("ftp")) != NULL) {
    416   1.1      cgd 			guest = 1;
    417   1.1      cgd 			askpasswd = 1;
    418   1.8  deraadt 			reply(331,
    419   1.8  deraadt 			    "Guest login ok, type your name as password.");
    420   1.1      cgd 		} else
    421   1.1      cgd 			reply(530, "User %s unknown.", name);
    422   1.8  deraadt 		if (!askpasswd && logging)
    423   1.8  deraadt 			syslog(LOG_NOTICE,
    424   1.8  deraadt 			    "ANONYMOUS FTP LOGIN REFUSED FROM %s", remotehost);
    425   1.1      cgd 		return;
    426   1.1      cgd 	}
    427  1.19      cjs 	pw = sgetpwnam(name);
    428   1.8  deraadt 	if (logging)
    429   1.8  deraadt 		strncpy(curname, name, sizeof(curname)-1);
    430   1.7  deraadt #ifdef SKEY
    431   1.8  deraadt 	if (!skey_haskey(name)) {
    432   1.8  deraadt 		char *myskey, *skey_keyinfo __P((char *name));
    433   1.7  deraadt 
    434   1.8  deraadt 		myskey = skey_keyinfo(name);
    435   1.7  deraadt 		reply(331, "Password [%s] for %s required.",
    436   1.8  deraadt 		    myskey ? myskey : "error getting challenge", name);
    437   1.7  deraadt 	} else
    438   1.7  deraadt #endif
    439   1.7  deraadt 		reply(331, "Password required for %s.", name);
    440   1.7  deraadt 
    441   1.1      cgd 	askpasswd = 1;
    442   1.1      cgd 	/*
    443   1.1      cgd 	 * Delay before reading passwd after first failed
    444   1.1      cgd 	 * attempt to slow down passwd-guessing programs.
    445   1.1      cgd 	 */
    446   1.1      cgd 	if (login_attempts)
    447   1.1      cgd 		sleep((unsigned) login_attempts);
    448   1.1      cgd }
    449   1.1      cgd 
    450   1.1      cgd /*
    451   1.5      cgd  * Check if a user is in the file "fname"
    452   1.1      cgd  */
    453   1.8  deraadt static int
    454   1.5      cgd checkuser(fname, name)
    455   1.5      cgd 	char *fname;
    456   1.1      cgd 	char *name;
    457   1.1      cgd {
    458   1.8  deraadt 	FILE *fd;
    459   1.8  deraadt 	int found = 0;
    460   1.8  deraadt 	char *p, line[BUFSIZ];
    461   1.1      cgd 
    462   1.5      cgd 	if ((fd = fopen(fname, "r")) != NULL) {
    463   1.1      cgd 		while (fgets(line, sizeof(line), fd) != NULL)
    464   1.8  deraadt 			if ((p = strchr(line, '\n')) != NULL) {
    465   1.1      cgd 				*p = '\0';
    466   1.1      cgd 				if (line[0] == '#')
    467   1.1      cgd 					continue;
    468   1.9      jtc 				if (strcmp(line, name) == 0) {
    469   1.8  deraadt 					found = 1;
    470   1.8  deraadt 					break;
    471   1.8  deraadt 				}
    472   1.1      cgd 			}
    473   1.1      cgd 		(void) fclose(fd);
    474   1.1      cgd 	}
    475   1.8  deraadt 	return (found);
    476   1.1      cgd }
    477   1.1      cgd 
    478   1.1      cgd /*
    479  1.19      cjs  * Determine whether a user has access, based on information in
    480  1.21      cjs  * _PATH_FTPUSERS. Each line is a shell-style glob followed by
    481  1.21      cjs  * `allow' or `deny' (with deny being the default if anything but
    482  1.21      cjs  * `allow', or nothing at all, is specified).
    483  1.19      cjs  *
    484  1.21      cjs  * Each glob is matched against the username in turn, and the first
    485  1.21      cjs  * match found is used. If no match is found, access is allowed.
    486  1.21      cjs  *
    487  1.21      cjs  * Any line starting with `#' is considered a comment and ignored.
    488  1.19      cjs  *
    489  1.19      cjs  * This is probably not the best way to do this, but it preserves
    490  1.19      cjs  * the old semantics where if a user was listed in the file he was
    491  1.19      cjs  * denied, otherwise he was allowed.
    492  1.19      cjs  *
    493  1.19      cjs  * There is one change in the semantics, however; ftpd will now `fail
    494  1.19      cjs  * safe' and deny all access if there's no /etc/ftpusers file.
    495  1.19      cjs  *
    496  1.19      cjs  * Return 1 if the user is denied, or 0 if he is allowed.
    497  1.19      cjs  */
    498  1.19      cjs static int
    499  1.19      cjs checkaccess(name)
    500  1.19      cjs 	char *name;
    501  1.19      cjs {
    502  1.19      cjs #define ALLOWED		0
    503  1.19      cjs #define	NOT_ALLOWED	1
    504  1.19      cjs 	FILE *fd;
    505  1.21      cjs 	int retval = ALLOWED;
    506  1.21      cjs 	char *glob, *perm, line[BUFSIZ];
    507  1.19      cjs 
    508  1.19      cjs 	if ((fd = fopen(_PATH_FTPUSERS, "r")) == NULL)
    509  1.19      cjs 		return NOT_ALLOWED;
    510  1.19      cjs 
    511  1.19      cjs 	while (fgets(line, sizeof(line), fd) != NULL)  {
    512  1.21      cjs 		glob = strtok(line, " \t\n");
    513  1.21      cjs 		if (glob[0] == '#')
    514  1.19      cjs 			continue;
    515  1.19      cjs 		perm = strtok(NULL, " \t\n");
    516  1.21      cjs 		if (fnmatch(glob, name, 0) == 0)  {
    517  1.19      cjs 			if (perm != NULL && strcmp(perm, "allow") == 0)
    518  1.21      cjs 				retval = ALLOWED;
    519  1.19      cjs 			else
    520  1.21      cjs 				retval = NOT_ALLOWED;
    521  1.21      cjs 			break;
    522  1.19      cjs 		}
    523  1.19      cjs 	}
    524  1.19      cjs 	(void) fclose(fd);
    525  1.21      cjs 	return (retval);
    526  1.21      cjs 
    527  1.19      cjs }
    528  1.19      cjs #undef	ALLOWED
    529  1.19      cjs #undef	NOT_ALLOWED
    530  1.19      cjs 
    531  1.19      cjs /*
    532   1.1      cgd  * Terminate login as previous user, if any, resetting state;
    533   1.1      cgd  * used when USER command is given or login fails.
    534   1.1      cgd  */
    535   1.8  deraadt static void
    536   1.1      cgd end_login()
    537   1.1      cgd {
    538   1.1      cgd 
    539   1.1      cgd 	(void) seteuid((uid_t)0);
    540   1.1      cgd 	if (logged_in)
    541   1.1      cgd 		logwtmp(ttyline, "", "");
    542   1.1      cgd 	pw = NULL;
    543   1.1      cgd 	logged_in = 0;
    544   1.1      cgd 	guest = 0;
    545   1.5      cgd 	dochroot = 0;
    546   1.1      cgd }
    547   1.1      cgd 
    548   1.8  deraadt void
    549   1.1      cgd pass(passwd)
    550   1.1      cgd 	char *passwd;
    551   1.1      cgd {
    552   1.4      cgd 	int rval;
    553   1.8  deraadt 	FILE *fd;
    554  1.19      cjs 	char *cp, *shell;
    555   1.1      cgd 
    556   1.1      cgd 	if (logged_in || askpasswd == 0) {
    557   1.1      cgd 		reply(503, "Login with USER first.");
    558   1.1      cgd 		return;
    559   1.1      cgd 	}
    560   1.1      cgd 	askpasswd = 0;
    561   1.1      cgd 	if (!guest) {		/* "ftp" is only account allowed no password */
    562   1.8  deraadt 		if (pw == NULL) {
    563   1.8  deraadt 			rval = 1;	/* failure below */
    564   1.8  deraadt 			goto skip;
    565   1.8  deraadt 		}
    566   1.4      cgd #if defined(KERBEROS)
    567   1.8  deraadt 		rval = klogin(pw, "", hostname, passwd);
    568   1.8  deraadt 		if (rval == 0)
    569   1.8  deraadt 			goto skip;
    570   1.4      cgd #endif
    571   1.7  deraadt #ifdef SKEY
    572   1.8  deraadt 		if (skey_haskey(pw->pw_name) == 0 &&
    573   1.8  deraadt 		   (skey_passcheck(pw->pw_name, passwd) != -1)) {
    574   1.8  deraadt 			rval = 0;
    575   1.8  deraadt 			goto skip;
    576   1.8  deraadt 		}
    577   1.7  deraadt #endif
    578   1.8  deraadt 		/* the strcmp does not catch null passwords! */
    579   1.8  deraadt 		if (pw == NULL || *pw->pw_passwd == '\0' ||
    580   1.8  deraadt 		    strcmp(crypt(passwd, (pw ? pw->pw_passwd : "xx")), pw->pw_passwd)) {
    581   1.8  deraadt 			rval = 1;	 /* failure */
    582   1.8  deraadt 			goto skip;
    583   1.7  deraadt 		}
    584   1.8  deraadt 		rval = 0;
    585   1.4      cgd 
    586   1.8  deraadt skip:
    587   1.4      cgd 		/*
    588   1.4      cgd 		 * If rval == 1, the user failed the authentication check
    589   1.4      cgd 		 * above.  If rval == 0, either Kerberos or local authentication
    590   1.4      cgd 		 * succeeded.
    591   1.4      cgd 		 */
    592   1.4      cgd 		if (rval) {
    593   1.1      cgd 			reply(530, "Login incorrect.");
    594  1.23    lukem 			if (logging) {
    595   1.8  deraadt 				syslog(LOG_NOTICE,
    596  1.23    lukem 				    "FTP LOGIN FAILED FROM %s", remotehost);
    597  1.23    lukem 				syslog(LOG_AUTHPRIV | LOG_NOTICE,
    598   1.8  deraadt 				    "FTP LOGIN FAILED FROM %s, %s",
    599   1.8  deraadt 				    remotehost, curname);
    600  1.23    lukem 			}
    601   1.1      cgd 			pw = NULL;
    602   1.1      cgd 			if (login_attempts++ >= 5) {
    603   1.1      cgd 				syslog(LOG_NOTICE,
    604   1.1      cgd 				    "repeated login failures from %s",
    605   1.1      cgd 				    remotehost);
    606   1.1      cgd 				exit(0);
    607   1.1      cgd 			}
    608   1.1      cgd 			return;
    609   1.1      cgd 		}
    610   1.1      cgd 	}
    611  1.19      cjs 
    612  1.19      cjs 	/* password was ok; see if anything else prevents login */
    613  1.19      cjs 	if (checkaccess(pw->pw_name))  {
    614  1.19      cjs 		reply(530, "User %s may not use FTP.", pw->pw_name);
    615  1.19      cjs 		if (logging)
    616  1.19      cjs 			syslog(LOG_NOTICE, "FTP LOGIN REFUSED FROM %s, %s",
    617  1.19      cjs 			    remotehost, pw->pw_name);
    618  1.19      cjs 		pw = (struct passwd *) NULL;
    619  1.19      cjs 		return;
    620  1.19      cjs 	}
    621  1.19      cjs 	/* check for valid shell, if not guest user */
    622  1.19      cjs 	if ((shell = pw->pw_shell) == NULL || *shell == 0)
    623  1.19      cjs 		shell = _PATH_BSHELL;
    624  1.19      cjs 	while ((cp = getusershell()) != NULL)
    625  1.19      cjs 		if (strcmp(cp, shell) == 0)
    626  1.19      cjs 			break;
    627  1.19      cjs 	endusershell();
    628  1.19      cjs 	if (cp == NULL && guest == 0) {
    629  1.19      cjs 		reply(530, "User %s may not use FTP.", pw->pw_name);
    630  1.19      cjs 		if (logging)
    631  1.19      cjs 			syslog(LOG_NOTICE,
    632  1.19      cjs 			    "FTP LOGIN REFUSED FROM %s, %s",
    633  1.19      cjs 			    remotehost, pw->pw_name);
    634  1.19      cjs 		pw = (struct passwd *) NULL;
    635  1.19      cjs 		return;
    636  1.19      cjs 	}
    637  1.19      cjs 
    638   1.1      cgd 	login_attempts = 0;		/* this time successful */
    639   1.8  deraadt 	if (setegid((gid_t)pw->pw_gid) < 0) {
    640   1.8  deraadt 		reply(550, "Can't set gid.");
    641   1.8  deraadt 		return;
    642   1.8  deraadt 	}
    643   1.1      cgd 	(void) initgroups(pw->pw_name, pw->pw_gid);
    644   1.1      cgd 
    645   1.1      cgd 	/* open wtmp before chroot */
    646   1.1      cgd 	logwtmp(ttyline, pw->pw_name, remotehost);
    647   1.1      cgd 	logged_in = 1;
    648   1.1      cgd 
    649   1.5      cgd 	dochroot = checkuser(_PATH_FTPCHROOT, pw->pw_name);
    650  1.24    lukem 
    651  1.24    lukem 	/* parse ftpd.conf, setting up various parameters */
    652  1.24    lukem 	if (guest)
    653  1.24    lukem 		parse_conf(CLASS_GUEST);
    654  1.24    lukem 	else if (dochroot)
    655  1.24    lukem 		parse_conf(CLASS_CHROOT);
    656  1.24    lukem 	else
    657  1.24    lukem 		parse_conf(CLASS_REAL);
    658  1.24    lukem 
    659   1.1      cgd 	if (guest) {
    660   1.1      cgd 		/*
    661   1.1      cgd 		 * We MUST do a chdir() after the chroot. Otherwise
    662   1.1      cgd 		 * the old current directory will be accessible as "."
    663   1.1      cgd 		 * outside the new root!
    664   1.1      cgd 		 */
    665  1.24    lukem 		if (chroot(anondir ? anondir : pw->pw_dir) < 0 ||
    666  1.24    lukem 		    chdir("/") < 0) {
    667   1.1      cgd 			reply(550, "Can't set guest privileges.");
    668   1.5      cgd 			goto bad;
    669   1.5      cgd 		}
    670   1.5      cgd 	} else if (dochroot) {
    671   1.5      cgd 		if (chroot(pw->pw_dir) < 0 || chdir("/") < 0) {
    672   1.5      cgd 			reply(550, "Can't change root.");
    673   1.1      cgd 			goto bad;
    674   1.1      cgd 		}
    675   1.1      cgd 	} else if (chdir(pw->pw_dir) < 0) {
    676   1.1      cgd 		if (chdir("/") < 0) {
    677   1.1      cgd 			reply(530, "User %s: can't change directory to %s.",
    678   1.1      cgd 			    pw->pw_name, pw->pw_dir);
    679   1.1      cgd 			goto bad;
    680   1.1      cgd 		} else
    681   1.1      cgd 			lreply(230, "No directory! Logging in with home=/");
    682   1.1      cgd 	}
    683   1.1      cgd 	if (seteuid((uid_t)pw->pw_uid) < 0) {
    684   1.1      cgd 		reply(550, "Can't set uid.");
    685   1.1      cgd 		goto bad;
    686   1.1      cgd 	}
    687   1.8  deraadt 	/*
    688   1.8  deraadt 	 * Display a login message, if it exists.
    689   1.8  deraadt 	 * N.B. reply(230,) must follow the message.
    690   1.8  deraadt 	 */
    691   1.8  deraadt 	if ((fd = fopen(_PATH_FTPLOGINMESG, "r")) != NULL) {
    692   1.8  deraadt 		char *cp, line[LINE_MAX];
    693   1.8  deraadt 
    694   1.8  deraadt 		while (fgets(line, sizeof(line), fd) != NULL) {
    695   1.8  deraadt 			if ((cp = strchr(line, '\n')) != NULL)
    696   1.8  deraadt 				*cp = '\0';
    697   1.8  deraadt 			lreply(230, "%s", line);
    698   1.8  deraadt 		}
    699   1.8  deraadt 		(void) fflush(stdout);
    700   1.8  deraadt 		(void) fclose(fd);
    701   1.8  deraadt 	}
    702  1.24    lukem 	show_chdir_messages(230);
    703   1.1      cgd 	if (guest) {
    704   1.1      cgd 		reply(230, "Guest login ok, access restrictions apply.");
    705   1.6      cgd #ifdef HASSETPROCTITLE
    706   1.8  deraadt 		snprintf(proctitle, sizeof(proctitle),
    707   1.8  deraadt 		    "%s: anonymous/%.*s", remotehost,
    708   1.1      cgd 		    sizeof(proctitle) - sizeof(remotehost) -
    709   1.1      cgd 		    sizeof(": anonymous/"), passwd);
    710   1.1      cgd 		setproctitle(proctitle);
    711   1.6      cgd #endif /* HASSETPROCTITLE */
    712   1.1      cgd 		if (logging)
    713   1.1      cgd 			syslog(LOG_INFO, "ANONYMOUS FTP LOGIN FROM %s, %s",
    714   1.1      cgd 			    remotehost, passwd);
    715   1.1      cgd 	} else {
    716   1.1      cgd 		reply(230, "User %s logged in.", pw->pw_name);
    717   1.6      cgd #ifdef HASSETPROCTITLE
    718   1.8  deraadt 		snprintf(proctitle, sizeof(proctitle),
    719   1.8  deraadt 		    "%s: %s", remotehost, pw->pw_name);
    720   1.1      cgd 		setproctitle(proctitle);
    721   1.6      cgd #endif /* HASSETPROCTITLE */
    722   1.1      cgd 		if (logging)
    723   1.8  deraadt 			syslog(LOG_INFO, "FTP LOGIN FROM %s as %s",
    724   1.1      cgd 			    remotehost, pw->pw_name);
    725   1.1      cgd 	}
    726  1.24    lukem 	(void) umask(curclass.umask);
    727   1.1      cgd 	return;
    728   1.1      cgd bad:
    729   1.1      cgd 	/* Forget all about it... */
    730   1.1      cgd 	end_login();
    731   1.1      cgd }
    732   1.1      cgd 
    733   1.8  deraadt void
    734   1.1      cgd retrieve(cmd, name)
    735   1.1      cgd 	char *cmd, *name;
    736   1.1      cgd {
    737   1.1      cgd 	FILE *fin, *dout;
    738   1.1      cgd 	struct stat st;
    739   1.8  deraadt 	int (*closefunc) __P((FILE *));
    740  1.24    lukem 	int log;
    741   1.1      cgd 
    742  1.24    lukem 	log = (cmd == 0);
    743   1.1      cgd 	if (cmd == 0) {
    744   1.1      cgd 		fin = fopen(name, "r"), closefunc = fclose;
    745  1.24    lukem 		if (fin == NULL)
    746  1.24    lukem 			cmd = do_conversion(name);
    747  1.24    lukem 	}
    748  1.24    lukem 	if (cmd) {
    749   1.1      cgd 		char line[BUFSIZ];
    750   1.1      cgd 
    751   1.1      cgd 		(void) sprintf(line, cmd, name), name = line;
    752  1.24    lukem 		fin = ftpd_popen(line, "r", 1), closefunc = ftpd_pclose;
    753   1.1      cgd 		st.st_size = -1;
    754   1.1      cgd 		st.st_blksize = BUFSIZ;
    755   1.1      cgd 	}
    756   1.1      cgd 	if (fin == NULL) {
    757   1.8  deraadt 		if (errno != 0) {
    758   1.1      cgd 			perror_reply(550, name);
    759  1.24    lukem 			if (log) {
    760   1.8  deraadt 				LOGCMD("get", name);
    761   1.8  deraadt 			}
    762   1.8  deraadt 		}
    763   1.1      cgd 		return;
    764   1.1      cgd 	}
    765   1.8  deraadt 	byte_count = -1;
    766   1.8  deraadt 	if (cmd == 0 && (fstat(fileno(fin), &st) < 0 || !S_ISREG(st.st_mode))) {
    767   1.1      cgd 		reply(550, "%s: not a plain file.", name);
    768   1.1      cgd 		goto done;
    769   1.1      cgd 	}
    770   1.1      cgd 	if (restart_point) {
    771   1.1      cgd 		if (type == TYPE_A) {
    772   1.8  deraadt 			off_t i, n;
    773   1.8  deraadt 			int c;
    774   1.1      cgd 
    775   1.1      cgd 			n = restart_point;
    776   1.1      cgd 			i = 0;
    777   1.1      cgd 			while (i++ < n) {
    778   1.1      cgd 				if ((c=getc(fin)) == EOF) {
    779   1.1      cgd 					perror_reply(550, name);
    780   1.1      cgd 					goto done;
    781   1.1      cgd 				}
    782   1.1      cgd 				if (c == '\n')
    783   1.1      cgd 					i++;
    784   1.8  deraadt 			}
    785   1.1      cgd 		} else if (lseek(fileno(fin), restart_point, L_SET) < 0) {
    786   1.1      cgd 			perror_reply(550, name);
    787   1.1      cgd 			goto done;
    788   1.1      cgd 		}
    789   1.1      cgd 	}
    790   1.1      cgd 	dout = dataconn(name, st.st_size, "w");
    791   1.1      cgd 	if (dout == NULL)
    792   1.1      cgd 		goto done;
    793   1.1      cgd 	send_data(fin, dout, st.st_blksize);
    794   1.1      cgd 	(void) fclose(dout);
    795   1.1      cgd 	data = -1;
    796   1.1      cgd 	pdata = -1;
    797   1.1      cgd done:
    798  1.24    lukem 	if (log)
    799   1.8  deraadt 		LOGBYTES("get", name, byte_count);
    800   1.1      cgd 	(*closefunc)(fin);
    801   1.1      cgd }
    802   1.1      cgd 
    803   1.8  deraadt void
    804   1.1      cgd store(name, mode, unique)
    805   1.1      cgd 	char *name, *mode;
    806   1.1      cgd 	int unique;
    807   1.1      cgd {
    808   1.1      cgd 	FILE *fout, *din;
    809   1.1      cgd 	struct stat st;
    810   1.8  deraadt 	int (*closefunc) __P((FILE *));
    811   1.1      cgd 
    812   1.1      cgd 	if (unique && stat(name, &st) == 0 &&
    813   1.8  deraadt 	    (name = gunique(name)) == NULL) {
    814   1.8  deraadt 		LOGCMD(*mode == 'w' ? "put" : "append", name);
    815   1.1      cgd 		return;
    816   1.8  deraadt 	}
    817   1.1      cgd 
    818   1.1      cgd 	if (restart_point)
    819   1.8  deraadt 		mode = "r+";
    820   1.1      cgd 	fout = fopen(name, mode);
    821   1.1      cgd 	closefunc = fclose;
    822   1.1      cgd 	if (fout == NULL) {
    823   1.1      cgd 		perror_reply(553, name);
    824   1.8  deraadt 		LOGCMD(*mode == 'w' ? "put" : "append", name);
    825   1.1      cgd 		return;
    826   1.1      cgd 	}
    827   1.8  deraadt 	byte_count = -1;
    828   1.1      cgd 	if (restart_point) {
    829   1.1      cgd 		if (type == TYPE_A) {
    830   1.8  deraadt 			off_t i, n;
    831   1.8  deraadt 			int c;
    832   1.1      cgd 
    833   1.1      cgd 			n = restart_point;
    834   1.1      cgd 			i = 0;
    835   1.1      cgd 			while (i++ < n) {
    836   1.1      cgd 				if ((c=getc(fout)) == EOF) {
    837   1.1      cgd 					perror_reply(550, name);
    838   1.1      cgd 					goto done;
    839   1.1      cgd 				}
    840   1.1      cgd 				if (c == '\n')
    841   1.1      cgd 					i++;
    842   1.8  deraadt 			}
    843   1.1      cgd 			/*
    844   1.1      cgd 			 * We must do this seek to "current" position
    845   1.1      cgd 			 * because we are changing from reading to
    846   1.1      cgd 			 * writing.
    847   1.1      cgd 			 */
    848  1.20    lukem 			if (fseek(fout, 0L, SEEK_CUR) < 0) {
    849   1.1      cgd 				perror_reply(550, name);
    850   1.1      cgd 				goto done;
    851   1.1      cgd 			}
    852   1.1      cgd 		} else if (lseek(fileno(fout), restart_point, L_SET) < 0) {
    853   1.1      cgd 			perror_reply(550, name);
    854   1.1      cgd 			goto done;
    855   1.1      cgd 		}
    856   1.1      cgd 	}
    857   1.1      cgd 	din = dataconn(name, (off_t)-1, "r");
    858   1.1      cgd 	if (din == NULL)
    859   1.1      cgd 		goto done;
    860   1.1      cgd 	if (receive_data(din, fout) == 0) {
    861   1.1      cgd 		if (unique)
    862   1.1      cgd 			reply(226, "Transfer complete (unique file name:%s).",
    863   1.1      cgd 			    name);
    864   1.1      cgd 		else
    865   1.1      cgd 			reply(226, "Transfer complete.");
    866   1.1      cgd 	}
    867   1.1      cgd 	(void) fclose(din);
    868   1.1      cgd 	data = -1;
    869   1.1      cgd 	pdata = -1;
    870   1.1      cgd done:
    871   1.8  deraadt 	LOGBYTES(*mode == 'w' ? "put" : "append", name, byte_count);
    872   1.1      cgd 	(*closefunc)(fout);
    873   1.1      cgd }
    874   1.1      cgd 
    875   1.8  deraadt static FILE *
    876   1.1      cgd getdatasock(mode)
    877   1.1      cgd 	char *mode;
    878   1.1      cgd {
    879   1.8  deraadt 	int on = 1, s, t, tries;
    880   1.1      cgd 
    881   1.1      cgd 	if (data >= 0)
    882   1.1      cgd 		return (fdopen(data, mode));
    883   1.1      cgd 	(void) seteuid((uid_t)0);
    884   1.1      cgd 	s = socket(AF_INET, SOCK_STREAM, 0);
    885   1.1      cgd 	if (s < 0)
    886   1.1      cgd 		goto bad;
    887   1.1      cgd 	if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR,
    888   1.8  deraadt 	    (char *) &on, sizeof(on)) < 0)
    889   1.1      cgd 		goto bad;
    890   1.1      cgd 	/* anchor socket to avoid multi-homing problems */
    891  1.15  mycroft 	data_source.sin_len = sizeof(struct sockaddr_in);
    892   1.1      cgd 	data_source.sin_family = AF_INET;
    893   1.1      cgd 	data_source.sin_addr = ctrl_addr.sin_addr;
    894   1.1      cgd 	for (tries = 1; ; tries++) {
    895   1.1      cgd 		if (bind(s, (struct sockaddr *)&data_source,
    896   1.8  deraadt 		    sizeof(data_source)) >= 0)
    897   1.1      cgd 			break;
    898   1.1      cgd 		if (errno != EADDRINUSE || tries > 10)
    899   1.1      cgd 			goto bad;
    900   1.1      cgd 		sleep(tries);
    901   1.1      cgd 	}
    902   1.1      cgd 	(void) seteuid((uid_t)pw->pw_uid);
    903   1.1      cgd #ifdef IP_TOS
    904   1.1      cgd 	on = IPTOS_THROUGHPUT;
    905   1.1      cgd 	if (setsockopt(s, IPPROTO_IP, IP_TOS, (char *)&on, sizeof(int)) < 0)
    906   1.1      cgd 		syslog(LOG_WARNING, "setsockopt (IP_TOS): %m");
    907   1.1      cgd #endif
    908   1.1      cgd 	return (fdopen(s, mode));
    909   1.1      cgd bad:
    910   1.8  deraadt 	/* Return the real value of errno (close may change it) */
    911   1.8  deraadt 	t = errno;
    912   1.1      cgd 	(void) seteuid((uid_t)pw->pw_uid);
    913   1.1      cgd 	(void) close(s);
    914   1.8  deraadt 	errno = t;
    915   1.1      cgd 	return (NULL);
    916   1.1      cgd }
    917   1.1      cgd 
    918   1.8  deraadt static FILE *
    919   1.1      cgd dataconn(name, size, mode)
    920   1.1      cgd 	char *name;
    921   1.1      cgd 	off_t size;
    922   1.1      cgd 	char *mode;
    923   1.1      cgd {
    924   1.1      cgd 	char sizebuf[32];
    925   1.1      cgd 	FILE *file;
    926   1.1      cgd 	int retry = 0, tos;
    927   1.1      cgd 
    928   1.1      cgd 	file_size = size;
    929   1.1      cgd 	byte_count = 0;
    930   1.1      cgd 	if (size != (off_t) -1)
    931   1.8  deraadt 		(void) sprintf(sizebuf, " (%qd bytes)", size);
    932   1.1      cgd 	else
    933   1.1      cgd 		(void) strcpy(sizebuf, "");
    934   1.1      cgd 	if (pdata >= 0) {
    935   1.1      cgd 		struct sockaddr_in from;
    936   1.1      cgd 		int s, fromlen = sizeof(from);
    937   1.1      cgd 
    938   1.1      cgd 		s = accept(pdata, (struct sockaddr *)&from, &fromlen);
    939   1.1      cgd 		if (s < 0) {
    940   1.1      cgd 			reply(425, "Can't open data connection.");
    941   1.1      cgd 			(void) close(pdata);
    942   1.1      cgd 			pdata = -1;
    943   1.8  deraadt 			return (NULL);
    944   1.1      cgd 		}
    945   1.1      cgd 		(void) close(pdata);
    946   1.1      cgd 		pdata = s;
    947   1.1      cgd #ifdef IP_TOS
    948  1.12  mycroft 		tos = IPTOS_THROUGHPUT;
    949   1.1      cgd 		(void) setsockopt(s, IPPROTO_IP, IP_TOS, (char *)&tos,
    950   1.1      cgd 		    sizeof(int));
    951   1.1      cgd #endif
    952   1.8  deraadt 		reply(150, "Opening %s mode data connection for '%s'%s.",
    953   1.1      cgd 		     type == TYPE_A ? "ASCII" : "BINARY", name, sizebuf);
    954   1.8  deraadt 		return (fdopen(pdata, mode));
    955   1.1      cgd 	}
    956   1.1      cgd 	if (data >= 0) {
    957   1.8  deraadt 		reply(125, "Using existing data connection for '%s'%s.",
    958   1.1      cgd 		    name, sizebuf);
    959   1.1      cgd 		usedefault = 1;
    960   1.1      cgd 		return (fdopen(data, mode));
    961   1.1      cgd 	}
    962   1.1      cgd 	if (usedefault)
    963   1.1      cgd 		data_dest = his_addr;
    964   1.1      cgd 	usedefault = 1;
    965   1.1      cgd 	file = getdatasock(mode);
    966   1.1      cgd 	if (file == NULL) {
    967   1.1      cgd 		reply(425, "Can't create data socket (%s,%d): %s.",
    968   1.1      cgd 		    inet_ntoa(data_source.sin_addr),
    969   1.1      cgd 		    ntohs(data_source.sin_port), strerror(errno));
    970   1.1      cgd 		return (NULL);
    971   1.1      cgd 	}
    972   1.1      cgd 	data = fileno(file);
    973   1.1      cgd 	while (connect(data, (struct sockaddr *)&data_dest,
    974   1.8  deraadt 	    sizeof(data_dest)) < 0) {
    975   1.1      cgd 		if (errno == EADDRINUSE && retry < swaitmax) {
    976   1.1      cgd 			sleep((unsigned) swaitint);
    977   1.1      cgd 			retry += swaitint;
    978   1.1      cgd 			continue;
    979   1.1      cgd 		}
    980   1.1      cgd 		perror_reply(425, "Can't build data connection");
    981   1.1      cgd 		(void) fclose(file);
    982   1.1      cgd 		data = -1;
    983   1.1      cgd 		return (NULL);
    984   1.1      cgd 	}
    985   1.8  deraadt 	reply(150, "Opening %s mode data connection for '%s'%s.",
    986   1.1      cgd 	     type == TYPE_A ? "ASCII" : "BINARY", name, sizebuf);
    987   1.1      cgd 	return (file);
    988   1.1      cgd }
    989   1.1      cgd 
    990   1.1      cgd /*
    991   1.8  deraadt  * Tranfer the contents of "instr" to "outstr" peer using the appropriate
    992   1.8  deraadt  * encapsulation of the data subject * to Mode, Structure, and Type.
    993   1.1      cgd  *
    994   1.1      cgd  * NB: Form isn't handled.
    995   1.1      cgd  */
    996   1.8  deraadt static void
    997   1.1      cgd send_data(instr, outstr, blksize)
    998   1.1      cgd 	FILE *instr, *outstr;
    999   1.1      cgd 	off_t blksize;
   1000   1.1      cgd {
   1001  1.24    lukem 	int	 c, cnt, filefd, netfd;
   1002  1.24    lukem 	char	*buf;
   1003   1.1      cgd 
   1004   1.1      cgd 	transflag++;
   1005   1.1      cgd 	if (setjmp(urgcatch)) {
   1006   1.1      cgd 		transflag = 0;
   1007   1.1      cgd 		return;
   1008   1.1      cgd 	}
   1009  1.24    lukem 
   1010   1.1      cgd 	switch (type) {
   1011   1.1      cgd 
   1012   1.1      cgd 	case TYPE_A:
   1013   1.1      cgd 		while ((c = getc(instr)) != EOF) {
   1014   1.1      cgd 			byte_count++;
   1015   1.1      cgd 			if (c == '\n') {
   1016   1.1      cgd 				if (ferror(outstr))
   1017   1.1      cgd 					goto data_err;
   1018   1.1      cgd 				(void) putc('\r', outstr);
   1019   1.1      cgd 			}
   1020   1.1      cgd 			(void) putc(c, outstr);
   1021   1.1      cgd 		}
   1022   1.1      cgd 		fflush(outstr);
   1023   1.1      cgd 		transflag = 0;
   1024   1.1      cgd 		if (ferror(instr))
   1025   1.1      cgd 			goto file_err;
   1026   1.1      cgd 		if (ferror(outstr))
   1027   1.1      cgd 			goto data_err;
   1028   1.1      cgd 		reply(226, "Transfer complete.");
   1029   1.1      cgd 		return;
   1030   1.1      cgd 
   1031   1.1      cgd 	case TYPE_I:
   1032   1.1      cgd 	case TYPE_L:
   1033   1.1      cgd 		if ((buf = malloc((u_int)blksize)) == NULL) {
   1034   1.1      cgd 			transflag = 0;
   1035   1.1      cgd 			perror_reply(451, "Local resource failure: malloc");
   1036   1.1      cgd 			return;
   1037   1.1      cgd 		}
   1038   1.1      cgd 		netfd = fileno(outstr);
   1039   1.1      cgd 		filefd = fileno(instr);
   1040   1.1      cgd 		while ((cnt = read(filefd, buf, (u_int)blksize)) > 0 &&
   1041   1.1      cgd 		    write(netfd, buf, cnt) == cnt)
   1042   1.1      cgd 			byte_count += cnt;
   1043   1.1      cgd 		transflag = 0;
   1044   1.1      cgd 		(void)free(buf);
   1045   1.1      cgd 		if (cnt != 0) {
   1046   1.1      cgd 			if (cnt < 0)
   1047   1.1      cgd 				goto file_err;
   1048   1.1      cgd 			goto data_err;
   1049   1.1      cgd 		}
   1050   1.1      cgd 		reply(226, "Transfer complete.");
   1051   1.1      cgd 		return;
   1052   1.1      cgd 	default:
   1053   1.1      cgd 		transflag = 0;
   1054   1.1      cgd 		reply(550, "Unimplemented TYPE %d in send_data", type);
   1055   1.1      cgd 		return;
   1056   1.1      cgd 	}
   1057   1.1      cgd 
   1058   1.1      cgd data_err:
   1059   1.1      cgd 	transflag = 0;
   1060   1.1      cgd 	perror_reply(426, "Data connection");
   1061   1.1      cgd 	return;
   1062   1.1      cgd 
   1063   1.1      cgd file_err:
   1064   1.1      cgd 	transflag = 0;
   1065   1.1      cgd 	perror_reply(551, "Error on input file");
   1066   1.1      cgd }
   1067   1.1      cgd 
   1068   1.1      cgd /*
   1069   1.8  deraadt  * Transfer data from peer to "outstr" using the appropriate encapulation of
   1070   1.8  deraadt  * the data subject to Mode, Structure, and Type.
   1071   1.1      cgd  *
   1072   1.1      cgd  * N.B.: Form isn't handled.
   1073   1.1      cgd  */
   1074   1.8  deraadt static int
   1075   1.1      cgd receive_data(instr, outstr)
   1076   1.1      cgd 	FILE *instr, *outstr;
   1077   1.1      cgd {
   1078  1.24    lukem 	int	c, cnt, bare_lfs;
   1079  1.24    lukem 	char	buf[BUFSIZ];
   1080   1.1      cgd 
   1081  1.24    lukem 	bare_lfs = 0;
   1082   1.1      cgd 	transflag++;
   1083   1.1      cgd 	if (setjmp(urgcatch)) {
   1084   1.1      cgd 		transflag = 0;
   1085   1.1      cgd 		return (-1);
   1086   1.1      cgd 	}
   1087  1.24    lukem 
   1088   1.1      cgd 	switch (type) {
   1089   1.1      cgd 
   1090   1.1      cgd 	case TYPE_I:
   1091   1.1      cgd 	case TYPE_L:
   1092   1.8  deraadt 		while ((cnt = read(fileno(instr), buf, sizeof(buf))) > 0) {
   1093   1.1      cgd 			if (write(fileno(outstr), buf, cnt) != cnt)
   1094   1.1      cgd 				goto file_err;
   1095   1.1      cgd 			byte_count += cnt;
   1096   1.1      cgd 		}
   1097   1.1      cgd 		if (cnt < 0)
   1098   1.1      cgd 			goto data_err;
   1099   1.1      cgd 		transflag = 0;
   1100   1.1      cgd 		return (0);
   1101   1.1      cgd 
   1102   1.1      cgd 	case TYPE_E:
   1103   1.1      cgd 		reply(553, "TYPE E not implemented.");
   1104   1.1      cgd 		transflag = 0;
   1105   1.1      cgd 		return (-1);
   1106   1.1      cgd 
   1107   1.1      cgd 	case TYPE_A:
   1108   1.1      cgd 		while ((c = getc(instr)) != EOF) {
   1109   1.1      cgd 			byte_count++;
   1110   1.1      cgd 			if (c == '\n')
   1111   1.1      cgd 				bare_lfs++;
   1112   1.1      cgd 			while (c == '\r') {
   1113   1.1      cgd 				if (ferror(outstr))
   1114   1.1      cgd 					goto data_err;
   1115   1.1      cgd 				if ((c = getc(instr)) != '\n') {
   1116   1.1      cgd 					(void) putc ('\r', outstr);
   1117   1.1      cgd 					if (c == '\0' || c == EOF)
   1118   1.1      cgd 						goto contin2;
   1119   1.1      cgd 				}
   1120   1.1      cgd 			}
   1121   1.1      cgd 			(void) putc(c, outstr);
   1122   1.1      cgd 	contin2:	;
   1123   1.1      cgd 		}
   1124   1.1      cgd 		fflush(outstr);
   1125   1.1      cgd 		if (ferror(instr))
   1126   1.1      cgd 			goto data_err;
   1127   1.1      cgd 		if (ferror(outstr))
   1128   1.1      cgd 			goto file_err;
   1129   1.1      cgd 		transflag = 0;
   1130   1.1      cgd 		if (bare_lfs) {
   1131   1.8  deraadt 			lreply(226,
   1132   1.8  deraadt 		"WARNING! %d bare linefeeds received in ASCII mode",
   1133   1.8  deraadt 			    bare_lfs);
   1134   1.8  deraadt 		(void)printf("   File may not have transferred correctly.\r\n");
   1135   1.1      cgd 		}
   1136   1.1      cgd 		return (0);
   1137   1.1      cgd 	default:
   1138   1.1      cgd 		reply(550, "Unimplemented TYPE %d in receive_data", type);
   1139   1.1      cgd 		transflag = 0;
   1140   1.1      cgd 		return (-1);
   1141   1.1      cgd 	}
   1142   1.1      cgd 
   1143   1.1      cgd data_err:
   1144   1.1      cgd 	transflag = 0;
   1145   1.1      cgd 	perror_reply(426, "Data Connection");
   1146   1.1      cgd 	return (-1);
   1147   1.1      cgd 
   1148   1.1      cgd file_err:
   1149   1.1      cgd 	transflag = 0;
   1150   1.1      cgd 	perror_reply(452, "Error writing file");
   1151   1.1      cgd 	return (-1);
   1152   1.1      cgd }
   1153   1.1      cgd 
   1154   1.8  deraadt void
   1155   1.1      cgd statfilecmd(filename)
   1156   1.1      cgd 	char *filename;
   1157   1.1      cgd {
   1158   1.1      cgd 	FILE *fin;
   1159   1.1      cgd 	int c;
   1160   1.8  deraadt 	char line[LINE_MAX];
   1161   1.1      cgd 
   1162   1.8  deraadt 	(void)snprintf(line, sizeof(line), "/bin/ls -lgA %s", filename);
   1163  1.24    lukem 	fin = ftpd_popen(line, "r", 0);
   1164   1.1      cgd 	lreply(211, "status of %s:", filename);
   1165   1.1      cgd 	while ((c = getc(fin)) != EOF) {
   1166   1.1      cgd 		if (c == '\n') {
   1167   1.1      cgd 			if (ferror(stdout)){
   1168   1.1      cgd 				perror_reply(421, "control connection");
   1169   1.1      cgd 				(void) ftpd_pclose(fin);
   1170   1.1      cgd 				dologout(1);
   1171   1.1      cgd 				/* NOTREACHED */
   1172   1.1      cgd 			}
   1173   1.1      cgd 			if (ferror(fin)) {
   1174   1.1      cgd 				perror_reply(551, filename);
   1175   1.1      cgd 				(void) ftpd_pclose(fin);
   1176   1.1      cgd 				return;
   1177   1.1      cgd 			}
   1178   1.1      cgd 			(void) putc('\r', stdout);
   1179   1.1      cgd 		}
   1180   1.1      cgd 		(void) putc(c, stdout);
   1181   1.1      cgd 	}
   1182   1.1      cgd 	(void) ftpd_pclose(fin);
   1183   1.1      cgd 	reply(211, "End of Status");
   1184   1.1      cgd }
   1185   1.1      cgd 
   1186   1.8  deraadt void
   1187   1.1      cgd statcmd()
   1188   1.1      cgd {
   1189   1.1      cgd 	struct sockaddr_in *sin;
   1190   1.1      cgd 	u_char *a, *p;
   1191   1.1      cgd 
   1192  1.24    lukem 	lreply(211, "%s FTP server status:", hostname);
   1193  1.24    lukem 	lreply(211, "%s", version);
   1194  1.24    lukem 	if (isdigit(remotehost[0]))
   1195  1.24    lukem 		lreply(211, "Connected to %s", remotehost);
   1196  1.24    lukem 	else
   1197  1.24    lukem 		lreply(211, "Connected to %s (%s)", remotehost,
   1198  1.24    lukem 		    inet_ntoa(his_addr.sin_addr));
   1199   1.1      cgd 	if (logged_in) {
   1200   1.1      cgd 		if (guest)
   1201  1.24    lukem 			lreply(211, "Logged in anonymously");
   1202   1.1      cgd 		else
   1203  1.24    lukem 			lreply(211, "Logged in as %s", pw->pw_name);
   1204   1.1      cgd 	} else if (askpasswd)
   1205  1.24    lukem 		lreply(211, "Waiting for password");
   1206   1.1      cgd 	else
   1207  1.24    lukem 		lreply(211, "Waiting for user name");
   1208  1.24    lukem 	printf("211- TYPE: %s", typenames[type]);
   1209   1.1      cgd 	if (type == TYPE_A || type == TYPE_E)
   1210   1.1      cgd 		printf(", FORM: %s", formnames[form]);
   1211   1.1      cgd 	if (type == TYPE_L)
   1212   1.1      cgd #if NBBY == 8
   1213   1.1      cgd 		printf(" %d", NBBY);
   1214   1.1      cgd #else
   1215   1.1      cgd 		printf(" %d", bytesize);	/* need definition! */
   1216   1.1      cgd #endif
   1217   1.1      cgd 	printf("; STRUcture: %s; transfer MODE: %s\r\n",
   1218   1.1      cgd 	    strunames[stru], modenames[mode]);
   1219   1.1      cgd 	if (data != -1)
   1220  1.24    lukem 		lreply(211, "Data connection open");
   1221   1.1      cgd 	else if (pdata != -1) {
   1222  1.24    lukem 		printf("211- in Passive mode");
   1223   1.1      cgd 		sin = &pasv_addr;
   1224   1.1      cgd 		goto printaddr;
   1225   1.1      cgd 	} else if (usedefault == 0) {
   1226  1.24    lukem 		printf("211- PORT");
   1227   1.1      cgd 		sin = &data_dest;
   1228   1.1      cgd printaddr:
   1229   1.1      cgd 		a = (u_char *) &sin->sin_addr;
   1230   1.1      cgd 		p = (u_char *) &sin->sin_port;
   1231   1.1      cgd #define UC(b) (((int) b) & 0xff)
   1232   1.1      cgd 		printf(" (%d,%d,%d,%d,%d,%d)\r\n", UC(a[0]),
   1233   1.1      cgd 			UC(a[1]), UC(a[2]), UC(a[3]), UC(p[0]), UC(p[1]));
   1234   1.1      cgd #undef UC
   1235   1.1      cgd 	} else
   1236  1.24    lukem 		lreply(211, "No data connection");
   1237  1.24    lukem 
   1238  1.24    lukem 	if (logged_in) {
   1239  1.24    lukem 		struct ftpconv *cp;
   1240  1.24    lukem 
   1241  1.24    lukem 		lreply(211, "");
   1242  1.24    lukem 		lreply(211, "Class: %s", curclass.classname);
   1243  1.24    lukem 		if (curclass.display)
   1244  1.24    lukem 			lreply(211, "Display file: %s", curclass.display);
   1245  1.24    lukem 		if (curclass.notify)
   1246  1.24    lukem 			lreply(211, "Notify fileglob: %s", curclass.notify);
   1247  1.24    lukem 		lreply(211, "Idle timeout: %d, maximum timeout: %d",
   1248  1.24    lukem 		    curclass.timeout, curclass.maxtimeout);
   1249  1.24    lukem 		lreply(211, "dele, mkd, rmd, umask, chmod: %sabled",
   1250  1.24    lukem 		    curclass.modify ? "en" : "dis");
   1251  1.24    lukem 		lreply(211, "Umask: %.04o", curclass.umask);
   1252  1.24    lukem 		for (cp = curclass.conversions; cp != NULL; cp=cp->next) {
   1253  1.24    lukem 			if (cp->suffix == NULL || cp->types == NULL ||
   1254  1.24    lukem 			    cp->command == NULL)
   1255  1.24    lukem 				continue;
   1256  1.24    lukem 			lreply(211,
   1257  1.24    lukem 			    "Conversion: %s [%s] disable: %s, command: %s",
   1258  1.24    lukem 			    cp->suffix, cp->types, cp->disable, cp->command);
   1259  1.24    lukem 		}
   1260  1.24    lukem 	}
   1261  1.24    lukem 
   1262   1.1      cgd 	reply(211, "End of status");
   1263   1.1      cgd }
   1264   1.1      cgd 
   1265   1.8  deraadt void
   1266   1.1      cgd fatal(s)
   1267   1.1      cgd 	char *s;
   1268   1.1      cgd {
   1269   1.8  deraadt 
   1270   1.1      cgd 	reply(451, "Error in server: %s\n", s);
   1271   1.1      cgd 	reply(221, "Closing connection due to server error.");
   1272   1.1      cgd 	dologout(0);
   1273   1.1      cgd 	/* NOTREACHED */
   1274   1.1      cgd }
   1275   1.1      cgd 
   1276   1.8  deraadt void
   1277   1.8  deraadt #if __STDC__
   1278   1.8  deraadt reply(int n, const char *fmt, ...)
   1279   1.8  deraadt #else
   1280   1.8  deraadt reply(n, fmt, va_alist)
   1281   1.1      cgd 	int n;
   1282   1.1      cgd 	char *fmt;
   1283   1.8  deraadt         va_dcl
   1284   1.8  deraadt #endif
   1285   1.1      cgd {
   1286   1.8  deraadt 	va_list ap;
   1287   1.8  deraadt #if __STDC__
   1288   1.8  deraadt 	va_start(ap, fmt);
   1289   1.8  deraadt #else
   1290   1.8  deraadt 	va_start(ap);
   1291   1.8  deraadt #endif
   1292   1.8  deraadt 	(void)printf("%d ", n);
   1293   1.8  deraadt 	(void)vprintf(fmt, ap);
   1294   1.8  deraadt 	(void)printf("\r\n");
   1295   1.1      cgd 	(void)fflush(stdout);
   1296   1.1      cgd 	if (debug) {
   1297   1.1      cgd 		syslog(LOG_DEBUG, "<--- %d ", n);
   1298   1.8  deraadt 		vsyslog(LOG_DEBUG, fmt, ap);
   1299   1.8  deraadt 	}
   1300   1.1      cgd }
   1301   1.1      cgd 
   1302   1.8  deraadt void
   1303   1.8  deraadt #if __STDC__
   1304   1.8  deraadt lreply(int n, const char *fmt, ...)
   1305   1.8  deraadt #else
   1306   1.8  deraadt lreply(n, fmt, va_alist)
   1307   1.1      cgd 	int n;
   1308   1.1      cgd 	char *fmt;
   1309   1.8  deraadt         va_dcl
   1310   1.8  deraadt #endif
   1311   1.1      cgd {
   1312   1.8  deraadt 	va_list ap;
   1313   1.8  deraadt #if __STDC__
   1314   1.8  deraadt 	va_start(ap, fmt);
   1315   1.8  deraadt #else
   1316   1.8  deraadt 	va_start(ap);
   1317   1.8  deraadt #endif
   1318   1.8  deraadt 	(void)printf("%d- ", n);
   1319   1.8  deraadt 	(void)vprintf(fmt, ap);
   1320   1.8  deraadt 	(void)printf("\r\n");
   1321   1.1      cgd 	(void)fflush(stdout);
   1322   1.1      cgd 	if (debug) {
   1323   1.1      cgd 		syslog(LOG_DEBUG, "<--- %d- ", n);
   1324   1.8  deraadt 		vsyslog(LOG_DEBUG, fmt, ap);
   1325   1.1      cgd 	}
   1326   1.1      cgd }
   1327   1.1      cgd 
   1328   1.8  deraadt static void
   1329   1.1      cgd ack(s)
   1330   1.1      cgd 	char *s;
   1331   1.1      cgd {
   1332   1.8  deraadt 
   1333   1.1      cgd 	reply(250, "%s command successful.", s);
   1334   1.1      cgd }
   1335   1.1      cgd 
   1336   1.8  deraadt void
   1337   1.1      cgd nack(s)
   1338   1.1      cgd 	char *s;
   1339   1.1      cgd {
   1340   1.8  deraadt 
   1341   1.1      cgd 	reply(502, "%s command not implemented.", s);
   1342   1.1      cgd }
   1343   1.1      cgd 
   1344   1.1      cgd /* ARGSUSED */
   1345   1.8  deraadt void
   1346   1.1      cgd yyerror(s)
   1347   1.1      cgd 	char *s;
   1348   1.1      cgd {
   1349   1.1      cgd 	char *cp;
   1350   1.1      cgd 
   1351  1.20    lukem 	if ((cp = strchr(cbuf,'\n')) != NULL)
   1352   1.1      cgd 		*cp = '\0';
   1353   1.1      cgd 	reply(500, "'%s': command not understood.", cbuf);
   1354   1.1      cgd }
   1355   1.1      cgd 
   1356   1.8  deraadt void
   1357   1.1      cgd delete(name)
   1358   1.1      cgd 	char *name;
   1359   1.1      cgd {
   1360   1.1      cgd 	struct stat st;
   1361   1.1      cgd 
   1362   1.8  deraadt 	LOGCMD("delete", name);
   1363   1.1      cgd 	if (stat(name, &st) < 0) {
   1364   1.1      cgd 		perror_reply(550, name);
   1365   1.1      cgd 		return;
   1366   1.1      cgd 	}
   1367   1.1      cgd 	if ((st.st_mode&S_IFMT) == S_IFDIR) {
   1368   1.1      cgd 		if (rmdir(name) < 0) {
   1369   1.1      cgd 			perror_reply(550, name);
   1370   1.1      cgd 			return;
   1371   1.1      cgd 		}
   1372   1.1      cgd 		goto done;
   1373   1.1      cgd 	}
   1374   1.1      cgd 	if (unlink(name) < 0) {
   1375   1.1      cgd 		perror_reply(550, name);
   1376   1.1      cgd 		return;
   1377   1.1      cgd 	}
   1378   1.1      cgd done:
   1379   1.1      cgd 	ack("DELE");
   1380   1.1      cgd }
   1381   1.1      cgd 
   1382   1.8  deraadt void
   1383   1.1      cgd cwd(path)
   1384   1.1      cgd 	char *path;
   1385   1.1      cgd {
   1386   1.8  deraadt 
   1387   1.1      cgd 	if (chdir(path) < 0)
   1388   1.1      cgd 		perror_reply(550, path);
   1389  1.24    lukem 	else {
   1390  1.24    lukem 		show_chdir_messages(250);
   1391   1.1      cgd 		ack("CWD");
   1392  1.24    lukem 	}
   1393   1.1      cgd }
   1394   1.1      cgd 
   1395   1.8  deraadt void
   1396   1.1      cgd makedir(name)
   1397   1.1      cgd 	char *name;
   1398   1.1      cgd {
   1399   1.8  deraadt 
   1400   1.8  deraadt 	LOGCMD("mkdir", name);
   1401   1.1      cgd 	if (mkdir(name, 0777) < 0)
   1402   1.1      cgd 		perror_reply(550, name);
   1403   1.1      cgd 	else
   1404   1.1      cgd 		reply(257, "MKD command successful.");
   1405   1.1      cgd }
   1406   1.1      cgd 
   1407   1.8  deraadt void
   1408   1.1      cgd removedir(name)
   1409   1.1      cgd 	char *name;
   1410   1.1      cgd {
   1411   1.8  deraadt 
   1412   1.8  deraadt 	LOGCMD("rmdir", name);
   1413   1.1      cgd 	if (rmdir(name) < 0)
   1414   1.1      cgd 		perror_reply(550, name);
   1415   1.1      cgd 	else
   1416   1.1      cgd 		ack("RMD");
   1417   1.1      cgd }
   1418   1.1      cgd 
   1419   1.8  deraadt void
   1420   1.1      cgd pwd()
   1421   1.1      cgd {
   1422   1.1      cgd 	char path[MAXPATHLEN + 1];
   1423   1.1      cgd 
   1424   1.1      cgd 	if (getwd(path) == (char *)NULL)
   1425   1.1      cgd 		reply(550, "%s.", path);
   1426   1.1      cgd 	else
   1427   1.1      cgd 		reply(257, "\"%s\" is current directory.", path);
   1428   1.1      cgd }
   1429   1.1      cgd 
   1430   1.1      cgd char *
   1431   1.1      cgd renamefrom(name)
   1432   1.1      cgd 	char *name;
   1433   1.1      cgd {
   1434   1.1      cgd 	struct stat st;
   1435   1.1      cgd 
   1436   1.1      cgd 	if (stat(name, &st) < 0) {
   1437   1.1      cgd 		perror_reply(550, name);
   1438   1.1      cgd 		return ((char *)0);
   1439   1.1      cgd 	}
   1440   1.1      cgd 	reply(350, "File exists, ready for destination name");
   1441   1.1      cgd 	return (name);
   1442   1.1      cgd }
   1443   1.1      cgd 
   1444   1.8  deraadt void
   1445   1.1      cgd renamecmd(from, to)
   1446   1.1      cgd 	char *from, *to;
   1447   1.1      cgd {
   1448   1.8  deraadt 
   1449   1.8  deraadt 	LOGCMD2("rename", from, to);
   1450   1.1      cgd 	if (rename(from, to) < 0)
   1451   1.1      cgd 		perror_reply(550, "rename");
   1452   1.1      cgd 	else
   1453   1.1      cgd 		ack("RNTO");
   1454   1.1      cgd }
   1455   1.1      cgd 
   1456   1.8  deraadt static void
   1457   1.1      cgd dolog(sin)
   1458   1.1      cgd 	struct sockaddr_in *sin;
   1459   1.1      cgd {
   1460   1.1      cgd 	struct hostent *hp = gethostbyaddr((char *)&sin->sin_addr,
   1461   1.8  deraadt 		sizeof(struct in_addr), AF_INET);
   1462   1.1      cgd 
   1463   1.1      cgd 	if (hp)
   1464   1.8  deraadt 		(void) strncpy(remotehost, hp->h_name, sizeof(remotehost));
   1465   1.1      cgd 	else
   1466   1.1      cgd 		(void) strncpy(remotehost, inet_ntoa(sin->sin_addr),
   1467   1.8  deraadt 		    sizeof(remotehost));
   1468   1.6      cgd #ifdef HASSETPROCTITLE
   1469   1.8  deraadt 	snprintf(proctitle, sizeof(proctitle), "%s: connected", remotehost);
   1470   1.1      cgd 	setproctitle(proctitle);
   1471   1.6      cgd #endif /* HASSETPROCTITLE */
   1472   1.1      cgd 
   1473   1.8  deraadt 	if (logging)
   1474   1.8  deraadt 		syslog(LOG_INFO, "connection from %s", remotehost);
   1475   1.1      cgd }
   1476   1.1      cgd 
   1477   1.1      cgd /*
   1478   1.1      cgd  * Record logout in wtmp file
   1479   1.1      cgd  * and exit with supplied status.
   1480   1.1      cgd  */
   1481   1.8  deraadt void
   1482   1.1      cgd dologout(status)
   1483   1.1      cgd 	int status;
   1484   1.1      cgd {
   1485  1.16      mrg 	/*
   1486  1.16      mrg 	* Prevent reception of SIGURG from resulting in a resumption
   1487  1.16      mrg 	* back to the main program loop.
   1488  1.16      mrg 	*/
   1489  1.16      mrg 	transflag = 0;
   1490   1.8  deraadt 
   1491   1.1      cgd 	if (logged_in) {
   1492   1.1      cgd 		(void) seteuid((uid_t)0);
   1493   1.1      cgd 		logwtmp(ttyline, "", "");
   1494   1.4      cgd #if defined(KERBEROS)
   1495   1.4      cgd 		if (!notickets && krbtkfile_env)
   1496   1.4      cgd 			unlink(krbtkfile_env);
   1497   1.4      cgd #endif
   1498   1.1      cgd 	}
   1499   1.1      cgd 	/* beware of flushing buffers after a SIGPIPE */
   1500   1.1      cgd 	_exit(status);
   1501   1.1      cgd }
   1502   1.1      cgd 
   1503   1.8  deraadt static void
   1504   1.8  deraadt myoob(signo)
   1505   1.8  deraadt 	int signo;
   1506   1.1      cgd {
   1507   1.1      cgd 	char *cp;
   1508   1.1      cgd 
   1509   1.1      cgd 	/* only process if transfer occurring */
   1510   1.1      cgd 	if (!transflag)
   1511   1.1      cgd 		return;
   1512   1.1      cgd 	cp = tmpline;
   1513   1.1      cgd 	if (getline(cp, 7, stdin) == NULL) {
   1514   1.1      cgd 		reply(221, "You could at least say goodbye.");
   1515   1.1      cgd 		dologout(0);
   1516   1.1      cgd 	}
   1517   1.1      cgd 	upper(cp);
   1518   1.1      cgd 	if (strcmp(cp, "ABOR\r\n") == 0) {
   1519   1.1      cgd 		tmpline[0] = '\0';
   1520   1.1      cgd 		reply(426, "Transfer aborted. Data connection closed.");
   1521   1.1      cgd 		reply(226, "Abort successful");
   1522   1.1      cgd 		longjmp(urgcatch, 1);
   1523   1.1      cgd 	}
   1524   1.1      cgd 	if (strcmp(cp, "STAT\r\n") == 0) {
   1525   1.1      cgd 		if (file_size != (off_t) -1)
   1526   1.8  deraadt 			reply(213, "Status: %qd of %qd bytes transferred",
   1527   1.1      cgd 			    byte_count, file_size);
   1528   1.1      cgd 		else
   1529   1.8  deraadt 			reply(213, "Status: %qd bytes transferred", byte_count);
   1530   1.1      cgd 	}
   1531   1.1      cgd }
   1532   1.1      cgd 
   1533   1.1      cgd /*
   1534   1.1      cgd  * Note: a response of 425 is not mentioned as a possible response to
   1535   1.8  deraadt  *	the PASV command in RFC959. However, it has been blessed as
   1536   1.8  deraadt  *	a legitimate response by Jon Postel in a telephone conversation
   1537   1.1      cgd  *	with Rick Adams on 25 Jan 89.
   1538   1.1      cgd  */
   1539   1.8  deraadt void
   1540   1.1      cgd passive()
   1541   1.1      cgd {
   1542   1.1      cgd 	int len;
   1543   1.8  deraadt 	char *p, *a;
   1544   1.1      cgd 
   1545   1.1      cgd 	pdata = socket(AF_INET, SOCK_STREAM, 0);
   1546  1.23    lukem 	if (pdata < 0 || !logged_in) {
   1547   1.1      cgd 		perror_reply(425, "Can't open passive connection");
   1548   1.1      cgd 		return;
   1549   1.1      cgd 	}
   1550   1.1      cgd 	pasv_addr = ctrl_addr;
   1551   1.1      cgd 	pasv_addr.sin_port = 0;
   1552   1.1      cgd 	(void) seteuid((uid_t)0);
   1553   1.1      cgd 	if (bind(pdata, (struct sockaddr *)&pasv_addr, sizeof(pasv_addr)) < 0) {
   1554   1.1      cgd 		(void) seteuid((uid_t)pw->pw_uid);
   1555   1.1      cgd 		goto pasv_error;
   1556   1.1      cgd 	}
   1557   1.1      cgd 	(void) seteuid((uid_t)pw->pw_uid);
   1558   1.1      cgd 	len = sizeof(pasv_addr);
   1559   1.1      cgd 	if (getsockname(pdata, (struct sockaddr *) &pasv_addr, &len) < 0)
   1560   1.1      cgd 		goto pasv_error;
   1561   1.1      cgd 	if (listen(pdata, 1) < 0)
   1562   1.1      cgd 		goto pasv_error;
   1563   1.1      cgd 	a = (char *) &pasv_addr.sin_addr;
   1564   1.1      cgd 	p = (char *) &pasv_addr.sin_port;
   1565   1.1      cgd 
   1566   1.1      cgd #define UC(b) (((int) b) & 0xff)
   1567   1.1      cgd 
   1568   1.1      cgd 	reply(227, "Entering Passive Mode (%d,%d,%d,%d,%d,%d)", UC(a[0]),
   1569   1.1      cgd 		UC(a[1]), UC(a[2]), UC(a[3]), UC(p[0]), UC(p[1]));
   1570   1.1      cgd 	return;
   1571   1.1      cgd 
   1572   1.1      cgd pasv_error:
   1573   1.1      cgd 	(void) close(pdata);
   1574   1.1      cgd 	pdata = -1;
   1575   1.1      cgd 	perror_reply(425, "Can't open passive connection");
   1576   1.1      cgd 	return;
   1577   1.1      cgd }
   1578   1.1      cgd 
   1579   1.1      cgd /*
   1580   1.1      cgd  * Generate unique name for file with basename "local".
   1581   1.1      cgd  * The file named "local" is already known to exist.
   1582   1.1      cgd  * Generates failure reply on error.
   1583   1.1      cgd  */
   1584   1.8  deraadt static char *
   1585   1.1      cgd gunique(local)
   1586   1.1      cgd 	char *local;
   1587   1.1      cgd {
   1588   1.1      cgd 	static char new[MAXPATHLEN];
   1589   1.1      cgd 	struct stat st;
   1590   1.8  deraadt 	int count;
   1591   1.8  deraadt 	char *cp;
   1592   1.1      cgd 
   1593   1.8  deraadt 	cp = strrchr(local, '/');
   1594   1.1      cgd 	if (cp)
   1595   1.1      cgd 		*cp = '\0';
   1596   1.1      cgd 	if (stat(cp ? local : ".", &st) < 0) {
   1597   1.1      cgd 		perror_reply(553, cp ? local : ".");
   1598   1.8  deraadt 		return ((char *) 0);
   1599   1.1      cgd 	}
   1600   1.1      cgd 	if (cp)
   1601   1.1      cgd 		*cp = '/';
   1602   1.1      cgd 	(void) strcpy(new, local);
   1603   1.1      cgd 	cp = new + strlen(new);
   1604   1.1      cgd 	*cp++ = '.';
   1605   1.1      cgd 	for (count = 1; count < 100; count++) {
   1606   1.8  deraadt 		(void)sprintf(cp, "%d", count);
   1607   1.1      cgd 		if (stat(new, &st) < 0)
   1608   1.8  deraadt 			return (new);
   1609   1.1      cgd 	}
   1610   1.1      cgd 	reply(452, "Unique file name cannot be created.");
   1611   1.8  deraadt 	return (NULL);
   1612   1.1      cgd }
   1613   1.1      cgd 
   1614   1.1      cgd /*
   1615   1.1      cgd  * Format and send reply containing system error number.
   1616   1.1      cgd  */
   1617   1.8  deraadt void
   1618   1.1      cgd perror_reply(code, string)
   1619   1.1      cgd 	int code;
   1620   1.1      cgd 	char *string;
   1621   1.1      cgd {
   1622   1.8  deraadt 
   1623   1.1      cgd 	reply(code, "%s: %s.", string, strerror(errno));
   1624   1.1      cgd }
   1625   1.1      cgd 
   1626   1.1      cgd static char *onefile[] = {
   1627   1.1      cgd 	"",
   1628   1.1      cgd 	0
   1629   1.1      cgd };
   1630   1.1      cgd 
   1631   1.8  deraadt void
   1632   1.8  deraadt send_file_list(whichf)
   1633   1.8  deraadt 	char *whichf;
   1634   1.1      cgd {
   1635   1.1      cgd 	struct stat st;
   1636   1.1      cgd 	DIR *dirp = NULL;
   1637   1.1      cgd 	struct dirent *dir;
   1638   1.1      cgd 	FILE *dout = NULL;
   1639   1.8  deraadt 	char **dirlist, *dirname;
   1640   1.1      cgd 	int simple = 0;
   1641   1.8  deraadt 	int freeglob = 0;
   1642   1.8  deraadt 	glob_t gl;
   1643   1.1      cgd 
   1644   1.8  deraadt 	if (strpbrk(whichf, "~{[*?") != NULL) {
   1645   1.8  deraadt 		int flags = GLOB_BRACE|GLOB_NOCHECK|GLOB_QUOTE|GLOB_TILDE;
   1646   1.1      cgd 
   1647   1.8  deraadt 		memset(&gl, 0, sizeof(gl));
   1648   1.8  deraadt 		freeglob = 1;
   1649   1.8  deraadt 		if (glob(whichf, flags, 0, &gl)) {
   1650   1.8  deraadt 			reply(550, "not found");
   1651   1.8  deraadt 			goto out;
   1652   1.8  deraadt 		} else if (gl.gl_pathc == 0) {
   1653   1.1      cgd 			errno = ENOENT;
   1654   1.8  deraadt 			perror_reply(550, whichf);
   1655   1.8  deraadt 			goto out;
   1656   1.1      cgd 		}
   1657   1.8  deraadt 		dirlist = gl.gl_pathv;
   1658   1.1      cgd 	} else {
   1659   1.8  deraadt 		onefile[0] = whichf;
   1660   1.1      cgd 		dirlist = onefile;
   1661   1.1      cgd 		simple = 1;
   1662   1.1      cgd 	}
   1663   1.1      cgd 
   1664   1.1      cgd 	if (setjmp(urgcatch)) {
   1665   1.1      cgd 		transflag = 0;
   1666   1.8  deraadt 		goto out;
   1667   1.1      cgd 	}
   1668  1.20    lukem 	while ((dirname = *dirlist++) != NULL) {
   1669   1.1      cgd 		if (stat(dirname, &st) < 0) {
   1670   1.1      cgd 			/*
   1671   1.1      cgd 			 * If user typed "ls -l", etc, and the client
   1672   1.1      cgd 			 * used NLST, do what the user meant.
   1673   1.1      cgd 			 */
   1674   1.1      cgd 			if (dirname[0] == '-' && *dirlist == NULL &&
   1675   1.1      cgd 			    transflag == 0) {
   1676   1.1      cgd 				retrieve("/bin/ls %s", dirname);
   1677   1.8  deraadt 				goto out;
   1678   1.1      cgd 			}
   1679   1.8  deraadt 			perror_reply(550, whichf);
   1680   1.1      cgd 			if (dout != NULL) {
   1681   1.1      cgd 				(void) fclose(dout);
   1682   1.1      cgd 				transflag = 0;
   1683   1.1      cgd 				data = -1;
   1684   1.1      cgd 				pdata = -1;
   1685   1.1      cgd 			}
   1686   1.8  deraadt 			goto out;
   1687   1.1      cgd 		}
   1688   1.1      cgd 
   1689   1.8  deraadt 		if (S_ISREG(st.st_mode)) {
   1690   1.1      cgd 			if (dout == NULL) {
   1691   1.1      cgd 				dout = dataconn("file list", (off_t)-1, "w");
   1692   1.1      cgd 				if (dout == NULL)
   1693   1.8  deraadt 					goto out;
   1694   1.1      cgd 				transflag++;
   1695   1.1      cgd 			}
   1696   1.1      cgd 			fprintf(dout, "%s%s\n", dirname,
   1697   1.1      cgd 				type == TYPE_A ? "\r" : "");
   1698   1.1      cgd 			byte_count += strlen(dirname) + 1;
   1699   1.1      cgd 			continue;
   1700   1.8  deraadt 		} else if (!S_ISDIR(st.st_mode))
   1701   1.1      cgd 			continue;
   1702   1.1      cgd 
   1703   1.1      cgd 		if ((dirp = opendir(dirname)) == NULL)
   1704   1.1      cgd 			continue;
   1705   1.1      cgd 
   1706   1.1      cgd 		while ((dir = readdir(dirp)) != NULL) {
   1707   1.1      cgd 			char nbuf[MAXPATHLEN];
   1708   1.1      cgd 
   1709   1.1      cgd 			if (dir->d_name[0] == '.' && dir->d_namlen == 1)
   1710   1.1      cgd 				continue;
   1711   1.1      cgd 			if (dir->d_name[0] == '.' && dir->d_name[1] == '.' &&
   1712   1.1      cgd 			    dir->d_namlen == 2)
   1713   1.1      cgd 				continue;
   1714   1.1      cgd 
   1715   1.1      cgd 			sprintf(nbuf, "%s/%s", dirname, dir->d_name);
   1716   1.1      cgd 
   1717   1.1      cgd 			/*
   1718   1.1      cgd 			 * We have to do a stat to insure it's
   1719   1.1      cgd 			 * not a directory or special file.
   1720   1.1      cgd 			 */
   1721   1.1      cgd 			if (simple || (stat(nbuf, &st) == 0 &&
   1722   1.8  deraadt 			    S_ISREG(st.st_mode))) {
   1723   1.1      cgd 				if (dout == NULL) {
   1724   1.1      cgd 					dout = dataconn("file list", (off_t)-1,
   1725   1.1      cgd 						"w");
   1726   1.1      cgd 					if (dout == NULL)
   1727   1.8  deraadt 						goto out;
   1728   1.1      cgd 					transflag++;
   1729   1.1      cgd 				}
   1730   1.1      cgd 				if (nbuf[0] == '.' && nbuf[1] == '/')
   1731   1.1      cgd 					fprintf(dout, "%s%s\n", &nbuf[2],
   1732   1.1      cgd 						type == TYPE_A ? "\r" : "");
   1733   1.1      cgd 				else
   1734   1.1      cgd 					fprintf(dout, "%s%s\n", nbuf,
   1735   1.1      cgd 						type == TYPE_A ? "\r" : "");
   1736   1.1      cgd 				byte_count += strlen(nbuf) + 1;
   1737   1.1      cgd 			}
   1738   1.1      cgd 		}
   1739   1.1      cgd 		(void) closedir(dirp);
   1740   1.1      cgd 	}
   1741   1.1      cgd 
   1742   1.1      cgd 	if (dout == NULL)
   1743   1.1      cgd 		reply(550, "No files found.");
   1744   1.1      cgd 	else if (ferror(dout) != 0)
   1745   1.1      cgd 		perror_reply(550, "Data connection");
   1746   1.1      cgd 	else
   1747   1.1      cgd 		reply(226, "Transfer complete.");
   1748   1.1      cgd 
   1749   1.1      cgd 	transflag = 0;
   1750   1.1      cgd 	if (dout != NULL)
   1751   1.1      cgd 		(void) fclose(dout);
   1752   1.1      cgd 	data = -1;
   1753   1.1      cgd 	pdata = -1;
   1754   1.8  deraadt out:
   1755   1.8  deraadt 	if (freeglob) {
   1756   1.8  deraadt 		freeglob = 0;
   1757   1.8  deraadt 		globfree(&gl);
   1758   1.8  deraadt 	}
   1759   1.1      cgd }
   1760