io_queued
if (io_queued(conn->io) > 65536)
else if (io_queued(conn->io) == 0)
if (io_queued(conn->io) == 0)
if (io_queued(conn->io) == 0)
if (io_queued(conn->io) == 0)
w = io_queued(io);
w2 = io_queued(io);
io_queued(io)) {
io_strflags(io->flags), ssl, io_datalen(io), io_queued(io));
if (IO_WRITING(io) && !(io->flags & IO_PAUSE_OUT) && io_queued(io))
if (ev & EV_WRITE && (w = io_queued(io))) {
size_t io_queued(struct io *);
s, io_queued(s->io));
n = io_queued(s->io);
while (io_queued(s->io) < BOUNCE_HIWAT) {
s, io_queued(s->io) - n);
if (io_queued(s->io) == 0)
io_pending(io), io_queued(io));
if (IO_WRITING(io) && !(io->flags & IO_PAUSE_OUT) && io_queued(io))
if (ev & EV_WRITE && (w = io_queued(io))) {
size_t io_queued(struct io*);
w = io_queued(io);
w2 = io_queued(io);
if (IO_WRITING(io) && !(io->flags & IO_PAUSE_OUT) && io_queued(io)) {
size_t io_queued(struct io *);
if (s->datafp || (s->io && io_queued(s->io))) {
while (io_queued(s->io) < MDA_HIWAT) {
if (io_queued(s->io) == 0)
if (io_queued(s->io) == 0)
q = io_queued(s->io);
while (io_queued(s->io) < MTA_HIWAT) {
return (io_queued(s->io) - q);
total = io_queued(proto->io);