interface/vchiq_arm/vchiq_arm.c

231 	VCHIQ_HEADER_T *header, USER_SERVICE_T *user_service,
265 	completion->service_userdata = user_service->service;
271 		lock_service(user_service->service);
273 			user_service->close_pending = 1;
281 		user_service->message_available_pos = insert;
305 	USER_SERVICE_T *user_service;
315 	user_service = (USER_SERVICE_T *)service->base.userdata;
316 	instance = user_service->instance;
324 		(unsigned long)user_service,
325 		service->localport, user_service->userdata,
329 	if (header && user_service->is_vchi) {
331 		while (user_service->msg_insert ==
332 			(user_service->msg_remove + MSG_QUEUE_SIZE)) {
341 			if ((user_service->message_available_pos -
348 					NULL, user_service, bulk_userdata);
356 			if (down_interruptible(&user_service->remove_event)
372 		user_service->msg_queue[user_service->msg_insert &
374 		user_service->msg_insert++;
380 		if (((user_service->message_available_pos -
382 			user_service->dequeue_pending) {
383 			user_service->dequeue_pending = 0;
389 		up(&user_service->insert_event);
401 	return add_completion(instance, reason, header, user_service,
413 	USER_SERVICE_T *user_service = userdata;
415 	_sema_destroy(&user_service->insert_event);
416 	_sema_destroy(&user_service->remove_event);
418 	kfree(user_service);
426 static void close_delivered(USER_SERVICE_T *user_service)
430 		user_service->service->handle);
432 	if (user_service->close_pending) {
434 		unlock_service(user_service->service);
437 		up(&user_service->close_event);
439 		user_service->close_pending = 0;
521 		USER_SERVICE_T *user_service = NULL;
526 		user_service = kzalloc(sizeof(USER_SERVICE_T), GFP_KERNEL);
527 		if (!user_service) {
535 				kfree(user_service);
548 		pargs->params.userdata = user_service;
550 		args.params.userdata = user_service;
557 			user_service->service = service;
558 			user_service->userdata = userdata;
559 			user_service->instance = instance;
560 			user_service->is_vchi = (args.is_vchi != 0);
561 			user_service->dequeue_pending = 0;
562 			user_service->close_pending = 0;
563 			user_service->message_available_pos =
565 			user_service->msg_insert = 0;
566 			user_service->msg_remove = 0;
567 			_sema_init(&user_service->insert_event, 0);
568 			_sema_init(&user_service->remove_event, 0);
569 			_sema_init(&user_service->close_event, 0);
591 			kfree(user_service);
604 			USER_SERVICE_T *user_service =
608 			if (!user_service->close_pending) {
617 			if (user_service->close_pending &&
618 				down_interruptible(&user_service->close_event))
634 			USER_SERVICE_T *user_service =
638 			if (!user_service->close_pending) {
647 			if (user_service->close_pending &&
648 				down_interruptible(&user_service->close_event))
836 				USER_SERVICE_T *user_service;
852 				user_service = service1->base.userdata;
854 					user_service->userdata;
946 		USER_SERVICE_T *user_service;
955 		user_service = (USER_SERVICE_T *)service->base.userdata;
956 		if (user_service->is_vchi == 0) {
962 		if (user_service->msg_remove == user_service->msg_insert) {
969 			user_service->dequeue_pending = 1;
974 					&user_service->insert_event) != 0) {
981 			} while (user_service->msg_remove ==
982 				user_service->msg_insert);
988 		BUG_ON((int)(user_service->msg_insert -
989 			user_service->msg_remove) < 0);
991 		header = user_service->msg_queue[user_service->msg_remove &
993 		user_service->msg_remove++;
996 		up(&user_service->remove_event);
1086 			USER_SERVICE_T *user_service =
1088 			close_delivered(user_service);
1248 			USER_SERVICE_T *user_service = service->base.userdata;
1251 			up(&user_service->remove_event);
1261 			USER_SERVICE_T *user_service = service->base.userdata;
1269 			while (user_service->msg_remove !=
1270 				user_service->msg_insert) {
1271 				VCHIQ_HEADER_T *header = user_service->
1272 					msg_queue[user_service->msg_remove &
1274 				user_service->msg_remove++;
1300 				USER_SERVICE_T *user_service =
1305 					up(&user_service->close_event);
1443 	USER_SERVICE_T *user_service = (USER_SERVICE_T *)service->base.userdata;
1451 		user_service->is_vchi) {
1454 			user_service->msg_insert - user_service->msg_remove,
1457 		if (user_service->dequeue_pending)