/*
- * $Id: ftp.cc,v 1.224 1998/05/11 18:44:37 rousskov Exp $
+ * $Id: ftp.cc,v 1.225 1998/05/21 07:05:38 wessels Exp $
*
* DEBUG: section 9 File Transfer Protocol (FTP)
* AUTHOR: Harvest Derived
#include "squid.h"
-enum {
- FTP_ISDIR,
- FTP_PASV_SUPPORTED,
- FTP_SKIP_WHITESPACE,
- FTP_REST_SUPPORTED,
- FTP_PASV_ONLY,
- FTP_AUTHENTICATED,
- FTP_HTTP_HEADER_SENT,
- FTP_TRIED_NLST,
- FTP_USE_BASE,
- FTP_ROOT_DIR,
- FTP_NO_DOTDOT,
- FTP_HTML_HEADER_SENT,
- FTP_BINARY,
- FTP_TRY_SLASH_HACK,
- FTP_PUT,
- FTP_PUT_MKDIR,
- FTP_LISTFORMAT_UNKNOWN,
- FTP_DATACHANNEL_HACK
-};
-
static const char *const crlf = "\r\n";
static char cbuf[1024];
SENT_MKDIR
} ftp_state_t;
+struct _ftp_flags {
+ int isdir:1;
+ int pasv_supported:1;
+ int skip_whitespace:1;
+ int rest_supported:1;
+ int pasv_only:1;
+ int authenticated:1;
+ int http_header_sent:1;
+ int tried_nlst:1;
+ int use_base:1;
+ int root_dir:1;
+ int no_dotdot:1;
+ int html_header_sent:1;
+ int binary:1;
+ int try_slash_hack:1;
+ int put:1;
+ int put_mkdir:1;
+ int listformat_unknown:1;
+ int datachannel_hack:1;
+};
+
typedef struct _Ftpdata {
StoreEntry *entry;
request_t *request;
ftp_state_t state;
time_t mdtm;
int size;
- int flags;
wordlist *pathcomps;
char *filepath;
int restart_offset;
char *host;
u_short port;
} data;
+ struct _ftp_flags flags;
} FtpStateData;
typedef struct {
storeAppendPrintf(e, "FTP Directory: %s\n",
ftpState->title_url);
storeAppendPrintf(e, "</TITLE>\n");
- if (EBIT_TEST(ftpState->flags, FTP_USE_BASE))
+ if (ftpState->flags.use_base)
storeAppendPrintf(e, "<BASE HREF=\"%s\">\n",
ftpState->title_url);
storeAppendPrintf(e, "</HEAD><BODY>\n");
storeAppendPrintf(e, "</H2>\n");
storeAppendPrintf(e, "<PRE>\n");
storeBufferFlush(e);
- EBIT_SET(ftpState->flags, FTP_HTML_HEADER_SENT);
+ ftpState->flags.html_header_sent = 1;
}
static void
StoreEntry *e = ftpState->entry;
storeBuffer(e);
storeAppendPrintf(e, "</PRE>\n");
- if (EBIT_TEST(ftpState->flags, FTP_LISTFORMAT_UNKNOWN) && !EBIT_TEST(ftpState->flags, FTP_TRIED_NLST)) {
+ if (ftpState->flags.listformat_unknown && !ftpState->flags.tried_nlst) {
storeAppendPrintf(e, "<A HREF=\"./;type=d\">[As plain directory]</A>\n");
} else if (ftpState->typecode == 'D') {
storeAppendPrintf(e, "<A HREF=\"./\">[As extended directory]</A>\n");
#define SCAN_FTP4 "%[0123456789]:%[0123456789]%[AaPp]%[Mm]"
static ftpListParts *
-ftpListParseParts(const char *buf, int flags)
+ftpListParseParts(const char *buf, struct _ftp_flags flags)
{
ftpListParts *p = NULL;
char *t = NULL;
for (i = 0; i < MAX_TOKENS; i++)
tokens[i] = (char *) NULL;
xbuf = xstrdup(buf);
- if (EBIT_TEST(flags, FTP_TRIED_NLST)) {
+ if (flags.tried_nlst) {
/* Machine readable format, one name per line */
p->name = xbuf;
p->type = '\0';
tokens[i], tokens[i + 1], tokens[i + 2]);
if ((t = strstr(buf, sbuf))) {
p->date = xstrdup(sbuf);
- if (EBIT_TEST(flags, FTP_SKIP_WHITESPACE)) {
+ if (flags.skip_whitespace) {
t += strlen(sbuf);
while (strchr(w_space, *t))
t++;
LOCAL_ARRAY(char, html, 8192);
size_t width = Config.Ftp.list_width;
ftpListParts *parts;
- int flags = ftpState->flags;
if ((int) strlen(line) > 1024) {
snprintf(html, 8192, "%s\n", line);
return html;
}
- if ((parts = ftpListParseParts(line, flags)) == NULL) {
+ if ((parts = ftpListParseParts(line, ftpState->flags)) == NULL) {
char *p;
snprintf(html, 8192, "%s\n", line);
for (p = line; *p && isspace(*p); p++);
if (*p && !isspace(*p))
- EBIT_SET(ftpState->flags, FTP_LISTFORMAT_UNKNOWN);
+ ftpState->flags.listformat_unknown = 1;
return html;
}
/* check .. as special case */
snprintf(icon, 2048, "<IMG BORDER=0 SRC=\"%s\" ALT=\"%-6s\">",
mimeGetIconURL("internal-dirup"),
"[DIRUP]");
- if (!EBIT_TEST(flags, FTP_NO_DOTDOT) && !EBIT_TEST(flags, FTP_ROOT_DIR)) {
+ if (!ftpState->flags.no_dotdot && !ftpState->flags.root_dir) {
/* Normal directory */
snprintf(link, 2048, "<A HREF=\"%s\">%s</A>",
"../",
"Parent Directory");
- } else if (!EBIT_TEST(flags, FTP_NO_DOTDOT) && EBIT_TEST(flags, FTP_ROOT_DIR)) {
+ } else if (!ftpState->flags.no_dotdot && ftpState->flags.root_dir) {
/* "Top level" directory */
snprintf(link, 2048, "<A HREF=\"%s\">%s</A> (<A HREF=\"%s\">%s</A>)",
"%2e%2e/",
"Parent Directory",
"%2f/",
"Root Directory");
- } else if (EBIT_TEST(flags, FTP_NO_DOTDOT) && !EBIT_TEST(flags, FTP_ROOT_DIR)) {
+ } else if (ftpState->flags.no_dotdot && !ftpState->flags.root_dir) {
/* Normal directory where last component is / or .. */
snprintf(link, 2048, "<A HREF=\"%s\">%s</A> (<A HREF=\"%s\">%s</A>)",
"%2e%2e/",
{
debug(9, 3) ("ftpReadComplete\n");
/* Connection closed; retrieval done. */
- if (EBIT_TEST(ftpState->flags, FTP_HTML_HEADER_SENT))
+ if (ftpState->flags.html_header_sent)
ftpListingFinish(ftpState);
- if (!EBIT_TEST(ftpState->flags, FTP_PUT)) {
+ if (!ftpState->flags.put) {
storeTimestampsSet(ftpState->entry);
storeComplete(ftpState->entry);
}
} else if (len == 0) {
ftpReadComplete(ftpState);
} else {
- if (EBIT_TEST(ftpState->flags, FTP_ISDIR)) {
- if (!EBIT_TEST(ftpState->flags, FTP_HTML_HEADER_SENT))
+ if (ftpState->flags.isdir) {
+ if (!ftpState->flags.html_header_sent)
ftpListingStart(ftpState);
ftpParseListing(ftpState, len);
} else {
}
}
l = strLen(request->urlpath);
- EBIT_SET(ftpState->flags, FTP_USE_BASE);
+ ftpState->flags.use_base = 1;
/* check for null path */
if (!l) {
stringReset(&request->urlpath, "/");
- EBIT_SET(ftpState->flags, FTP_ISDIR);
- EBIT_SET(ftpState->flags, FTP_ROOT_DIR);
+ ftpState->flags.isdir = 1;
+ ftpState->flags.root_dir = 1;
} else if (!strCmp(request->urlpath, "/%2f/")) {
- EBIT_SET(ftpState->flags, FTP_ISDIR);
- EBIT_SET(ftpState->flags, FTP_ROOT_DIR);
+ ftpState->flags.isdir = 1;
+ ftpState->flags.root_dir = 1;
} else if ((l >= 1) && (*(strBuf(request->urlpath) + l - 1) == '/')) {
- EBIT_SET(ftpState->flags, FTP_ISDIR);
- EBIT_CLR(ftpState->flags, FTP_USE_BASE);
+ ftpState->flags.isdir = 1;
+ ftpState->flags.use_base = 0;
if (l == 1)
- EBIT_SET(ftpState->flags, FTP_ROOT_DIR);
+ ftpState->flags.root_dir = 1;
}
}
ftpState->ctrl.fd = -1;
ftpState->data.fd = -1;
ftpState->size = -1;
- EBIT_SET(ftpState->flags, FTP_PASV_SUPPORTED);
- EBIT_SET(ftpState->flags, FTP_REST_SUPPORTED);
+ ftpState->flags.pasv_supported = 1;
+ ftpState->flags.rest_supported = 1;
if (ftpState->request->method == METHOD_PUT)
- EBIT_SET(ftpState->flags, FTP_PUT);
+ ftpState->flags.put = 1;
if (!ftpCheckAuth(ftpState, &request->header)) {
/* This request is not fully authenticated */
if (request->port == 21) {
{
int code = ftpState->ctrl.replycode;
debug(9, 3) ("ftpReadWelcome\n");
- if (EBIT_TEST(ftpState->flags, FTP_PASV_ONLY))
+ if (ftpState->flags.pasv_only)
ftpState->login_att++;
if (code == 220) {
if (ftpState->ctrl.message)
if (strstr(ftpState->ctrl.message->key, "NetWare"))
- EBIT_SET(ftpState->flags, FTP_SKIP_WHITESPACE);
+ ftpState->flags.skip_whitespace = 1;
ftpSendUser(ftpState);
} else if (code == 120) {
if (NULL != ftpState->ctrl.message)
case 'I':
break;
default:
- if (EBIT_TEST(ftpState->flags, FTP_ISDIR)) {
+ if (ftpState->flags.isdir) {
mode = 'A';
} else {
t = strRChr(ftpState->request->urlpath, '/');
break;
}
if (mode == 'I')
- EBIT_SET(ftpState->flags, FTP_BINARY);
+ ftpState->flags.binary = 1;
snprintf(cbuf, 1024, "TYPE %c\r\n", mode);
ftpWriteCommand(cbuf, ftpState);
ftpState->state = SENT_TYPE;
ftpState->pathcomps = w->next;
xfree(w);
/* Check if we are to CWD or RETR */
- if (ftpState->pathcomps != NULL || EBIT_TEST(ftpState->flags, FTP_ISDIR)) {
+ if (ftpState->pathcomps != NULL || ftpState->flags.isdir) {
ftpSendCwd(ftpState);
} else {
debug(9, 3) ("final component is probably a file\n");
char *path = ftpState->filepath;
debug(9, 3) ("ftpSendCwd\n");
if (!strcmp(path, "..") || !strcmp(path, "/")) {
- EBIT_SET(ftpState->flags, FTP_NO_DOTDOT);
+ ftpState->flags.no_dotdot = 1;
} else {
- EBIT_CLR(ftpState->flags, FTP_NO_DOTDOT);
+ ftpState->flags.no_dotdot = 0;
}
snprintf(cbuf, 1024, "CWD %s\r\n", path);
ftpWriteCommand(cbuf, ftpState);
ftpTraverseDirectory(ftpState);
} else {
/* CWD FAILED */
- if (!EBIT_TEST(ftpState->flags, FTP_PUT))
+ if (!ftpState->flags.put)
ftpFail(ftpState);
else
ftpTryMkdir(ftpState);
if (code == 257) { /* success */
ftpSendCwd(ftpState);
} else if (code == 550) { /* dir exists */
- if (EBIT_TEST(ftpState->flags, FTP_PUT_MKDIR)) {
- EBIT_SET(ftpState->flags, FTP_PUT_MKDIR);
+ if (ftpState->flags.put_mkdir) {
+ ftpState->flags.put_mkdir = 1;
ftpSendCwd(ftpState);
} else
ftpSendReply(ftpState);
ftpGetFile(FtpStateData * ftpState)
{
assert(*ftpState->filepath != '\0');
- EBIT_CLR(ftpState->flags, FTP_ISDIR);
+ ftpState->flags.isdir = 0;
ftpSendMdtm(ftpState);
}
static void
ftpListDir(FtpStateData * ftpState)
{
- if (!EBIT_TEST(ftpState->flags, FTP_ISDIR)) {
+ if (!ftpState->flags.isdir) {
debug(9, 3) ("Directory path did not end in /\n");
strcat(ftpState->title_url, "/");
- EBIT_SET(ftpState->flags, FTP_ISDIR);
- EBIT_SET(ftpState->flags, FTP_USE_BASE);
+ ftpState->flags.isdir = 1;
+ ftpState->flags.use_base = 1;
}
ftpSendPasv(ftpState);
}
{
/* Only send SIZE for binary transfers. The returned size
* is useless on ASCII transfers */
- if (EBIT_TEST(ftpState->flags, FTP_BINARY)) {
+ if (ftpState->flags.binary) {
assert(ftpState->filepath != NULL);
assert(*ftpState->filepath != '\0');
snprintf(cbuf, 1024, "SIZE %s\r\n", ftpState->filepath);
struct sockaddr_in addr;
int addr_len;
if (ftpState->data.fd >= 0) {
- if (!EBIT_TEST(ftpState->flags, FTP_DATACHANNEL_HACK)) {
+ if (!ftpState->flags.datachannel_hack) {
/* We are already connected, reuse this connection. */
ftpRestOrList(ftpState);
return;
ftpState->data.fd = -1;
}
}
- if (!EBIT_TEST(ftpState->flags, FTP_PASV_SUPPORTED)) {
+ if (!ftpState->flags.pasv_supported) {
ftpSendPort(ftpState);
return;
}
unsigned char *addrptr;
unsigned char *portptr;
debug(9, 3) ("This is ftpSendPort\n");
- EBIT_CLR(ftpState->flags, FTP_PASV_SUPPORTED);
+ ftpState->flags.pasv_supported = 0;
fd = ftpOpenListenSocket(ftpState, 0);
addr_len = sizeof(addr);
if (getsockname(fd, (struct sockaddr *) &addr, &addr_len)) {
{
debug(9, 3) ("This is ftpRestOrList\n");
- if (EBIT_TEST(ftpState->flags, FTP_PUT)) {
+ if (ftpState->flags.put) {
debug(9, 3) ("ftpRestOrList: Sending STOR request...\n");
ftpSendStor(ftpState);
} else if (ftpState->typecode == 'D') {
/* XXX This should NOT be here */
ftpSendNlst(ftpState); /* sec 3.2.2 of RFC 1738 */
- EBIT_SET(ftpState->flags, FTP_ISDIR);
- EBIT_SET(ftpState->flags, FTP_USE_BASE);
- } else if (EBIT_TEST(ftpState->flags, FTP_ISDIR))
+ ftpState->flags.isdir = 1;
+ ftpState->flags.use_base = 1;
+ } else if (ftpState->flags.isdir)
ftpSendList(ftpState);
else if (ftpState->restart_offset > 0)
ftpSendRest(ftpState);
ftpSendRetr(ftpState);
} else if (code > 0) {
debug(9, 3) ("ftpReadRest: REST not supported\n");
- EBIT_CLR(ftpState->flags, FTP_REST_SUPPORTED);
+ ftpState->flags.rest_supported = 0;
} else {
ftpFail(ftpState);
}
ftpSendList(FtpStateData * ftpState)
{
if (ftpState->filepath) {
- EBIT_SET(ftpState->flags, FTP_USE_BASE);
+ ftpState->flags.use_base = 1;
snprintf(cbuf, 1024, "LIST %s\r\n", ftpState->filepath);
} else {
snprintf(cbuf, 1024, "LIST\r\n");
static void
ftpSendNlst(FtpStateData * ftpState)
{
- EBIT_SET(ftpState->flags, FTP_TRIED_NLST);
+ ftpState->flags.tried_nlst = 1;
if (ftpState->filepath) {
- EBIT_SET(ftpState->flags, FTP_USE_BASE);
+ ftpState->flags.use_base = 1;
snprintf(cbuf, 1024, "NLST %s\r\n", ftpState->filepath);
} else {
snprintf(cbuf, 1024, "NLST\r\n");
commSetTimeout(ftpState->ctrl.fd, -1, NULL, NULL);
commSetTimeout(ftpState->data.fd, Config.Timeout.read, ftpTimeout, ftpState);
return;
- } else if (!EBIT_TEST(ftpState->flags, FTP_TRIED_NLST) && code > 300) {
+ } else if (!ftpState->flags.tried_nlst && code > 300) {
ftpSendNlst(ftpState);
} else {
ftpFail(ftpState);
commSetTimeout(ftpState->data.fd, Config.Timeout.read, ftpTimeout,
ftpState);
} else if (code >= 300) {
- if (!EBIT_TEST(ftpState->flags, FTP_TRY_SLASH_HACK)) {
+ if (!ftpState->flags.try_slash_hack) {
/* Try this as a directory missing trailing slash... */
ftpHackShortcut(ftpState, ftpSendCwd);
} else {
ftpTrySlashHack(FtpStateData * ftpState)
{
char *path;
- EBIT_SET(ftpState->flags, FTP_TRY_SLASH_HACK);
+ ftpState->flags.try_slash_hack = 1;
/* Free old paths */
if (ftpState->pathcomps)
wordlistDestroy(&ftpState->pathcomps);
static void
ftpTryDatachannelHack(FtpStateData * ftpState)
{
- EBIT_SET(ftpState->flags, FTP_DATACHANNEL_HACK);
+ ftpState->flags.datachannel_hack = 1;
/* we have to undo some of the slash hack... */
if (ftpState->old_filepath != NULL) {
- EBIT_CLR(ftpState->flags, FTP_TRY_SLASH_HACK);
+ ftpState->flags.try_slash_hack = 0;
safe_free(ftpState->filepath);
ftpState->filepath = ftpState->old_filepath;
ftpState->old_filepath = NULL;
}
- EBIT_CLR(ftpState->flags, FTP_TRIED_NLST);
+ ftpState->flags.tried_nlst = 0;
/* And off we go */
- if (EBIT_TEST(ftpState->flags, FTP_ISDIR)) {
+ if (ftpState->flags.isdir) {
safe_free(ftpState->filepath);
ftpListDir(ftpState);
} else {
ErrorState *err;
debug(9, 3) ("ftpFail\n");
/* Try the / hack to support "Netscape" FTP URL's for retreiving files */
- if (!EBIT_TEST(ftpState->flags, FTP_ISDIR) &&
- !EBIT_TEST(ftpState->flags, FTP_TRY_SLASH_HACK)) {
+ if (!ftpState->flags.isdir &&
+ !ftpState->flags.try_slash_hack) {
switch (ftpState->state) {
case SENT_CWD:
case SENT_RETR:
}
}
/* Try to reopen datachannel */
- if (!EBIT_TEST(ftpState->flags, FTP_DATACHANNEL_HACK) &&
+ if (!ftpState->flags.datachannel_hack &&
ftpState->pathcomps == NULL) {
switch (ftpState->state) {
case SENT_RETR:
const char *t = NULL;
StoreEntry *e = ftpState->entry;
http_reply *reply = e->mem_obj->reply;
- if (EBIT_TEST(ftpState->flags, FTP_HTTP_HEADER_SENT))
+ if (ftpState->flags.http_header_sent)
return;
- EBIT_SET(ftpState->flags, FTP_HTTP_HEADER_SENT);
+ ftpState->flags.http_header_sent = 1;
assert(e->mem_obj->inmem_hi == 0);
filename = (t = strRChr(urlpath, '/')) ? t + 1 : strBuf(urlpath);
- if (EBIT_TEST(ftpState->flags, FTP_ISDIR)) {
+ if (ftpState->flags.isdir) {
mime_type = "text/html";
} else {
switch (ftpState->typecode) {
projects / thirdparty / squid.git / commitdiff
