1 /* $NetBSD: ftp.c,v 1.164 2012/07/04 06:09:37 is Exp $ */
4 * Copyright (c) 1996-2009 The NetBSD Foundation, Inc.
7 * This code is derived from software contributed to The NetBSD Foundation
10 * Redistribution and use in source and binary forms, with or without
11 * modification, are permitted provided that the following conditions
13 * 1. Redistributions of source code must retain the above copyright
14 * notice, this list of conditions and the following disclaimer.
15 * 2. Redistributions in binary form must reproduce the above copyright
16 * notice, this list of conditions and the following disclaimer in the
17 * documentation and/or other materials provided with the distribution.
19 * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 * POSSIBILITY OF SUCH DAMAGE.
33 * Copyright (c) 1985, 1989, 1993, 1994
34 * The Regents of the University of California. All rights reserved.
36 * Redistribution and use in source and binary forms, with or without
37 * modification, are permitted provided that the following conditions
39 * 1. Redistributions of source code must retain the above copyright
40 * notice, this list of conditions and the following disclaimer.
41 * 2. Redistributions in binary form must reproduce the above copyright
42 * notice, this list of conditions and the following disclaimer in the
43 * documentation and/or other materials provided with the distribution.
44 * 3. Neither the name of the University nor the names of its contributors
45 * may be used to endorse or promote products derived from this software
46 * without specific prior written permission.
48 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
49 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
50 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
51 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
52 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
53 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
54 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
55 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
56 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
57 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
62 * Copyright (C) 1997 and 1998 WIDE Project.
63 * All rights reserved.
65 * Redistribution and use in source and binary forms, with or without
66 * modification, are permitted provided that the following conditions
68 * 1. Redistributions of source code must retain the above copyright
69 * notice, this list of conditions and the following disclaimer.
70 * 2. Redistributions in binary form must reproduce the above copyright
71 * notice, this list of conditions and the following disclaimer in the
72 * documentation and/or other materials provided with the distribution.
73 * 3. Neither the name of the project nor the names of its contributors
74 * may be used to endorse or promote products derived from this software
75 * without specific prior written permission.
77 * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
78 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
79 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
80 * ARE DISCLAIMED. IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
81 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
82 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
83 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
84 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
85 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
86 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
90 #include <sys/cdefs.h>
93 static char sccsid
[] = "@(#)ftp.c 8.6 (Berkeley) 10/27/94";
95 __RCSID("$NetBSD: ftp.c,v 1.164 2012/07/04 06:09:37 is Exp $");
99 #include <sys/types.h>
100 #include <sys/stat.h>
101 #include <sys/socket.h>
102 #include <sys/time.h>
104 #include <netinet/in.h>
105 #if !defined(__minix)
106 #include <netinet/in_systm.h>
107 #include <netinet/ip.h>
108 #endif /* !defined(__minix) */
109 #include <arpa/inet.h>
110 #include <arpa/ftp.h>
111 #include <arpa/telnet.h>
128 volatile sig_atomic_t abrtflag
;
129 volatile sig_atomic_t timeoutflag
;
134 char pasv
[BUFSIZ
]; /* passive port for proxy data connection */
136 static int empty(FILE *, FILE *, int);
137 __dead
static void abort_squared(int);
141 struct sockaddr_in su_sin
;
143 struct sockaddr_in6 su_sin6
;
146 #if !defined(HAVE_STRUCT_SOCKADDR_IN_SIN_LEN)
151 #if !defined(HAVE_STRUCT_SOCKADDR_IN_SIN_LEN)
152 # define su_len si_len
154 # define su_len si_su.su_sin.sin_len
156 #define su_family si_su.su_sin.sin_family
157 #define su_port si_su.su_sin.sin_port
159 struct sockinet myctladdr
, hisctladdr
, data_addr
;
162 hookup(const char *host
, const char *port
)
165 struct addrinfo hints
, *res
, *res0
;
166 static char hostnamebuf
[MAXHOSTNAMELEN
];
168 #if !defined(__minix)
170 #endif /* !defined(__minix) */
172 memset((char *)&hisctladdr
, 0, sizeof (hisctladdr
));
173 memset((char *)&myctladdr
, 0, sizeof (myctladdr
));
174 memset(&hints
, 0, sizeof(hints
));
175 hints
.ai_flags
= AI_CANONNAME
;
176 hints
.ai_family
= family
;
177 hints
.ai_socktype
= SOCK_STREAM
;
178 hints
.ai_protocol
= 0;
179 error
= getaddrinfo(host
, port
, &hints
, &res0
);
181 warnx("Can't lookup `%s:%s': %s", host
, port
,
182 (error
== EAI_SYSTEM
) ? strerror(errno
)
183 : gai_strerror(error
));
188 if (res0
->ai_canonname
)
189 (void)strlcpy(hostnamebuf
, res0
->ai_canonname
,
190 sizeof(hostnamebuf
));
192 (void)strlcpy(hostnamebuf
, host
, sizeof(hostnamebuf
));
193 hostname
= hostnamebuf
;
195 for (res
= res0
; res
; res
= res
->ai_next
) {
196 char hname
[NI_MAXHOST
], sname
[NI_MAXSERV
];
199 if (getnameinfo(res
->ai_addr
, res
->ai_addrlen
,
200 hname
, sizeof(hname
), sname
, sizeof(sname
),
201 NI_NUMERICHOST
| NI_NUMERICSERV
) != 0) {
202 strlcpy(hname
, "?", sizeof(hname
));
203 strlcpy(sname
, "?", sizeof(sname
));
205 if (verbose
&& res0
->ai_next
) {
206 /* if we have multiple possibilities */
207 fprintf(ttyout
, "Trying %s:%s ...\n", hname
, sname
);
209 s
= socket(res
->ai_family
, SOCK_STREAM
, res
->ai_protocol
);
211 warn("Can't create socket for connection to `%s:%s'",
215 if (ftp_connect(s
, res
->ai_addr
, res
->ai_addrlen
,
216 verbose
|| !res
->ai_next
) < 0) {
222 /* finally we got one */
226 warnx("Can't connect to `%s:%s'", host
, port
);
231 memcpy(&hisctladdr
.si_su
, res
->ai_addr
, res
->ai_addrlen
);
232 hisctladdr
.su_len
= res
->ai_addrlen
;
236 len
= hisctladdr
.su_len
;
237 if (getsockname(s
, (struct sockaddr
*)&myctladdr
.si_su
, &len
) == -1) {
238 warn("Can't determine my address of connection to `%s:%s'",
243 myctladdr
.su_len
= len
;
245 #ifdef IPTOS_LOWDELAY
246 if (hisctladdr
.su_family
== AF_INET
) {
247 int tos
= IPTOS_LOWDELAY
;
248 if (setsockopt(s
, IPPROTO_IP
, IP_TOS
,
249 (void *)&tos
, sizeof(tos
)) == -1) {
250 DWARN("setsockopt %s (ignored)",
255 cin
= fdopen(s
, "r");
256 cout
= fdopen(s
, "w");
257 if (cin
== NULL
|| cout
== NULL
) {
258 warnx("Can't fdopen socket");
267 fprintf(ttyout
, "Connected to %s.\n", hostname
);
268 if (getreply(0) > 2) { /* read startup message from server */
277 #if !defined(__minix)
278 if (setsockopt(s
, SOL_SOCKET
, SO_OOBINLINE
,
279 (void *)&on
, sizeof(on
)) == -1) {
280 DWARN("setsockopt %s (ignored)", "SO_OOBINLINE");
282 #endif /* !defined(__minix) */
291 cmdabort(int notused
)
298 write(fileno(ttyout
), "\n", 1);
301 siglongjmp(ptabort
, 1);
306 cmdtimeout(int notused
)
312 write(fileno(ttyout
), "\n", 1);
315 siglongjmp(ptabort
, 1);
321 command(const char *fmt
, ...)
329 fputs("---> ", ttyout
);
331 if (strncmp("PASS ", fmt
, 5) == 0)
332 fputs("PASS XXXX", ttyout
);
333 else if (strncmp("ACCT ", fmt
, 5) == 0)
334 fputs("ACCT XXXX", ttyout
);
336 vfprintf(ttyout
, fmt
, ap
);
342 warnx("No control connection for command");
349 oldsigint
= xsignal(SIGINT
, cmdabort
);
352 vfprintf(cout
, fmt
, ap
);
357 r
= getreply(!strcmp(fmt
, "QUIT"));
358 if (abrtflag
&& oldsigint
!= SIG_IGN
)
359 (*oldsigint
)(SIGINT
);
360 (void)xsignal(SIGINT
, oldsigint
);
364 static const char *m421
[] = {
365 "remote server timed out. Connection closed",
366 "user interrupt. Connection closed",
367 "remote server has closed connection",
371 getreply(int expecteof
)
373 char current_line
[BUFSIZ
]; /* last line of previous reply */
376 int originalcode
= 0, continuation
= 0;
377 sigfunc oldsigint
, oldsigalrm
;
379 char *cp
, *pt
= pasv
;
384 oldsigint
= xsignal(SIGINT
, cmdabort
);
385 oldsigalrm
= xsignal(SIGALRM
, cmdtimeout
);
387 for (lineno
= 0 ;; lineno
++) {
390 while (alarmtimer(quit_time
? quit_time
: 60),
391 ((c
= getc(cin
)) != '\n')) {
392 if (c
== IAC
) { /* handle telnet commands */
393 switch (c
= getc(cin
)) {
397 fprintf(cout
, "%c%c%c", IAC
, DONT
, c
);
403 fprintf(cout
, "%c%c%c", IAC
, WONT
, c
);
414 * these will get trashed by pswitch()
417 int reply_timeoutflag
= timeoutflag
;
418 int reply_abrtflag
= abrtflag
;
421 if (expecteof
&& feof(cin
)) {
422 (void)xsignal(SIGINT
, oldsigint
);
423 (void)xsignal(SIGALRM
, oldsigalrm
);
431 if (reply_timeoutflag
)
433 else if (reply_abrtflag
)
437 (void)fprintf(ttyout
,
438 "421 Service not available, %s.\n", m421
[midx
]);
439 (void)fflush(ttyout
);
442 (void)xsignal(SIGINT
, oldsigint
);
443 (void)xsignal(SIGALRM
, oldsigalrm
);
446 if (c
!= '\r' && (verbose
> 0 ||
447 ((verbose
> -1 && n
== '5' && dig
> 4) &&
448 (((!n
&& c
< '5') || (n
&& n
< '5'))
449 || !retry_connect
)))) {
451 (dig
== 1 || (dig
== 5 && verbose
== 0)))
452 fprintf(ttyout
, "%s:", hostname
);
453 (void)putc(c
, ttyout
);
455 if (dig
< 4 && isdigit(c
))
456 code
= code
* 10 + (c
- '0');
457 if (!pflag
&& (code
== 227 || code
== 228))
459 else if (!pflag
&& code
== 229)
461 if (dig
> 4 && pflag
== 1 && isdigit(c
))
464 if (c
!= '\r' && c
!= ')') {
465 if (pt
< &pasv
[sizeof(pasv
) - 1])
472 if (pflag
== 100 && c
== '(')
474 if (dig
== 4 && c
== '-') {
481 if (cp
< ¤t_line
[sizeof(current_line
) - 1])
484 if (verbose
> 0 || ((verbose
> -1 && n
== '5') &&
485 (n
< '5' || !retry_connect
))) {
486 (void)putc(c
, ttyout
);
487 (void)fflush(ttyout
);
493 (void)strlcpy(reply_string
, current_line
,
494 sizeof(reply_string
));
495 if (lineno
> 0 && code
== 0 && reply_callback
!= NULL
)
496 (*reply_callback
)(current_line
);
497 if (continuation
&& code
!= originalcode
) {
498 if (originalcode
== 0)
505 (void)xsignal(SIGINT
, oldsigint
);
506 (void)xsignal(SIGALRM
, oldsigalrm
);
507 if (code
== 421 || originalcode
== 421)
509 if (abrtflag
&& oldsigint
!= cmdabort
&& oldsigint
!= SIG_IGN
)
510 (*oldsigint
)(SIGINT
);
511 if (timeoutflag
&& oldsigalrm
!= cmdtimeout
&&
512 oldsigalrm
!= SIG_IGN
)
513 (*oldsigalrm
)(SIGINT
);
519 empty(FILE *ecin
, FILE *din
, int sec
)
522 struct pollfd pfd
[2];
526 pfd
[nfd
].fd
= fileno(ecin
);
527 pfd
[nfd
++].events
= POLLIN
;
531 pfd
[nfd
].fd
= fileno(din
);
532 pfd
[nfd
++].events
= POLLIN
;
535 if ((nr
= ftp_poll(pfd
, nfd
, sec
* 1000)) <= 0)
541 nr
|= (pfd
[nfd
++].revents
& POLLIN
) ? 1 : 0;
543 nr
|= (pfd
[nfd
++].revents
& POLLIN
) ? 2 : 0;
547 sigjmp_buf xferabort
;
550 abortxfer(int notused
)
559 switch (direction
[0]) {
561 strlcpy(msgbuf
, "\nreceive", sizeof(msgbuf
));
564 strlcpy(msgbuf
, "\nsend", sizeof(msgbuf
));
567 errx(1, "abortxfer: unknown direction `%s'", direction
);
569 len
= strlcat(msgbuf
, " aborted. Waiting for remote to finish abort.\n",
571 write(fileno(ttyout
), msgbuf
, len
);
572 siglongjmp(xferabort
, 1);
576 * Read data from infd & write to outfd, using buf/bufsize as the temporary
577 * buffer, dealing with short writes.
578 * If rate_limit != 0, rate-limit the transfer.
579 * If hash_interval != 0, fputc('c', ttyout) every hash_interval bytes.
580 * Updates global variables: bytes.
581 * Returns 0 if ok, 1 if there was a read error, 2 if there was a write error.
582 * In the case of error, errno contains the appropriate error code.
585 copy_bytes(int infd
, int outfd
, char *buf
, size_t bufsize
,
586 int rate_limit
, int hash_interval
)
588 volatile off_t hashc
;
591 struct timeval tvthen
, tvnow
, tvdiff
;
592 off_t bufrem
, bufchunk
;
595 hashc
= hash_interval
;
597 bufchunk
= rate_limit
;
603 (void)gettimeofday(&tvthen
, NULL
);
607 /* copy bufchunk at a time */
610 inc
= read(infd
, buf
, MIN((off_t
)bufsize
, bufrem
));
617 outc
= write(outfd
, bufp
, inc
);
624 while (bytes
>= hashc
) {
625 (void)putc('#', ttyout
);
626 hashc
+= hash_interval
;
628 (void)fflush(ttyout
);
631 if (rate_limit
) { /* rate limited; wait if necessary */
633 (void)gettimeofday(&tvnow
, NULL
);
634 timersub(&tvnow
, &tvthen
, &tvdiff
);
635 if (tvdiff
.tv_sec
> 0)
637 usleep(1000000 - tvdiff
.tv_usec
);
644 if (hash_interval
&& bytes
> 0) {
645 if (bytes
< hash_interval
)
646 (void)putc('#', ttyout
);
647 (void)putc('\n', ttyout
);
648 (void)fflush(ttyout
);
660 sendrequest(const char *cmd
, const char *local
, const char *remote
,
667 int (*volatile closefunc
)(FILE *);
668 sigfunc
volatile oldintr
;
669 sigfunc
volatile oldintp
;
670 off_t
volatile hashbytes
;
673 static size_t bufsize
;
682 oprogress
= progress
;
683 if (verbose
&& printnames
) {
685 fprintf(ttyout
, "local: %s ", local
);
687 fprintf(ttyout
, "remote: %s\n", remote
);
690 proxtrans(cmd
, local
, remote
);
699 if (sigsetjmp(xferabort
, 1)) {
705 (void)xsignal(SIGQUIT
, psummary
);
706 oldintr
= xsignal(SIGINT
, abortxfer
);
707 if (strcmp(local
, "-") == 0) {
710 } else if (*local
== '|') {
711 oldintp
= xsignal(SIGPIPE
, SIG_IGN
);
712 fin
= popen(local
+ 1, "r");
714 warn("Can't execute `%s'", local
+ 1);
721 fin
= fopen(local
, "r");
723 warn("Can't open `%s'", local
);
728 if (fstat(fileno(fin
), &st
) < 0 || !S_ISREG(st
.st_mode
)) {
729 fprintf(ttyout
, "%s: not a plain file.\n", local
);
733 filesize
= st
.st_size
;
739 if (sigsetjmp(xferabort
, 1))
743 (strcmp(cmd
, "STOR") == 0 || strcmp(cmd
, "APPE") == 0)) {
749 rc
= fseeko(fin
, restart_point
, SEEK_SET
);
753 rc
= lseek(fileno(fin
), restart_point
, SEEK_SET
);
757 warn("Can't seek to restart `%s'", local
);
760 if (command("REST " LLF
, (LLT
)restart_point
) != CONTINUE
)
765 if (command("%s %s", cmd
, remote
) != PRELIM
)
768 if (command("%s", cmd
) != PRELIM
)
772 dout
= dataconn(lmode
);
776 assert(sndbuf_size
> 0);
777 if ((size_t)sndbuf_size
> bufsize
) {
780 bufsize
= sndbuf_size
;
781 buf
= ftp_malloc(bufsize
);
785 oldintp
= xsignal(SIGPIPE
, SIG_IGN
);
786 hash_interval
= (hash
&& (!progress
|| filesize
< 0)) ? mark
: 0;
792 c
= copy_bytes(fileno(fin
), fileno(dout
), buf
, bufsize
,
793 rate_put
, hash_interval
);
795 warn("Reading `%s'", local
);
798 warn("Writing to network");
804 while ((c
= getc(fin
)) != EOF
) {
806 while (hash_interval
&& bytes
>= hashbytes
) {
807 (void)putc('#', ttyout
);
808 (void)fflush(ttyout
);
813 (void)putc('\r', dout
);
818 #if 0 /* this violates RFC 959 */
820 (void)putc('\0', dout
);
826 if (bytes
< hashbytes
)
827 (void)putc('#', ttyout
);
828 (void)putc('\n', ttyout
);
831 warn("Reading `%s'", local
);
834 warn("Writing to network");
841 if (closefunc
!= NULL
) {
853 (void)xsignal(SIGINT
, oldintr
);
874 (void)xsignal(SIGINT
, oldintr
);
876 (void)xsignal(SIGPIPE
, oldintp
);
881 if (closefunc
!= NULL
&& fin
!= NULL
)
885 progress
= oprogress
;
891 recvrequest(const char *cmd
, const char *volatile local
, const char *remote
,
892 const char *lmode
, int printnames
, int ignorespecial
)
896 int (*volatile closefunc
)(FILE *);
897 sigfunc
volatile oldintr
;
898 sigfunc
volatile oldintp
;
900 int volatile is_retr
;
901 int volatile tcrflag
;
902 int volatile bare_lfs
;
903 static size_t bufsize
;
905 off_t
volatile hashbytes
;
909 struct timeval tval
[2];
916 direction
= "received";
920 oprogress
= progress
;
921 opreserve
= preserve
;
922 is_retr
= (strcmp(cmd
, "RETR") == 0);
923 if (is_retr
&& verbose
&& printnames
) {
924 if (ignorespecial
|| *local
!= '-')
925 fprintf(ttyout
, "local: %s ", local
);
927 fprintf(ttyout
, "remote: %s\n", remote
);
929 if (proxy
&& is_retr
) {
930 proxtrans(cmd
, local
, remote
);
936 tcrflag
= !crflag
&& is_retr
;
937 if (sigsetjmp(xferabort
, 1)) {
943 (void)xsignal(SIGQUIT
, psummary
);
944 oldintr
= xsignal(SIGINT
, abortxfer
);
945 if (ignorespecial
|| (strcmp(local
, "-") && *local
!= '|')) {
946 if (access(local
, W_OK
) < 0) {
947 char *dir
= strrchr(local
, '/');
949 if (errno
!= ENOENT
&& errno
!= EACCES
) {
950 warn("Can't access `%s'", local
);
956 d
= access(dir
== local
? "/" :
957 dir
? local
: ".", W_OK
);
961 warn("Can't access `%s'", local
);
965 if (!runique
&& errno
== EACCES
&&
966 chmod(local
, (S_IRUSR
|S_IWUSR
)) < 0) {
967 warn("Can't chmod `%s'", local
);
971 if (runique
&& errno
== EACCES
&&
972 (local
= gunique(local
)) == NULL
) {
977 else if (runique
&& (local
= gunique(local
)) == NULL
) {
983 if (curtype
!= TYPE_A
)
984 changetype(TYPE_A
, 0);
988 filesize
= remotesize(remote
, 0);
989 if (code
== 421 || code
== -1)
996 if (sigsetjmp(xferabort
, 1))
998 if (is_retr
&& restart_point
&&
999 command("REST " LLF
, (LLT
) restart_point
) != CONTINUE
)
1001 if (! EMPTYSTRING(remote
)) {
1002 if (command("%s %s", cmd
, remote
) != PRELIM
)
1005 if (command("%s", cmd
) != PRELIM
)
1008 din
= dataconn("r");
1011 if (!ignorespecial
&& strcmp(local
, "-") == 0) {
1015 } else if (!ignorespecial
&& *local
== '|') {
1016 oldintp
= xsignal(SIGPIPE
, SIG_IGN
);
1017 fout
= popen(local
+ 1, "w");
1019 warn("Can't execute `%s'", local
+1);
1026 fout
= fopen(local
, lmode
);
1028 warn("Can't open `%s'", local
);
1034 if (fstat(fileno(fout
), &st
) != -1 && !S_ISREG(st
.st_mode
)) {
1038 assert(rcvbuf_size
> 0);
1039 if ((size_t)rcvbuf_size
> bufsize
) {
1042 bufsize
= rcvbuf_size
;
1043 buf
= ftp_malloc(bufsize
);
1047 hash_interval
= (hash
&& (!progress
|| filesize
< 0)) ? mark
: 0;
1053 if (is_retr
&& restart_point
&&
1054 lseek(fileno(fout
), restart_point
, SEEK_SET
) < 0) {
1055 warn("Can't seek to restart `%s'", local
);
1058 c
= copy_bytes(fileno(din
), fileno(fout
), buf
, bufsize
,
1059 rate_get
, hash_interval
);
1062 warn("Reading from network");
1064 } else if (c
== 2) {
1065 warn("Writing `%s'", local
);
1070 if (is_retr
&& restart_point
) {
1074 if (fseeko(fout
, (off_t
)0, SEEK_SET
) < 0)
1076 for (i
= 0; i
++ < restart_point
;) {
1077 if ((ch
= getc(fout
)) == EOF
)
1082 if (fseeko(fout
, (off_t
)0, SEEK_CUR
) < 0) {
1084 warn("Can't seek to restart `%s'", local
);
1088 while ((c
= getc(din
)) != EOF
) {
1092 while (hash_interval
&& bytes
>= hashbytes
) {
1093 (void)putc('#', ttyout
);
1094 (void)fflush(ttyout
);
1098 if ((c
= getc(din
)) != '\n' || tcrflag
) {
1101 (void)putc('\r', fout
);
1110 (void)putc(c
, fout
);
1115 if (hash_interval
) {
1116 if (bytes
< hashbytes
)
1117 (void)putc('#', ttyout
);
1118 (void)putc('\n', ttyout
);
1122 warn("Reading from network");
1126 warn("Writing `%s'", local
);
1131 if (closefunc
!= NULL
) {
1140 "WARNING! %d bare linefeeds received in ASCII mode.\n",
1142 fputs("File may not have transferred correctly.\n", ttyout
);
1144 if (bytes
>= 0 && is_retr
) {
1147 if (preserve
&& (closefunc
== fclose
)) {
1148 mtime
= remotemodtime(remote
, 0);
1150 (void)gettimeofday(&tval
[0], NULL
);
1151 tval
[1].tv_sec
= mtime
;
1152 tval
[1].tv_usec
= 0;
1153 if (utimes(local
, tval
) == -1) {
1155 "Can't change modification time on %s to %s",
1157 rfc2822time(localtime(&mtime
)));
1166 * abort using RFC 959 recommended IP,SYNC sequence
1168 if (! sigsetjmp(xferabort
, 1)) {
1169 /* this is the first call */
1170 (void)xsignal(SIGINT
, abort_squared
);
1183 (void)xsignal(SIGINT
, oldintr
);
1185 (void)xsignal(SIGPIPE
, oldintp
);
1190 if (closefunc
!= NULL
&& fout
!= NULL
)
1194 progress
= oprogress
;
1195 preserve
= opreserve
;
1200 * Need to start a listen on the data channel before we send the command,
1201 * otherwise the server's connect may fail.
1207 int result
, tmpno
= 0;
1210 unsigned int addr
[16], port
[2];
1211 unsigned int af
, hal
, pal
;
1213 const char *pasvcmd
= NULL
;
1218 if (myctladdr
.su_family
== AF_INET6
&& ftp_debug
&&
1219 (IN6_IS_ADDR_LINKLOCAL(&myctladdr
.si_su
.su_sin6
.sin6_addr
) ||
1220 IN6_IS_ADDR_SITELOCAL(&myctladdr
.si_su
.su_sin6
.sin6_addr
))) {
1221 warnx("Use of scoped addresses can be troublesome");
1228 data_addr
= myctladdr
;
1229 data
= socket(data_addr
.su_family
, SOCK_STREAM
, 0);
1231 warn("Can't create socket for data connection");
1234 if ((options
& SO_DEBUG
) &&
1235 setsockopt(data
, SOL_SOCKET
, SO_DEBUG
,
1236 (void *)&on
, sizeof(on
)) == -1) {
1237 DWARN("setsockopt %s (ignored)", "SO_DEBUG");
1239 result
= COMPLETE
+ 1;
1240 switch (data_addr
.su_family
) {
1242 if (epsv4
&& !epsv4bad
) {
1247 result
= command("EPSV");
1250 (result
== COMPLETE
|| !connected
))
1251 fprintf(ttyout
, "%s\n", reply_string
);
1255 * this code is to be friendly with broken
1258 if (code
/ 10 == 22 && code
!= 229) {
1260 "wrong server: return code must be 229\n",
1262 result
= COMPLETE
+ 1;
1264 if (result
!= COMPLETE
) {
1266 DPRINTF("disabling epsv4 for this "
1270 if (result
!= COMPLETE
) {
1272 result
= command("PASV");
1279 if (epsv6
&& !epsv6bad
) {
1284 result
= command("EPSV");
1287 (result
== COMPLETE
|| !connected
))
1288 fprintf(ttyout
, "%s\n", reply_string
);
1292 * this code is to be friendly with
1295 if (code
/ 10 == 22 && code
!= 229) {
1297 "wrong server: return code must be 229\n",
1299 result
= COMPLETE
+ 1;
1301 if (result
!= COMPLETE
) {
1303 DPRINTF("disabling epsv6 for this "
1307 if (result
!= COMPLETE
) {
1309 result
= command("LPSV");
1316 result
= COMPLETE
+ 1;
1319 if (result
!= COMPLETE
) {
1320 if (activefallback
) {
1329 fputs("Passive mode refused.\n", ttyout
);
1333 #define pack2(var, off) \
1334 (((var[(off) + 0] & 0xff) << 8) | ((var[(off) + 1] & 0xff) << 0))
1335 #define pack4(var, off) \
1336 (((var[(off) + 0] & 0xff) << 24) | ((var[(off) + 1] & 0xff) << 16) | \
1337 ((var[(off) + 2] & 0xff) << 8) | ((var[(off) + 3] & 0xff) << 0))
1338 #define UC(b) (((int)b)&0xff)
1341 * What we've got at this point is a string of comma separated
1342 * one-byte unsigned integer values, separated by commas.
1344 if (strcmp(pasvcmd
, "PASV") == 0) {
1345 if (data_addr
.su_family
!= AF_INET
) {
1347 "Passive mode AF mismatch. Shouldn't happen!\n", ttyout
);
1351 if (code
/ 10 == 22 && code
!= 227) {
1352 fputs("wrong server: return code must be 227\n",
1357 error
= sscanf(pasv
, "%u,%u,%u,%u,%u,%u",
1358 &addr
[0], &addr
[1], &addr
[2], &addr
[3],
1359 &port
[0], &port
[1]);
1362 "Passive mode address scan failure. Shouldn't happen!\n", ttyout
);
1367 memset(&data_addr
, 0, sizeof(data_addr
));
1368 data_addr
.su_family
= AF_INET
;
1369 data_addr
.su_len
= sizeof(struct sockaddr_in
);
1370 data_addr
.si_su
.su_sin
.sin_addr
.s_addr
=
1371 htonl(pack4(addr
, 0));
1372 data_addr
.su_port
= htons(pack2(port
, 0));
1373 } else if (strcmp(pasvcmd
, "LPSV") == 0) {
1374 if (code
/ 10 == 22 && code
!= 228) {
1375 fputs("wrong server: return code must be 228\n",
1380 switch (data_addr
.su_family
) {
1382 error
= sscanf(pasv
,
1383 "%u,%u,%u,%u,%u,%u,%u,%u,%u",
1385 &addr
[0], &addr
[1], &addr
[2], &addr
[3],
1386 &pal
, &port
[0], &port
[1]);
1389 "Passive mode address scan failure. Shouldn't happen!\n", ttyout
);
1393 if (af
!= 4 || hal
!= 4 || pal
!= 2) {
1395 "Passive mode AF mismatch. Shouldn't happen!\n", ttyout
);
1401 memset(&data_addr
, 0, sizeof(data_addr
));
1402 data_addr
.su_family
= AF_INET
;
1403 data_addr
.su_len
= sizeof(struct sockaddr_in
);
1404 data_addr
.si_su
.su_sin
.sin_addr
.s_addr
=
1405 htonl(pack4(addr
, 0));
1406 data_addr
.su_port
= htons(pack2(port
, 0));
1410 error
= sscanf(pasv
,
1411 "%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u,%u",
1413 &addr
[0], &addr
[1], &addr
[2], &addr
[3],
1414 &addr
[4], &addr
[5], &addr
[6], &addr
[7],
1415 &addr
[8], &addr
[9], &addr
[10],
1416 &addr
[11], &addr
[12], &addr
[13],
1417 &addr
[14], &addr
[15],
1418 &pal
, &port
[0], &port
[1]);
1421 "Passive mode address scan failure. Shouldn't happen!\n", ttyout
);
1425 if (af
!= 6 || hal
!= 16 || pal
!= 2) {
1427 "Passive mode AF mismatch. Shouldn't happen!\n", ttyout
);
1433 memset(&data_addr
, 0, sizeof(data_addr
));
1434 data_addr
.su_family
= AF_INET6
;
1435 data_addr
.su_len
= sizeof(struct sockaddr_in6
);
1438 for (i
= 0; i
< sizeof(struct in6_addr
); i
++) {
1439 data_addr
.si_su
.su_sin6
.sin6_addr
.s6_addr
[i
] =
1443 data_addr
.su_port
= htons(pack2(port
, 0));
1449 } else if (strcmp(pasvcmd
, "EPSV") == 0) {
1453 if (code
/ 10 == 22 && code
!= 229) {
1454 fputs("wrong server: return code must be 229\n",
1459 if (sscanf(pasv
, "%c%c%c%d%c", &delim
[0],
1460 &delim
[1], &delim
[2], &port
[1],
1462 fputs("parse error!\n", ttyout
);
1466 if (delim
[0] != delim
[1] || delim
[0] != delim
[2]
1467 || delim
[0] != delim
[3]) {
1468 fputs("parse error!\n", ttyout
);
1472 data_addr
= hisctladdr
;
1473 data_addr
.su_port
= htons(port
[1]);
1477 if (ftp_connect(data
, (struct sockaddr
*)&data_addr
.si_su
,
1478 data_addr
.su_len
, 1) < 0) {
1479 if (activefallback
) {
1490 #ifdef IPTOS_THROUGHPUT
1491 if (data_addr
.su_family
== AF_INET
) {
1492 on
= IPTOS_THROUGHPUT
;
1493 if (setsockopt(data
, IPPROTO_IP
, IP_TOS
,
1494 (void *)&on
, sizeof(on
)) == -1) {
1495 DWARN("setsockopt %s (ignored)",
1496 "IPTOS_THROUGHPUT");
1504 data_addr
= myctladdr
;
1506 data_addr
.su_port
= 0; /* let system pick one */
1509 data
= socket(data_addr
.su_family
, SOCK_STREAM
, 0);
1511 warn("Can't create socket for data connection");
1517 if (setsockopt(data
, SOL_SOCKET
, SO_REUSEADDR
,
1518 (void *)&on
, sizeof(on
)) == -1) {
1519 warn("Can't set SO_REUSEADDR on data connection");
1522 if (bind(data
, (struct sockaddr
*)&data_addr
.si_su
,
1523 data_addr
.su_len
) < 0) {
1524 warn("Can't bind for data connection");
1527 if ((options
& SO_DEBUG
) &&
1528 setsockopt(data
, SOL_SOCKET
, SO_DEBUG
,
1529 (void *)&on
, sizeof(on
)) == -1) {
1530 DWARN("setsockopt %s (ignored)", "SO_DEBUG");
1532 len
= sizeof(data_addr
.si_su
);
1533 memset((char *)&data_addr
, 0, sizeof (data_addr
));
1534 if (getsockname(data
, (struct sockaddr
*)&data_addr
.si_su
, &len
) == -1) {
1535 warn("Can't determine my address of data connection");
1538 data_addr
.su_len
= len
;
1539 if (ftp_listen(data
, 1) < 0)
1540 warn("Can't listen to data connection");
1543 char hname
[NI_MAXHOST
], sname
[NI_MAXSERV
];
1544 struct sockinet tmp
;
1546 switch (data_addr
.su_family
) {
1548 if (!epsv4
|| epsv4bad
) {
1549 result
= COMPLETE
+ 1;
1555 if (!epsv6
|| epsv6bad
) {
1556 result
= COMPLETE
+ 1;
1560 af
= (data_addr
.su_family
== AF_INET
) ? 1 : 2;
1563 if (tmp
.su_family
== AF_INET6
)
1564 tmp
.si_su
.su_sin6
.sin6_scope_id
= 0;
1566 if (getnameinfo((struct sockaddr
*)&tmp
.si_su
,
1567 tmp
.su_len
, hname
, sizeof(hname
), sname
,
1568 sizeof(sname
), NI_NUMERICHOST
| NI_NUMERICSERV
)) {
1574 result
= command("EPRT |%u|%s|%s|", af
, hname
,
1578 (result
== COMPLETE
|| !connected
))
1579 fprintf(ttyout
, "%s\n", reply_string
);
1582 if (result
!= COMPLETE
) {
1584 DPRINTF("disabling epsv4 for this "
1590 result
= COMPLETE
+ 1;
1593 if (result
== COMPLETE
)
1596 switch (data_addr
.su_family
) {
1598 a
= (char *)&data_addr
.si_su
.su_sin
.sin_addr
;
1599 p
= (char *)&data_addr
.su_port
;
1600 result
= command("PORT %d,%d,%d,%d,%d,%d",
1601 UC(a
[0]), UC(a
[1]), UC(a
[2]), UC(a
[3]),
1602 UC(p
[0]), UC(p
[1]));
1606 uint8_t ua
[sizeof(data_addr
.si_su
.su_sin6
.sin6_addr
)];
1607 uint8_t up
[sizeof(data_addr
.su_port
)];
1609 memcpy(ua
, &data_addr
.si_su
.su_sin6
.sin6_addr
,
1611 memcpy(up
, &data_addr
.su_port
, sizeof(up
));
1614 "LPRT %d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d",
1616 ua
[0], ua
[1], ua
[2], ua
[3],
1617 ua
[4], ua
[5], ua
[6], ua
[7],
1618 ua
[8], ua
[9], ua
[10], ua
[11],
1619 ua
[12], ua
[13], ua
[14], ua
[15],
1626 result
= COMPLETE
+ 1; /* xxx */
1632 if (result
== ERROR
&& sendport
== -1) {
1637 return (result
!= COMPLETE
);
1641 #ifdef IPTOS_THROUGHPUT
1642 if (data_addr
.su_family
== AF_INET
) {
1643 on
= IPTOS_THROUGHPUT
;
1644 if (setsockopt(data
, IPPROTO_IP
, IP_TOS
,
1645 (void *)&on
, sizeof(on
)) == -1) {
1646 DWARN("setsockopt %s (ignored)", "IPTOS_THROUGHPUT");
1660 dataconn(const char *lmode
)
1662 struct sockinet from
;
1663 int s
, flags
, rv
, timeout
;
1664 struct timeval endtime
, now
, td
;
1665 struct pollfd pfd
[1];
1668 if (passivemode
) /* passive data connection */
1669 return (fdopen(data
, lmode
));
1671 /* active mode data connection */
1673 if ((flags
= fcntl(data
, F_GETFL
, 0)) == -1)
1674 goto dataconn_failed
; /* get current socket flags */
1675 if (fcntl(data
, F_SETFL
, flags
| O_NONBLOCK
) == -1)
1676 goto dataconn_failed
; /* set non-blocking connect */
1678 /* NOTE: we now must restore socket flags on successful exit */
1680 /* limit time waiting on listening socket */
1682 pfd
[0].events
= POLLIN
;
1683 (void)gettimeofday(&endtime
, NULL
); /* determine end time */
1684 endtime
.tv_sec
+= (quit_time
> 0) ? quit_time
: 60;
1685 /* without -q, default to 60s */
1687 (void)gettimeofday(&now
, NULL
);
1688 timersub(&endtime
, &now
, &td
);
1689 timeout
= td
.tv_sec
* 1000 + td
.tv_usec
/1000;
1692 rv
= ftp_poll(pfd
, 1, timeout
);
1693 } while (rv
== -1 && errno
== EINTR
); /* loop until poll ! EINTR */
1695 warn("Can't poll waiting before accept");
1696 goto dataconn_failed
;
1699 warnx("Poll timeout waiting before accept");
1700 goto dataconn_failed
;
1703 /* (non-blocking) accept the connection */
1704 fromlen
= myctladdr
.su_len
;
1706 s
= accept(data
, (struct sockaddr
*) &from
.si_su
, &fromlen
);
1707 } while (s
== -1 && errno
== EINTR
); /* loop until accept ! EINTR */
1709 warn("Can't accept data connection");
1710 goto dataconn_failed
;
1715 if (fcntl(data
, F_SETFL
, flags
) == -1) /* restore socket flags */
1716 goto dataconn_failed
;
1718 #ifdef IPTOS_THROUGHPUT
1719 if (from
.su_family
== AF_INET
) {
1720 int tos
= IPTOS_THROUGHPUT
;
1721 if (setsockopt(s
, IPPROTO_IP
, IP_TOS
,
1722 (void *)&tos
, sizeof(tos
)) == -1) {
1723 DWARN("setsockopt %s (ignored)", "IPTOS_THROUGHPUT");
1727 return (fdopen(data
, lmode
));
1736 psabort(int notused
)
1750 static struct comvars
{
1752 char name
[MAXHOSTNAMELEN
];
1753 struct sockinet mctl
;
1754 struct sockinet hctl
;
1767 char mi
[MAXPATHLEN
];
1768 char mo
[MAXPATHLEN
];
1769 } proxstruct
, tmpstruct
;
1770 struct comvars
*ip
, *op
;
1773 oldintr
= xsignal(SIGINT
, psabort
);
1787 ip
->connect
= connected
;
1788 connected
= op
->connect
;
1790 (void)strlcpy(ip
->name
, hostname
, sizeof(ip
->name
));
1793 hostname
= op
->name
;
1794 ip
->hctl
= hisctladdr
;
1795 hisctladdr
= op
->hctl
;
1796 ip
->mctl
= myctladdr
;
1797 myctladdr
= op
->mctl
;
1804 ip
->curtpe
= curtype
;
1805 curtype
= op
->curtpe
;
1808 ip
->sunqe
= sunique
;
1809 sunique
= op
->sunqe
;
1810 ip
->runqe
= runique
;
1811 runique
= op
->runqe
;
1816 (void)strlcpy(ip
->nti
, ntin
, sizeof(ip
->nti
));
1817 (void)strlcpy(ntin
, op
->nti
, sizeof(ntin
));
1818 (void)strlcpy(ip
->nto
, ntout
, sizeof(ip
->nto
));
1819 (void)strlcpy(ntout
, op
->nto
, sizeof(ntout
));
1820 ip
->mapflg
= mapflag
;
1821 mapflag
= op
->mapflg
;
1822 (void)strlcpy(ip
->mi
, mapin
, sizeof(ip
->mi
));
1823 (void)strlcpy(mapin
, op
->mi
, sizeof(mapin
));
1824 (void)strlcpy(ip
->mo
, mapout
, sizeof(ip
->mo
));
1825 (void)strlcpy(mapout
, op
->mo
, sizeof(mapout
));
1826 (void)xsignal(SIGINT
, oldintr
);
1834 abortpt(int notused
)
1840 write(fileno(ttyout
), "\n", 1);
1844 siglongjmp(ptabort
, 1);
1848 proxtrans(const char *cmd
, const char *local
, const char *remote
)
1850 sigfunc
volatile oldintr
;
1851 int prox_type
, nfnd
;
1852 int volatile secndflag
;
1853 const char *volatile cmd2
;
1857 if (strcmp(cmd
, "RETR"))
1860 cmd2
= runique
? "STOU" : "STOR";
1861 if ((prox_type
= type
) == 0) {
1862 if (unix_server
&& unix_proxy
)
1867 if (curtype
!= prox_type
)
1868 changetype(prox_type
, 1);
1869 if (command("PASV") != COMPLETE
) {
1870 fputs("proxy server does not support third party transfers.\n",
1876 fputs("No primary connection.\n", ttyout
);
1881 if (curtype
!= prox_type
)
1882 changetype(prox_type
, 1);
1883 if (command("PORT %s", pasv
) != COMPLETE
) {
1887 if (sigsetjmp(ptabort
, 1))
1889 oldintr
= xsignal(SIGINT
, abortpt
);
1890 if ((restart_point
&&
1891 (command("REST " LLF
, (LLT
) restart_point
) != CONTINUE
))
1892 || (command("%s %s", cmd
, remote
) != PRELIM
)) {
1893 (void)xsignal(SIGINT
, oldintr
);
1900 if ((restart_point
&&
1901 (command("REST " LLF
, (LLT
) restart_point
) != CONTINUE
))
1902 || (command("%s %s", cmd2
, local
) != PRELIM
))
1908 (void)xsignal(SIGINT
, oldintr
);
1911 fprintf(ttyout
, "local: %s remote: %s\n", local
, remote
);
1914 if (sigsetjmp(xferabort
, 1)) {
1915 (void)xsignal(SIGINT
, oldintr
);
1918 (void)xsignal(SIGINT
, abort_squared
);
1920 if (strcmp(cmd
, "RETR") && !proxy
)
1922 else if (!strcmp(cmd
, "RETR") && proxy
)
1924 if (!cpend
&& !secndflag
) { /* only here if cmd = "STOR" (proxy=1) */
1925 if (command("%s %s", cmd2
, local
) != PRELIM
) {
1933 (void)xsignal(SIGINT
, oldintr
);
1939 if (!cpend
&& !secndflag
) { /* only if cmd = "RETR" (proxy=1) */
1940 if (command("%s %s", cmd2
, local
) != PRELIM
) {
1947 (void)xsignal(SIGINT
, oldintr
);
1955 if ((nfnd
= empty(cin
, NULL
, 10)) <= 0) {
1957 warn("Error aborting proxy command");
1970 (void)xsignal(SIGINT
, oldintr
);
1974 reset(int argc
, char *argv
[])
1978 if (argc
== 0 && argv
!= NULL
) {
1979 UPRINTF("usage: %s\n", argv
[0]);
1984 if ((nfnd
= empty(cin
, NULL
, 0)) < 0) {
1985 warn("Error resetting connection");
1994 gunique(const char *local
)
1996 static char new[MAXPATHLEN
];
1997 char *cp
= strrchr(local
, '/');
1998 int d
, count
=0, len
;
2003 d
= access(cp
== local
? "/" : cp
? local
: ".", W_OK
);
2007 warn("Can't access `%s'", local
);
2010 len
= strlcpy(new, local
, sizeof(new));
2014 if (++count
== 100) {
2015 fputs("runique: can't find unique file name.\n",
2025 if ((d
= access(new, F_OK
)) < 0)
2029 else if (*(cp
- 2) == '.')
2032 *(cp
- 2) = *(cp
- 2) + 1;
2041 * aborts abort_remote(). lostpeer() is called because if the user is
2042 * too impatient to wait or there's another problem then ftp really
2043 * needs to get back to a known state.
2046 abort_squared(int dummy
)
2053 len
= strlcpy(msgbuf
, "\nremote abort aborted; closing connection.\n",
2055 write(fileno(ttyout
), msgbuf
, len
);
2057 siglongjmp(xferabort
, 1);
2061 abort_remote(FILE *din
)
2067 warnx("Lost control connection for abort");
2074 * send IAC in urgent mode instead of DM because 4.3BSD places oob mark
2075 * after urgent byte rather than before as is protocol now
2080 if (send(fileno(cout
), buf
, 3, MSG_OOB
) != 3)
2081 warn("Can't send abort message");
2082 fprintf(cout
, "%cABOR\r\n", DM
);
2084 if ((nfnd
= empty(cin
, din
, 10)) <= 0) {
2086 warn("Can't send abort message");
2091 if (din
&& (nfnd
& 2)) {
2092 while (read(fileno(din
), buf
, BUFSIZ
) > 0)
2095 if (getreply(0) == ERROR
&& code
== 552) {
2096 /* 552 needed for nic style abort */
2103 * Ensure that ai->ai_addr is NOT an IPv4 mapped address.
2104 * IPv4 mapped address complicates too many things in FTP
2105 * protocol handling, as FTP protocol is defined differently
2106 * between IPv4 and IPv6.
2108 * This may not be the best way to handle this situation,
2109 * since the semantics of IPv4 mapped address is defined in
2110 * the kernel. There are configurations where we should use
2111 * IPv4 mapped address as native IPv6 address, not as
2112 * "an IPv6 address that embeds IPv4 address" (namely, SIIT).
2114 * More complete solution would be to have an additional
2115 * getsockopt to grab "real" peername/sockname. "real"
2116 * peername/sockname will be AF_INET if IPv4 mapped address
2117 * is used to embed IPv4 address, and will be AF_INET6 if
2118 * we use it as native. What a mess!
2121 ai_unmapped(struct addrinfo
*ai
)
2124 struct sockaddr_in6
*sin6
;
2125 struct sockaddr_in sin
;
2128 if (ai
->ai_family
!= AF_INET6
)
2130 if (ai
->ai_addrlen
!= sizeof(struct sockaddr_in6
) ||
2131 sizeof(sin
) > ai
->ai_addrlen
)
2133 sin6
= (struct sockaddr_in6
*)ai
->ai_addr
;
2134 if (!IN6_IS_ADDR_V4MAPPED(&sin6
->sin6_addr
))
2137 memset(&sin
, 0, sizeof(sin
));
2138 sin
.sin_family
= AF_INET
;
2139 len
= sizeof(struct sockaddr_in
);
2140 memcpy(&sin
.sin_addr
, &sin6
->sin6_addr
.s6_addr
[12],
2141 sizeof(sin
.sin_addr
));
2142 sin
.sin_port
= sin6
->sin6_port
;
2144 ai
->ai_family
= AF_INET
;
2145 #if defined(HAVE_STRUCT_SOCKADDR_IN_SIN_LEN)
2148 memcpy(ai
->ai_addr
, &sin
, len
);
2149 ai
->ai_addrlen
= len
;
2157 fputs("Usage error\n", ttyout
);