struct receiver_node *rn = t->private_data;
struct private_http_recv_data *phd = rn->private_data;
+ t->ret = -E_HTTP_RECV_EOF;
+ if (rn->output_eof && *rn->output_eof) {
+ rn->eof = 1;
+ return;
+ }
t->ret = 1;
if (!s->select_ret) /* we're not interested in timeouts */
return;
}
t->ret = -E_OVERRUN;
/* already streaming */
- if (rn->loaded >= BUFSIZE)
+ if (rn->loaded >= BUFSIZE) {
+ rn->eof = 1;
return;
+ }
t->ret = recv_bin_buffer(phd->fd, rn->buf + rn->loaded,
BUFSIZE - rn->loaded);
if (t->ret <= 0) {