intel/common/sst-ipc.c

34 	struct ipc_message *msg = NULL;
37 		msg = list_first_entry(&ipc->empty_list, struct ipc_message,
39 		list_del(&msg->list);
42 	return msg;
46 	struct ipc_message *msg, struct sst_ipc_message *reply)
52 	ret = wait_event_timeout(msg->waitq, msg->complete,
60 		list_del(&msg->list);
66 			reply->header = msg->rx.header;
68 				memcpy(reply->data, msg->rx.data, msg->rx.size);
70 		ret = msg->errno;
73 	list_add_tail(&msg->list, &ipc->empty_list);
82 	struct ipc_message *msg;
87 	msg = msg_get_empty(ipc);
88 	if (msg == NULL) {
93 	msg->tx.header = request.header;
94 	msg->tx.size = request.size;
95 	msg->rx.header = 0;
96 	msg->rx.size = reply ? reply->size : 0;
97 	msg->wait = wait;
98 	msg->errno = 0;
99 	msg->pending = false;
100 	msg->complete = false;
103 		ipc->ops.tx_data_copy(msg, request.data, request.size);
105 	list_add_tail(&msg->list, &ipc->tx_list);
110 		return tx_wait_done(ipc, msg, reply);
119 	ipc->msg = kcalloc(IPC_EMPTY_LIST_SIZE, sizeof(struct ipc_message),
121 	if (ipc->msg == NULL)
125 		ipc->msg[i].tx.data = kzalloc(ipc->tx_data_max_size, GFP_KERNEL);
126 		if (ipc->msg[i].tx.data == NULL)
129 		ipc->msg[i].rx.data = kzalloc(ipc->rx_data_max_size, GFP_KERNEL);
130 		if (ipc->msg[i].rx.data == NULL) {
131 			kfree(ipc->msg[i].tx.data);
135 		init_waitqueue_head(&ipc->msg[i].waitq);
136 		list_add(&ipc->msg[i].list, &ipc->empty_list);
143 		kfree(ipc->msg[i-1].tx.data);
144 		kfree(ipc->msg[i-1].rx.data);
147 	kfree(ipc->msg);
156 	struct ipc_message *msg;
170 		msg = list_first_entry(&ipc->tx_list, struct ipc_message, list);
171 		list_move(&msg->list, &ipc->rx_list);
174 			ipc->ops.tx_msg(ipc, msg);
221 	struct ipc_message *msg;
235 	list_for_each_entry(msg, &ipc->rx_list, list) {
236 		if ((msg->tx.header & mask) == header)
237 			return msg;
246 	struct ipc_message *msg)
248 	msg->complete = true;
250 	if (!msg->wait)
251 		list_add_tail(&msg->list, &ipc->empty_list);
253 		wake_up(&msg->waitq);
281 	if (ipc->msg) {
283 			kfree(ipc->msg[i].tx.data);
284 			kfree(ipc->msg[i].rx.data);
286 		kfree(ipc->msg);