+rpc_exec_ipipe_write_cb(struct ustream *s, int bytes)
+{
+ struct rpc_exec_context *c =
+ container_of(s, struct rpc_exec_context, ipipe.stream);
+
+ if (c->stdin_cb(s, c->priv) <= 0)
+ {
+ ustream_free(&c->ipipe.stream);
+ close(c->ipipe.fd.fd);
+ }
+}
+
+static void