#include "ustream.h"
-void ustream_init_buf(struct ustream_buf *buf, int len)
+static void ustream_init_buf(struct ustream_buf *buf, int len)
{
if (!len)
abort();
static void ustream_add_buf(struct ustream_buf_list *l, struct ustream_buf *buf)
{
+ l->buffers++;
if (!l->tail)
l->head = buf;
else
if (s->write_error)
ustream_free_buffers(&s->w);
- s->notify_state(s);
+ if (s->notify_state)
+ s->notify_state(s);
}
void ustream_init_defaults(struct ustream *s)
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;
int ustream_write(struct ustream *s, const char *data, int len, bool more)
{
struct ustream_buf_list *l = &s->w;
- int wr;
+ int wr = 0;
if (s->write_error)
return 0;
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);