591 	struct asyncio_reader *reader;  in new_asyncio_reader()  local
593 	reader = emalloc_zero(sizeof(*reader));  in new_asyncio_reader()
594 	reader->fd = INVALID_SOCKET;  in new_asyncio_reader()
596 	return reader;  in new_asyncio_reader()
604 	struct asyncio_reader *reader  in delete_asyncio_reader()  argument
607 	free(reader);  in delete_asyncio_reader()
615 	struct asyncio_reader *	reader,  in add_asyncio_reader()  argument
618 	LINK_SLIST(asyncio_reader_list, reader, link);  in add_asyncio_reader()
619 	add_fd_to_list(reader->fd, type);  in add_asyncio_reader()
627 	struct asyncio_reader *reader  in remove_asyncio_reader()  argument
632 	UNLINK_SLIST(unlinked, asyncio_reader_list, reader, link,  in remove_asyncio_reader()
635 	if (reader->fd != INVALID_SOCKET) {  in remove_asyncio_reader()
636 		close_and_delete_fd_from_list(reader->fd, NULL);  in remove_asyncio_reader()
638 	reader->fd = INVALID_SOCKET;  in remove_asyncio_reader()
4745 process_routing_msgs(struct asyncio_reader *reader)  argument
4771 	cnt = read(reader->fd, buffer, buffsz);
4777 			if (0 > getsockopt(reader->fd, SOL_SOCKET, SO_RCVBUF, &cnt, &len) ||
4785 			if (0 > setsockopt(reader->fd, SOL_SOCKET, SO_RCVBUF, &new, sizeof new)) {
4795 			remove_asyncio_reader(reader);
4796 			delete_asyncio_reader(reader);
4819 			remove_asyncio_reader(reader);
4820 			delete_asyncio_reader(reader);
4896 	struct asyncio_reader *reader;  local
4928 	reader = new_asyncio_reader();
4930 	reader->fd = fd;
4931 	reader->receiver = process_routing_msgs;
4933 	add_asyncio_reader(reader, FD_TYPE_SOCKET);