Searched refs:io_queued (Results 1 – 9 of 9) sorted by relevance
79 size_t io_queued(struct io*);118 io_pending(io), io_queued(io)); in io_strio()476 io_queued(struct io *io) in io_queued() function540 if (IO_WRITING(io) && !(io->flags & IO_PAUSE_OUT) && io_queued(io)) in io_reload()689 if (ev & EV_WRITE && (w = io_queued(io))) { in io_dispatch()937 w = io_queued(io); in io_dispatch_write_tls()954 w2 = io_queued(io); in io_dispatch_write_tls()975 if (IO_WRITING(io) && !(io->flags & IO_PAUSE_OUT) && io_queued(io)) { in io_reload_tls()
524 s, io_queued(s->io)); in bounce_next()537 n = io_queued(s->io); in bounce_next()538 while (io_queued(s->io) < BOUNCE_HIWAT) { in bounce_next()573 s, io_queued(s->io) - n); in bounce_next()761 if (io_queued(s->io) == 0) in bounce_io()
66 size_t io_queued(struct io *);
331 if (s->datafp || (s->io && io_queued(s->io))) { in mda_imsg()414 while (io_queued(s->io) < MDA_HIWAT) { in mda_io()448 if (io_queued(s->io) == 0) in mda_io()
1353 if (io_queued(s->io) == 0) in mta_io()1436 q = io_queued(s->io); in mta_queue_data()1438 while (io_queued(s->io) < MTA_HIWAT) { in mta_queue_data()1458 return (io_queued(s->io) - q); in mta_queue_data()
836 total = io_queued(proto->io); in smtp_client_sendbody()
138 io_strflags(io->flags), ssl, io_datalen(io), io_queued(io)); in io_strio()491 io_queued(struct io *io) in io_queued() function635 if (IO_WRITING(io) && !(io->flags & IO_PAUSE_OUT) && io_queued(io)) in io_reload()772 if (ev & EV_WRITE && (w = io_queued(io))) { in io_dispatch()1078 w = io_queued(io); in io_dispatch_write_tls()1103 w2 = io_queued(io); in io_dispatch_write_tls()1135 io_queued(io)) { in io_reload_tls()
671 if (io_queued(conn->io) > 65536) in lpr_stream()700 else if (io_queued(conn->io) == 0) in lpr_stream()718 if (io_queued(conn->io) == 0) in lpr_forward()728 if (io_queued(conn->io) == 0) in lpr_forward()788 if (io_queued(conn->io) == 0) in lpr_iofwd_dispatch()
79 size_t io_queued(struct io *);