if (s->write_error)
return false;
- while (buf) {
+ while (buf && s->w.data_bytes) {
struct ustream_buf *next = buf->next;
int maxlen = buf->tail - buf->data;
struct ustream_buf_list *l = &s->w;
struct ustream_buf *buf;
int maxlen;
+ bool has_data = !!s->w.data_bytes;
while (len) {
if (!ustream_prepare_buf(s, &s->w, len))
l->data_bytes += maxlen;
}
+ if (s->poll && !has_data)
+ s->poll(s);
+
return wr;
}
va_list arg2;
int wr, maxlen, buflen;
+ if (s->write_error)
+ return 0;
+
if (!l->data_bytes) {
buf = alloca(MAX_STACK_BUFLEN);
va_copy(arg2, arg);
va_list arg;
int ret;
+ if (s->write_error)
+ return 0;
+
va_start(arg, format);
ret = ustream_vprintf(s, format, arg);
va_end(arg);