", 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');
a = add_fragment(ce, *pos, str, sl);
if (a < 0) return a;
if (a == 1) *tr = 0;
*pos += sl;
mem_free(str);
goto again;
}
static void created_data_connection(struct connection *c)
{
struct ftp_connection_info *inf = c->info;
#ifdef HAVE_IPTOS
if (ftp_options.set_tos) {
int rx;
int on = IPTOS_THROUGHPUT;
EINTRLOOP(rx, setsockopt(c->sock2, IPPROTO_IP, IP_TOS, (char *)&on, sizeof(int)));
}
#endif
inf->d = 1;
set_handlers(c->sock2, (void (*)(void *))got_something_from_data_connection, NULL, NULL, c);
}
static void got_something_from_data_connection(struct connection *c)
{
struct ftp_connection_info *inf = c->info;
int l;
int m;
int rs;
set_timeout(c);
if (!inf->d) {
int ns;
inf->d = 1;
set_handlers(c->sock2, NULL, NULL, NULL, NULL);
EINTRLOOP(ns, accept(c->sock2, NULL, NULL));
if (ns == -1) goto e;
EINTRLOOP(rs, close(c->sock2));
c->sock2 = ns;
set_handlers(ns, (void (*)(void *))got_something_from_data_connection, NULL, NULL, c);
return;
}
if (!c->cache) {
if (get_cache_entry(c->url, &c->cache)) {
setcstate(c, S_OUT_OF_MEM);
abort_connection(c);
return;
}
c->cache->refcount--;
}
if (inf->dir && !c->from) {
unsigned char *ud;
unsigned char *s0;
int s0l;
int err = 0;
static unsigned char ftp_head[] = "/";
static unsigned char ftp_head2[] = "Directory /";
static unsigned char ftp_head3[] = "
";
#define A(s) \
do { \
m = add_fragment(c->cache, c->from, s, strlen(s)); \
if (m < 0 && !err) err = m; \
c->from += strlen(s); \
} while (0)
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");
if (err) {
setcstate(c, err);
abort_connection(c);
return;
}
#undef A
}
EINTRLOOP(l, read(c->sock2, inf->ftp_buffer + inf->buf_pos, FTP_BUF - inf->buf_pos));
if (l == -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, get_error_from_errno(errno));
retry_connection(c);
return;
}
if (l > 0) {
if (!inf->dir) {
if ((off_t)(0UL + c->from + l) < 0) {
setcstate(c, S_LARGE_FILE);
abort_connection(c);
return;
}
c->received += l;
m = add_fragment(c->cache, c->from, inf->ftp_buffer, l);
if (m < 0) {
setcstate(c, m);
abort_connection(c);
return;
}
if (m == 1) c->tries = 0;
c->from += l;
} else {
c->received += l;
m = ftp_process_dirlist(c->cache, &c->from, &inf->dpos, inf->ftp_buffer, l + inf->buf_pos, 0, &c->tries);
if (m < 0) {
setcstate(c, m);
abort_connection(c);
return;
}
memmove(inf->ftp_buffer, inf->ftp_buffer + m, inf->buf_pos + l - m);
inf->buf_pos += l - m;
}
setcstate(c, S_TRANS);
return;
}
m = ftp_process_dirlist(c->cache, &c->from, &inf->dpos, inf->ftp_buffer, inf->buf_pos, 1, &c->tries);
if (m < 0) {
setcstate(c, m);
abort_connection(c);
return;
}
set_handlers(c->sock2, NULL, NULL, NULL, NULL);
close_socket(&c->sock2);
if (inf->conn_st == 1) {
ftp_end_request(c, S__OK);
} else {
inf->conn_st = 2;
}
}
static void ftp_end_request(struct connection *c, int state)
{
if (state == S__OK) {
if (c->cache) {
truncate_entry(c->cache, c->from, 1);
c->cache->incomplete = 0;
}
}
setcstate(c, state);
add_keepalive_socket(c, FTP_KEEPALIVE_TIMEOUT);
}