+#define ustream_declare_write(us, fd, name) \
+ do { \
+ us.stream.string_data = true; \
+ us.stream.w.buffer_len = 4096; \
+ us.stream.w.max_buffers = RPC_EXEC_MAX_SIZE / 4096; \
+ us.stream.notify_write = rpc_exec_##name##_write_cb; \
+ ustream_fd_init(&us, fd); \
+ } while(0)
+
+
+typedef int (*rpc_exec_write_cb_t)(struct ustream *, void *);