Lines Matching defs:io
36 #include "io.h"
55 struct io *io;
67 struct io *iofwd;
81 static void lpr_io_dispatch(struct io *, int, void *);
94 static void lpr_iofwd_dispatch(struct io *, int, void *);
118 conn->io = io_new();
119 if (conn->io == NULL) {
127 io_set_callback(conn->io, lpr_io_dispatch, conn);
128 io_set_timeout(conn->io, CLIENT_TIMEOUT);
129 io_set_write(conn->io);
130 io_attach(conn->io, sock);
200 io_set_read(conn->io);
300 lpr_io_dispatch(struct io *io, int evt, void *arg)
319 io_set_write(conn->io);
324 io_set_read(conn->io);
354 log_debug("%08x io-error", conn->id);
373 line = io_getline(conn->io, NULL);
375 if (io_datalen(conn->io) >= LPR_MAXCMDLEN) {
527 data = io_data(conn->io);
528 len = io_datalen(conn->io);
540 io_drop(conn->io, w);
552 len = io_datalen(conn->io);
555 data = io_data(conn->io);
556 io_drop(conn->io, 1);
625 io_free(conn->io);
650 io_write(conn->io, &c, 1);
658 io_printf(conn->io, "%s\n", s);
671 if (io_queued(conn->io) > 65536)
688 if (io_write(conn->io, buf, r) == -1) {
700 else if (io_queued(conn->io) == 0)
718 if (io_queued(conn->io) == 0)
728 if (io_queued(conn->io) == 0)
733 io_set_timeout(conn->io, SERVER_TIMEOUT);
739 lpr_iofwd_dispatch(struct io *io, int evt, void *arg)
747 io_print(io, conn->cmd);
748 io_print(io, "\n");
749 io_set_write(io);
754 io_write(conn->io, io_data(io), io_datalen(io));
755 io_drop(io, io_datalen(io));
760 io_set_read(io);
775 log_debug("%08x forward io-error", conn->id);
784 io_free(io);
788 if (io_queued(conn->io) == 0)