interface/vchiq_arm/vchiq_core.c

143 release_message_sync(VCHIQ_STATE_T *state, VCHIQ_HEADER_T *header);
392 	VCHIQ_HEADER_T *header, void *bulk_userdata)
397 		(unsigned int)header, (unsigned int)bulk_userdata);
398 	status = service->base.callback(reason, header, service->handle,
479 ** enough for a header. This relies on header size being a power of two, which
485 	/* Allow room for the header */
569 		VCHIQ_HEADER_T *header;
572 		header = (VCHIQ_HEADER_T *)
574 		header->msgid = VCHIQ_MSGID_PADDING;
575 		header->size = slot_space - sizeof(VCHIQ_HEADER_T);
654 			VCHIQ_HEADER_T *header =
656 			int msgid = header->msgid;
678 						"(header %x, msgid %x, "
679 						"header->msgid %x, "
680 						"header->size %x)",
684 						(unsigned int)header, msgid,
685 						header->msgid,
686 						header->size);
710 							header->size,
711 							(unsigned int)header,
718 								"=%d (header %x"
720 								"header->msgid"
721 								" %x, header->"
724 							(unsigned int)header,
726 							header->msgid,
727 							header->size);
735 			pos += calc_stride(header->size);
738 					"pfq - pos %x: header %x, msgid %x, "
739 					"header->msgid %x, header->size %x",
740 					pos, (unsigned int)header, msgid,
741 					header->msgid, header->size);
773 	VCHIQ_HEADER_T *header;
869 	header = reserve_space(state, stride, flags & QMFLAGS_IS_BLOCKING);
871 	if (!header) {
891 			(unsigned int)header, size,
903 					(header->data + pos, elements[i].data,
916 				header->data,
948 				slot_use_count, header);
956 			(unsigned int)header, size,
961 			memcpy(header->data, elements[0].data,
967 	header->msgid = msgid;
968 	header->size = size;
987 	/* Make sure the new header is visible to the peer. */
1012 	VCHIQ_HEADER_T *header;
1024 	header = (VCHIQ_HEADER_T *)SLOT_DATA_FROM_INDEX(state,
1028 		int oldmsgid = header->msgid;
1041 			(unsigned int)header, size,
1049 					(header->data + pos, elements[i].data,
1061 				0, header->data,
1070 			(unsigned int)header, size,
1075 			memcpy(header->data, elements[0].data,
1081 	header->size = size;
1082 	header->msgid = msgid;
1101 	/* Make sure the new header is visible to the peer. */
1120 	VCHIQ_HEADER_T *header, VCHIQ_SERVICE_T *service)
1126 	if (header) {
1127 		int msgid = header->msgid;
1134 		/* Rewrite the message header to prevent a double
1136 		header->msgid = msgid & ~VCHIQ_MSGID_CLAIMED;
1367 			const char *header = (queue == &service->bulk_tx) ?
1372 					header,
1383 					header,
1507 parse_open(VCHIQ_STATE_T *state, VCHIQ_HEADER_T *header)
1513 	msgid = header->msgid;
1514 	size = header->size;
1520 			(struct vchiq_open_payload *)header->data;
1526 			state->id, (unsigned int)header,
1597 			service->client_id = ((int *)header->data)[1];
1639 		VCHIQ_HEADER_T *header;
1662 		header = (VCHIQ_HEADER_T *)(state->rx_data +
1664 		DEBUG_VALUE(PARSE_HEADER, (int)header);
1665 		msgid = header->msgid;
1667 		size = header->size;
1701 						(unsigned int)header,
1711 					(unsigned int)header,
1733 				vchiq_log_dump_mem("Rcvd", 0, header->data,
1737 		if (((unsigned int)header & VCHIQ_SLOT_MASK) + calc_stride(size)
1740 				"header %x (msgid %x) - size %x too big for "
1742 				(unsigned int)header, (unsigned int)msgid,
1750 			if (!parse_open(state, header))
1757 					header->data;
1762 				state->id, (unsigned int)header, size,
1780 				state->id, (unsigned int)header,
1798 				state->id, (unsigned int)header, size,
1804 				header->msgid = msgid | VCHIQ_MSGID_CLAIMED;
1808 					VCHIQ_MESSAGE_AVAILABLE, header,
1823 				state->id, (unsigned int)header);
1852 					(void *)((int *)header->data)[0];
1853 				bulk->remote_size = ((int *)header->data)[1];
1859 					(unsigned int)header,
1918 						(unsigned int)header,
1931 				bulk->actual = *(int *)header->data;
1937 					(unsigned int)header,
1962 				state->id, (unsigned int)header, size);
1968 				state->id, (unsigned int)header, size);
1992 				state->id, (unsigned int)header, size);
2014 				state->id, msgid, (unsigned int)header, size);
2159 	VCHIQ_HEADER_T *header = (VCHIQ_HEADER_T *)SLOT_DATA_FROM_INDEX(state,
2172 		msgid = header->msgid;
2173 		size = header->size;
2185 				(unsigned int)header,
2187 			release_message_sync(state, header);
2203 				vchiq_log_dump_mem("Rcvd", 0, header->data,
2212 					header->data;
2217 				state->id, (unsigned int)header, size,
2226 			release_message_sync(state, header);
2232 				state->id, (unsigned int)header, size,
2239 					VCHIQ_MESSAGE_AVAILABLE, header,
2252 				state->id, msgid, (unsigned int)header, size);
2253 			release_message_sync(state, header);
2745 		VCHIQ_HEADER_T *header =
2748 		if (VCHIQ_MSG_DSTPORT(header->msgid) == service->localport)
2749 			release_message_sync(state, header);
2771 				VCHIQ_HEADER_T *header =
2773 				int msgid = header->msgid;
2779 						(unsigned int)header);
2780 					release_slot(state, slot_info, header,
2783 				pos += calc_stride(header->size);
2786 						"fsi - pos %x: header %x, "
2787 						"msgid %x, header->msgid %x, "
2788 						"header->size %x",
2789 						pos, (unsigned int)header,
2790 						msgid, header->msgid,
2791 						header->size);
3495 vchiq_release_message(VCHIQ_SERVICE_HANDLE_T handle, VCHIQ_HEADER_T *header)
3508 	slot_index = SLOT_INDEX_FROM_DATA(state, (void *)header);
3512 		int msgid = header->msgid;
3517 			release_slot(state, slot_info, header, service);
3520 		release_message_sync(state, header);
3526 release_message_sync(VCHIQ_STATE_T *state, VCHIQ_HEADER_T *header)
3528 	header->msgid = VCHIQ_MSGID_PADDING;