Lines Matching defs:reader
604 struct asyncio_reader *reader;
606 reader = emalloc_zero(sizeof(*reader));
607 reader->fd = INVALID_SOCKET;
609 return reader;
613 * delete a reader
617 struct asyncio_reader *reader
620 free(reader);
628 struct asyncio_reader * reader,
631 LINK_SLIST(asyncio_reader_list, reader, link);
632 add_fd_to_list(reader->fd, type);
640 struct asyncio_reader *reader
645 UNLINK_SLIST(unlinked, asyncio_reader_list, reader, link,
648 if (reader->fd != INVALID_SOCKET)
649 close_and_delete_fd_from_list(reader->fd);
651 reader->fd = INVALID_SOCKET;
4617 process_routing_msgs(struct asyncio_reader *reader)
4633 remove_asyncio_reader(reader);
4634 delete_asyncio_reader(reader);
4638 cnt = read(reader->fd, buffer, sizeof(buffer));
4647 remove_asyncio_reader(reader);
4648 delete_asyncio_reader(reader);
4671 remove_asyncio_reader(reader);
4672 delete_asyncio_reader(reader);
4748 struct asyncio_reader *reader;
4780 reader = new_asyncio_reader();
4782 reader->fd = fd;
4783 reader->receiver = process_routing_msgs;
4785 add_asyncio_reader(reader, FD_TYPE_SOCKET);