system/linux
system/linux
1
0
Fork 0
mirror of https://github.com/torvalds/linux synced 2024-11-05 18:23:50 +00:00
Code Issues Projects Releases Packages Wiki Activity

HID: hid-sensor-hub: Allow parallel synchronous reads

Browse source 
Current implementation only allows one outstanding synchronous read.
This is a performance hit when user mode is requesting raw reads
of sensor attributes on multiple sensors together.
This change changes the mutex lock to per hid sensor hub device instead
of global lock. Although request to hid sensor hub is serialized, there
can be multiple outstanding read requests pending for responses via
hid reports.

Signed-off-by: Srinivas Pandruvada <srinivas.pandruvada@linux.intel.com>
Acked-by: Jonathan Cameron <jic23@kernel.org>
Signed-off-by: Jiri Kosina <jkosina@suse.cz>
This commit is contained in:
Srinivas Pandruvada 2015-02-19 15:31:25 -08:00 committed by Jiri Kosina
parent 870fd0f5df
commit e651a1da44
2 changed files with 65 additions and 49 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

90
drivers/hid/hid-sensor-hub.c
View file

@ -28,30 +28,11 @@
#define HID_SENSOR_HUB_ENUM_QUIRK 0x01 #define HID_SENSOR_HUB_ENUM_QUIRK 0x01
/**
* struct sensor_hub_pending - Synchronous read pending information
* @status: Pending status true/false.
* @ready: Completion synchronization data.
* @usage_id: Usage id for physical device, E.g. Gyro usage id.
* @attr_usage_id: Usage Id of a field, E.g. X-AXIS for a gyro.
* @raw_size: Response size for a read request.
* @raw_data: Place holder for received response.
*/
struct sensor_hub_pending {
bool status;
struct completion ready;
u32 usage_id;
u32 attr_usage_id;
int raw_size;
u8 *raw_data;
};
/** /**
* struct sensor_hub_data - Hold a instance data for a HID hub device * struct sensor_hub_data - Hold a instance data for a HID hub device
* @hsdev: Stored hid instance for current hub device. * @hsdev: Stored hid instance for current hub device.
* @mutex: Mutex to serialize synchronous request. * @mutex: Mutex to serialize synchronous request.
* @lock: Spin lock to protect pending request structure. * @lock: Spin lock to protect pending request structure.
* @pending: Holds information of pending sync read request.
* @dyn_callback_list: Holds callback function * @dyn_callback_list: Holds callback function
* @dyn_callback_lock: spin lock to protect callback list * @dyn_callback_lock: spin lock to protect callback list
* @hid_sensor_hub_client_devs: Stores all MFD cells for a hub instance. * @hid_sensor_hub_client_devs: Stores all MFD cells for a hub instance.
@ -61,7 +42,6 @@ struct sensor_hub_pending {
struct sensor_hub_data { struct sensor_hub_data {
struct mutex mutex; struct mutex mutex;
spinlock_t lock; spinlock_t lock;
struct sensor_hub_pending pending;
struct list_head dyn_callback_list; struct list_head dyn_callback_list;
spinlock_t dyn_callback_lock; spinlock_t dyn_callback_lock;
struct mfd_cell *hid_sensor_hub_client_devs; struct mfd_cell *hid_sensor_hub_client_devs;
@ -264,40 +244,42 @@ int sensor_hub_input_attr_get_raw_value(struct hid_sensor_hub_device *hsdev,
struct hid_report *report; struct hid_report *report;
int ret_val = 0; int ret_val = 0;
mutex_lock(&data->mutex); mutex_lock(&hsdev->mutex);
memset(&data->pending, 0, sizeof(data->pending)); memset(&hsdev->pending, 0, sizeof(hsdev->pending));
init_completion(&data->pending.ready); init_completion(&hsdev->pending.ready);
data->pending.usage_id = usage_id; hsdev->pending.usage_id = usage_id;
data->pending.attr_usage_id = attr_usage_id; hsdev->pending.attr_usage_id = attr_usage_id;
data->pending.raw_size = 0; hsdev->pending.raw_size = 0;
spin_lock_irqsave(&data->lock, flags); spin_lock_irqsave(&data->lock, flags);
data->pending.status = true; hsdev->pending.status = true;
spin_unlock_irqrestore(&data->lock, flags); spin_unlock_irqrestore(&data->lock, flags);
report = sensor_hub_report(report_id, hsdev->hdev, HID_INPUT_REPORT); report = sensor_hub_report(report_id, hsdev->hdev, HID_INPUT_REPORT);
if (!report) if (!report)
goto err_free; goto err_free;
mutex_lock(&data->mutex);
hid_hw_request(hsdev->hdev, report, HID_REQ_GET_REPORT); hid_hw_request(hsdev->hdev, report, HID_REQ_GET_REPORT);
wait_for_completion_interruptible_timeout(&data->pending.ready, HZ*5); mutex_unlock(&data->mutex);
switch (data->pending.raw_size) { wait_for_completion_interruptible_timeout(&hsdev->pending.ready, HZ*5);
switch (hsdev->pending.raw_size) {
case 1: case 1:
ret_val = *(u8 *)data->pending.raw_data; ret_val = *(u8 *)hsdev->pending.raw_data;
break; break;
case 2: case 2:
ret_val = *(u16 *)data->pending.raw_data; ret_val = *(u16 *)hsdev->pending.raw_data;
break; break;
case 4: case 4:
ret_val = *(u32 *)data->pending.raw_data; ret_val = *(u32 *)hsdev->pending.raw_data;
break; break;
default: default:
ret_val = 0; ret_val = 0;
} }
kfree(data->pending.raw_data); kfree(hsdev->pending.raw_data);
err_free: err_free:
data->pending.status = false; hsdev->pending.status = false;
mutex_unlock(&data->mutex); mutex_unlock(&hsdev->mutex);
return ret_val; return ret_val;
} }
@ -453,16 +435,6 @@ static int sensor_hub_raw_event(struct hid_device *hdev,
report->field[i]->report_count)/8); report->field[i]->report_count)/8);
sz = (report->field[i]->report_size * sz = (report->field[i]->report_size *
report->field[i]->report_count)/8; report->field[i]->report_count)/8;
if (pdata->pending.status && pdata->pending.attr_usage_id ==
report->field[i]->usage->hid) {
hid_dbg(hdev, "data was pending ...\n");
pdata->pending.raw_data = kmemdup(ptr, sz, GFP_ATOMIC);
if (pdata->pending.raw_data)
pdata->pending.raw_size = sz;
else
pdata->pending.raw_size = 0;
complete(&pdata->pending.ready);
}
collection = &hdev->collection[ collection = &hdev->collection[
report->field[i]->usage->collection_index]; report->field[i]->usage->collection_index];
hid_dbg(hdev, "collection->usage %x\n", hid_dbg(hdev, "collection->usage %x\n",
@ -472,8 +444,21 @@ static int sensor_hub_raw_event(struct hid_device *hdev,
report->field[i]->physical, report->field[i]->physical,
report->field[i]->usage[0].collection_index, report->field[i]->usage[0].collection_index,
&hsdev, &priv); &hsdev, &priv);
if (!callback) {
if (callback && callback->capture_sample) { ptr += sz;
continue;
}
if (hsdev->pending.status && hsdev->pending.attr_usage_id ==
report->field[i]->usage->hid) {
hid_dbg(hdev, "data was pending ...\n");
hsdev->pending.raw_data = kmemdup(ptr, sz, GFP_ATOMIC);
if (hsdev->pending.raw_data)
hsdev->pending.raw_size = sz;
else
hsdev->pending.raw_size = 0;
complete(&hsdev->pending.ready);
}
if (callback->capture_sample) {
if (report->field[i]->logical) if (report->field[i]->logical)
callback->capture_sample(hsdev, callback->capture_sample(hsdev,
report->field[i]->logical, sz, ptr, report->field[i]->logical, sz, ptr,
@ -628,6 +613,8 @@ static int sensor_hub_probe(struct hid_device *hdev,
hsdev->hdev = hdev; hsdev->hdev = hdev;
hsdev->vendor_id = hdev->vendor; hsdev->vendor_id = hdev->vendor;
hsdev->product_id = hdev->product; hsdev->product_id = hdev->product;
hsdev->usage = collection->usage;
mutex_init(&hsdev->mutex);
hsdev->start_collection_index = i; hsdev->start_collection_index = i;
if (last_hsdev) if (last_hsdev)
last_hsdev->end_collection_index = i; last_hsdev->end_collection_index = i;
@ -674,13 +661,18 @@ static void sensor_hub_remove(struct hid_device *hdev)
{ {
struct sensor_hub_data *data = hid_get_drvdata(hdev); struct sensor_hub_data *data = hid_get_drvdata(hdev);
unsigned long flags; unsigned long flags;
int i;
hid_dbg(hdev, " hardware removed\n"); hid_dbg(hdev, " hardware removed\n");
hid_hw_close(hdev); hid_hw_close(hdev);
hid_hw_stop(hdev); hid_hw_stop(hdev);
spin_lock_irqsave(&data->lock, flags); spin_lock_irqsave(&data->lock, flags);
if (data->pending.status) for (i = 0; i < data->hid_sensor_client_cnt; ++i) {
complete(&data->pending.ready); struct hid_sensor_hub_device *hsdev =
data->hid_sensor_hub_client_devs[i].platform_data;
if (hsdev->pending.status)
complete(&hsdev->pending.ready);
}
spin_unlock_irqrestore(&data->lock, flags); spin_unlock_irqrestore(&data->lock, flags);
mfd_remove_devices(&hdev->dev); mfd_remove_devices(&hdev->dev);
hid_set_drvdata(hdev, NULL); hid_set_drvdata(hdev, NULL);

24
include/linux/hid-sensor-hub.h
View file

@ -46,20 +46,44 @@ struct hid_sensor_hub_attribute_info {
s32 logical_maximum; s32 logical_maximum;
}; };
/**
* struct sensor_hub_pending - Synchronous read pending information
* @status: Pending status true/false.
* @ready: Completion synchronization data.
* @usage_id: Usage id for physical device, E.g. Gyro usage id.
* @attr_usage_id: Usage Id of a field, E.g. X-AXIS for a gyro.
* @raw_size: Response size for a read request.
* @raw_data: Place holder for received response.
*/
struct sensor_hub_pending {
bool status;
struct completion ready;
u32 usage_id;
u32 attr_usage_id;
int raw_size;
u8 *raw_data;
};
/** /**
* struct hid_sensor_hub_device - Stores the hub instance data * struct hid_sensor_hub_device - Stores the hub instance data
* @hdev: Stores the hid instance. * @hdev: Stores the hid instance.
* @vendor_id: Vendor id of hub device. * @vendor_id: Vendor id of hub device.
* @product_id: Product id of hub device. * @product_id: Product id of hub device.
* @usage: Usage id for this hub device instance.
* @start_collection_index: Starting index for a phy type collection * @start_collection_index: Starting index for a phy type collection
* @end_collection_index: Last index for a phy type collection * @end_collection_index: Last index for a phy type collection
* @mutex: synchronizing mutex.
* @pending: Holds information of pending sync read request.
*/ */
struct hid_sensor_hub_device { struct hid_sensor_hub_device {
struct hid_device *hdev; struct hid_device *hdev;
u32 vendor_id; u32 vendor_id;
u32 product_id; u32 product_id;
u32 usage;
int start_collection_index; int start_collection_index;
int end_collection_index; int end_collection_index;
struct mutex mutex;
struct sensor_hub_pending pending;
}; };
/** /**