interface/vchiq_arm/vchiq_core.c

782 	 * to the available queue.
1239 		/* Add to the freed queue */
1285 notify_bulks(struct vchiq_service *service, struct vchiq_bulk_queue *queue,
1293 		(queue == &service->bulk_tx) ? 't' : 'r',
1294 		queue->process, queue->remote_notify, queue->remove);
1296 	queue->remote_notify = queue->process;
1298 	while (queue->remove != queue->remote_notify) {
1300 			&queue->bulks[BULK_INDEX(queue->remove)];
1340 		queue->remove++;
1347 		request_poll(service->state, service, (queue == &service->bulk_tx) ?
1413 			struct vchiq_bulk_queue *queue)
1415 	int is_tx = (queue == &service->bulk_tx);
1420 		is_tx ? 't' : 'r', queue->local_insert,
1421 		queue->remote_insert, queue->process);
1423 	WARN_ON((int)(queue->local_insert - queue->process) < 0);
1424 	WARN_ON((int)(queue->remote_insert - queue->process) < 0);
1426 	while ((queue->process != queue->local_insert) ||
1427 	       (queue->process != queue->remote_insert)) {
1428 		struct vchiq_bulk *bulk = &queue->bulks[BULK_INDEX(queue->process)];
1430 		if (queue->process == queue->remote_insert) {
1434 			queue->remote_insert++;
1437 		if (queue->process != queue->local_insert) {
1452 			queue->local_insert++;
1455 		queue->process++;
1714 			struct vchiq_bulk_queue *queue;
1717 			queue = (type == VCHIQ_MSG_BULK_RX_DONE) ?
1725 			if ((int)(queue->remote_insert -
1726 				queue->local_insert) >= 0) {
1730 					localport, queue->remote_insert, queue->local_insert);
1734 			if (queue->process != queue->remote_insert) {
1736 					__func__, queue->process,
1737 					queue->remote_insert);
1742 			bulk = &queue->bulks[BULK_INDEX(queue->remote_insert)];
1744 			queue->remote_insert++;
1753 				queue->local_insert, queue->remote_insert, queue->process);
1756 			WARN_ON(queue->process == queue->local_insert);
1758 			queue->process++;
1761 			notify_bulks(service, queue, RETRY_POLL);
2979 	struct vchiq_bulk_queue *queue;
3021 	queue = (dir == VCHIQ_BULK_TRANSMIT) ?
3029 	if (queue->local_insert == queue->remove + VCHIQ_NUM_SERVICE_BULKS) {
3041 		} while (queue->local_insert == queue->remove +
3045 	bulk = &queue->bulks[BULK_INDEX(queue->local_insert)];
3094 	queue->local_insert++;
3100 		state->id, service->localport, dir_char, queue->local_insert,
3101 		queue->remote_insert, queue->process);