}
buf = ustream_get_read_buf(s, &len);
+ if (!buf || !len)
+ return;
+
uh_chunk_write(cl, buf, len);
ustream_consume(s, len);
}
relay_close_if_done(r);
}
+void uh_relay_kill(struct client *cl, struct relay *r)
+{
+ struct ustream *us = &r->sfd.stream;
+
+ kill(r->proc.pid, SIGKILL);
+ us->eof = true;
+ ustream_state_change(us);
+}
+
void uh_relay_open(struct client *cl, struct relay *r, int fd, int pid)
{
struct ustream *us = &r->sfd.stream;