projects / unix-history / blob
? search:
summary | tags | clone url | shortlog | log | commit | commitdiff | tree
blame | history | raw | HEAD
problem with a.b.c.d specification
[unix-history] / usr / src / usr.bin / ftp / ftp.c
#ifndef lint
static char sccsid[] = "@(#)ftp.c 4.4 (Berkeley) %G%";
#endif
#include <sys/param.h>
#include <sys/stat.h>
#include <sys/ioctl.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <stdio.h>
#include <signal.h>
#include <time.h>
#include <errno.h>
#include <netdb.h>
#include "ftp.h"
#include "ftp_var.h"
struct sockaddr_in hisctladdr;
struct sockaddr_in data_addr;
int data = -1;
int connected;
struct sockaddr_in myctladdr;
FILE *cin, *cout;
FILE *dataconn();
struct hostent *
hookup(host, port)
char *host;
int port;
{
register struct hostent *hp;
int s;
bzero((char *)&hisctladdr, sizeof (hisctladdr));
hp = gethostbyname(host);
if (hp == NULL) {
static struct hostent def;
static struct in_addr defaddr;
static char namebuf[128];
int inet_addr();
defaddr.s_addr = inet_addr(host);
if (defaddr.s_addr == -1) {
fprintf(stderr, "%s: Unknown host.\n", host);
return (0);
}
strcpy(namebuf, host);
def.h_name = namebuf;
hostname = namebuf;
def.h_addr = (char *)&defaddr;
def.h_length = sizeof (struct in_addr);
def.h_addrtype = AF_INET;
def.h_aliases = 0;
hp = &def;
}
hostname = hp->h_name;
hisctladdr.sin_family = hp->h_addrtype;
s = socket(hp->h_addrtype, SOCK_STREAM, 0, 0);
if (s < 0) {
perror("ftp: socket");
return (0);
}
if (bind(s, (char *)&hisctladdr, sizeof (hisctladdr), 0) < 0) {
perror("ftp: bind");
goto bad;
}
bcopy(hp->h_addr, (char *)&hisctladdr.sin_addr, hp->h_length);
hisctladdr.sin_port = port;
if (connect(s, (char *)&hisctladdr, sizeof (hisctladdr), 0) < 0) {
perror("ftp: connect");
goto bad;
}
if (socketaddr(s, &myctladdr) < 0) {
perror("ftp: socketaddr");
goto bad;
}
cin = fdopen(s, "r");
cout = fdopen(s, "w");
if (cin == NULL || cout == NULL) {
fprintf(stderr, "ftp: fdopen failed.\n");
if (cin)
fclose(cin);
if (cout)
fclose(cout);
goto bad;
}
if (verbose)
printf("Connected to %s.\n", hp->h_name);
(void) getreply(0); /* read startup message from server */
return (hp);
bad:
close(s);
return ((struct hostent *)0);
}
login(hp)
struct hostent *hp;
{
char acct[80];
char *user, *pass;
int n;
user = pass = 0;
ruserpass(hp->h_name, &user, &pass);
n = command("USER %s", user);
if (n == CONTINUE)
n = command("PASS %s", pass);
if (n == CONTINUE) {
printf("Account: "); (void) fflush(stdout);
(void) fgets(acct, sizeof(acct) - 1, stdin);
acct[strlen(acct) - 1] = '\0';
n = command("ACCT %s", acct);
}
if (n != COMPLETE) {
fprintf(stderr, "Login failed.\n");
return (0);
}
return (1);
}
/*VARARGS 1*/
command(fmt, args)
char *fmt;
{
if (debug) {
printf("---> ");
_doprnt(fmt, &args, stdout);
printf("\n");
(void) fflush(stdout);
}
if (cout == NULL) {
perror ("No control connection for command");
return (0);
}
_doprnt(fmt, &args, cout);
fprintf(cout, "\r\n");
(void) fflush(cout);
return (getreply(!strcmp(fmt, "QUIT")));
}
#include <ctype.h>
getreply(expecteof)
int expecteof;
{
register int c, n;
register int code, dig;
int originalcode = 0, continuation = 0;
for (;;) {
dig = n = code = 0;
while ((c = getc(cin)) != '\n') {
dig++;
if (c == EOF) {
if (expecteof)
return (0);
lostpeer();
exit(1);
}
if (verbose && c != '\r' ||
(n == '5' && dig > 4))
putchar(c);
if (dig < 4 && isdigit(c))
code = code * 10 + (c - '0');
if (dig == 4 && c == '-')
continuation++;
if (n == 0)
n = c;
}
if (verbose || n == '5')
putchar(c);
if (continuation && code != originalcode) {
if (originalcode == 0)
originalcode = code;
continue;
}
if (expecteof || empty(cin))
return (n - '0');
}
}
empty(f)
FILE *f;
{
int mask;
struct timeval t;
if (f->_cnt > 0)
return (0);
mask = (1 << fileno(f));
t.tv_sec = t.tv_usec = 0;
(void) select(20, &mask, 0, 0, &t);
return (mask == 0);
}
jmp_buf sendabort;
abortsend()
{
longjmp(sendabort, 1);
}
sendrequest(cmd, local, remote)
char *cmd, *local, *remote;
{
FILE *fin, *dout, *popen();
int (*closefunc)(), pclose(), fclose(), (*oldintr)();
char buf[BUFSIZ];
register int bytes = 0, c;
struct stat st;
struct timeval start, stop;
extern int errno;
closefunc = NULL;
if (setjmp(sendabort))
goto bad;
oldintr = signal(SIGINT, abortsend);
if (strcmp(local, "-") == 0)
fin = stdin;
else if (*local == '|') {
fin = popen(local + 1, "r");
if (fin == NULL) {
perror(local + 1);
goto bad;
}
closefunc = pclose;
} else {
fin = fopen(local, "r");
if (fin == NULL) {
perror(local);
goto bad;
}
closefunc = fclose;
if (fstat(fileno(fin), &st) < 0 ||
(st.st_mode&S_IFMT) != S_IFREG) {
fprintf(stderr, "%s: not a plain file.", local);
goto bad;
}
}
if (initconn())
goto bad;
if (remote) {
if (command("%s %s", cmd, remote) != PRELIM)
goto bad;
} else
if (command("%s", cmd) != PRELIM)
goto bad;
dout = dataconn("w");
if (dout == NULL)
goto bad;
gettimeofday(&start, (struct timezone *)0);
switch (type) {
case TYPE_I:
case TYPE_L:
errno = 0;
while ((c = read(fileno (fin), buf, sizeof (buf))) > 0) {
if (write(fileno (dout), buf, c) < 0)
break;
bytes += c;
}
if (c < 0)
perror(local);
else if (errno)
perror("netout");
break;
case TYPE_A:
while ((c = getc(fin)) != EOF) {
if (c == '\n') {
if (ferror(dout))
break;
putc('\r', dout);
bytes++;
}
putc(c, dout);
bytes++;
if (c == '\r') {
putc('\0', dout);
bytes++;
}
}
if (ferror(fin))
perror(local);
else if (ferror(dout))
perror("netout");
break;
}
gettimeofday(&stop, (struct timezone *)0);
if (closefunc != NULL)
(*closefunc)(fin);
(void) fclose(dout);
(void) getreply(0);
done:
signal(SIGINT, oldintr);
if (bytes > 0 && verbose)
ptransfer("sent", bytes, &start, &stop);
return;
bad:
if (data >= 0)
(void) close(data), data = -1;
if (closefunc != NULL && fin != NULL)
(*closefunc)(fin);
goto done;
}
jmp_buf recvabort;
abortrecv()
{
longjmp(recvabort, 1);
}
recvrequest(cmd, local, remote)
char *cmd, *local, *remote;
{
FILE *fout, *din, *popen();
char buf[BUFSIZ];
int (*closefunc)(), pclose(), fclose(), (*oldintr)(), c;
register int bytes = 0;
struct timeval start, stop;
extern int errno;
closefunc = NULL;
if (setjmp(recvabort))
goto bad;
oldintr = signal(SIGINT, abortrecv);
if (strcmp(local, "-") && *local != '|')
if (access(local, 2) < 0) {
char *dir = rindex(local, '/');
if (dir != NULL)
*dir = 0;
if (access(dir ? dir : ".", 2) < 0) {
perror(local);
goto bad;
}
if (dir != NULL)
*dir = '/';
}
if (initconn())
goto bad;
if (remote) {
if (command("%s %s", cmd, remote) != PRELIM)
goto bad;
} else
if (command("%s", cmd) != PRELIM)
goto bad;
if (strcmp(local, "-") == 0)
fout = stdout;
else if (*local == '|') {
fout = popen(local + 1, "w");
closefunc = pclose;
} else {
fout = fopen(local, "w");
closefunc = fclose;
}
if (fout == NULL) {
perror(local + 1);
goto bad;
}
din = dataconn("r");
if (din == NULL)
goto bad;
gettimeofday(&start, (struct timezone *)0);
switch (type) {
case TYPE_I:
case TYPE_L:
errno = 0;
while ((c = read(fileno(din), buf, sizeof (buf))) > 0) {
if (write(fileno(fout), buf, c) < 0)
break;
bytes += c;
}
if (c < 0)
perror("netin");
if (errno)
perror(local);
break;
case TYPE_A:
while ((c = getc(din)) != EOF) {
if (c == '\r') {
bytes++;
if ((c = getc(din)) != '\n') {
if (ferror (fout))
break;
putc ('\r', fout);
}
if (c == '\0') {
bytes++;
continue;
}
}
putc (c, fout);
bytes++;
}
if (ferror (din))
perror ("netin");
if (ferror (fout))
perror (local);
break;
}
gettimeofday(&stop, (struct timezone *)0);
(void) fclose(din);
if (closefunc != NULL)
(*closefunc)(fout);
(void) getreply(0);
done:
signal(SIGINT, oldintr);
if (bytes > 0 && verbose)
ptransfer("received", bytes, &start, &stop);
return;
bad:
if (data >= 0)
(void) close(data), data = -1;
if (closefunc != NULL && fout != NULL)
(*closefunc)(fout);
goto done;
}
/*
* Need to start a listen on the data channel
* before we send the command, otherwise the
* server's connect may fail.
*/
initconn()
{
register char *p, *a;
int result;
data_addr = myctladdr;
data_addr.sin_port = 0; /* let system pick one */
data = socket(AF_INET, SOCK_STREAM, 0, 0);
if (data < 0) {
perror("ftp: socket");
return (1);
}
if (bind(data, (char *)&data_addr, sizeof (data_addr), 0) < 0) {
perror("ftp: bind");
goto bad;
}
if (options & SO_DEBUG &&
setsockopt(data, SOL_SOCKET, SO_DEBUG, 0, 0) < 0)
perror("ftp: setsockopt (ignored)");
if (socketaddr(data, &data_addr) < 0) {
perror("ftp: socketaddr");
goto bad;
}
if (listen(data, 1) < 0) {
perror("ftp: listen");
goto bad;
}
a = (char *)&data_addr.sin_addr;
p = (char *)&data_addr.sin_port;
#define UC(b) (((int)b)&0xff)
result =
command("PORT %d,%d,%d,%d,%d,%d",
UC(a[0]), UC(a[1]), UC(a[2]), UC(a[3]),
UC(p[0]), UC(p[1]));
return (result != COMPLETE);
bad:
(void) close(data), data = -1;
return (1);
}
FILE *
dataconn(mode)
char *mode;
{
struct sockaddr_in from;
int s, fromlen = sizeof (from);
s = accept(data, &from, &fromlen, 0);
if (s < 0) {
perror("ftp: accept");
(void) close(data), data = -1;
return (NULL);
}
(void) close(data);
data = s;
return (fdopen(data, mode));
}
ptransfer(direction, bytes, t0, t1)
char *direction;
int bytes;
struct timeval *t0, *t1;
{
struct timeval td;
int ms, bs;
tvsub(&td, t1, t0);
ms = (td.tv_sec * 1000) + (td.tv_usec / 1000);
#define nz(x) ((x) == 0 ? 1 : (x))
bs = ((bytes * NBBY * 1000) / nz(ms)) / NBBY;
printf("%d bytes %s in %d.%02d seconds (%d.%01d Kbytes/s)\n",
bytes, direction, td.tv_sec, td.tv_usec / 10000,
bs / 1024, (((bs % 1024) * 10) + 1023) / 1024);
}
tvadd(tsum, t0)
struct timeval *tsum, *t0;
{
tsum->tv_sec += t0->tv_sec;
tsum->tv_usec += t0->tv_usec;
if (tsum->tv_usec > 1000000)
tsum->tv_sec++, tsum->tv_usec -= 1000000;
}
tvsub(tdiff, t1, t0)
struct timeval *tdiff, *t1, *t0;
{
tdiff->tv_sec = t1->tv_sec - t0->tv_sec;
tdiff->tv_usec = t1->tv_usec - t0->tv_usec;
if (tdiff->tv_usec < 0)
tdiff->tv_sec--, tdiff->tv_usec += 1000000;
}
Continuous source code history from original PDP-7 UNIX to FreeBSD 2, the first fully unencumbered FreeBSD release.