r->header_cb = NULL;
if (r->header_end)
r->header_end(r);
+ ustream_consume(s, line_len);
break;
}
{
struct relay *r = container_of(proc, struct relay, proc);
+ ustream_poll(&r->sfd.stream);
r->process_done = true;
r->ret = ret;
relay_close_if_done(r);
struct ustream *us = &r->sfd.stream;
r->cl = cl;
- ustream_fd_init(&r->sfd, fd);
us->notify_read = relay_read_cb;
us->notify_state = relay_state_cb;
us->string_data = true;
+ ustream_fd_init(&r->sfd, fd);
r->proc.pid = pid;
r->proc.cb = relay_proc_cb;