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