Lines Matching refs:reader
608 struct asyncio_reader *reader;
610 reader = emalloc_zero(sizeof(*reader));
611 reader->fd = INVALID_SOCKET;
613 return reader;
617 * delete a reader
621 struct asyncio_reader *reader
624 free(reader);
632 struct asyncio_reader * reader,
635 LINK_SLIST(asyncio_reader_list, reader, link);
636 add_fd_to_list(reader->fd, type);
644 struct asyncio_reader *reader
649 UNLINK_SLIST(unlinked, asyncio_reader_list, reader, link,
652 if (reader->fd != INVALID_SOCKET)
653 close_and_delete_fd_from_list(reader->fd);
655 reader->fd = INVALID_SOCKET;
4709 process_routing_msgs(struct asyncio_reader *reader)
4725 remove_asyncio_reader(reader);
4726 delete_asyncio_reader(reader);
4730 cnt = read(reader->fd, buffer, sizeof(buffer));
4739 remove_asyncio_reader(reader);
4740 delete_asyncio_reader(reader);
4765 remove_asyncio_reader(reader);
4766 delete_asyncio_reader(reader);
4842 struct asyncio_reader *reader;
4874 reader = new_asyncio_reader();
4876 reader->fd = fd;
4877 reader->receiver = process_routing_msgs;
4879 add_asyncio_reader(reader, FD_TYPE_SOCKET);