Home | History | Annotate | Line # | Download | only in ftp
ftp.c revision 1.90
      1 /*	$NetBSD: ftp.c,v 1.90 2000/01/31 22:01:04 lukem Exp $	*/
      2 
      3 /*-
      4  * Copyright (c) 1996-1999 The NetBSD Foundation, Inc.
      5  * All rights reserved.
      6  *
      7  * This code is derived from software contributed to The NetBSD Foundation
      8  * by Luke Mewburn.
      9  *
     10  * Redistribution and use in source and binary forms, with or without
     11  * modification, are permitted provided that the following conditions
     12  * are met:
     13  * 1. Redistributions of source code must retain the above copyright
     14  *    notice, this list of conditions and the following disclaimer.
     15  * 2. Redistributions in binary form must reproduce the above copyright
     16  *    notice, this list of conditions and the following disclaimer in the
     17  *    documentation and/or other materials provided with the distribution.
     18  * 3. All advertising materials mentioning features or use of this software
     19  *    must display the following acknowledgement:
     20  *	This product includes software developed by the NetBSD
     21  *	Foundation, Inc. and its contributors.
     22  * 4. Neither the name of The NetBSD Foundation nor the names of its
     23  *    contributors may be used to endorse or promote products derived
     24  *    from this software without specific prior written permission.
     25  *
     26  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     27  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     28  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     29  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     30  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     31  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     32  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     33  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     34  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     35  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     36  * POSSIBILITY OF SUCH DAMAGE.
     37  */
     38 
     39 /*
     40  * Copyright (c) 1985, 1989, 1993, 1994
     41  *	The Regents of the University of California.  All rights reserved.
     42  *
     43  * Redistribution and use in source and binary forms, with or without
     44  * modification, are permitted provided that the following conditions
     45  * are met:
     46  * 1. Redistributions of source code must retain the above copyright
     47  *    notice, this list of conditions and the following disclaimer.
     48  * 2. Redistributions in binary form must reproduce the above copyright
     49  *    notice, this list of conditions and the following disclaimer in the
     50  *    documentation and/or other materials provided with the distribution.
     51  * 3. All advertising materials mentioning features or use of this software
     52  *    must display the following acknowledgement:
     53  *	This product includes software developed by the University of
     54  *	California, Berkeley and its contributors.
     55  * 4. Neither the name of the University nor the names of its contributors
     56  *    may be used to endorse or promote products derived from this software
     57  *    without specific prior written permission.
     58  *
     59  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     60  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     61  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     62  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     63  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     64  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     65  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     66  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     67  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     68  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     69  * SUCH DAMAGE.
     70  */
     71 
     72 /*
     73  * Copyright (C) 1997 and 1998 WIDE Project.
     74  * All rights reserved.
     75  *
     76  * Redistribution and use in source and binary forms, with or without
     77  * modification, are permitted provided that the following conditions
     78  * are met:
     79  * 1. Redistributions of source code must retain the above copyright
     80  *    notice, this list of conditions and the following disclaimer.
     81  * 2. Redistributions in binary form must reproduce the above copyright
     82  *    notice, this list of conditions and the following disclaimer in the
     83  *    documentation and/or other materials provided with the distribution.
     84  * 3. Neither the name of the project nor the names of its contributors
     85  *    may be used to endorse or promote products derived from this software
     86  *    without specific prior written permission.
     87  *
     88  * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
     89  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     90  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     91  * ARE DISCLAIMED.  IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
     92  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     93  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     94  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     95  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     96  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     97  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     98  * SUCH DAMAGE.
     99  */
    100 
    101 #include <sys/cdefs.h>
    102 #ifndef lint
    103 #if 0
    104 static char sccsid[] = "@(#)ftp.c	8.6 (Berkeley) 10/27/94";
    105 #else
    106 __RCSID("$NetBSD: ftp.c,v 1.90 2000/01/31 22:01:04 lukem Exp $");
    107 #endif
    108 #endif /* not lint */
    109 
    110 #include <sys/types.h>
    111 #include <sys/stat.h>
    112 #include <sys/socket.h>
    113 #include <sys/time.h>
    114 
    115 #include <netinet/in.h>
    116 #include <netinet/in_systm.h>
    117 #include <netinet/ip.h>
    118 #include <arpa/inet.h>
    119 #include <arpa/ftp.h>
    120 #include <arpa/telnet.h>
    121 
    122 #include <ctype.h>
    123 #include <err.h>
    124 #include <errno.h>
    125 #include <netdb.h>
    126 #include <stdio.h>
    127 #include <stdlib.h>
    128 #include <string.h>
    129 #include <time.h>
    130 #include <unistd.h>
    131 #ifdef __STDC__
    132 #include <stdarg.h>
    133 #else
    134 #include <varargs.h>
    135 #endif
    136 #ifndef __USE_SELECT
    137 #include <poll.h>
    138 #endif
    139 
    140 #include "ftp_var.h"
    141 
    142 volatile int	abrtflag = 0;
    143 volatile int	timeoutflag = 0;
    144 sigjmp_buf	ptabort;
    145 int	ptabflg;
    146 int	ptflag = 0;
    147 char	pasv[BUFSIZ];	/* passive port for proxy data connection */
    148 
    149 static int empty __P((FILE *, FILE *, int));
    150 
    151 union sockunion {
    152 	struct sockinet {
    153 #ifdef BSD4_4
    154 		u_char si_len;
    155 		u_char si_family;
    156 #else
    157 		u_short si_family;
    158 #endif
    159 		u_short si_port;
    160 #ifndef BSD4_4
    161 		u_char  si_pad[
    162 #ifdef INET6
    163 				sizeof(struct sockaddr_in6)
    164 #else
    165 				sizeof(struct sockaddr_in)
    166 #endif
    167 				- sizeof(u_int)];
    168 		u_char	si_len;
    169 #endif
    170 	} su_si;
    171 	struct sockaddr_in  su_sin;
    172 #ifdef INET6
    173 	struct sockaddr_in6 su_sin6;
    174 #endif
    175 };
    176 
    177 #define	su_len		su_si.si_len
    178 #define	su_family	su_si.si_family
    179 #define	su_port		su_si.si_port
    180 
    181 union sockunion myctladdr, hisctladdr, data_addr;
    182 
    183 char *
    184 hookup(host, port)
    185 	char *host;
    186 	char *port;
    187 {
    188 	int s = -1, len, error;
    189 #ifdef NI_NUMERICHOST
    190 	struct addrinfo hints, *res, *res0;
    191 	char hbuf[MAXHOSTNAMELEN];
    192 #else
    193 	struct hostent *hp = NULL;
    194 	char **ptr, *ep;
    195 	struct sockaddr_in sin;
    196 	long nport;
    197 #endif
    198 	static char hostnamebuf[MAXHOSTNAMELEN];
    199 	char *cause = "unknown";
    200 	int family;
    201 
    202 #ifdef NI_NUMERICHOST
    203 	memset((char *)&hisctladdr, 0, sizeof (hisctladdr));
    204 	memset(&hints, 0, sizeof(hints));
    205 	hints.ai_flags = AI_CANONNAME;
    206 	hints.ai_family = AF_UNSPEC;
    207 	hints.ai_socktype = SOCK_STREAM;
    208 	hints.ai_protocol = 0;
    209 	error = getaddrinfo(host, port, &hints, &res0);
    210 	if (error) {
    211 		warnx(gai_strerror(error));
    212 		code = -1;
    213 		return (0);
    214 	}
    215 
    216 	if (res0->ai_canonname)
    217 		(void)strlcpy(hostnamebuf, res0->ai_canonname,
    218 		    sizeof(hostnamebuf));
    219 	else
    220 		(void)strlcpy(hostnamebuf, host, sizeof(hostnamebuf));
    221 	hostname = hostnamebuf;
    222 
    223 	for (res = res0; res; res = res->ai_next) {
    224 #if 0	/*old behavior*/
    225 		if (res != res0)	/* not on the first address */
    226 #else
    227 		if (res0->ai_next)	/* if we have multiple possibilities */
    228 #endif
    229 		{
    230 			getnameinfo(res->ai_addr, res->ai_addrlen,
    231 				hbuf, sizeof(hbuf), NULL, 0, NI_NUMERICHOST);
    232 			fprintf(ttyout, "Trying %s...\n", hbuf);
    233 		}
    234 		s = socket(res->ai_family, res->ai_socktype, res->ai_protocol);
    235 		if (s < 0) {
    236 			cause = "socket";
    237 			continue;
    238 		}
    239 		while ((error = xconnect(s, res->ai_addr, res->ai_addrlen)) < 0
    240 				&& errno == EINTR) {
    241 			;
    242 		}
    243 		if (error) {
    244 			/* this "if" clause is to prevent print warning twice */
    245 			if (res->ai_next) {
    246 				getnameinfo(res->ai_addr, res->ai_addrlen,
    247 					hbuf, sizeof(hbuf), NULL, 0,
    248 					NI_NUMERICHOST);
    249 				warn("connect to address %s", hbuf);
    250 			}
    251 			cause = "connect";
    252 			close(s);
    253 			s = -1;
    254 			continue;
    255 		}
    256 
    257 		/* finally we got one */
    258 		break;
    259 	}
    260 	if (s < 0) {
    261 		warn(cause);
    262 		code = -1;
    263 		freeaddrinfo(res0);
    264 		return 0;
    265 	}
    266 	memcpy(&hisctladdr, res->ai_addr, res->ai_addrlen);
    267 	len = res->ai_addrlen;
    268 	freeaddrinfo(res0);
    269 	res0 = res = NULL;
    270 	family = hisctladdr.su_family;
    271 #else
    272 	memset(&sin, 0, sizeof(sin));
    273 	sin.sin_family = AF_INET;
    274 	if ((hp = gethostbyname(host)) == NULL) {
    275 		warnx("%s: %s", host, hstrerror(h_errno));
    276 		code = -1;
    277 		return 0;
    278 	}
    279 
    280 	nport = strtol(port, &ep, 10);
    281 	if (*ep != '\0' && ep == port) {
    282 		struct servent	*svp;
    283 
    284 		svp = getservbyname(port, "tcp");
    285 		if (svp == NULL) {
    286 			warnx("hookup: unknown port `%s'", port);
    287 			sin.sin_port = htons(FTP_PORT);
    288 		} else
    289 			sin.sin_port = svp->s_port;
    290 	} else if (nport < 1 || nport > MAX_IN_PORT_T || *ep != '\0') {
    291 		warnx("hookup: invalid port `%s'", port);
    292 		sin.sin_port = htons(FTP_PORT);
    293 	} else
    294 		sin.sin_port = htons(nport);
    295 
    296 	(void)strlcpy(hostnamebuf, hp->h_name, sizeof(hostnamebuf));
    297 	hostname = hostnamebuf;
    298 
    299 	if (hp->h_length > sizeof(sin.sin_addr))
    300 		hp->h_length = sizeof(sin.sin_addr);
    301 
    302 	for (ptr = hp->h_addr_list; *ptr; ptr++) {
    303 		memcpy(&sin.sin_addr, *ptr, (size_t)hp->h_length);
    304 		if (hp->h_addr_list[1])
    305 			fprintf(ttyout, "Trying %s...\n",
    306 			    inet_ntoa(sin.sin_addr));
    307 		s = socket(AF_INET, SOCK_STREAM, 0);
    308 		if (s < 0) {
    309 			cause = "socket";
    310 			continue;
    311 		}
    312 		while ((error = xconnect(s, (struct sockaddr *)&sin,
    313 		    sizeof(sin))) < 0 && errno == EINTR) {
    314 			;
    315 		}
    316 		if (error) {
    317 			/* this "if" clause is to prevent print warning twice */
    318 			if (hp->h_addr_list[1]) {
    319 				warn("connect to address %s",
    320 				    inet_ntoa(sin.sin_addr));
    321 			}
    322 			cause = "connect";
    323 			close(s);
    324 			s = -1;
    325 			continue;
    326 		}
    327 
    328 		/* finally we got one */
    329 		break;
    330 	}
    331 	if (s < 0) {
    332 		warn(cause);
    333 		code = -1;
    334 		return 0;
    335 	}
    336 	memcpy(&hisctladdr, &sin, sizeof(sin));
    337 	len = sizeof(sin);
    338 	if (hisctladdr.su_len == 0)
    339 		hisctladdr.su_len = len;
    340 	family = AF_INET;
    341 #endif
    342 
    343 	if (getsockname(s, (struct sockaddr *)&myctladdr, &len) < 0) {
    344 		warn("getsockname");
    345 		code = -1;
    346 		goto bad;
    347 	}
    348 	if (myctladdr.su_len == 0)
    349 		myctladdr.su_len = len;
    350 
    351 	if (family == AF_INET) {
    352 		int tos = IPTOS_LOWDELAY;
    353 		if (setsockopt(s, IPPROTO_IP, IP_TOS, (char *)&tos,
    354 			       sizeof(int)) < 0)
    355 			warn("setsockopt TOS (ignored)");
    356 	}
    357 	cin = fdopen(s, "r");
    358 	cout = fdopen(s, "w");
    359 	if (cin == NULL || cout == NULL) {
    360 		warnx("fdopen failed.");
    361 		if (cin)
    362 			(void)fclose(cin);
    363 		if (cout)
    364 			(void)fclose(cout);
    365 		code = -1;
    366 		goto bad;
    367 	}
    368 	if (verbose)
    369 		fprintf(ttyout, "Connected to %s.\n", hostname);
    370 	if (getreply(0) > 2) {	/* read startup message from server */
    371 		if (cin)
    372 			(void)fclose(cin);
    373 		if (cout)
    374 			(void)fclose(cout);
    375 		code = -1;
    376 		goto bad;
    377 	}
    378 	{
    379 	int on = 1;
    380 
    381 	if (setsockopt(s, SOL_SOCKET, SO_OOBINLINE, (char *)&on, sizeof(on))
    382 		< 0 && debug) {
    383 			warn("setsockopt");
    384 		}
    385 	}
    386 
    387 	return (hostname);
    388 bad:
    389 	(void)close(s);
    390 	return (NULL);
    391 }
    392 
    393 void
    394 cmdabort(notused)
    395 	int notused;
    396 {
    397 	int oerrno = errno;
    398 
    399 	alarmtimer(0);
    400 	if (fromatty)
    401 		write(fileno(ttyout), "\n", 1);
    402 	abrtflag++;
    403 	if (ptflag)
    404 		siglongjmp(ptabort, 1);
    405 	errno = oerrno;
    406 }
    407 
    408 void
    409 cmdtimeout(notused)
    410 	int notused;
    411 {
    412 	int oerrno = errno;
    413 
    414 	alarmtimer(0);
    415 	if (fromatty)
    416 		write(fileno(ttyout), "\n", 1);
    417 	timeoutflag++;
    418 	if (ptflag)
    419 		siglongjmp(ptabort, 1);
    420 	errno = oerrno;
    421 }
    422 
    423 
    424 /*VARARGS*/
    425 int
    426 #ifdef __STDC__
    427 command(const char *fmt, ...)
    428 #else
    429 command(va_alist)
    430 	va_dcl
    431 #endif
    432 {
    433 	va_list ap;
    434 	int r;
    435 	sigfunc oldsigint;
    436 #ifndef __STDC__
    437 	const char *fmt;
    438 #endif
    439 
    440 	if (debug) {
    441 		fputs("---> ", ttyout);
    442 #ifdef __STDC__
    443 		va_start(ap, fmt);
    444 #else
    445 		va_start(ap);
    446 		fmt = va_arg(ap, const char *);
    447 #endif
    448 		if (strncmp("PASS ", fmt, 5) == 0)
    449 			fputs("PASS XXXX", ttyout);
    450 		else if (strncmp("ACCT ", fmt, 5) == 0)
    451 			fputs("ACCT XXXX", ttyout);
    452 		else
    453 			vfprintf(ttyout, fmt, ap);
    454 		va_end(ap);
    455 		putc('\n', ttyout);
    456 	}
    457 	if (cout == NULL) {
    458 		warnx("No control connection for command.");
    459 		code = -1;
    460 		return (0);
    461 	}
    462 
    463 	abrtflag = 0;
    464 
    465 	oldsigint = xsignal(SIGINT, cmdabort);
    466 
    467 #ifdef __STDC__
    468 	va_start(ap, fmt);
    469 #else
    470 	va_start(ap);
    471 	fmt = va_arg(ap, char *);
    472 #endif
    473 	vfprintf(cout, fmt, ap);
    474 	va_end(ap);
    475 	fputs("\r\n", cout);
    476 	(void)fflush(cout);
    477 	cpend = 1;
    478 	r = getreply(!strcmp(fmt, "QUIT"));
    479 	if (abrtflag && oldsigint != SIG_IGN)
    480 		(*oldsigint)(SIGINT);
    481 	(void)xsignal(SIGINT, oldsigint);
    482 	return (r);
    483 }
    484 
    485 int
    486 getreply(expecteof)
    487 	int expecteof;
    488 {
    489 	char current_line[BUFSIZ];	/* last line of previous reply */
    490 	int c, n, line;
    491 	int dig;
    492 	int originalcode = 0, continuation = 0;
    493 	sigfunc oldsigint, oldsigalrm;
    494 	int pflag = 0;
    495 	char *cp, *pt = pasv;
    496 
    497 	abrtflag = 0;
    498 	timeoutflag = 0;
    499 
    500 	oldsigint = xsignal(SIGINT, cmdabort);
    501 	oldsigalrm = xsignal(SIGALRM, cmdtimeout);
    502 
    503 	for (line = 0 ;; line++) {
    504 		dig = n = code = 0;
    505 		cp = current_line;
    506 		while (alarmtimer(60),((c = getc(cin)) != '\n')) {
    507 			if (c == IAC) {     /* handle telnet commands */
    508 				switch (c = getc(cin)) {
    509 				case WILL:
    510 				case WONT:
    511 					c = getc(cin);
    512 					fprintf(cout, "%c%c%c", IAC, DONT, c);
    513 					(void)fflush(cout);
    514 					break;
    515 				case DO:
    516 				case DONT:
    517 					c = getc(cin);
    518 					fprintf(cout, "%c%c%c", IAC, WONT, c);
    519 					(void)fflush(cout);
    520 					break;
    521 				default:
    522 					break;
    523 				}
    524 				continue;
    525 			}
    526 			dig++;
    527 			if (c == EOF) {
    528 				/*
    529 				 * these will get trashed by pswitch()
    530 				 * in lostpeer()
    531 				 */
    532 				int reply_timeoutflag = timeoutflag;
    533 				int reply_abrtflag = abrtflag;
    534 
    535 				alarmtimer(0);
    536 				if (expecteof && feof(cin)) {
    537 					(void)xsignal(SIGINT, oldsigint);
    538 					(void)xsignal(SIGALRM, oldsigalrm);
    539 					code = 221;
    540 					return (0);
    541 				}
    542 				cpend = 0;
    543 				lostpeer(0);
    544 				if (verbose) {
    545 					if (reply_timeoutflag)
    546 						fputs(
    547     "421 Service not available, remote server timed out. Connection closed\n",
    548 						    ttyout);
    549 					else if (reply_abrtflag)
    550 						fputs(
    551     "421 Service not available, user interrupt. Connection closed.\n",
    552 						    ttyout);
    553 					else
    554 						fputs(
    555     "421 Service not available, remote server has closed connection.\n",
    556 						    ttyout);
    557 					(void)fflush(ttyout);
    558 				}
    559 				code = 421;
    560 				(void)xsignal(SIGINT, oldsigint);
    561 				(void)xsignal(SIGALRM, oldsigalrm);
    562 				return (4);
    563 			}
    564 			if (c != '\r' && (verbose > 0 ||
    565 			    ((verbose > -1 && n == '5' && dig > 4) &&
    566 			    (((!n && c < '5') || (n && n < '5'))
    567 			     || !retry_connect)))) {
    568 				if (proxflag &&
    569 				   (dig == 1 || (dig == 5 && verbose == 0)))
    570 					fprintf(ttyout, "%s:", hostname);
    571 				(void)putc(c, ttyout);
    572 			}
    573 			if (dig < 4 && isdigit(c))
    574 				code = code * 10 + (c - '0');
    575 			if (!pflag && (code == 227 || code == 228))
    576 				pflag = 1;
    577 			else if (!pflag && code == 229)
    578 				pflag = 100;
    579 			if (dig > 4 && pflag == 1 && isdigit(c))
    580 				pflag = 2;
    581 			if (pflag == 2) {
    582 				if (c != '\r' && c != ')')
    583 					*pt++ = c;
    584 				else {
    585 					*pt = '\0';
    586 					pflag = 3;
    587 				}
    588 			}
    589 			if (pflag == 100 && c == '(')
    590 				pflag = 2;
    591 			if (dig == 4 && c == '-') {
    592 				if (continuation)
    593 					code = 0;
    594 				continuation++;
    595 			}
    596 			if (n == 0)
    597 				n = c;
    598 			if (cp < &current_line[sizeof(current_line) - 1])
    599 				*cp++ = c;
    600 		}
    601 		if (verbose > 0 || ((verbose > -1 && n == '5') &&
    602 		    (n < '5' || !retry_connect))) {
    603 			(void)putc(c, ttyout);
    604 			(void)fflush (ttyout);
    605 		}
    606 		if (line == 0) {
    607 			size_t len = cp - current_line;
    608 
    609 			if (len > sizeof(reply_string))
    610 				len = sizeof(reply_string);
    611 
    612 			(void)strlcpy(reply_string, current_line, len);
    613 		}
    614 		if (continuation && code != originalcode) {
    615 			if (originalcode == 0)
    616 				originalcode = code;
    617 			continue;
    618 		}
    619 		*cp = '\0';
    620 		if (n != '1')
    621 			cpend = 0;
    622 		alarmtimer(0);
    623 		(void)xsignal(SIGINT, oldsigint);
    624 		(void)xsignal(SIGALRM, oldsigalrm);
    625 		if (code == 421 || originalcode == 421)
    626 			lostpeer(0);
    627 		if (abrtflag && oldsigint != cmdabort && oldsigint != SIG_IGN)
    628 			(*oldsigint)(SIGINT);
    629 		if (timeoutflag && oldsigalrm != cmdtimeout &&
    630 		    oldsigalrm != SIG_IGN)
    631 			(*oldsigalrm)(SIGINT);
    632 		return (n - '0');
    633 	}
    634 }
    635 
    636 static int
    637 empty(cin, din, sec)
    638 	FILE *cin;
    639 	FILE *din;
    640 	int sec;
    641 {
    642 	int nr;
    643 	int nfd = 0;
    644 
    645 #ifdef __USE_SELECT
    646 	struct timeval t;
    647 	fd_set rmask;
    648 
    649 	FD_ZERO(&rmask);
    650 	if (cin) {
    651 		if (nfd < fileno(cin))
    652 			nfd = fileno(cin);
    653 		FD_SET(fileno(cin), &rmask);
    654 	}
    655 	if (din) {
    656 		if (nfd < fileno(din))
    657 			nfd = fileno(din);
    658 		FD_SET(fileno(din), &rmask);
    659 	}
    660 
    661 	t.tv_sec = (long) sec;
    662 	t.tv_usec = 0;
    663 	if ((nr = select(nfd, &rmask, NULL, NULL, &t)) <= 0)
    664 		return nr;
    665 
    666 	nr = 0;
    667 	if (cin)
    668 		nr |= FD_ISSET(fileno(cin), &rmask) ? 1 : 0;
    669 	if (din)
    670 		nr |= FD_ISSET(fileno(din), &rmask) ? 2 : 0;
    671 
    672 #else
    673 	struct pollfd pfd[2];
    674 
    675 	if (cin) {
    676 	    pfd[nfd].fd = fileno(cin);
    677 	    pfd[nfd++].events = POLLIN;
    678 	}
    679 
    680 	if (din) {
    681 	    pfd[nfd].fd = fileno(din);
    682 	    pfd[nfd++].events = POLLIN;
    683 	}
    684 
    685 	if ((nr = poll(pfd, nfd, sec * 1000)) <= 0)
    686 		return nr;
    687 
    688 	nr = 0;
    689 	nfd = 0;
    690 	if (cin)
    691 		nr |= (pfd[nfd++].revents & POLLIN) ? 1 : 0;
    692 	if (din)
    693 		nr |= (pfd[nfd++].revents & POLLIN) ? 2 : 0;
    694 #endif
    695 	return nr;
    696 }
    697 
    698 sigjmp_buf	xferabort;
    699 
    700 void
    701 abortxfer(notused)
    702 	int notused;
    703 {
    704 	char msgbuf[100];
    705 	int len;
    706 
    707 	alarmtimer(0);
    708 	mflag = 0;
    709 	abrtflag = 0;
    710 	switch (direction[0]) {
    711 	case 'r':
    712 		strlcpy(msgbuf, "\nreceive", sizeof(msgbuf));
    713 		break;
    714 	case 's':
    715 		strlcpy(msgbuf, "\nsend", sizeof(msgbuf));
    716 		break;
    717 	default:
    718 		errx(1, "abortxfer called with unknown direction `%s'",
    719 		    direction);
    720 	}
    721 	len = strlcat(msgbuf, " aborted. Waiting for remote to finish abort.\n",
    722 	    sizeof(msgbuf));
    723 	write(fileno(ttyout), msgbuf, len);
    724 	siglongjmp(xferabort, 1);
    725 }
    726 
    727 void
    728 sendrequest(cmd, local, remote, printnames)
    729 	const char *cmd, *local, *remote;
    730 	int printnames;
    731 {
    732 	struct stat st;
    733 	int c, d;
    734 	FILE *fin, *dout;
    735 	int (*closefunc) __P((FILE *));
    736 	sigfunc oldintr, oldintp;
    737 	volatile off_t hashbytes;
    738 	char *lmode, *bufp;
    739 	static size_t bufsize;
    740 	static char *buf;
    741 	int oprogress;
    742 
    743 #ifdef __GNUC__			/* to shut up gcc warnings */
    744 	(void)&fin;
    745 	(void)&dout;
    746 	(void)&closefunc;
    747 	(void)&oldintr;
    748 	(void)&oldintp;
    749 	(void)&lmode;
    750 #endif
    751 
    752 	hashbytes = mark;
    753 	direction = "sent";
    754 	dout = NULL;
    755 	bytes = 0;
    756 	filesize = -1;
    757 	oprogress = progress;
    758 	if (verbose && printnames) {
    759 		if (local && *local != '-')
    760 			fprintf(ttyout, "local: %s ", local);
    761 		if (remote)
    762 			fprintf(ttyout, "remote: %s\n", remote);
    763 	}
    764 	if (proxy) {
    765 		proxtrans(cmd, local, remote);
    766 		return;
    767 	}
    768 	if (curtype != type)
    769 		changetype(type, 0);
    770 	closefunc = NULL;
    771 	oldintr = NULL;
    772 	oldintp = NULL;
    773 	lmode = "w";
    774 	if (sigsetjmp(xferabort, 1)) {
    775 		while (cpend)
    776 			(void)getreply(0);
    777 		code = -1;
    778 		goto cleanupsend;
    779 	}
    780 	(void)xsignal(SIGQUIT, psummary);
    781 	oldintr = xsignal(SIGINT, abortxfer);
    782 	if (strcmp(local, "-") == 0) {
    783 		fin = stdin;
    784 		progress = 0;
    785 	} else if (*local == '|') {
    786 		oldintp = xsignal(SIGPIPE, SIG_IGN);
    787 		fin = popen(local + 1, "r");
    788 		if (fin == NULL) {
    789 			warn("%s", local + 1);
    790 			code = -1;
    791 			goto cleanupsend;
    792 		}
    793 		progress = 0;
    794 		closefunc = pclose;
    795 	} else {
    796 		fin = fopen(local, "r");
    797 		if (fin == NULL) {
    798 			warn("local: %s", local);
    799 			code = -1;
    800 			goto cleanupsend;
    801 		}
    802 		closefunc = fclose;
    803 		if (fstat(fileno(fin), &st) < 0 || !S_ISREG(st.st_mode)) {
    804 			fprintf(ttyout, "%s: not a plain file.\n", local);
    805 			code = -1;
    806 			goto cleanupsend;
    807 		}
    808 		filesize = st.st_size;
    809 	}
    810 	if (initconn()) {
    811 		code = -1;
    812 		goto cleanupsend;
    813 	}
    814 	if (sigsetjmp(xferabort, 1))
    815 		goto abort;
    816 
    817 	if (restart_point &&
    818 	    (strcmp(cmd, "STOR") == 0 || strcmp(cmd, "APPE") == 0)) {
    819 		int rc;
    820 
    821 		rc = -1;
    822 		switch (curtype) {
    823 		case TYPE_A:
    824 			rc = fseek(fin, (long) restart_point, SEEK_SET);
    825 			break;
    826 		case TYPE_I:
    827 		case TYPE_L:
    828 			rc = lseek(fileno(fin), restart_point, SEEK_SET);
    829 			break;
    830 		}
    831 		if (rc < 0) {
    832 			warn("local: %s", local);
    833 			goto cleanupsend;
    834 		}
    835 #ifndef NO_QUAD
    836 		if (command("REST %lld", (long long) restart_point) !=
    837 #else
    838 		if (command("REST %ld", (long) restart_point) !=
    839 #endif
    840 		    CONTINUE)
    841 			goto cleanupsend;
    842 		lmode = "r+w";
    843 	}
    844 	if (remote) {
    845 		if (command("%s %s", cmd, remote) != PRELIM)
    846 			goto cleanupsend;
    847 	} else {
    848 		if (command("%s", cmd) != PRELIM)
    849 			goto cleanupsend;
    850 	}
    851 	dout = dataconn(lmode);
    852 	if (dout == NULL)
    853 		goto abort;
    854 
    855 	if (sndbuf_size > bufsize) {
    856 		if (buf)
    857 			(void)free(buf);
    858 		bufsize = sndbuf_size;
    859 		buf = xmalloc(bufsize);
    860 	}
    861 
    862 	progressmeter(-1);
    863 	oldintp = xsignal(SIGPIPE, SIG_IGN);
    864 
    865 	switch (curtype) {
    866 
    867 	case TYPE_I:
    868 	case TYPE_L:
    869 		if (rate_put) {		/* rate limited */
    870 			while (1) {
    871 				struct timeval then, now, td;
    872 				off_t bufrem;
    873 
    874 				(void)gettimeofday(&then, NULL);
    875 				errno = c = d = 0;
    876 				bufrem = rate_put;
    877 				while (bufrem > 0) {
    878 					if ((c = read(fileno(fin), buf,
    879 					    MIN(bufsize, bufrem))) <= 0)
    880 						goto senddone;
    881 					bytes += c;
    882 					bufrem -= c;
    883 					for (bufp = buf; c > 0;
    884 					    c -= d, bufp += d)
    885 						if ((d = write(fileno(dout),
    886 						    bufp, c)) <= 0)
    887 							break;
    888 					if (d < 0)
    889 						goto senddone;
    890 					if (hash &&
    891 					    (!progress || filesize < 0) ) {
    892 						while (bytes >= hashbytes) {
    893 							(void)putc('#', ttyout);
    894 							hashbytes += mark;
    895 						}
    896 						(void)fflush(ttyout);
    897 					}
    898 				}
    899 				while (1) {
    900 					(void)gettimeofday(&now, NULL);
    901 					timersub(&now, &then, &td);
    902 					if (td.tv_sec > 0)
    903 						break;
    904 					usleep(1000000 - td.tv_usec);
    905 				}
    906 			}
    907 		} else {		/* simpler/faster no rate limit */
    908 			while (1) {
    909 				errno = c = d = 0;
    910 				if ((c = read(fileno(fin), buf, bufsize)) <= 0)
    911 					goto senddone;
    912 				bytes += c;
    913 				for (bufp = buf; c > 0; c -= d, bufp += d)
    914 					if ((d = write(fileno(dout), bufp, c))
    915 					    <= 0)
    916 						break;
    917 				if (d < 0)
    918 					goto senddone;
    919 				if (hash && (!progress || filesize < 0) ) {
    920 					while (bytes >= hashbytes) {
    921 						(void)putc('#', ttyout);
    922 						hashbytes += mark;
    923 					}
    924 					(void)fflush(ttyout);
    925 				}
    926 			}
    927 		}
    928  senddone:
    929 		if (hash && (!progress || filesize < 0) && bytes > 0) {
    930 			if (bytes < mark)
    931 				(void)putc('#', ttyout);
    932 			(void)putc('\n', ttyout);
    933 		}
    934 		if (c < 0)
    935 			warn("local: %s", local);
    936 		if (d < 0) {
    937 			if (errno != EPIPE)
    938 				warn("netout");
    939 			bytes = -1;
    940 		}
    941 		break;
    942 
    943 	case TYPE_A:
    944 		while ((c = getc(fin)) != EOF) {
    945 			if (c == '\n') {
    946 				while (hash && (!progress || filesize < 0) &&
    947 				    (bytes >= hashbytes)) {
    948 					(void)putc('#', ttyout);
    949 					(void)fflush(ttyout);
    950 					hashbytes += mark;
    951 				}
    952 				if (ferror(dout))
    953 					break;
    954 				(void)putc('\r', dout);
    955 				bytes++;
    956 			}
    957 			(void)putc(c, dout);
    958 			bytes++;
    959 #if 0	/* this violates RFC */
    960 			if (c == '\r') {
    961 				(void)putc('\0', dout);
    962 				bytes++;
    963 			}
    964 #endif
    965 		}
    966 		if (hash && (!progress || filesize < 0)) {
    967 			if (bytes < hashbytes)
    968 				(void)putc('#', ttyout);
    969 			(void)putc('\n', ttyout);
    970 		}
    971 		if (ferror(fin))
    972 			warn("local: %s", local);
    973 		if (ferror(dout)) {
    974 			if (errno != EPIPE)
    975 				warn("netout");
    976 			bytes = -1;
    977 		}
    978 		break;
    979 	}
    980 
    981 	progressmeter(1);
    982 	if (closefunc != NULL) {
    983 		(*closefunc)(fin);
    984 		fin = NULL;
    985 	}
    986 	(void)fclose(dout);
    987 	dout = NULL;
    988 	(void)getreply(0);
    989 	if (bytes > 0)
    990 		ptransfer(0);
    991 	goto cleanupsend;
    992 
    993 abort:
    994 	(void)xsignal(SIGINT, oldintr);
    995 	oldintr = NULL;
    996 	if (!cpend) {
    997 		code = -1;
    998 		goto cleanupsend;
    999 	}
   1000 	if (data >= 0) {
   1001 		(void)close(data);
   1002 		data = -1;
   1003 	}
   1004 	if (dout) {
   1005 		(void)fclose(dout);
   1006 		dout = NULL;
   1007 	}
   1008 	(void)getreply(0);
   1009 	code = -1;
   1010 	if (bytes > 0)
   1011 		ptransfer(0);
   1012 
   1013 cleanupsend:
   1014 	if (oldintr)
   1015 		(void)xsignal(SIGINT, oldintr);
   1016 	if (oldintp)
   1017 		(void)xsignal(SIGPIPE, oldintp);
   1018 	if (data >= 0) {
   1019 		(void)close(data);
   1020 		data = -1;
   1021 	}
   1022 	if (closefunc != NULL && fin != NULL)
   1023 		(*closefunc)(fin);
   1024 	if (dout)
   1025 		(void)fclose(dout);
   1026 	progress = oprogress;
   1027 	restart_point = 0;
   1028 	bytes = 0;
   1029 }
   1030 
   1031 void
   1032 recvrequest(cmd, local, remote, lmode, printnames, ignorespecial)
   1033 	const char *cmd, *local, *remote, *lmode;
   1034 	int printnames, ignorespecial;
   1035 {
   1036 	FILE *fout, *din;
   1037 	int (*closefunc) __P((FILE *));
   1038 	sigfunc oldintr, oldintp;
   1039 	int c, d;
   1040 	volatile int is_retr, tcrflag, bare_lfs;
   1041 	static size_t bufsize;
   1042 	static char *buf;
   1043 	volatile off_t hashbytes;
   1044 	struct stat st;
   1045 	time_t mtime;
   1046 	struct timeval tval[2];
   1047 	int oprogress;
   1048 	int opreserve;
   1049 
   1050 #ifdef __GNUC__			/* to shut up gcc warnings */
   1051 	(void)&local;
   1052 	(void)&fout;
   1053 	(void)&din;
   1054 	(void)&closefunc;
   1055 	(void)&oldintr;
   1056 	(void)&oldintp;
   1057 #endif
   1058 
   1059 	fout = NULL;
   1060 	din = NULL;
   1061 	hashbytes = mark;
   1062 	direction = "received";
   1063 	bytes = 0;
   1064 	bare_lfs = 0;
   1065 	filesize = -1;
   1066 	oprogress = progress;
   1067 	opreserve = preserve;
   1068 	is_retr = (strcmp(cmd, "RETR") == 0);
   1069 	if (is_retr && verbose && printnames) {
   1070 		if (local && (ignorespecial || *local != '-'))
   1071 			fprintf(ttyout, "local: %s ", local);
   1072 		if (remote)
   1073 			fprintf(ttyout, "remote: %s\n", remote);
   1074 	}
   1075 	if (proxy && is_retr) {
   1076 		proxtrans(cmd, local, remote);
   1077 		return;
   1078 	}
   1079 	closefunc = NULL;
   1080 	oldintr = NULL;
   1081 	oldintp = NULL;
   1082 	tcrflag = !crflag && is_retr;
   1083 	if (sigsetjmp(xferabort, 1)) {
   1084 		while (cpend)
   1085 			(void)getreply(0);
   1086 		code = -1;
   1087 		goto cleanuprecv;
   1088 	}
   1089 	(void)xsignal(SIGQUIT, psummary);
   1090 	oldintr = xsignal(SIGINT, abortxfer);
   1091 	if (ignorespecial || (strcmp(local, "-") && *local != '|')) {
   1092 		if (access(local, W_OK) < 0) {
   1093 			char *dir = strrchr(local, '/');
   1094 
   1095 			if (errno != ENOENT && errno != EACCES) {
   1096 				warn("local: %s", local);
   1097 				code = -1;
   1098 				goto cleanuprecv;
   1099 			}
   1100 			if (dir != NULL)
   1101 				*dir = 0;
   1102 			d = access(dir == local ? "/" :
   1103 			    dir ? local : ".", W_OK);
   1104 			if (dir != NULL)
   1105 				*dir = '/';
   1106 			if (d < 0) {
   1107 				warn("local: %s", local);
   1108 				code = -1;
   1109 				goto cleanuprecv;
   1110 			}
   1111 			if (!runique && errno == EACCES &&
   1112 			    chmod(local, (S_IRUSR|S_IWUSR)) < 0) {
   1113 				warn("local: %s", local);
   1114 				code = -1;
   1115 				goto cleanuprecv;
   1116 			}
   1117 			if (runique && errno == EACCES &&
   1118 			   (local = gunique(local)) == NULL) {
   1119 				code = -1;
   1120 				goto cleanuprecv;
   1121 			}
   1122 		}
   1123 		else if (runique && (local = gunique(local)) == NULL) {
   1124 			code = -1;
   1125 			goto cleanuprecv;
   1126 		}
   1127 	}
   1128 	if (!is_retr) {
   1129 		if (curtype != TYPE_A)
   1130 			changetype(TYPE_A, 0);
   1131 	} else {
   1132 		if (curtype != type)
   1133 			changetype(type, 0);
   1134 		filesize = remotesize(remote, 0);
   1135 		if (code == 421 || code == -1)
   1136 			goto cleanuprecv;
   1137 	}
   1138 	if (initconn()) {
   1139 		code = -1;
   1140 		goto cleanuprecv;
   1141 	}
   1142 	if (sigsetjmp(xferabort, 1))
   1143 		goto abort;
   1144 	if (is_retr && restart_point &&
   1145 #ifndef NO_QUAD
   1146 	    command("REST %lld", (long long) restart_point) != CONTINUE)
   1147 #else
   1148 	    command("REST %ld", (long) restart_point) != CONTINUE)
   1149 #endif
   1150 		goto cleanuprecv;
   1151 	if (! EMPTYSTRING(remote)) {
   1152 		if (command("%s %s", cmd, remote) != PRELIM)
   1153 			goto cleanuprecv;
   1154 	} else {
   1155 		if (command("%s", cmd) != PRELIM)
   1156 			goto cleanuprecv;
   1157 	}
   1158 	din = dataconn("r");
   1159 	if (din == NULL)
   1160 		goto abort;
   1161 	if (!ignorespecial && strcmp(local, "-") == 0) {
   1162 		fout = stdout;
   1163 		progress = 0;
   1164 		preserve = 0;
   1165 	} else if (!ignorespecial && *local == '|') {
   1166 		oldintp = xsignal(SIGPIPE, SIG_IGN);
   1167 		fout = popen(local + 1, "w");
   1168 		if (fout == NULL) {
   1169 			warn("%s", local+1);
   1170 			goto abort;
   1171 		}
   1172 		progress = 0;
   1173 		preserve = 0;
   1174 		closefunc = pclose;
   1175 	} else {
   1176 		fout = fopen(local, lmode);
   1177 		if (fout == NULL) {
   1178 			warn("local: %s", local);
   1179 			goto abort;
   1180 		}
   1181 		closefunc = fclose;
   1182 	}
   1183 
   1184 	if (fstat(fileno(fout), &st) != -1 && !S_ISREG(st.st_mode)) {
   1185 		progress = 0;
   1186 		preserve = 0;
   1187 	}
   1188 	if (rcvbuf_size > bufsize) {
   1189 		if (buf)
   1190 			(void)free(buf);
   1191 		bufsize = rcvbuf_size;
   1192 		buf = xmalloc(bufsize);
   1193 	}
   1194 
   1195 	progressmeter(-1);
   1196 
   1197 	switch (curtype) {
   1198 
   1199 	case TYPE_I:
   1200 	case TYPE_L:
   1201 		if (is_retr && restart_point &&
   1202 		    lseek(fileno(fout), restart_point, SEEK_SET) < 0) {
   1203 			warn("local: %s", local);
   1204 			goto cleanuprecv;
   1205 		}
   1206 		if (rate_get) {		/* rate limiting */
   1207 			while (1) {
   1208 				struct timeval then, now, td;
   1209 				off_t bufrem;
   1210 
   1211 				(void)gettimeofday(&then, NULL);
   1212 				errno = c = d = 0;
   1213 				for (bufrem = rate_get; bufrem > 0; ) {
   1214 					if ((c = read(fileno(din), buf,
   1215 					    MIN(bufsize, bufrem))) <= 0)
   1216 						goto recvdone;
   1217 					bytes += c;
   1218 					bufrem -=c;
   1219 					if ((d = write(fileno(fout), buf, c))
   1220 					    != c)
   1221 						goto recvdone;
   1222 					if (hash &&
   1223 					    (!progress || filesize < 0)) {
   1224 						while (bytes >= hashbytes) {
   1225 							(void)putc('#', ttyout);
   1226 							hashbytes += mark;
   1227 						}
   1228 						(void)fflush(ttyout);
   1229 					}
   1230 				}
   1231 					/* sleep until time is up */
   1232 				while (1) {
   1233 					(void)gettimeofday(&now, NULL);
   1234 					timersub(&now, &then, &td);
   1235 					if (td.tv_sec > 0)
   1236 						break;
   1237 					usleep(1000000 - td.tv_usec);
   1238 				}
   1239 			}
   1240 		} else {		/* faster code (no limiting) */
   1241 			while (1) {
   1242 				errno = c = d = 0;
   1243 				if ((c = read(fileno(din), buf, bufsize)) <= 0)
   1244 					goto recvdone;
   1245 				bytes += c;
   1246 				if ((d = write(fileno(fout), buf, c)) != c)
   1247 					goto recvdone;
   1248 				if (hash && (!progress || filesize < 0)) {
   1249 					while (bytes >= hashbytes) {
   1250 						(void)putc('#', ttyout);
   1251 						hashbytes += mark;
   1252 					}
   1253 					(void)fflush(ttyout);
   1254 				}
   1255 			}
   1256 		}
   1257  recvdone:
   1258 		if (hash && (!progress || filesize < 0) && bytes > 0) {
   1259 			if (bytes < mark)
   1260 				(void)putc('#', ttyout);
   1261 			(void)putc('\n', ttyout);
   1262 		}
   1263 		if (c < 0) {
   1264 			if (errno != EPIPE)
   1265 				warn("netin");
   1266 			bytes = -1;
   1267 		}
   1268 		if (d < c) {
   1269 			if (d < 0)
   1270 				warn("local: %s", local);
   1271 			else
   1272 				warnx("%s: short write", local);
   1273 		}
   1274 		break;
   1275 
   1276 	case TYPE_A:
   1277 		if (is_retr && restart_point) {
   1278 			int ch;
   1279 			long i, n;
   1280 
   1281 			if (fseek(fout, 0L, SEEK_SET) < 0)
   1282 				goto done;
   1283 			n = (long)restart_point;
   1284 			for (i = 0; i++ < n;) {
   1285 				if ((ch = getc(fout)) == EOF)
   1286 					goto done;
   1287 				if (ch == '\n')
   1288 					i++;
   1289 			}
   1290 			if (fseek(fout, 0L, SEEK_CUR) < 0) {
   1291 done:
   1292 				warn("local: %s", local);
   1293 				goto cleanuprecv;
   1294 			}
   1295 		}
   1296 		while ((c = getc(din)) != EOF) {
   1297 			if (c == '\n')
   1298 				bare_lfs++;
   1299 			while (c == '\r') {
   1300 				while (hash && (!progress || filesize < 0) &&
   1301 				    (bytes >= hashbytes)) {
   1302 					(void)putc('#', ttyout);
   1303 					(void)fflush(ttyout);
   1304 					hashbytes += mark;
   1305 				}
   1306 				bytes++;
   1307 				if ((c = getc(din)) != '\n' || tcrflag) {
   1308 					if (ferror(fout))
   1309 						goto break2;
   1310 					(void)putc('\r', fout);
   1311 					if (c == '\0') {
   1312 						bytes++;
   1313 						goto contin2;
   1314 					}
   1315 					if (c == EOF)
   1316 						goto contin2;
   1317 				}
   1318 			}
   1319 			(void)putc(c, fout);
   1320 			bytes++;
   1321 	contin2:	;
   1322 		}
   1323 break2:
   1324 		if (hash && (!progress || filesize < 0)) {
   1325 			if (bytes < hashbytes)
   1326 				(void)putc('#', ttyout);
   1327 			(void)putc('\n', ttyout);
   1328 		}
   1329 		if (ferror(din)) {
   1330 			if (errno != EPIPE)
   1331 				warn("netin");
   1332 			bytes = -1;
   1333 		}
   1334 		if (ferror(fout))
   1335 			warn("local: %s", local);
   1336 		break;
   1337 	}
   1338 
   1339 	progressmeter(1);
   1340 	if (closefunc != NULL) {
   1341 		(*closefunc)(fout);
   1342 		fout = NULL;
   1343 	}
   1344 	(void)fclose(din);
   1345 	din = NULL;
   1346 	(void)getreply(0);
   1347 	if (bare_lfs) {
   1348 		fprintf(ttyout,
   1349 		    "WARNING! %d bare linefeeds received in ASCII mode.\n",
   1350 		    bare_lfs);
   1351 		fputs("File may not have transferred correctly.\n", ttyout);
   1352 	}
   1353 	if (bytes >= 0 && is_retr) {
   1354 		if (bytes > 0)
   1355 			ptransfer(0);
   1356 		if (preserve && (closefunc == fclose)) {
   1357 			mtime = remotemodtime(remote, 0);
   1358 			if (mtime != -1) {
   1359 				(void)gettimeofday(&tval[0], NULL);
   1360 				tval[1].tv_sec = mtime;
   1361 				tval[1].tv_usec = 0;
   1362 				if (utimes(local, tval) == -1) {
   1363 					fprintf(ttyout,
   1364 				"Can't change modification time on %s to %s",
   1365 					    local, asctime(localtime(&mtime)));
   1366 				}
   1367 			}
   1368 		}
   1369 	}
   1370 	goto cleanuprecv;
   1371 
   1372 abort:
   1373 			/*
   1374 			 * abort using RFC 959 recommended IP,SYNC sequence
   1375 			 */
   1376 	if (! sigsetjmp(xferabort, 1)) {
   1377 			/* this is the first call */
   1378 		(void)xsignal(SIGINT, abort_squared);
   1379 		if (!cpend) {
   1380 			code = -1;
   1381 			goto cleanuprecv;
   1382 		}
   1383 		abort_remote(din);
   1384 	}
   1385 	code = -1;
   1386 	if (bytes > 0)
   1387 		ptransfer(0);
   1388 
   1389 cleanuprecv:
   1390 	if (oldintr)
   1391 		(void)xsignal(SIGINT, oldintr);
   1392 	if (oldintp)
   1393 		(void)xsignal(SIGPIPE, oldintp);
   1394 	if (data >= 0) {
   1395 		(void)close(data);
   1396 		data = -1;
   1397 	}
   1398 	if (closefunc != NULL && fout != NULL)
   1399 		(*closefunc)(fout);
   1400 	if (din)
   1401 		(void)fclose(din);
   1402 	progress = oprogress;
   1403 	preserve = opreserve;
   1404 	bytes = 0;
   1405 }
   1406 
   1407 /*
   1408  * Need to start a listen on the data channel before we send the command,
   1409  * otherwise the server's connect may fail.
   1410  */
   1411 int
   1412 initconn()
   1413 {
   1414 	char *p, *a;
   1415 	int result, len, tmpno = 0;
   1416 	int on = 1;
   1417 	int error;
   1418 	u_int addr[16], port[2];
   1419 	u_int af, hal, pal;
   1420 	char *pasvcmd = NULL;
   1421 
   1422 #ifdef INET6
   1423 	if (myctladdr.su_family == AF_INET6
   1424 	 && (IN6_IS_ADDR_LINKLOCAL(&myctladdr.su_sin6.sin6_addr)
   1425 	  || IN6_IS_ADDR_SITELOCAL(&myctladdr.su_sin6.sin6_addr))) {
   1426 		warnx("use of scoped address can be troublesome");
   1427 	}
   1428 #endif
   1429 reinit:
   1430 	if (passivemode) {
   1431 		data_addr = myctladdr;
   1432 		data = socket(data_addr.su_family, SOCK_STREAM, 0);
   1433 		if (data < 0) {
   1434 			warn("socket");
   1435 			return (1);
   1436 		}
   1437 		if ((options & SO_DEBUG) &&
   1438 		    setsockopt(data, SOL_SOCKET, SO_DEBUG, (char *)&on,
   1439 			       sizeof(on)) < 0)
   1440 			warn("setsockopt (ignored)");
   1441 		result = COMPLETE + 1;
   1442 		switch (data_addr.su_family) {
   1443 		case AF_INET:
   1444 			if (epsv4 && !epsv4bad) {
   1445 				result = command(pasvcmd = "EPSV");
   1446 				if (!connected)
   1447 					return (1);
   1448 				/*
   1449 				 * this code is to be friendly with broken
   1450 				 * BSDI ftpd
   1451 				 */
   1452 				if (code / 10 == 22 && code != 229) {
   1453 					fputs(
   1454 "wrong server: return code must be 229\n",
   1455 						ttyout);
   1456 					result = COMPLETE + 1;
   1457 				}
   1458 				if (result != COMPLETE) {
   1459 					epsv4bad = 1;
   1460 					if (debug)
   1461 						fputs(
   1462 					"disabling epsv4 for this connection\n",
   1463 						    ttyout);
   1464 				}
   1465 			}
   1466 			if (result != COMPLETE) {
   1467 				result = command(pasvcmd = "PASV");
   1468 				if (!connected)
   1469 					return (1);
   1470 			}
   1471 			break;
   1472 #ifdef INET6
   1473 		case AF_INET6:
   1474 			result = command(pasvcmd = "EPSV");
   1475 			if (!connected)
   1476 				return (1);
   1477 			/* this code is to be friendly with broken BSDI ftpd */
   1478 			if (code / 10 == 22 && code != 229) {
   1479 				fputs(
   1480 "wrong server: return code must be 229\n",
   1481 					ttyout);
   1482 				result = COMPLETE + 1;
   1483 			}
   1484 			if (result != COMPLETE)
   1485 				result = command(pasvcmd = "LPSV");
   1486 			if (!connected)
   1487 				return (1);
   1488 			break;
   1489 #endif
   1490 		default:
   1491 			result = COMPLETE + 1;
   1492 			break;
   1493 		}
   1494 		if (result != COMPLETE) {
   1495 			if (activefallback) {
   1496 				(void)close(data);
   1497 				data = -1;
   1498 				passivemode = 0;
   1499 #if 0
   1500 				activefallback = 0;
   1501 #endif
   1502 				goto reinit;
   1503 			}
   1504 			fputs("Passive mode refused.\n", ttyout);
   1505 			goto bad;
   1506 		}
   1507 
   1508 #define	pack2(var, off) \
   1509 	(((var[(off) + 0] & 0xff) << 8) | ((var[(off) + 1] & 0xff) << 0))
   1510 #define	pack4(var, off) \
   1511 	(((var[(off) + 0] & 0xff) << 24) | ((var[(off) + 1] & 0xff) << 16) | \
   1512 	 ((var[(off) + 2] & 0xff) << 8) | ((var[(off) + 3] & 0xff) << 0))
   1513 
   1514 		/*
   1515 		 * What we've got at this point is a string of comma separated
   1516 		 * one-byte unsigned integer values, separated by commas.
   1517 		 */
   1518 		if (strcmp(pasvcmd, "PASV") == 0) {
   1519 			if (data_addr.su_family != AF_INET) {
   1520 				fputs(
   1521 "Passive mode AF mismatch. Shouldn't happen!\n", ttyout);
   1522 				error = 1;
   1523 				goto bad;
   1524 			}
   1525 			if (code / 10 == 22 && code != 227) {
   1526 				fputs("wrong server: return code must be 227\n",
   1527 					ttyout);
   1528 				error = 1;
   1529 				goto bad;
   1530 			}
   1531 			error = sscanf(pasv, "%u,%u,%u,%u,%u,%u",
   1532 					&addr[0], &addr[1], &addr[2], &addr[3],
   1533 					&port[0], &port[1]);
   1534 			if (error != 6) {
   1535 				fputs(
   1536 "Passive mode address scan failure. Shouldn't happen!\n", ttyout);
   1537 				error = 1;
   1538 				goto bad;
   1539 			}
   1540 			error = 0;
   1541 			memset(&data_addr, 0, sizeof(data_addr));
   1542 			data_addr.su_family = AF_INET;
   1543 			data_addr.su_len = sizeof(struct sockaddr_in);
   1544 			data_addr.su_sin.sin_addr.s_addr =
   1545 				htonl(pack4(addr, 0));
   1546 			data_addr.su_port = htons(pack2(port, 0));
   1547 		} else if (strcmp(pasvcmd, "LPSV") == 0) {
   1548 			if (code / 10 == 22 && code != 228) {
   1549 				fputs("wrong server: return code must be 228\n",
   1550 					ttyout);
   1551 				error = 1;
   1552 				goto bad;
   1553 			}
   1554 			switch (data_addr.su_family) {
   1555 			case AF_INET:
   1556 				error = sscanf(pasv,
   1557 "%u,%u,%u,%u,%u,%u,%u,%u,%u",
   1558 					&af, &hal,
   1559 					&addr[0], &addr[1], &addr[2], &addr[3],
   1560 					&pal, &port[0], &port[1]);
   1561 				if (error != 9) {
   1562 					fputs(
   1563 "Passive mode address scan failure. Shouldn't happen!\n", ttyout);
   1564 					error = 1;
   1565 					goto bad;
   1566 				}
   1567 				if (af != 4 || hal != 4 || pal != 2) {
   1568 					fputs(
   1569 "Passive mode AF mismatch. Shouldn't happen!\n", ttyout);
   1570 					error = 1;
   1571 					goto bad;
   1572 				}
   1573 
   1574 				error = 0;
   1575 				memset(&data_addr, 0, sizeof(data_addr));
   1576 				data_addr.su_family = AF_INET;
   1577 				data_addr.su_len = sizeof(struct sockaddr_in);
   1578 				data_addr.su_sin.sin_addr.s_addr =
   1579 					htonl(pack4(addr, 0));
   1580 				data_addr.su_port = htons(pack2(port, 0));
   1581 				break;
   1582 #ifdef INET6
   1583 			case AF_INET6:
   1584 				error = sscanf(pasv,
   1585 "%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u",
   1586 					&af, &hal,
   1587 					&addr[0], &addr[1], &addr[2], &addr[3],
   1588 					&addr[4], &addr[5], &addr[6], &addr[7],
   1589 					&addr[8], &addr[9], &addr[10],
   1590 					&addr[11], &addr[12], &addr[13],
   1591 					&addr[14], &addr[15],
   1592 					&pal, &port[0], &port[1]);
   1593 				if (error != 21) {
   1594 					fputs(
   1595 "Passive mode address scan failure. Shouldn't happen!\n", ttyout);
   1596 					error = 1;
   1597 					goto bad;
   1598 				}
   1599 				if (af != 6 || hal != 16 || pal != 2) {
   1600 					fputs(
   1601 "Passive mode AF mismatch. Shouldn't happen!\n", ttyout);
   1602 					error = 1;
   1603 					goto bad;
   1604 				}
   1605 
   1606 				error = 0;
   1607 				memset(&data_addr, 0, sizeof(data_addr));
   1608 				data_addr.su_family = AF_INET6;
   1609 				data_addr.su_len = sizeof(struct sockaddr_in6);
   1610 			    {
   1611 				u_int32_t *p32;
   1612 				p32 = (u_int32_t *)&data_addr.su_sin6.sin6_addr;
   1613 				p32[0] = htonl(pack4(addr, 0));
   1614 				p32[1] = htonl(pack4(addr, 4));
   1615 				p32[2] = htonl(pack4(addr, 8));
   1616 				p32[3] = htonl(pack4(addr, 12));
   1617 			    }
   1618 				data_addr.su_port = htons(pack2(port, 0));
   1619 				break;
   1620 #endif
   1621 			default:
   1622 				error = 1;
   1623 			}
   1624 		} else if (strcmp(pasvcmd, "EPSV") == 0) {
   1625 			char delim[4];
   1626 
   1627 			port[0] = 0;
   1628 			if (code / 10 == 22 && code != 229) {
   1629 				fputs("wrong server: return code must be 229\n",
   1630 					ttyout);
   1631 				error = 1;
   1632 				goto bad;
   1633 			}
   1634 			if (sscanf(pasv, "%c%c%c%d%c", &delim[0],
   1635 					&delim[1], &delim[2], &port[1],
   1636 					&delim[3]) != 5) {
   1637 				fputs("parse error!\n", ttyout);
   1638 				error = 1;
   1639 				goto bad;
   1640 			}
   1641 			if (delim[0] != delim[1] || delim[0] != delim[2]
   1642 			 || delim[0] != delim[3]) {
   1643 				fputs("parse error!\n", ttyout);
   1644 				error = 1;
   1645 				goto bad;
   1646 			}
   1647 			data_addr = hisctladdr;
   1648 			data_addr.su_port = htons(port[1]);
   1649 		} else
   1650 			goto bad;
   1651 
   1652 		while (xconnect(data, (struct sockaddr *)&data_addr,
   1653 			    data_addr.su_len) < 0) {
   1654 			if (errno == EINTR)
   1655 				continue;
   1656 			if (activefallback) {
   1657 				(void)close(data);
   1658 				data = -1;
   1659 				passivemode = 0;
   1660 #if 0
   1661 				activefallback = 0;
   1662 #endif
   1663 				goto reinit;
   1664 			}
   1665 			warn("connect");
   1666 			goto bad;
   1667 		}
   1668 		if (data_addr.su_family == AF_INET) {
   1669 			on = IPTOS_THROUGHPUT;
   1670 			if (setsockopt(data, IPPROTO_IP, IP_TOS, (char *)&on,
   1671 				       sizeof(int)) < 0)
   1672 				warn("setsockopt TOS (ignored)");
   1673 		}
   1674 		return (0);
   1675 	}
   1676 
   1677 noport:
   1678 	data_addr = myctladdr;
   1679 	if (sendport)
   1680 		data_addr.su_port = 0;	/* let system pick one */
   1681 	if (data != -1)
   1682 		(void)close(data);
   1683 	data = socket(data_addr.su_family, SOCK_STREAM, 0);
   1684 	if (data < 0) {
   1685 		warn("socket");
   1686 		if (tmpno)
   1687 			sendport = 1;
   1688 		return (1);
   1689 	}
   1690 	if (!sendport)
   1691 		if (setsockopt(data, SOL_SOCKET, SO_REUSEADDR, (char *)&on,
   1692 				sizeof(on)) < 0) {
   1693 			warn("setsockopt (reuse address)");
   1694 			goto bad;
   1695 		}
   1696 	if (bind(data, (struct sockaddr *)&data_addr, data_addr.su_len) < 0) {
   1697 		warn("bind");
   1698 		goto bad;
   1699 	}
   1700 	if (options & SO_DEBUG &&
   1701 	    setsockopt(data, SOL_SOCKET, SO_DEBUG, (char *)&on,
   1702 			sizeof(on)) < 0)
   1703 		warn("setsockopt (ignored)");
   1704 	len = sizeof(data_addr);
   1705 	if (getsockname(data, (struct sockaddr *)&data_addr, &len) < 0) {
   1706 		warn("getsockname");
   1707 		goto bad;
   1708 	}
   1709 	if (xlisten(data, 1) < 0)
   1710 		warn("listen");
   1711 
   1712 #define	UC(b)	(((int)b)&0xff)
   1713 
   1714 	if (sendport) {
   1715 #ifdef INET6
   1716 		char hname[INET6_ADDRSTRLEN];
   1717 		int af;
   1718 #endif
   1719 
   1720 		switch (data_addr.su_family) {
   1721 		case AF_INET:
   1722 			if (!epsv4 || epsv4bad) {
   1723 				result = COMPLETE + 1;
   1724 				break;
   1725 			}
   1726 			/* FALLTHROUGH */
   1727 #ifdef INET6
   1728 		case AF_INET6:
   1729 			af = (data_addr.su_family == AF_INET) ? 1 : 2;
   1730 			if (getnameinfo((struct sockaddr *)&data_addr,
   1731 					data_addr.su_len, hname, sizeof(hname),
   1732 					NULL, 0, NI_NUMERICHOST)) {
   1733 				result = ERROR;
   1734 			} else {
   1735 				result = command("EPRT |%d|%s|%d|", af, hname,
   1736 						ntohs(data_addr.su_port));
   1737 				if (!connected)
   1738 					return (1);
   1739 				if (result != COMPLETE) {
   1740 					epsv4bad = 1;
   1741 					if (debug)
   1742 						fputs(
   1743 					"disabling epsv4 for this connection\n",
   1744 						    ttyout);
   1745 				}
   1746 			}
   1747 			break;
   1748 #endif
   1749 		default:
   1750 			result = COMPLETE + 1;
   1751 			break;
   1752 		}
   1753 		if (result == COMPLETE)
   1754 			goto skip_port;
   1755 
   1756 		switch (data_addr.su_family) {
   1757 		case AF_INET:
   1758 			a = (char *)&data_addr.su_sin.sin_addr;
   1759 			p = (char *)&data_addr.su_port;
   1760 			result = command("PORT %d,%d,%d,%d,%d,%d",
   1761 				 UC(a[0]), UC(a[1]), UC(a[2]), UC(a[3]),
   1762 				 UC(p[0]), UC(p[1]));
   1763 			break;
   1764 #ifdef INET6
   1765 		case AF_INET6:
   1766 			a = (char *)&data_addr.su_sin6.sin6_addr;
   1767 			p = (char *)&data_addr.su_port;
   1768 			result = command(
   1769 	"LPRT %d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d",
   1770 				 6, 16,
   1771 				 UC(a[0]),UC(a[1]),UC(a[2]),UC(a[3]),
   1772 				 UC(a[4]),UC(a[5]),UC(a[6]),UC(a[7]),
   1773 				 UC(a[8]),UC(a[9]),UC(a[10]),UC(a[11]),
   1774 				 UC(a[12]),UC(a[13]),UC(a[14]),UC(a[15]),
   1775 				 2, UC(p[0]), UC(p[1]));
   1776 			break;
   1777 #endif
   1778 		default:
   1779 			result = COMPLETE + 1; /* xxx */
   1780 		}
   1781 		if (!connected)
   1782 			return (1);
   1783 	skip_port:
   1784 
   1785 		if (result == ERROR && sendport == -1) {
   1786 			sendport = 0;
   1787 			tmpno = 1;
   1788 			goto noport;
   1789 		}
   1790 		return (result != COMPLETE);
   1791 	}
   1792 	if (tmpno)
   1793 		sendport = 1;
   1794 	if (data_addr.su_family == AF_INET) {
   1795 		on = IPTOS_THROUGHPUT;
   1796 		if (setsockopt(data, IPPROTO_IP, IP_TOS, (char *)&on,
   1797 			       sizeof(int)) < 0)
   1798 			warn("setsockopt TOS (ignored)");
   1799 	}
   1800 	return (0);
   1801 bad:
   1802 	(void)close(data), data = -1;
   1803 	if (tmpno)
   1804 		sendport = 1;
   1805 	return (1);
   1806 }
   1807 
   1808 FILE *
   1809 dataconn(lmode)
   1810 	const char *lmode;
   1811 {
   1812 	union sockunion from;
   1813 	int s, fromlen = myctladdr.su_len;
   1814 
   1815 	if (passivemode)
   1816 		return (fdopen(data, lmode));
   1817 
   1818 	s = accept(data, (struct sockaddr *) &from, &fromlen);
   1819 	if (s < 0) {
   1820 		warn("accept");
   1821 		(void)close(data), data = -1;
   1822 		return (NULL);
   1823 	}
   1824 	(void)close(data);
   1825 	data = s;
   1826 	if (from.su_family == AF_INET) {
   1827 		int tos = IPTOS_THROUGHPUT;
   1828 		if (setsockopt(s, IPPROTO_IP, IP_TOS, (char *)&tos,
   1829 				sizeof(int)) < 0) {
   1830 			warn("setsockopt TOS (ignored)");
   1831 		}
   1832 	}
   1833 	return (fdopen(data, lmode));
   1834 }
   1835 
   1836 void
   1837 psabort(notused)
   1838 	int notused;
   1839 {
   1840 	int oerrno = errno;
   1841 
   1842 	alarmtimer(0);
   1843 	abrtflag++;
   1844 	errno = oerrno;
   1845 }
   1846 
   1847 void
   1848 pswitch(flag)
   1849 	int flag;
   1850 {
   1851 	sigfunc oldintr;
   1852 	static struct comvars {
   1853 		int connect;
   1854 		char name[MAXHOSTNAMELEN];
   1855 		union sockunion mctl;
   1856 		union sockunion hctl;
   1857 		FILE *in;
   1858 		FILE *out;
   1859 		int tpe;
   1860 		int curtpe;
   1861 		int cpnd;
   1862 		int sunqe;
   1863 		int runqe;
   1864 		int mcse;
   1865 		int ntflg;
   1866 		char nti[17];
   1867 		char nto[17];
   1868 		int mapflg;
   1869 		char mi[MAXPATHLEN];
   1870 		char mo[MAXPATHLEN];
   1871 	} proxstruct, tmpstruct;
   1872 	struct comvars *ip, *op;
   1873 
   1874 	abrtflag = 0;
   1875 	oldintr = xsignal(SIGINT, psabort);
   1876 	if (flag) {
   1877 		if (proxy)
   1878 			return;
   1879 		ip = &tmpstruct;
   1880 		op = &proxstruct;
   1881 		proxy++;
   1882 	} else {
   1883 		if (!proxy)
   1884 			return;
   1885 		ip = &proxstruct;
   1886 		op = &tmpstruct;
   1887 		proxy = 0;
   1888 	}
   1889 	ip->connect = connected;
   1890 	connected = op->connect;
   1891 	if (hostname)
   1892 		(void)strlcpy(ip->name, hostname, sizeof(ip->name));
   1893 	else
   1894 		ip->name[0] = '\0';
   1895 	hostname = op->name;
   1896 	ip->hctl = hisctladdr;
   1897 	hisctladdr = op->hctl;
   1898 	ip->mctl = myctladdr;
   1899 	myctladdr = op->mctl;
   1900 	ip->in = cin;
   1901 	cin = op->in;
   1902 	ip->out = cout;
   1903 	cout = op->out;
   1904 	ip->tpe = type;
   1905 	type = op->tpe;
   1906 	ip->curtpe = curtype;
   1907 	curtype = op->curtpe;
   1908 	ip->cpnd = cpend;
   1909 	cpend = op->cpnd;
   1910 	ip->sunqe = sunique;
   1911 	sunique = op->sunqe;
   1912 	ip->runqe = runique;
   1913 	runique = op->runqe;
   1914 	ip->mcse = mcase;
   1915 	mcase = op->mcse;
   1916 	ip->ntflg = ntflag;
   1917 	ntflag = op->ntflg;
   1918 	(void)strlcpy(ip->nti, ntin, sizeof(ip->nti));
   1919 	(void)strlcpy(ntin, op->nti, sizeof(ntin));
   1920 	(void)strlcpy(ip->nto, ntout, sizeof(ip->nto));
   1921 	(void)strlcpy(ntout, op->nto, sizeof(ntout));
   1922 	ip->mapflg = mapflag;
   1923 	mapflag = op->mapflg;
   1924 	(void)strlcpy(ip->mi, mapin, sizeof(ip->mi));
   1925 	(void)strlcpy(mapin, op->mi, sizeof(mapin));
   1926 	(void)strlcpy(ip->mo, mapout, sizeof(ip->mo));
   1927 	(void)strlcpy(mapout, op->mo, sizeof(mapout));
   1928 	(void)xsignal(SIGINT, oldintr);
   1929 	if (abrtflag) {
   1930 		abrtflag = 0;
   1931 		(*oldintr)(SIGINT);
   1932 	}
   1933 }
   1934 
   1935 void
   1936 abortpt(notused)
   1937 	int notused;
   1938 {
   1939 
   1940 	alarmtimer(0);
   1941 	if (fromatty)
   1942 		write(fileno(ttyout), "\n", 1);
   1943 	ptabflg++;
   1944 	mflag = 0;
   1945 	abrtflag = 0;
   1946 	siglongjmp(ptabort, 1);
   1947 }
   1948 
   1949 void
   1950 proxtrans(cmd, local, remote)
   1951 	const char *cmd, *local, *remote;
   1952 {
   1953 	sigfunc oldintr;
   1954 	int prox_type, nfnd;
   1955 	volatile int secndflag;
   1956 	char *cmd2;
   1957 
   1958 #ifdef __GNUC__			/* to shut up gcc warnings */
   1959 	(void)&oldintr;
   1960 	(void)&cmd2;
   1961 #endif
   1962 
   1963 	oldintr = NULL;
   1964 	secndflag = 0;
   1965 	if (strcmp(cmd, "RETR"))
   1966 		cmd2 = "RETR";
   1967 	else
   1968 		cmd2 = runique ? "STOU" : "STOR";
   1969 	if ((prox_type = type) == 0) {
   1970 		if (unix_server && unix_proxy)
   1971 			prox_type = TYPE_I;
   1972 		else
   1973 			prox_type = TYPE_A;
   1974 	}
   1975 	if (curtype != prox_type)
   1976 		changetype(prox_type, 1);
   1977 	if (command("PASV") != COMPLETE) {
   1978 		fputs("proxy server does not support third party transfers.\n",
   1979 		    ttyout);
   1980 		return;
   1981 	}
   1982 	pswitch(0);
   1983 	if (!connected) {
   1984 		fputs("No primary connection.\n", ttyout);
   1985 		pswitch(1);
   1986 		code = -1;
   1987 		return;
   1988 	}
   1989 	if (curtype != prox_type)
   1990 		changetype(prox_type, 1);
   1991 	if (command("PORT %s", pasv) != COMPLETE) {
   1992 		pswitch(1);
   1993 		return;
   1994 	}
   1995 	if (sigsetjmp(ptabort, 1))
   1996 		goto abort;
   1997 	oldintr = xsignal(SIGINT, abortpt);
   1998 	if ((restart_point &&
   1999 #ifndef NO_QUAD
   2000 	    (command("REST %lld", (long long) restart_point) != CONTINUE)
   2001 #else
   2002 	    (command("REST %ld", (long) restart_point) != CONTINUE)
   2003 #endif
   2004 	    ) || (command("%s %s", cmd, remote) != PRELIM)) {
   2005 		(void)xsignal(SIGINT, oldintr);
   2006 		pswitch(1);
   2007 		return;
   2008 	}
   2009 	sleep(2);
   2010 	pswitch(1);
   2011 	secndflag++;
   2012 	if ((restart_point &&
   2013 #ifndef NO_QUAD
   2014 	    (command("REST %lld", (long long) restart_point) != CONTINUE)
   2015 #else
   2016 	    (command("REST %ld", (long) restart_point) != CONTINUE)
   2017 #endif
   2018 	    ) || (command("%s %s", cmd2, local) != PRELIM))
   2019 		goto abort;
   2020 	ptflag++;
   2021 	(void)getreply(0);
   2022 	pswitch(0);
   2023 	(void)getreply(0);
   2024 	(void)xsignal(SIGINT, oldintr);
   2025 	pswitch(1);
   2026 	ptflag = 0;
   2027 	fprintf(ttyout, "local: %s remote: %s\n", local, remote);
   2028 	return;
   2029 abort:
   2030 	if (sigsetjmp(xferabort, 1)) {
   2031 		(void)xsignal(SIGINT, oldintr);
   2032 		return;
   2033 	}
   2034 	(void)xsignal(SIGINT, abort_squared);
   2035 	ptflag = 0;
   2036 	if (strcmp(cmd, "RETR") && !proxy)
   2037 		pswitch(1);
   2038 	else if (!strcmp(cmd, "RETR") && proxy)
   2039 		pswitch(0);
   2040 	if (!cpend && !secndflag) {  /* only here if cmd = "STOR" (proxy=1) */
   2041 		if (command("%s %s", cmd2, local) != PRELIM) {
   2042 			pswitch(0);
   2043 			if (cpend)
   2044 				abort_remote(NULL);
   2045 		}
   2046 		pswitch(1);
   2047 		if (ptabflg)
   2048 			code = -1;
   2049 		(void)xsignal(SIGINT, oldintr);
   2050 		return;
   2051 	}
   2052 	if (cpend)
   2053 		abort_remote(NULL);
   2054 	pswitch(!proxy);
   2055 	if (!cpend && !secndflag) {  /* only if cmd = "RETR" (proxy=1) */
   2056 		if (command("%s %s", cmd2, local) != PRELIM) {
   2057 			pswitch(0);
   2058 			if (cpend)
   2059 				abort_remote(NULL);
   2060 			pswitch(1);
   2061 			if (ptabflg)
   2062 				code = -1;
   2063 			(void)xsignal(SIGINT, oldintr);
   2064 			return;
   2065 		}
   2066 	}
   2067 	if (cpend)
   2068 		abort_remote(NULL);
   2069 	pswitch(!proxy);
   2070 	if (cpend) {
   2071 		if ((nfnd = empty(cin, NULL, 10)) <= 0) {
   2072 			if (nfnd < 0)
   2073 				warn("abort");
   2074 			if (ptabflg)
   2075 				code = -1;
   2076 			lostpeer(0);
   2077 		}
   2078 		(void)getreply(0);
   2079 		(void)getreply(0);
   2080 	}
   2081 	if (proxy)
   2082 		pswitch(0);
   2083 	pswitch(1);
   2084 	if (ptabflg)
   2085 		code = -1;
   2086 	(void)xsignal(SIGINT, oldintr);
   2087 }
   2088 
   2089 void
   2090 reset(argc, argv)
   2091 	int argc;
   2092 	char *argv[];
   2093 {
   2094 	int nfnd = 1;
   2095 
   2096 	if (argc == 0 && argv != NULL) {
   2097 		fprintf(ttyout, "usage: %s\n", argv[0]);
   2098 		code = -1;
   2099 		return;
   2100 	}
   2101 	while (nfnd > 0) {
   2102 		if ((nfnd = empty(cin, NULL, 0)) < 0) {
   2103 			warn("reset");
   2104 			code = -1;
   2105 			lostpeer(0);
   2106 		} else if (nfnd)
   2107 			(void)getreply(0);
   2108 	}
   2109 }
   2110 
   2111 char *
   2112 gunique(local)
   2113 	const char *local;
   2114 {
   2115 	static char new[MAXPATHLEN];
   2116 	char *cp = strrchr(local, '/');
   2117 	int d, count=0, len;
   2118 	char ext = '1';
   2119 
   2120 	if (cp)
   2121 		*cp = '\0';
   2122 	d = access(cp == local ? "/" : cp ? local : ".", W_OK);
   2123 	if (cp)
   2124 		*cp = '/';
   2125 	if (d < 0) {
   2126 		warn("local: %s", local);
   2127 		return (NULL);
   2128 	}
   2129 	len = strlcpy(new, local, sizeof(new));
   2130 	cp = &new[len];
   2131 	*cp++ = '.';
   2132 	while (!d) {
   2133 		if (++count == 100) {
   2134 			fputs("runique: can't find unique file name.\n",
   2135 			    ttyout);
   2136 			return (NULL);
   2137 		}
   2138 		*cp++ = ext;
   2139 		*cp = '\0';
   2140 		if (ext == '9')
   2141 			ext = '0';
   2142 		else
   2143 			ext++;
   2144 		if ((d = access(new, F_OK)) < 0)
   2145 			break;
   2146 		if (ext != '0')
   2147 			cp--;
   2148 		else if (*(cp - 2) == '.')
   2149 			*(cp - 1) = '1';
   2150 		else {
   2151 			*(cp - 2) = *(cp - 2) + 1;
   2152 			cp--;
   2153 		}
   2154 	}
   2155 	return (new);
   2156 }
   2157 
   2158 /*
   2159  * abort_squared --
   2160  *	aborts abort_remote(). lostpeer() is called because if the user is
   2161  *	too impatient to wait or there's another problem then ftp really
   2162  *	needs to get back to a known state.
   2163  */
   2164 void
   2165 abort_squared(dummy)
   2166 	int dummy;
   2167 {
   2168 	char msgbuf[100];
   2169 	int len;
   2170 
   2171 	alarmtimer(0);
   2172 	len = strlcpy(msgbuf, "\nremote abort aborted; closing connection.\n",
   2173 	    sizeof(msgbuf));
   2174 	write(fileno(ttyout), msgbuf, len);
   2175 	lostpeer(0);
   2176 	siglongjmp(xferabort, 1);
   2177 }
   2178 
   2179 void
   2180 abort_remote(din)
   2181 	FILE *din;
   2182 {
   2183 	char buf[BUFSIZ];
   2184 	int nfnd;
   2185 
   2186 	if (cout == NULL) {
   2187 		warnx("Lost control connection for abort.");
   2188 		if (ptabflg)
   2189 			code = -1;
   2190 		lostpeer(0);
   2191 		return;
   2192 	}
   2193 	/*
   2194 	 * send IAC in urgent mode instead of DM because 4.3BSD places oob mark
   2195 	 * after urgent byte rather than before as is protocol now
   2196 	 */
   2197 	buf[0] = IAC;
   2198 	buf[1] = IP;
   2199 	buf[2] = IAC;
   2200 	if (send(fileno(cout), buf, 3, MSG_OOB) != 3)
   2201 		warn("abort");
   2202 	fprintf(cout, "%cABOR\r\n", DM);
   2203 	(void)fflush(cout);
   2204 	if ((nfnd = empty(cin, din, 10)) <= 0) {
   2205 		if (nfnd < 0)
   2206 			warn("abort");
   2207 		if (ptabflg)
   2208 			code = -1;
   2209 		lostpeer(0);
   2210 	}
   2211 	if (din && (nfnd & 2)) {
   2212 		while (read(fileno(din), buf, BUFSIZ) > 0)
   2213 			continue;
   2214 	}
   2215 	if (getreply(0) == ERROR && code == 552) {
   2216 		/* 552 needed for nic style abort */
   2217 		(void)getreply(0);
   2218 	}
   2219 	(void)getreply(0);
   2220 }
   2221