e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe#include "mod_proxy.h"

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe#include "http_main.h"

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe#include "http_log.h"

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe#include "http_core.h"

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe#define AUTODETECT_PWD

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowestatic void skiplf(BUFF *foo)

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe{

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe char c;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe do

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe {

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe c = ap_bgetc(foo);

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe } while(c != '\n');

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe}

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowestatic int decodeenc(char *x)

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe{

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe int i, j, ch;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe if (x[0] == '\0')

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe return 0; /* special case for no characters */

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe for (i = 0, j = 0; x[i] != '\0'; i++, j++) {

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe ch = x[i];

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe if (ch == '%' && apr_isxdigit(x[i + 1]) && apr_isxdigit(x[i + 2])) {

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe ch = ap_proxy_hex2c(&x[i + 1]);

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe i += 2;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe }

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe x[j] = ch;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe }

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe x[j] = '\0';

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe return j;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe}

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowestatic int ftp_check_string(const char *x)

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe{

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe int i, ch;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe for (i = 0; x[i] != '\0'; i++) {

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe ch = x[i];

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe if (ch == '%' && apr_isxdigit(x[i + 1]) && apr_isxdigit(x[i + 2])) {

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe ch = ap_proxy_hex2c(&x[i + 1]);

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe i += 2;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe }

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe#ifndef CHARSET_EBCDIC

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe if (ch == '\015' || ch == '\012' || (ch & 0x80))

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe#else /*CHARSET_EBCDIC*/

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe if (ch == '\r' || ch == '\n' || (os_toascii[ch] & 0x80))

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe#endif /*CHARSET_EBCDIC*/

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe return 0;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe }

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe return 1;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe}

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wroweint ap_proxy_ftp_canon(request_rec *r, char *url)

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe{

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe char *user, *password, *host, *path, *parms, *strp, sport[7];

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe apr_pool_t *p = r->pool;

c6e3de48da56d5a2d6298585b895cf75e3ffada2ben const char *err;

6e8fa9b44c6d5f5b3ac9dab52c4734259bcd8335coar int port;

3f4d7fdb598d64d80ab8656852276246f2f3b502rbb

3f4d7fdb598d64d80ab8656852276246f2f3b502rbb port = DEFAULT_FTP_PORT;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe err = ap_proxy_canon_netloc(p, &url, &user, &password, &host, &port);

6e8fa9b44c6d5f5b3ac9dab52c4734259bcd8335coar if (err)

6e8fa9b44c6d5f5b3ac9dab52c4734259bcd8335coar return HTTP_BAD_REQUEST;

c6e3de48da56d5a2d6298585b895cf75e3ffada2ben if (user != NULL && !ftp_check_string(user))

6e8fa9b44c6d5f5b3ac9dab52c4734259bcd8335coar return HTTP_BAD_REQUEST;

6e8fa9b44c6d5f5b3ac9dab52c4734259bcd8335coar if (password != NULL && !ftp_check_string(password))

6e8fa9b44c6d5f5b3ac9dab52c4734259bcd8335coar return HTTP_BAD_REQUEST;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe strp = strchr(url, ';');

ac00100e1ead618f1d91b77ba2d8a468782a23b7jorton if (strp != NULL) {

3f4d7fdb598d64d80ab8656852276246f2f3b502rbb *(strp++) = '\0';

b931e2cf90d43b0894c2e2927a2a42aca46f277erpluem parms = ap_proxy_canonenc(p, strp, strlen(strp), enc_parm, r->proxyreq);

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe if (parms == NULL)

b0870018de400ab2bec8ddcd102c401900253046jorton return HTTP_BAD_REQUEST;

2db7bac8c6d32ddb851946eeaeed8ded0fbe656awrowe }

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe else

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe parms = "";

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe path = ap_proxy_canonenc(p, url, strlen(url), enc_path, r->proxyreq);

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe if (path == NULL)

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe return HTTP_BAD_REQUEST;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe if (!ftp_check_string(path))

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe return HTTP_BAD_REQUEST;

b0870018de400ab2bec8ddcd102c401900253046jorton

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe if (!r->proxyreq && r->args != NULL) {

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe if (strp != NULL) {

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe strp = ap_proxy_canonenc(p, r->args, strlen(r->args), enc_parm, 1);

6e8fa9b44c6d5f5b3ac9dab52c4734259bcd8335coar if (strp == NULL)

6e8fa9b44c6d5f5b3ac9dab52c4734259bcd8335coar return HTTP_BAD_REQUEST;

3f4d7fdb598d64d80ab8656852276246f2f3b502rbb parms = apr_pstrcat(p, parms, "?", strp, NULL);

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe }

9bec939825399ac2816ea0d912d2e3c3b2ed91f4sf else {

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe strp = ap_proxy_canonenc(p, r->args, strlen(r->args), enc_fpath, 1);

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe if (strp == NULL)

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe return HTTP_BAD_REQUEST;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe path = apr_pstrcat(p, path, "?", strp, NULL);

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe }

3f4d7fdb598d64d80ab8656852276246f2f3b502rbb r->args = NULL;

2fc50921b88defeb7127985dfe4b4130175e069ejwoolley }

3f4d7fdb598d64d80ab8656852276246f2f3b502rbb

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe if (port != DEFAULT_FTP_PORT)

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe apr_snprintf(sport, sizeof(sport), ":%d", port);

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe else

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe sport[0] = '\0';

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe r->filename = apr_pstrcat(p, "proxy:ftp://", (user != NULL) ? user : "",

ac00100e1ead618f1d91b77ba2d8a468782a23b7jorton (password != NULL) ? ":" : "",

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe (password != NULL) ? password : "",

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe (user != NULL) ? "@" : "", host, sport, "/", path,

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe (parms[0] != '\0') ? ";" : "", parms, NULL);

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe return OK;

e46d12b7a404d93e9ed9d09299e98b9431d95800wrowe}

6e8fa9b44c6d5f5b3ac9dab52c4734259bcd8335coar

e4afb803ff9a51f9ec7969f232b7fd4a4e94d5d4rbbstatic int ftp_getrc(BUFF *f)

e4afb803ff9a51f9ec7969f232b7fd4a4e94d5d4rbb{

ebe70c2684539a5fb2d899241d1601710dfa38a4trawick int len, status;

c6e3de48da56d5a2d6298585b895cf75e3ffada2ben char linebuff[100], buff[5];

c6e3de48da56d5a2d6298585b895cf75e3ffada2ben

73e8b26287de5c06fa470d36162e103dbac9c7e5wrowe len = ap_bgets(linebuff, sizeof linebuff, f);

2bf9d434b718368d72c1be69ede336cf19162902ben if (len == -1)

6e8fa9b44c6d5f5b3ac9dab52c4734259bcd8335coar return -1;

2bf9d434b718368d72c1be69ede336cf19162902ben if (len < 5 || !apr_isdigit(linebuff[0]) || !apr_isdigit(linebuff[1]) ||

c6e3de48da56d5a2d6298585b895cf75e3ffada2ben !apr_isdigit(linebuff[2]) || (linebuff[3] != ' ' && linebuff[3] != '-'))

36ef8f77bffe75d1aa327882be1b5bdbe2ff567asf status = 0;

c6e3de48da56d5a2d6298585b895cf75e3ffada2ben else

f05787953018140838ad51456c86c965d6a86267jim status = 100 * linebuff[0] + 10 * linebuff[1] + linebuff[2] - 111 * '0';

f05787953018140838ad51456c86c965d6a86267jim

f05787953018140838ad51456c86c965d6a86267jim if (linebuff[len - 1] != '\n') {

f05787953018140838ad51456c86c965d6a86267jim skiplf(f);

f05787953018140838ad51456c86c965d6a86267jim }

f05787953018140838ad51456c86c965d6a86267jim

if (linebuff[3] == '-') {

memcpy(buff, linebuff, 3);

buff[3] = ' ';

do {

len = ap_bgets(linebuff, sizeof linebuff, f);

if (len == -1)

return -1;

if (linebuff[len - 1] != '\n') {

skiplf(f);

}

} while (memcmp(linebuff, buff, 4) != 0);

}

return status;

}

static int ftp_getrc_msg(BUFF *f, char *msgbuf, int msglen)

{

int len, status;

char linebuff[100], buff[5];

char *mb = msgbuf,

*me = &msgbuf[msglen];

len = ap_bgets(linebuff, sizeof linebuff, f);

if (len == -1)

return -1;

if (len < 5 || !apr_isdigit(linebuff[0]) || !apr_isdigit(linebuff[1]) ||

!apr_isdigit(linebuff[2]) || (linebuff[3] != ' ' && linebuff[3] != '-'))

status = 0;

else

status = 100 * linebuff[0] + 10 * linebuff[1] + linebuff[2] - 111 * '0';

mb = apr_cpystrn(mb, linebuff+4, me - mb);

if (linebuff[len - 1] != '\n')

skiplf(f);

if (linebuff[3] == '-') {

memcpy(buff, linebuff, 3);

buff[3] = ' ';

do {

len = ap_bgets(linebuff, sizeof linebuff, f);

if (len == -1)

return -1;

if (linebuff[len - 1] != '\n') {

skiplf(f);

}

mb = apr_cpystrn(mb, linebuff+4, me - mb);

} while (memcmp(linebuff, buff, 4) != 0);

}

return status;

}

static long int send_dir(BUFF *f, request_rec *r, ap_cache_el *c, char *cwd)

{

char buf[IOBUFSIZE];

char buf2[IOBUFSIZE];

char *filename;

int searchidx = 0;

char *searchptr = NULL;

int firstfile = 1;

apr_ssize_t cntr;

unsigned long total_bytes_sent = 0;

register int n, o, w;

conn_rec *con = r->connection;

char *dir, *path, *reldir, *site;

BUFF *cachefp = NULL;

if(c) ap_cache_el_data(c, &cachefp);

/* Save "scheme://site" prefix without password */

site = ap_unparse_uri_components(r->pool, &r->parsed_uri, UNP_OMITPASSWORD|UNP_OMITPATHINFO);

/* ... and path without query args */

path = ap_unparse_uri_components(r->pool, &r->parsed_uri, UNP_OMITSITEPART|UNP_OMITQUERY);

(void)decodeenc(path);

/* Copy path, strip (all except the last) trailing slashes */

path = dir = apr_pstrcat(r->pool, path, "/", NULL);

while ((n = strlen(path)) > 1 && path[n-1] == '/' && path[n-2] == '/')

path[n-1] = '\0';

/* print "ftp://host/" */

n = apr_snprintf(buf, sizeof(buf), DOCTYPE_HTML_3_2

"<HTML><HEAD><TITLE>%s%s</TITLE>\n"

"<BASE HREF=\"%s%s\"></HEAD>\n"

"<BODY><H2>Directory of "

"<A HREF=\"/\">%s</A>/",

site, path, site, path, site);

total_bytes_sent += ap_proxy_bputs2(buf, con->client, c);

while ((dir = strchr(dir+1, '/')) != NULL)

{

*dir = '\0';

if ((reldir = strrchr(path+1, '/'))==NULL)

reldir = path+1;

else

++reldir;

/* print "path/" component */

apr_snprintf(buf, sizeof(buf), "<A HREF=\"/%s/\">%s</A>/", path+1, reldir);

total_bytes_sent += ap_proxy_bputs2(buf, con->client, c);

*dir = '/';

}

/* If the caller has determined the current directory, and it differs */

/* from what the client requested, then show the real name */

if (cwd == NULL || strncmp (cwd, path, strlen(cwd)) == 0) {

apr_snprintf(buf, sizeof(buf), "</H2>\n<HR><PRE>");

} else {

apr_snprintf(buf, sizeof(buf), "</H2>\n(%s)\n<HR><PRE>", cwd);

}

total_bytes_sent += ap_proxy_bputs2(buf, con->client, c);

while (!con->aborted) {

n = ap_bgets(buf, sizeof buf, f);

if (n == -1) { /* input error */

if (c != NULL) {

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"proxy: error reading from cache");

ap_proxy_cache_error(&c);

}

break;

}

if (n == 0)

break; /* EOF */

if (buf[0] == 'l' && (filename=strstr(buf, " -> ")) != NULL) {

char *link_ptr = filename;

do {

filename--;

} while (filename[0] != ' ');

*(filename++) = '\0';

*(link_ptr++) = '\0';

if ((n = strlen(link_ptr)) > 1 && link_ptr[n - 1] == '\n')

link_ptr[n - 1] = '\0';

apr_snprintf(buf2, sizeof(buf2), "%s <A HREF=\"%s\">%s %s</A>\n", buf, filename, filename, link_ptr);

apr_cpystrn(buf, buf2, sizeof(buf));

n = strlen(buf);

}

else if (buf[0] == 'd' || buf[0] == '-' || buf[0] == 'l' || apr_isdigit(buf[0])) {

if (apr_isdigit(buf[0])) { /* handle DOS dir */

searchptr = strchr(buf, '<');

if (searchptr != NULL)

*searchptr = '[';

searchptr = strchr(buf, '>');

if (searchptr != NULL)

*searchptr = ']';

}

filename = strrchr(buf, ' ');

*(filename++) = 0;

filename[strlen(filename) - 1] = 0;

/* handle filenames with spaces in 'em */

if (!strcmp(filename, ".") || !strcmp(filename, "..") || firstfile) {

firstfile = 0;

searchidx = filename - buf;

}

else if (searchidx != 0 && buf[searchidx] != 0) {

*(--filename) = ' ';

buf[searchidx - 1] = 0;

filename = &buf[searchidx];

}

/* Special handling for '.' and '..' */

if (!strcmp(filename, ".") || !strcmp(filename, "..") || buf[0] == 'd') {

apr_snprintf(buf2, sizeof(buf2), "%s <A HREF=\"%s/\">%s</A>\n",

buf, filename, filename);

}

else {

apr_snprintf(buf2, sizeof(buf2), "%s <A HREF=\"%s\">%s</A>\n", buf, filename, filename);

}

apr_cpystrn(buf, buf2, sizeof(buf));

n = strlen(buf);

}

o = 0;

total_bytes_sent += n;

if (cachefp && ap_bwrite(cachefp, buf, n, &cntr) != n) {

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"proxy: error writing to cache");

ap_proxy_cache_error(&c);

cachefp = NULL;

}

while (n && !r->connection->aborted) {

w = ap_bwrite(con->client, &buf[o], n, &cntr);

if (w <= 0)

break;

n -= w;

o += w;

}

}

total_bytes_sent += ap_proxy_bputs2("</PRE><HR>\n", con->client, c);

total_bytes_sent += ap_proxy_bputs2(ap_psignature("", r), con->client, c);

total_bytes_sent += ap_proxy_bputs2("</BODY></HTML>\n", con->client, c);

ap_bflush(con->client);

return total_bytes_sent;

}

static int ftp_unauthorized (request_rec *r, int log_it)

{

r->proxyreq = 0;

/* Log failed requests if they supplied a password

if (log_it)

ap_log_rerror(APLOG_MARK, APLOG_INFO|APLOG_NOERRNO, 0, r,

"proxy: missing or failed auth to %s",

ap_unparse_uri_components(r->pool,

&r->parsed_uri, UNP_OMITPATHINFO));

apr_table_setn(r->err_headers_out, "WWW-Authenticate",

apr_pstrcat(r->pool, "Basic realm=\"",

ap_unparse_uri_components(r->pool, &r->parsed_uri,

UNP_OMITPASSWORD|UNP_OMITPATHINFO),

"\"", NULL));

return HTTP_UNAUTHORIZED;

}

int ap_proxy_ftp_handler(request_rec *r, ap_cache_el *c, char *url)

{

char *host, *path, *strp, *parms;

char *cwd = NULL;

char *user = NULL;

const char *password = NULL;

apr_socket_t *sock, *dsock, *inc;

int port, i, j, len, rc, nocache = 0;

apr_socket_t *csd;

struct in_addr destaddr;

BUFF *f, *cachefp = NULL;

BUFF *data = NULL;

apr_pool_t *p = r->pool;

int one = 1;

const long int zero = 0L;

apr_table_t *resp_hdrs;

void *sconf = r->server->module_config;

proxy_server_conf *conf =

(proxy_server_conf *) ap_get_module_config(sconf, &proxy_module);

struct noproxy_entry *npent = (struct noproxy_entry *) conf->noproxies->elts;

struct nocache_entry *ncent = (struct nocache_entry *) conf->nocaches->elts;

unsigned int presult, h0, h1, h2, h3, p0, p1;

unsigned short pport;

int pasvmode = 0;

char pasv[64];

char *pstr, dates[APR_RFC822_DATE_LEN];

char *npaddr;

apr_uint32_t npport;

char resp[MAX_STRING_LEN];

char *size = NULL;

if (r->method_number != M_GET)

return HTTP_NOT_IMPLEMENTED;

host = r->parsed_uri.hostname;

port = (r->parsed_uri.port != 0)

? r->parsed_uri.port

: ap_default_port_for_request(r);

path = apr_pstrdup(p, r->parsed_uri.path);

path = (path != NULL && path[0] != '\0') ? &path[1] : "";

/* The "Authorization:" header must be checked first.

if ((password = apr_table_get(r->headers_in, "Authorization")) != NULL

&& strcasecmp(ap_getword(r->pool, &password, ' '), "Basic") == 0

&& (password = ap_pbase64decode(r->pool, password))[0] != ':') {

/* Note that this allocation has to be made from r->connection->pool

user = ap_getword_nulls (r->pool, &password, ':');

r->ap_auth_type = "Basic";

r->user = r->parsed_uri.user = user;

nocache = 1; /* This resource only accessible with username/password */

}

else if ((user = r->parsed_uri.user) != NULL) {

user = apr_pstrdup(p, user);

decodeenc(user);

if ((password = r->parsed_uri.password) != NULL) {

char *tmp = apr_pstrdup(p, password);

decodeenc(tmp);

password = tmp;

}

nocache = 1; /* This resource only accessible with username/password */

}

else {

user = "anonymous";

password = "apache_proxy@";

}

destaddr.s_addr = apr_inet_addr(host);

for (i = 0; i < conf->noproxies->nelts; i++) {

if ((npent[i].name != NULL && strstr(host, npent[i].name) != NULL)

|| destaddr.s_addr == npent[i].addr.s_addr || npent[i].name[0] == '*')

return ap_proxyerror(r, HTTP_FORBIDDEN,

"Connect to remote machine blocked");

}

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: connect to %s:%d", host, port);

parms = strchr(path, ';');

if (parms != NULL)

*(parms++) = '\0';

if ((apr_create_tcp_socket(&sock, r->pool)) != APR_SUCCESS) {

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"proxy: error creating socket");

return HTTP_INTERNAL_SERVER_ERROR;

}

if (conf->recv_buffer_size > 0 && apr_setsocketopt(sock, APR_SO_RCVBUF,conf->recv_buffer_size)) {

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"setsockopt(SO_RCVBUF): Failed to set ProxyReceiveBufferSize, using default");

}

if (apr_setsocketopt(sock, APR_SO_REUSEADDR, one)) {

#ifndef _OSD_POSIX /* BS2000 has this option "always on" */

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"proxy: error setting reuseaddr option: setsockopt(SO_REUSEADDR)");

apr_close_socket(sock);

return HTTP_INTERNAL_SERVER_ERROR;

#endif /*_OSD_POSIX*/

}

if (ap_proxy_doconnect(sock, host, port, r) == -1) {

apr_close_socket(sock);

return ap_proxyerror(r, HTTP_BAD_GATEWAY,

apr_pstrcat(r->pool, "Could not connect to remote machine: ",

strerror(errno), NULL));

}

f = ap_bcreate(p, B_RDWR);

ap_bpush_socket(f, sock);

#ifdef CHARSET_EBCDIC

ap_bsetflag(f, B_ASCII2EBCDIC|B_EBCDIC2ASCII, 1);

#endif /*CHARSET_EBCDIC*/

/* 120 Service ready in nnn minutes. */

/* 220 Service ready for new user. */

/* 421 Service not available, closing control connection. */

i = ftp_getrc_msg(f, resp, sizeof resp);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: returned status %d", i);

if (i == -1) {

return ap_proxyerror(r, HTTP_BAD_GATEWAY,

"Error reading from remote server");

}

#if 0

if (i == 120) {

/* RFC2068 states:

ap_set_header("Retry-After", apr_psprintf(p, "%u", 60*wait_mins);

return ap_proxyerror(r, HTTP_SERVICE_UNAVAILABLE, resp);

}

#endif

if (i != 220) {

return ap_proxyerror(r, HTTP_BAD_GATEWAY, resp);

}

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: connected.");

ap_bvputs(f, "USER ", user, CRLF, NULL);

ap_bflush(f); /* capture any errors */

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: USER %s", user);

/* 230 User logged in, proceed. */

/* 331 User name okay, need password. */

/* 332 Need account for login. */

/* 421 Service not available, closing control connection. */

/* 500 Syntax error, command unrecognized. */

/* (This may include errors such as command line too long.) */

/* 501 Syntax error in parameters or arguments. */

/* 530 Not logged in. */

i = ftp_getrc(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: returned status %d", i);

if (i == -1) {

return ap_proxyerror(r, HTTP_BAD_GATEWAY,

"Error reading from remote server");

}

if (i == 530) {

return ftp_unauthorized (r, 1); /* log it: user name guessing attempt? */

}

if (i != 230 && i != 331) {

return HTTP_BAD_GATEWAY;

}

if (i == 331) { /* send password */

if (password == NULL) {

return ftp_unauthorized (r, 0);

}

ap_bvputs(f, "PASS ", password, CRLF, NULL);

ap_bflush(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: PASS %s", password);

/* 230 User logged in, proceed. */

/* 332 Need account for login. */

/* 421 Service not available, closing control connection. */

/* 500 Syntax error, command unrecognized. */

/* 501 Syntax error in parameters or arguments. */

/* 503 Bad sequence of commands. */

/* 530 Not logged in. */

i = ftp_getrc(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: returned status %d", i);

if (i == -1) {

return ap_proxyerror(r, HTTP_BAD_GATEWAY, "Error reading from remote server");

}

if (i == 332) {

return ap_proxyerror(r, HTTP_UNAUTHORIZED, "Need account for login");

}

/* @@@ questionable -- we might as well return a 403 Forbidden here */

if (i == 530) {

return ftp_unauthorized (r, 1); /* log it: passwd guessing attempt? */

}

if (i != 230 && i != 202) {

return HTTP_BAD_GATEWAY;

}

}

for (;;) {

strp = strchr(path, '/');

if (strp == NULL)

break;

*strp = '\0';

len = decodeenc(path);

ap_bvputs(f, "CWD ", path, CRLF, NULL);

ap_bflush(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: CWD %s", path);

*strp = '/';

/* 250 Requested file action okay, completed. */

/* 421 Service not available, closing control connection. */

/* 500 Syntax error, command unrecognized. */

/* 501 Syntax error in parameters or arguments. */

/* 502 Command not implemented. */

/* 530 Not logged in. */

/* 550 Requested action not taken. */

i = ftp_getrc(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: returned status %d", i);

if (i == -1) {

return ap_proxyerror(r, HTTP_BAD_GATEWAY,

"Error reading from remote server");

}

if (i == 550) {

return HTTP_NOT_FOUND;

}

if (i != 250) {

return HTTP_BAD_GATEWAY;

}

path = strp + 1;

}

if (parms != NULL && strncmp(parms, "type=", 5) == 0) {

parms += 5;

if ((parms[0] != 'd' && parms[0] != 'a' && parms[0] != 'i') ||

parms[1] != '\0')

parms = "";

}

else

parms = "";

/* changed to make binary transfers the default */

if (parms[0] != 'a') {

/* set type to image */

/* TM - Added \015\012 to the end of TYPE I, otherwise it hangs the

ap_bputs("TYPE I" CRLF, f);

ap_bflush(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: TYPE I");

/* 200 Command okay. */

/* 421 Service not available, closing control connection. */

/* 500 Syntax error, command unrecognized. */

/* 501 Syntax error in parameters or arguments. */

/* 504 Command not implemented for that parameter. */

/* 530 Not logged in. */

i = ftp_getrc(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: returned status %d", i);

if (i == -1) {

return ap_proxyerror(r, HTTP_BAD_GATEWAY,

"Error reading from remote server");

}

if (i != 200 && i != 504) {

return HTTP_BAD_GATEWAY;

}

if (i == 504)

parms[0] = '\0';

}

if ((apr_create_tcp_socket(&dsock, r->pool)) != APR_SUCCESS) {

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"proxy: error creating PASV socket");

ap_bclose(f);

return HTTP_INTERNAL_SERVER_ERROR;

}

if (conf->recv_buffer_size > 0 && apr_setsocketopt(dsock, APR_SO_RCVBUF,conf->recv_buffer_size)) {

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"setsockopt(SO_RCVBUF): Failed to set ProxyReceiveBufferSize, using default");

}

ap_bputs("PASV" CRLF, f);

ap_bflush(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: PASV command issued");

/* 227 Entering Passive Mode (h1,h2,h3,h4,p1,p2). */

/* 421 Service not available, closing control connection. */

/* 500 Syntax error, command unrecognized. */

/* 501 Syntax error in parameters or arguments. */

/* 502 Command not implemented. */

/* 530 Not logged in. */

i = ap_bgets(pasv, sizeof(pasv), f);

if (i == -1) {

ap_log_rerror(APLOG_MARK, APLOG_ERR|APLOG_NOERRNO, 0, r,

"PASV: control connection is toast");

apr_close_socket(dsock);

ap_bclose(f);

return HTTP_INTERNAL_SERVER_ERROR;

}

else {

pasv[i - 1] = '\0';

pstr = strtok(pasv, " "); /* separate result code */

if (pstr != NULL) {

presult = atoi(pstr);

if (*(pstr + strlen(pstr) + 1) == '=')

pstr += strlen(pstr) + 2;

else

{

pstr = strtok(NULL, "("); /* separate address & port params */

if (pstr != NULL)

pstr = strtok(NULL, ")");

}

}

else

presult = atoi(pasv);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: returned status %d", presult);

if (presult == 227 && pstr != NULL && (sscanf(pstr,

"%d,%d,%d,%d,%d,%d", &h3, &h2, &h1, &h0, &p1, &p0) == 6)) {

/* pardon the parens, but it makes gcc happy */

destaddr.s_addr = htonl((((((h3 << 8) + h2) << 8) + h1) << 8) + h0);

pport = (p1 << 8) + p0;

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: contacting host %d.%d.%d.%d:%d",

h3, h2, h1, h0, pport);

if (ap_proxy_doconnect(dsock, inet_ntoa(destaddr), pport, r) == -1) {

return ap_proxyerror(r, HTTP_BAD_GATEWAY,

apr_pstrcat(r->pool,

"Could not connect to remote machine: ",

strerror(errno), NULL));

}

else {

pasvmode = 1;

}

}

else

apr_close_socket(dsock); /* and try the regular way */

}

if (!pasvmode) { /* set up data connection */

if ((apr_create_tcp_socket(&dsock, r->pool)) != APR_SUCCESS) {

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"proxy: error creating socket");

ap_bclose(f);

return HTTP_INTERNAL_SERVER_ERROR;

}

apr_get_local_port(&npport, sock);

apr_get_local_ipaddr(&npaddr, sock);

apr_set_local_port(dsock, npport);

apr_set_local_ipaddr(dsock, npaddr);

if (apr_setsocketopt(dsock, APR_SO_REUSEADDR, one) != APR_SUCCESS) {

#ifndef _OSD_POSIX /* BS2000 has this option "always on" */

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"proxy: error setting reuseaddr option");

apr_close_socket(dsock);

ap_bclose(f);

return HTTP_INTERNAL_SERVER_ERROR;

#endif /*_OSD_POSIX*/

}

if (apr_bind(dsock) != APR_SUCCESS) {

char buff[22];

apr_snprintf(buff, sizeof(buff), "%s:%d", npaddr, npport);

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"proxy: error binding to ftp data socket %s", buff);

ap_bclose(f);

apr_close_socket(dsock);

return HTTP_INTERNAL_SERVER_ERROR;

}

apr_listen(dsock, 2); /* only need a short queue */

}

len = decodeenc(path);

/* TM - if len == 0 then it must be a directory (you can't RETR nothing) */

if (len == 0) {

parms = "d";

}

else {

ap_bvputs(f, "SIZE ", path, CRLF, NULL);

ap_bflush(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: SIZE %s", path);

i = ftp_getrc_msg(f, resp, sizeof resp);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: returned status %d with response %s", i, resp);

if (i != 500) { /* Size command not recognized */

if (i == 550) { /* Not a regular file */

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: SIZE shows this is a directory");

parms = "d";

ap_bvputs(f, "CWD ", path, CRLF, NULL);

ap_bflush(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: CWD %s", path);

i = ftp_getrc(f);

/* possible results: 250, 421, 500, 501, 502, 530, 550 */

/* 250 Requested file action okay, completed. */

/* 421 Service not available, closing control connection. */

/* 500 Syntax error, command unrecognized. */

/* 501 Syntax error in parameters or arguments. */

/* 502 Command not implemented. */

/* 530 Not logged in. */

/* 550 Requested action not taken. */

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: returned status %d", i);

if (i == -1) {

return ap_proxyerror(r, HTTP_BAD_GATEWAY,

"Error reading from remote server");

}

if (i == 550) {

return HTTP_NOT_FOUND;

}

if (i != 250) {

return HTTP_BAD_GATEWAY;

}

path = "";

len = 0;

}

else if (i == 213) { /* Size command ok */

for (j = 0; j < sizeof resp && apr_isdigit(resp[j]); j++)

;

resp[j] = '\0';

if (resp[0] != '\0')

size = apr_pstrdup(p, resp);

}

}

}

#ifdef AUTODETECT_PWD

ap_bvputs(f, "PWD", CRLF, NULL);

ap_bflush(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: PWD");

/* 257 "<directory-name>" <commentary> */

/* 421 Service not available, closing control connection. */

/* 500 Syntax error, command unrecognized. */

/* 501 Syntax error in parameters or arguments. */

/* 502 Command not implemented. */

/* 550 Requested action not taken. */

i = ftp_getrc_msg(f, resp, sizeof resp);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: PWD returned status %d", i);

if (i == -1 || i == 421) {

return ap_proxyerror(r, HTTP_BAD_GATEWAY,

"Error reading from remote server");

}

if (i == 550) {

return HTTP_NOT_FOUND;

}

if (i == 257) {

const char *dirp = resp;

cwd = ap_getword_conf(r->pool, &dirp);

}

#endif /*AUTODETECT_PWD*/

if (parms[0] == 'd') {

if (len != 0)

ap_bvputs(f, "LIST ", path, CRLF, NULL);

else

ap_bputs("LIST -lag" CRLF, f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: LIST %s", (len == 0 ? "" : path));

}

else {

ap_bvputs(f, "RETR ", path, CRLF, NULL);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: RETR %s", path);

}

ap_bflush(f);

/* 110 Restart marker reply. */

/* 125 Data connection already open; transfer starting. */

/* 150 File status okay; about to open data connection. */

/* 226 Closing data connection. */

/* 250 Requested file action okay, completed. */

/* 421 Service not available, closing control connection. */

/* 425 Can't open data connection. */

/* 426 Connection closed; transfer aborted. */

/* 450 Requested file action not taken. */

/* 451 Requested action aborted. Local error in processing. */

/* 500 Syntax error, command unrecognized. */

/* 501 Syntax error in parameters or arguments. */

/* 530 Not logged in. */

/* 550 Requested action not taken. */

rc = ftp_getrc(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: returned status %d", rc);

if (rc == -1) {

return ap_proxyerror(r, HTTP_BAD_GATEWAY,

"Error reading from remote server");

}

if (rc == 550) {

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: RETR failed, trying LIST instead");

parms = "d";

ap_bvputs(f, "CWD ", path, CRLF, NULL);

ap_bflush(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: CWD %s", path);

/* possible results: 250, 421, 500, 501, 502, 530, 550 */

/* 250 Requested file action okay, completed. */

/* 421 Service not available, closing control connection. */

/* 500 Syntax error, command unrecognized. */

/* 501 Syntax error in parameters or arguments. */

/* 502 Command not implemented. */

/* 530 Not logged in. */

/* 550 Requested action not taken. */

rc = ftp_getrc(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: returned status %d", rc);

if (rc == -1) {

return ap_proxyerror(r, HTTP_BAD_GATEWAY,

"Error reading from remote server");

}

if (rc == 550) {

return HTTP_NOT_FOUND;

}

if (rc != 250) {

return HTTP_BAD_GATEWAY;

}

#ifdef AUTODETECT_PWD

ap_bvputs(f, "PWD", CRLF, NULL);

ap_bflush(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: PWD");

/* 257 "<directory-name>" <commentary> */

/* 421 Service not available, closing control connection. */

/* 500 Syntax error, command unrecognized. */

/* 501 Syntax error in parameters or arguments. */

/* 502 Command not implemented. */

/* 550 Requested action not taken. */

i = ftp_getrc_msg(f, resp, sizeof resp);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: PWD returned status %d", i);

if (i == -1 || i == 421) {

return ap_proxyerror(r, HTTP_BAD_GATEWAY,

"Error reading from remote server");

}

if (i == 550) {

return HTTP_NOT_FOUND;

}

if (i == 257) {

const char *dirp = resp;

cwd = ap_getword_conf(r->pool, &dirp);

}

#endif /*AUTODETECT_PWD*/

ap_bputs("LIST -lag" CRLF, f);

ap_bflush(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: LIST -lag");

rc = ftp_getrc(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: returned status %d", rc);

if (rc == -1)

return ap_proxyerror(r, HTTP_BAD_GATEWAY,

"Error reading from remote server");

}

if (rc != 125 && rc != 150 && rc != 226 && rc != 250)

return HTTP_BAD_GATEWAY;

r->status = HTTP_OK;

r->status_line = "200 OK";

resp_hdrs = apr_make_table(p, 2);

apr_rfc822_date(dates, r->request_time);

apr_table_setn(resp_hdrs, "Date", dates);

apr_table_setn(resp_hdrs, "Server", ap_get_server_version());

if (parms[0] == 'd')

apr_table_setn(resp_hdrs, "Content-Type", "text/html");

else {

if (r->content_type != NULL) {

apr_table_setn(resp_hdrs, "Content-Type", r->content_type);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: Content-Type set to %s", r->content_type);

}

else {

apr_table_setn(resp_hdrs, "Content-Type", ap_default_type(r));

}

if (parms[0] != 'a' && size != NULL) {

/* We "trust" the ftp server to really serve (size) bytes... */

apr_table_setn(resp_hdrs, "Content-Length", size);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: Content-Length set to %s", size);

}

}

if (r->content_encoding != NULL && r->content_encoding[0] != '\0') {

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: Content-Encoding set to %s", r->content_encoding);

apr_table_setn(resp_hdrs, "Content-Encoding", r->content_encoding);

}

ap_cache_el_header_merge(c, resp_hdrs);

for (i = 0; i < conf->nocaches->nelts; i++) {

if ((ncent[i].name != NULL && strstr(host, ncent[i].name) != NULL)

|| destaddr.s_addr == ncent[i].addr.s_addr || ncent[i].name[0] == '*')

nocache = 1;

}

if(nocache || !ap_proxy_cache_should_cache(r, resp_hdrs, 0))

ap_proxy_cache_error(&c);

else

ap_cache_el_data(c, &cachefp);

if (!pasvmode) { /* wait for connection */

for(;;)

{

switch(apr_accept(&inc, dsock, r->pool))

{

case APR_EINTR:

continue;

case APR_SUCCESS:

break;

default:

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"proxy: failed to accept data connection");

apr_close_socket(dsock);

ap_bclose(f);

if (c != NULL) ap_proxy_cache_error(&c);

return HTTP_BAD_GATEWAY;

}

}

data = ap_bcreate(p, B_RDWR);

ap_bpush_socket(f, csd);

}

else {

data = ap_bcreate(p, B_RDWR);

ap_bpush_socket(data, dsock);

}

if (!r->assbackwards)

ap_rvputs(r, "HTTP/1.0 ", r->status_line, CRLF, NULL);

if (cachefp && ap_bvputs(cachefp, "HTTP/1.0 ", r->status_line, CRLF, NULL) == -1) {

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"proxy: error writing CRLF to cache");

ap_proxy_cache_error(&c);

cachefp = NULL;

}

ap_cache_el_header_walk(c, ap_proxy_send_hdr_line, r, NULL);

if (!r->assbackwards)

ap_rputs(CRLF, r);

if (cachefp && ap_bputs(CRLF, cachefp) == -1) {

ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,

"proxy: error writing CRLF to cache");

ap_proxy_cache_error(&c);

cachefp = NULL;

}

ap_bsetopt(r->connection->client, BO_BYTECT, &zero);

r->sent_bodyct = 1;

if (!r->header_only) {

if (parms[0] != 'd') {

/* we don't need no steekin' cache completion*/

ap_proxy_send_fb(NULL, data, r, c);

} else

send_dir(data, r, c, cwd);

if (rc == 125 || rc == 150)

rc = ftp_getrc(f);

/* XXX: we checked for 125||150||226||250 above. This is redundant. */

if (rc != 226 && rc != 250)

/* XXX: we no longer log an "error writing to c->tempfile" - should we? */

ap_proxy_cache_error(&c);

}

else {

ap_bputs("ABOR" CRLF, f);

ap_bflush(f);

if (!pasvmode)

ap_bclose(data);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: ABOR");

/* 225 Data connection open; no transfer in progress. */

/* 226 Closing data connection. */

/* 421 Service not available, closing control connection. */

/* 500 Syntax error, command unrecognized. */

/* 501 Syntax error in parameters or arguments. */

/* 502 Command not implemented. */

i = ftp_getrc(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: returned status %d", i);

}

ap_bputs("QUIT" CRLF, f);

ap_bflush(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: QUIT");

/* 221 Service closing control connection. */

/* 500 Syntax error, command unrecognized. */

i = ftp_getrc(f);

ap_log_error(APLOG_MARK, APLOG_DEBUG|APLOG_NOERRNO, 0, NULL,

"FTP: QUIT: status %d", i);

if (pasvmode)

ap_bclose(data);

ap_bclose(f);

ap_rflush(r); /* flush before garbage collection */

if(c) ap_proxy_cache_update(c);

return OK;

}