", 5)) {
pp += 4;
while (pp + 1 < p && WHITECHAR(buf[pp + 1])) pp++;
if (pp + 1 < p) goto done;
}
bn = -1;
bp = 0; /* warning, go away */
for (pp = 0; pp < p; ) {
if (buf[pp] >= '0' && buf[pp] <= '9') {
int i;
for (i = pp; i < p; i++)
if (buf[i] < '0' || buf[i] > '9') break;
if (i < p && WHITECHAR(buf[i])) {
if (i - pp > bn) {
bn = i - pp;
bp = pp;
}
}
pp = i;
}
while (pp < p && !WHITECHAR(buf[pp])) pp++;
while (pp < p && WHITECHAR(buf[pp])) pp++;
}
if (bn >= 0) {
pp = bp + bn;
while (pp + 1 < p && WHITECHAR(buf[pp + 1])) pp++;
if (pp + 1 < p) goto done;
}
for (pp = p - 1; pp >= 0; pp--) if (!WHITECHAR(buf[pp])) break;
if (pp < 0) goto raw;
for (; pp >= 0; pp--) if (WHITECHAR(buf[pp]) && (pp < 3 || memcmp(buf + pp - 3, " -> ", 4)) && (pp > p - 4 || memcmp(buf + pp, " -> ", 4))) break;
done:
*d = pp + 1;
goto ppp;
raw:
add_conv_str(&str, &sl, buf, p, 0);
}
add_chr_to_str(&str, &sl, '\n');
if (add_fragment(ce, *pos, str, sl)) *tr = 0;
*pos += sl;
mem_free(str);
goto again;
}
void got_something_from_data_connection(struct connection *c)
{
struct ftp_connection_info *inf = c->info;
int l;
set_timeout(c);
if (!inf->d) {
int ns;
inf->d = 1;
set_handlers(c->sock2, NULL, NULL, NULL, NULL);
if ((ns = accept(c->sock2, NULL, NULL)) == -1) goto e;
close(c->sock2);
c->sock2 = ns;
set_handlers(ns, (void (*)(void *))got_something_from_data_connection, NULL, NULL, c);
return;
}
if (!c->cache && get_cache_entry(c->url, &c->cache)) {
setcstate(c, S_OUT_OF_MEM);
abort_connection(c);
return;
}
if (inf->dir && !c->from) {
unsigned char *ud;
unsigned char *s0;
int s0l;
static unsigned char ftp_head[] = "/";
static unsigned char ftp_head2[] = "Directory /";
static unsigned char ftp_head3[] = "
";
#define A(s) add_fragment(c->cache, c->from, s, strlen(s)), c->from += strlen(s)
A(ftp_head);
ud = stracpy(get_url_data(c->url));
if (strchr(ud, POST_CHAR)) *strchr(ud, POST_CHAR) = 0;
s0 = init_str();
s0l = 0;
add_conv_str(&s0, &s0l, ud, strlen(ud), -1);
mem_free(ud);
A(s0);
A(ftp_head2);
A(s0);
A(ftp_head3);
mem_free(s0);
if (!c->cache->head) c->cache->head = stracpy("\r\n");
add_to_strn(&c->cache->head, "Content-Type: text/html\r\n");
#undef A
}
if ((l = read(c->sock2, inf->ftp_buffer + inf->buf_pos, FTP_BUF - inf->buf_pos)) == -1) {
e:
if (inf->conn_st != 1 && !inf->dir && !c->from) {
set_handlers(c->sock2, NULL, NULL, NULL, NULL);
close_socket(&c->sock2);
inf->conn_st = 2;
return;
}
setcstate(c, -errno);
retry_connection(c);
return;
}
if (l > 0) {
if (!inf->dir) {
if (c->from + l < 0) {
setcstate(c, S_LARGE_FILE);
abort_connection(c);
return;
}
c->received += l;
if (add_fragment(c->cache, c->from, inf->ftp_buffer, l) == 1) c->tries = 0;
c->from += l;
} else {
int m;
c->received += l;
m = ftp_process_dirlist(c->cache, &c->from, &inf->dpos, inf->ftp_buffer, l + inf->buf_pos, 0, &c->tries);
memmove(inf->ftp_buffer, inf->ftp_buffer + m, inf->buf_pos + l - m);
inf->buf_pos += l - m;
}
setcstate(c, S_TRANS);
return;
}
ftp_process_dirlist(c->cache, &c->from, &inf->dpos, inf->ftp_buffer, inf->buf_pos, 1, &c->tries);
set_handlers(c->sock2, NULL, NULL, NULL, NULL);
close_socket(&c->sock2);
if (inf->conn_st == 1) {
setcstate(c, S_OK);
ftp_end_request(c);
} else {
inf->conn_st = 2;
}
}
void ftp_end_request(struct connection *c)
{
if (c->state == S_OK) {
if (c->cache) {
truncate_entry(c->cache, c->from, 1);
c->cache->incomplete = 0;
}
}
add_keepalive_socket(c, FTP_KEEPALIVE_TIMEOUT);
}