^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 1) // SPDX-License-Identifier: GPL-2.0
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 2) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 3) * Media device request objects
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 4) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 5) * Copyright 2018 Cisco Systems, Inc. and/or its affiliates. All rights reserved.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 6) * Copyright (C) 2018 Intel Corporation
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 7) * Copyright (C) 2018 Google, Inc.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 8) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 9) * Author: Hans Verkuil <hans.verkuil@cisco.com>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 10) * Author: Sakari Ailus <sakari.ailus@linux.intel.com>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 11) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 12)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 13) #include <linux/anon_inodes.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 14) #include <linux/file.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 15) #include <linux/refcount.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 16)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 17) #include <media/media-device.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 18) #include <media/media-request.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 19)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 20) static const char * const request_state[] = {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 21) [MEDIA_REQUEST_STATE_IDLE] = "idle",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 22) [MEDIA_REQUEST_STATE_VALIDATING] = "validating",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 23) [MEDIA_REQUEST_STATE_QUEUED] = "queued",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 24) [MEDIA_REQUEST_STATE_COMPLETE] = "complete",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 25) [MEDIA_REQUEST_STATE_CLEANING] = "cleaning",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 26) [MEDIA_REQUEST_STATE_UPDATING] = "updating",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 27) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 28)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 29) static const char *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 30) media_request_state_str(enum media_request_state state)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 31) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 32) BUILD_BUG_ON(ARRAY_SIZE(request_state) != NR_OF_MEDIA_REQUEST_STATE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 33)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 34) if (WARN_ON(state >= ARRAY_SIZE(request_state)))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 35) return "invalid";
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 36) return request_state[state];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 37) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 38)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 39) static void media_request_clean(struct media_request *req)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 40) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 41) struct media_request_object *obj, *obj_safe;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 42)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 43) /* Just a sanity check. No other code path is allowed to change this. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 44) WARN_ON(req->state != MEDIA_REQUEST_STATE_CLEANING);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 45) WARN_ON(req->updating_count);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 46) WARN_ON(req->access_count);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 47)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 48) list_for_each_entry_safe(obj, obj_safe, &req->objects, list) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 49) media_request_object_unbind(obj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 50) media_request_object_put(obj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 51) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 52)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 53) req->updating_count = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 54) req->access_count = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 55) WARN_ON(req->num_incomplete_objects);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 56) req->num_incomplete_objects = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 57) wake_up_interruptible_all(&req->poll_wait);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 58) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 59)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 60) static void media_request_release(struct kref *kref)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 61) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 62) struct media_request *req =
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 63) container_of(kref, struct media_request, kref);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 64) struct media_device *mdev = req->mdev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 65)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 66) dev_dbg(mdev->dev, "request: release %s\n", req->debug_str);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 67)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 68) /* No other users, no need for a spinlock */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 69) req->state = MEDIA_REQUEST_STATE_CLEANING;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 70)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 71) media_request_clean(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 72)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 73) if (mdev->ops->req_free)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 74) mdev->ops->req_free(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 75) else
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 76) kfree(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 77) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 78)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 79) void media_request_put(struct media_request *req)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 80) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 81) kref_put(&req->kref, media_request_release);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 82) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 83) EXPORT_SYMBOL_GPL(media_request_put);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 84)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 85) static int media_request_close(struct inode *inode, struct file *filp)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 86) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 87) struct media_request *req = filp->private_data;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 88)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 89) media_request_put(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 90) return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 91) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 92)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 93) static __poll_t media_request_poll(struct file *filp,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 94) struct poll_table_struct *wait)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 95) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 96) struct media_request *req = filp->private_data;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 97) unsigned long flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 98) __poll_t ret = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 99)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 100) if (!(poll_requested_events(wait) & EPOLLPRI))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 101) return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 102)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 103) poll_wait(filp, &req->poll_wait, wait);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 104) spin_lock_irqsave(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 105) if (req->state == MEDIA_REQUEST_STATE_COMPLETE) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 106) ret = EPOLLPRI;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 107) goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 108) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 109) if (req->state != MEDIA_REQUEST_STATE_QUEUED) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 110) ret = EPOLLERR;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 111) goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 112) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 113)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 114) unlock:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 115) spin_unlock_irqrestore(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 116) return ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 117) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 118)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 119) static long media_request_ioctl_queue(struct media_request *req)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 120) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 121) struct media_device *mdev = req->mdev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 122) enum media_request_state state;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 123) unsigned long flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 124) int ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 125)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 126) dev_dbg(mdev->dev, "request: queue %s\n", req->debug_str);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 127)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 128) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 129) * Ensure the request that is validated will be the one that gets queued
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 130) * next by serialising the queueing process. This mutex is also used
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 131) * to serialize with canceling a vb2 queue and with setting values such
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 132) * as controls in a request.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 133) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 134) mutex_lock(&mdev->req_queue_mutex);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 135)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 136) media_request_get(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 137)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 138) spin_lock_irqsave(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 139) if (req->state == MEDIA_REQUEST_STATE_IDLE)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 140) req->state = MEDIA_REQUEST_STATE_VALIDATING;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 141) state = req->state;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 142) spin_unlock_irqrestore(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 143) if (state != MEDIA_REQUEST_STATE_VALIDATING) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 144) dev_dbg(mdev->dev,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 145) "request: unable to queue %s, request in state %s\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 146) req->debug_str, media_request_state_str(state));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 147) media_request_put(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 148) mutex_unlock(&mdev->req_queue_mutex);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 149) return -EBUSY;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 150) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 151)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 152) ret = mdev->ops->req_validate(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 153)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 154) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 155) * If the req_validate was successful, then we mark the state as QUEUED
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 156) * and call req_queue. The reason we set the state first is that this
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 157) * allows req_queue to unbind or complete the queued objects in case
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 158) * they are immediately 'consumed'. State changes from QUEUED to another
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 159) * state can only happen if either the driver changes the state or if
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 160) * the user cancels the vb2 queue. The driver can only change the state
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 161) * after each object is queued through the req_queue op (and note that
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 162) * that op cannot fail), so setting the state to QUEUED up front is
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 163) * safe.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 164) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 165) * The other reason for changing the state is if the vb2 queue is
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 166) * canceled, and that uses the req_queue_mutex which is still locked
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 167) * while req_queue is called, so that's safe as well.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 168) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 169) spin_lock_irqsave(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 170) req->state = ret ? MEDIA_REQUEST_STATE_IDLE
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 171) : MEDIA_REQUEST_STATE_QUEUED;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 172) spin_unlock_irqrestore(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 173)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 174) if (!ret)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 175) mdev->ops->req_queue(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 176)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 177) mutex_unlock(&mdev->req_queue_mutex);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 178)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 179) if (ret) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 180) dev_dbg(mdev->dev, "request: can't queue %s (%d)\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 181) req->debug_str, ret);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 182) media_request_put(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 183) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 184)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 185) return ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 186) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 187)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 188) static long media_request_ioctl_reinit(struct media_request *req)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 189) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 190) struct media_device *mdev = req->mdev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 191) unsigned long flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 192)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 193) spin_lock_irqsave(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 194) if (req->state != MEDIA_REQUEST_STATE_IDLE &&
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 195) req->state != MEDIA_REQUEST_STATE_COMPLETE) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 196) dev_dbg(mdev->dev,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 197) "request: %s not in idle or complete state, cannot reinit\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 198) req->debug_str);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 199) spin_unlock_irqrestore(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 200) return -EBUSY;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 201) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 202) if (req->access_count) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 203) dev_dbg(mdev->dev,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 204) "request: %s is being accessed, cannot reinit\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 205) req->debug_str);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 206) spin_unlock_irqrestore(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 207) return -EBUSY;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 208) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 209) req->state = MEDIA_REQUEST_STATE_CLEANING;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 210) spin_unlock_irqrestore(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 211)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 212) media_request_clean(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 213)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 214) spin_lock_irqsave(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 215) req->state = MEDIA_REQUEST_STATE_IDLE;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 216) spin_unlock_irqrestore(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 217)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 218) return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 219) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 220)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 221) static long media_request_ioctl(struct file *filp, unsigned int cmd,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 222) unsigned long arg)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 223) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 224) struct media_request *req = filp->private_data;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 225)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 226) switch (cmd) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 227) case MEDIA_REQUEST_IOC_QUEUE:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 228) return media_request_ioctl_queue(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 229) case MEDIA_REQUEST_IOC_REINIT:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 230) return media_request_ioctl_reinit(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 231) default:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 232) return -ENOIOCTLCMD;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 233) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 234) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 235)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 236) static const struct file_operations request_fops = {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 237) .owner = THIS_MODULE,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 238) .poll = media_request_poll,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 239) .unlocked_ioctl = media_request_ioctl,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 240) #ifdef CONFIG_COMPAT
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 241) .compat_ioctl = media_request_ioctl,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 242) #endif /* CONFIG_COMPAT */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 243) .release = media_request_close,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 244) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 245)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 246) struct media_request *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 247) media_request_get_by_fd(struct media_device *mdev, int request_fd)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 248) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 249) struct fd f;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 250) struct media_request *req;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 251)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 252) if (!mdev || !mdev->ops ||
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 253) !mdev->ops->req_validate || !mdev->ops->req_queue)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 254) return ERR_PTR(-EBADR);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 255)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 256) f = fdget(request_fd);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 257) if (!f.file)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 258) goto err_no_req_fd;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 259)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 260) if (f.file->f_op != &request_fops)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 261) goto err_fput;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 262) req = f.file->private_data;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 263) if (req->mdev != mdev)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 264) goto err_fput;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 265)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 266) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 267) * Note: as long as someone has an open filehandle of the request,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 268) * the request can never be released. The fdget() above ensures that
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 269) * even if userspace closes the request filehandle, the release()
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 270) * fop won't be called, so the media_request_get() always succeeds
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 271) * and there is no race condition where the request was released
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 272) * before media_request_get() is called.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 273) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 274) media_request_get(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 275) fdput(f);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 276)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 277) return req;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 278)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 279) err_fput:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 280) fdput(f);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 281)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 282) err_no_req_fd:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 283) dev_dbg(mdev->dev, "cannot find request_fd %d\n", request_fd);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 284) return ERR_PTR(-EINVAL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 285) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 286) EXPORT_SYMBOL_GPL(media_request_get_by_fd);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 287)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 288) int media_request_alloc(struct media_device *mdev, int *alloc_fd)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 289) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 290) struct media_request *req;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 291) struct file *filp;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 292) int fd;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 293) int ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 294)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 295) /* Either both are NULL or both are non-NULL */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 296) if (WARN_ON(!mdev->ops->req_alloc ^ !mdev->ops->req_free))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 297) return -ENOMEM;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 298)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 299) if (mdev->ops->req_alloc)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 300) req = mdev->ops->req_alloc(mdev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 301) else
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 302) req = kzalloc(sizeof(*req), GFP_KERNEL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 303) if (!req)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 304) return -ENOMEM;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 305)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 306) fd = get_unused_fd_flags(O_CLOEXEC);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 307) if (fd < 0) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 308) ret = fd;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 309) goto err_free_req;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 310) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 311)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 312) filp = anon_inode_getfile("request", &request_fops, NULL, O_CLOEXEC);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 313) if (IS_ERR(filp)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 314) ret = PTR_ERR(filp);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 315) goto err_put_fd;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 316) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 317)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 318) filp->private_data = req;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 319) req->mdev = mdev;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 320) req->state = MEDIA_REQUEST_STATE_IDLE;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 321) req->num_incomplete_objects = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 322) kref_init(&req->kref);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 323) INIT_LIST_HEAD(&req->objects);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 324) spin_lock_init(&req->lock);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 325) init_waitqueue_head(&req->poll_wait);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 326) req->updating_count = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 327) req->access_count = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 328)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 329) *alloc_fd = fd;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 330)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 331) snprintf(req->debug_str, sizeof(req->debug_str), "%u:%d",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 332) atomic_inc_return(&mdev->request_id), fd);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 333) dev_dbg(mdev->dev, "request: allocated %s\n", req->debug_str);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 334)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 335) fd_install(fd, filp);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 336)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 337) return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 338)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 339) err_put_fd:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 340) put_unused_fd(fd);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 341)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 342) err_free_req:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 343) if (mdev->ops->req_free)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 344) mdev->ops->req_free(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 345) else
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 346) kfree(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 347)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 348) return ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 349) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 350)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 351) static void media_request_object_release(struct kref *kref)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 352) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 353) struct media_request_object *obj =
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 354) container_of(kref, struct media_request_object, kref);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 355) struct media_request *req = obj->req;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 356)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 357) if (WARN_ON(req))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 358) media_request_object_unbind(obj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 359) obj->ops->release(obj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 360) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 361)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 362) struct media_request_object *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 363) media_request_object_find(struct media_request *req,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 364) const struct media_request_object_ops *ops,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 365) void *priv)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 366) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 367) struct media_request_object *obj;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 368) struct media_request_object *found = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 369) unsigned long flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 370)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 371) if (WARN_ON(!ops || !priv))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 372) return NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 373)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 374) spin_lock_irqsave(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 375) list_for_each_entry(obj, &req->objects, list) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 376) if (obj->ops == ops && obj->priv == priv) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 377) media_request_object_get(obj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 378) found = obj;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 379) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 380) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 381) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 382) spin_unlock_irqrestore(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 383) return found;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 384) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 385) EXPORT_SYMBOL_GPL(media_request_object_find);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 386)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 387) void media_request_object_put(struct media_request_object *obj)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 388) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 389) kref_put(&obj->kref, media_request_object_release);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 390) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 391) EXPORT_SYMBOL_GPL(media_request_object_put);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 392)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 393) void media_request_object_init(struct media_request_object *obj)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 394) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 395) obj->ops = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 396) obj->req = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 397) obj->priv = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 398) obj->completed = false;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 399) INIT_LIST_HEAD(&obj->list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 400) kref_init(&obj->kref);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 401) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 402) EXPORT_SYMBOL_GPL(media_request_object_init);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 403)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 404) int media_request_object_bind(struct media_request *req,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 405) const struct media_request_object_ops *ops,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 406) void *priv, bool is_buffer,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 407) struct media_request_object *obj)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 408) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 409) unsigned long flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 410) int ret = -EBUSY;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 411)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 412) if (WARN_ON(!ops->release))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 413) return -EBADR;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 414)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 415) spin_lock_irqsave(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 416)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 417) if (WARN_ON(req->state != MEDIA_REQUEST_STATE_UPDATING))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 418) goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 419)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 420) obj->req = req;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 421) obj->ops = ops;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 422) obj->priv = priv;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 423)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 424) if (is_buffer)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 425) list_add_tail(&obj->list, &req->objects);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 426) else
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 427) list_add(&obj->list, &req->objects);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 428) req->num_incomplete_objects++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 429) ret = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 430)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 431) unlock:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 432) spin_unlock_irqrestore(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 433) return ret;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 434) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 435) EXPORT_SYMBOL_GPL(media_request_object_bind);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 436)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 437) void media_request_object_unbind(struct media_request_object *obj)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 438) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 439) struct media_request *req = obj->req;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 440) unsigned long flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 441) bool completed = false;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 442)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 443) if (WARN_ON(!req))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 444) return;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 445)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 446) spin_lock_irqsave(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 447) list_del(&obj->list);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 448) obj->req = NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 449)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 450) if (req->state == MEDIA_REQUEST_STATE_COMPLETE)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 451) goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 452)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 453) if (WARN_ON(req->state == MEDIA_REQUEST_STATE_VALIDATING))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 454) goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 455)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 456) if (req->state == MEDIA_REQUEST_STATE_CLEANING) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 457) if (!obj->completed)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 458) req->num_incomplete_objects--;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 459) goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 460) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 461)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 462) if (WARN_ON(!req->num_incomplete_objects))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 463) goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 464)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 465) req->num_incomplete_objects--;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 466) if (req->state == MEDIA_REQUEST_STATE_QUEUED &&
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 467) !req->num_incomplete_objects) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 468) req->state = MEDIA_REQUEST_STATE_COMPLETE;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 469) completed = true;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 470) wake_up_interruptible_all(&req->poll_wait);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 471) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 472)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 473) unlock:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 474) spin_unlock_irqrestore(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 475) if (obj->ops->unbind)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 476) obj->ops->unbind(obj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 477) if (completed)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 478) media_request_put(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 479) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 480) EXPORT_SYMBOL_GPL(media_request_object_unbind);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 481)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 482) void media_request_object_complete(struct media_request_object *obj)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 483) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 484) struct media_request *req = obj->req;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 485) unsigned long flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 486) bool completed = false;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 487)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 488) spin_lock_irqsave(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 489) if (obj->completed)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 490) goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 491) obj->completed = true;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 492) if (WARN_ON(!req->num_incomplete_objects) ||
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 493) WARN_ON(req->state != MEDIA_REQUEST_STATE_QUEUED))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 494) goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 495)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 496) if (!--req->num_incomplete_objects) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 497) req->state = MEDIA_REQUEST_STATE_COMPLETE;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 498) wake_up_interruptible_all(&req->poll_wait);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 499) completed = true;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 500) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 501) unlock:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 502) spin_unlock_irqrestore(&req->lock, flags);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 503) if (completed)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 504) media_request_put(req);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 505) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 506) EXPORT_SYMBOL_GPL(media_request_object_complete);
Orange Pi5 kernel
Deprecated Linux kernel 5.10.110 for OrangePi 5/5B/5+ boards
3 Commits
0 Branches
0 Tags