static void ustream_fd_read_pending(struct ustream_fd *sf, bool *more)
{
struct ustream *s = &sf->stream;
static void ustream_fd_read_pending(struct ustream_fd *sf, bool *more)
{
struct ustream *s = &sf->stream;
ustream_fd_read_pending(sf, &more);
if (events & ULOOP_WRITE) {
ustream_fd_read_pending(sf, &more);
if (events & ULOOP_WRITE) {
- if (ustream_write_pending(s))
- ustream_fd_set_uloop(s);
+ if (!ustream_write_pending(s))
+ ustream_fd_set_uloop(s, false);
s->write = ustream_fd_write;
s->free = ustream_fd_free;
s->poll = ustream_fd_poll;
s->write = ustream_fd_write;
s->free = ustream_fd_free;
s->poll = ustream_fd_poll;