Commit 622a50dc authored by K. Y. Srinivasan's avatar K. Y. Srinivasan Committed by Greg Kroah-Hartman

Staging: hv: mousevsc: Use completion primitive to synchronize

Use completion primitive to synchronize.
Signed-off-by: default avatarK. Y. Srinivasan <kys@microsoft.com>
Signed-off-by: default avatarHaiyang Zhang <haiyangz@microsoft.com>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@suse.de>
parent 1738067e
...@@ -162,10 +162,7 @@ struct mousevsc_dev { ...@@ -162,10 +162,7 @@ struct mousevsc_dev {
struct mousevsc_prt_msg protocol_req; struct mousevsc_prt_msg protocol_req;
struct mousevsc_prt_msg protocol_resp; struct mousevsc_prt_msg protocol_resp;
/* Synchronize the request/response if needed */ /* Synchronize the request/response if needed */
wait_queue_head_t protocol_wait_event; struct completion wait_event;
wait_queue_head_t dev_info_wait_event;
int protocol_wait_condition;
int device_wait_condition;
int dev_info_status; int dev_info_status;
struct hid_descriptor *hid_desc; struct hid_descriptor *hid_desc;
...@@ -194,6 +191,7 @@ static struct mousevsc_dev *alloc_input_device(struct hv_device *device) ...@@ -194,6 +191,7 @@ static struct mousevsc_dev *alloc_input_device(struct hv_device *device)
input_dev->device = device; input_dev->device = device;
hv_set_drvdata(device, input_dev); hv_set_drvdata(device, input_dev);
init_completion(&input_dev->wait_event);
return input_dev; return input_dev;
} }
...@@ -379,8 +377,7 @@ static void mousevsc_on_receive_device_info(struct mousevsc_dev *input_device, ...@@ -379,8 +377,7 @@ static void mousevsc_on_receive_device_info(struct mousevsc_dev *input_device,
goto cleanup; goto cleanup;
} }
input_device->device_wait_condition = 1; complete(&input_device->wait_event);
wake_up(&input_device->dev_info_wait_event);
return; return;
...@@ -392,8 +389,7 @@ static void mousevsc_on_receive_device_info(struct mousevsc_dev *input_device, ...@@ -392,8 +389,7 @@ static void mousevsc_on_receive_device_info(struct mousevsc_dev *input_device,
input_device->report_desc = NULL; input_device->report_desc = NULL;
input_device->dev_info_status = -1; input_device->dev_info_status = -1;
input_device->device_wait_condition = 1; complete(&input_device->wait_event);
wake_up(&input_device->dev_info_wait_event);
} }
static void mousevsc_on_receive_input_report(struct mousevsc_dev *input_device, static void mousevsc_on_receive_input_report(struct mousevsc_dev *input_device,
...@@ -444,8 +440,7 @@ static void mousevsc_on_receive(struct hv_device *device, ...@@ -444,8 +440,7 @@ static void mousevsc_on_receive(struct hv_device *device,
memcpy(&input_dev->protocol_resp, pipe_msg, memcpy(&input_dev->protocol_resp, pipe_msg,
pipe_msg->size + sizeof(struct pipe_prt_msg) - pipe_msg->size + sizeof(struct pipe_prt_msg) -
sizeof(unsigned char)); sizeof(unsigned char));
input_dev->protocol_wait_condition = 1; complete(&input_dev->wait_event);
wake_up(&input_dev->protocol_wait_event);
break; break;
case SynthHidInitialDeviceInfo: case SynthHidInitialDeviceInfo:
...@@ -565,6 +560,7 @@ static void mousevsc_on_channel_callback(void *context) ...@@ -565,6 +560,7 @@ static void mousevsc_on_channel_callback(void *context)
static int mousevsc_connect_to_vsp(struct hv_device *device) static int mousevsc_connect_to_vsp(struct hv_device *device)
{ {
int ret = 0; int ret = 0;
int t;
struct mousevsc_dev *input_dev; struct mousevsc_dev *input_dev;
struct mousevsc_prt_msg *request; struct mousevsc_prt_msg *request;
struct mousevsc_prt_msg *response; struct mousevsc_prt_msg *response;
...@@ -576,8 +572,6 @@ static int mousevsc_connect_to_vsp(struct hv_device *device) ...@@ -576,8 +572,6 @@ static int mousevsc_connect_to_vsp(struct hv_device *device)
return -1; return -1;
} }
init_waitqueue_head(&input_dev->protocol_wait_event);
init_waitqueue_head(&input_dev->dev_info_wait_event);
request = &input_dev->protocol_req; request = &input_dev->protocol_req;
...@@ -607,10 +601,8 @@ static int mousevsc_connect_to_vsp(struct hv_device *device) ...@@ -607,10 +601,8 @@ static int mousevsc_connect_to_vsp(struct hv_device *device)
goto cleanup; goto cleanup;
} }
input_dev->protocol_wait_condition = 0; t = wait_for_completion_timeout(&input_dev->wait_event, 5*HZ);
wait_event_timeout(input_dev->protocol_wait_event, if (t == 0) {
input_dev->protocol_wait_condition, msecs_to_jiffies(1000));
if (input_dev->protocol_wait_condition == 0) {
ret = -ETIMEDOUT; ret = -ETIMEDOUT;
goto cleanup; goto cleanup;
} }
...@@ -624,10 +616,8 @@ static int mousevsc_connect_to_vsp(struct hv_device *device) ...@@ -624,10 +616,8 @@ static int mousevsc_connect_to_vsp(struct hv_device *device)
goto cleanup; goto cleanup;
} }
input_dev->device_wait_condition = 0; t = wait_for_completion_timeout(&input_dev->wait_event, 5*HZ);
wait_event_timeout(input_dev->dev_info_wait_event, if (t == 0) {
input_dev->device_wait_condition, msecs_to_jiffies(1000));
if (input_dev->device_wait_condition == 0) {
ret = -ETIMEDOUT; ret = -ETIMEDOUT;
goto cleanup; goto cleanup;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment