113 	struct ap_message *ap_msg;  in ap_sm_recv()  local
141 		list_for_each_entry(ap_msg, &aq->pendingq, list) {  in ap_sm_recv()
142 			if (ap_msg->psmid != aq->reply->psmid)  in ap_sm_recv()
144 			list_del_init(&ap_msg->list);  in ap_sm_recv()
147 				ap_msg->rc = -EMSGSIZE;  in ap_sm_recv()
148 				ap_msg->receive(aq, ap_msg, NULL);  in ap_sm_recv()
150 				ap_msg->receive(aq, ap_msg, aq->reply);  in ap_sm_recv()
224 	struct ap_message *ap_msg;  in ap_sm_write()  local
231 	ap_msg = list_entry(aq->requestq.next, struct ap_message, list);  in ap_sm_write()
232 	status = __ap_send(qid, ap_msg->psmid,  in ap_sm_write()
233 			   ap_msg->msg, ap_msg->len,  in ap_sm_write()
234 			   ap_msg->flags & AP_MSG_FLAG_SPECIAL);  in ap_sm_write()
242 		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()
1048 int ap_queue_message(struct ap_queue *aq, struct ap_message *ap_msg)  in ap_queue_message()  argument
1053 	BUG_ON(!ap_msg->receive);  in ap_queue_message()
1059 		list_add_tail(&ap_msg->list, &aq->requestq);  in ap_queue_message()
1086 void ap_cancel_message(struct ap_queue *aq, struct ap_message *ap_msg)  in ap_cancel_message()  argument
1091 	if (!list_empty(&ap_msg->list)) {  in ap_cancel_message()
1093 			if (tmp->psmid == ap_msg->psmid) {  in ap_cancel_message()
1099 		list_del_init(&ap_msg->list);  in ap_cancel_message()
1113 	struct ap_message *ap_msg, *next;  in __ap_flush_queue()  local
1115 	list_for_each_entry_safe(ap_msg, next, &aq->pendingq, list) {  in __ap_flush_queue()
1116 		list_del_init(&ap_msg->list);  in __ap_flush_queue()
1118 		ap_msg->rc = -EAGAIN;  in __ap_flush_queue()
1119 		ap_msg->receive(aq, ap_msg, NULL);  in __ap_flush_queue()
1121 	list_for_each_entry_safe(ap_msg, next, &aq->requestq, list) {  in __ap_flush_queue()
1122 		list_del_init(&ap_msg->list);  in __ap_flush_queue()
1124 		ap_msg->rc = -EAGAIN;  in __ap_flush_queue()
1125 		ap_msg->receive(aq, ap_msg, NULL);  in __ap_flush_queue()