void (*notify_write)(struct ustream *s, int bytes);
/*
- * notify_state:
+ * notify_state: (optional)
* called by the ustream implementation to notify that the read
* side of the stream is closed (eof is set) or there was a write
* error (write_error is set).
return !!(s->read_blocked & READ_BLOCKED_USER);
}
+static inline bool ustream_read_buf_full(struct ustream *s)
+{
+ return s->r.data_bytes == s->r.buffer_len;
+}
+
/*** --- functions only used by ustream implementations --- ***/
/* ustream_init_defaults: fill default callbacks and options */