134 	struct ap_message *ap_msg;  in ap_sm_recv()  local
144 		list_for_each_entry(ap_msg, &aq->pendingq, list) {  in ap_sm_recv()
145 			if (ap_msg->psmid != aq->reply->psmid)  in ap_sm_recv()
147 			list_del_init(&ap_msg->list);  in ap_sm_recv()
149 			ap_msg->receive(aq, ap_msg, aq->reply);  in ap_sm_recv()
233 	struct ap_message *ap_msg;  in ap_sm_write()  local
238 	ap_msg = list_entry(aq->requestq.next, struct ap_message, list);  in ap_sm_write()
239 	status = __ap_send(aq->qid, ap_msg->psmid,  in ap_sm_write()
240 			   ap_msg->message, ap_msg->length, ap_msg->special);  in ap_sm_write()
246 		list_move_tail(&ap_msg->list, &aq->pendingq);  in ap_sm_write()
262 		list_del_init(&ap_msg->list);  in ap_sm_write()
264 		ap_msg->rc = -EINVAL;  in ap_sm_write()
265 		ap_msg->receive(aq, ap_msg, NULL);  in ap_sm_write()
637 void ap_queue_message(struct ap_queue *aq, struct ap_message *ap_msg)  in ap_queue_message()  argument
642 	BUG_ON(!ap_msg->receive);  in ap_queue_message()
646 	list_add_tail(&ap_msg->list, &aq->requestq);  in ap_queue_message()
666 void ap_cancel_message(struct ap_queue *aq, struct ap_message *ap_msg)  in ap_cancel_message()  argument
671 	if (!list_empty(&ap_msg->list)) {  in ap_cancel_message()
673 			if (tmp->psmid == ap_msg->psmid) {  in ap_cancel_message()
679 		list_del_init(&ap_msg->list);  in ap_cancel_message()
693 	struct ap_message *ap_msg, *next;  in __ap_flush_queue()  local
695 	list_for_each_entry_safe(ap_msg, next, &aq->pendingq, list) {  in __ap_flush_queue()
696 		list_del_init(&ap_msg->list);  in __ap_flush_queue()
698 		ap_msg->rc = -EAGAIN;  in __ap_flush_queue()
699 		ap_msg->receive(aq, ap_msg, NULL);  in __ap_flush_queue()
701 	list_for_each_entry_safe(ap_msg, next, &aq->requestq, list) {  in __ap_flush_queue()
702 		list_del_init(&ap_msg->list);  in __ap_flush_queue()
704 		ap_msg->rc = -EAGAIN;  in __ap_flush_queue()
705 		ap_msg->receive(aq, ap_msg, NULL);  in __ap_flush_queue()