941 	struct ap_message *ap_msg, *next;  in __ap_flush_queue()  local
943 	list_for_each_entry_safe(ap_msg, next, &ap_dev->pendingq, list) {  in __ap_flush_queue()
944 		list_del_init(&ap_msg->list);  in __ap_flush_queue()
946 		ap_msg->receive(ap_dev, ap_msg, ERR_PTR(-ENODEV));  in __ap_flush_queue()
948 	list_for_each_entry_safe(ap_msg, next, &ap_dev->requestq, list) {  in __ap_flush_queue()
949 		list_del_init(&ap_msg->list);  in __ap_flush_queue()
951 		ap_msg->receive(ap_dev, ap_msg, ERR_PTR(-ENODEV));  in __ap_flush_queue()
1563 	struct ap_message *ap_msg;  in ap_poll_read()  local
1573 		list_for_each_entry(ap_msg, &ap_dev->pendingq, list) {  in ap_poll_read()
1574 			if (ap_msg->psmid != ap_dev->reply->psmid)  in ap_poll_read()
1576 			list_del_init(&ap_msg->list);  in ap_poll_read()
1578 			ap_msg->receive(ap_dev, ap_msg, ap_dev->reply);  in ap_poll_read()
1612 	struct ap_message *ap_msg;  in ap_poll_write()  local
1618 	ap_msg = list_entry(ap_dev->requestq.next, struct ap_message, list);  in ap_poll_write()
1619 	status = __ap_send(ap_dev->qid, ap_msg->psmid,  in ap_poll_write()
1620 			   ap_msg->message, ap_msg->length, ap_msg->special);  in ap_poll_write()
1625 		list_move_tail(&ap_msg->list, &ap_dev->pendingq);  in ap_poll_write()
1674 static int __ap_queue_message(struct ap_device *ap_dev, struct ap_message *ap_msg)  in __ap_queue_message()  argument
1680 		status = __ap_send(ap_dev->qid, ap_msg->psmid,  in __ap_queue_message()
1681 				   ap_msg->message, ap_msg->length,  in __ap_queue_message()
1682 				   ap_msg->special);  in __ap_queue_message()
1685 			list_add_tail(&ap_msg->list, &ap_dev->pendingq);  in __ap_queue_message()
1693 			list_add_tail(&ap_msg->list, &ap_dev->requestq);  in __ap_queue_message()
1699 			ap_msg->receive(ap_dev, ap_msg, ERR_PTR(-EINVAL));  in __ap_queue_message()
1702 			ap_msg->receive(ap_dev, ap_msg, ERR_PTR(-ENODEV));  in __ap_queue_message()
1706 		list_add_tail(&ap_msg->list, &ap_dev->requestq);  in __ap_queue_message()
1715 void ap_queue_message(struct ap_device *ap_dev, struct ap_message *ap_msg)  in ap_queue_message()  argument
1722 	BUG_ON(!ap_msg->receive);  in ap_queue_message()
1729 			rc = __ap_queue_message(ap_dev, ap_msg);  in ap_queue_message()
1735 		ap_msg->receive(ap_dev, ap_msg, ERR_PTR(-ENODEV));  in ap_queue_message()
1754 void ap_cancel_message(struct ap_device *ap_dev, struct ap_message *ap_msg)  in ap_cancel_message()  argument
1759 	if (!list_empty(&ap_msg->list)) {  in ap_cancel_message()
1761 			if (tmp->psmid == ap_msg->psmid) {  in ap_cancel_message()
1767 		list_del_init(&ap_msg->list);  in ap_cancel_message()