Commit a52c4352 authored by Johan Hovold's avatar Johan Hovold Committed by Greg Kroah-Hartman

greybus: operation: allow atomic request submissions

Add gfp mask argument to gb_operation_request_send in order to allow
submissions from atomic context.

Note that responses are currently always sent from non-atomic context as
incoming requests are processed in a work queue.
Signed-off-by: default avatarJohan Hovold <johan@hovoldconsulting.com>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@google.com>
parent e420721b
...@@ -129,7 +129,7 @@ gb_operation_find(struct gb_connection *connection, u16 operation_id) ...@@ -129,7 +129,7 @@ gb_operation_find(struct gb_connection *connection, u16 operation_id)
return found ? operation : NULL; return found ? operation : NULL;
} }
static int gb_message_send(struct gb_message *message) static int gb_message_send(struct gb_message *message, gfp_t gfp)
{ {
struct gb_connection *connection = message->operation->connection; struct gb_connection *connection = message->operation->connection;
...@@ -563,7 +563,8 @@ static void gb_operation_sync_callback(struct gb_operation *operation) ...@@ -563,7 +563,8 @@ static void gb_operation_sync_callback(struct gb_operation *operation)
* dropping the initial reference to the operation. * dropping the initial reference to the operation.
*/ */
int gb_operation_request_send(struct gb_operation *operation, int gb_operation_request_send(struct gb_operation *operation,
gb_operation_callback callback) gb_operation_callback callback,
gfp_t gfp)
{ {
struct gb_connection *connection = operation->connection; struct gb_connection *connection = operation->connection;
struct gb_operation_msg_hdr *header; struct gb_operation_msg_hdr *header;
...@@ -601,7 +602,7 @@ int gb_operation_request_send(struct gb_operation *operation, ...@@ -601,7 +602,7 @@ int gb_operation_request_send(struct gb_operation *operation,
/* All set, send the request */ /* All set, send the request */
gb_operation_result_set(operation, -EINPROGRESS); gb_operation_result_set(operation, -EINPROGRESS);
ret = gb_message_send(operation->request); ret = gb_message_send(operation->request, gfp);
if (ret) if (ret)
gb_operation_put(operation); gb_operation_put(operation);
...@@ -620,7 +621,8 @@ int gb_operation_request_send_sync(struct gb_operation *operation) ...@@ -620,7 +621,8 @@ int gb_operation_request_send_sync(struct gb_operation *operation)
int ret; int ret;
unsigned long timeout; unsigned long timeout;
ret = gb_operation_request_send(operation, gb_operation_sync_callback); ret = gb_operation_request_send(operation, gb_operation_sync_callback,
GFP_KERNEL);
if (ret) if (ret)
return ret; return ret;
...@@ -677,7 +679,7 @@ int gb_operation_response_send(struct gb_operation *operation, int errno) ...@@ -677,7 +679,7 @@ int gb_operation_response_send(struct gb_operation *operation, int errno)
/* Fill in the response header and send it */ /* Fill in the response header and send it */
operation->response->header->result = gb_operation_errno_map(errno); operation->response->header->result = gb_operation_errno_map(errno);
ret = gb_message_send(operation->response); ret = gb_message_send(operation->response, GFP_KERNEL);
if (ret) if (ret)
gb_operation_put(operation); gb_operation_put(operation);
......
...@@ -147,7 +147,8 @@ bool gb_operation_response_alloc(struct gb_operation *operation, ...@@ -147,7 +147,8 @@ bool gb_operation_response_alloc(struct gb_operation *operation,
size_t response_size); size_t response_size);
int gb_operation_request_send(struct gb_operation *operation, int gb_operation_request_send(struct gb_operation *operation,
gb_operation_callback callback); gb_operation_callback callback,
gfp_t gfp);
int gb_operation_request_send_sync(struct gb_operation *operation); int gb_operation_request_send_sync(struct gb_operation *operation);
int gb_operation_response_send(struct gb_operation *operation, int errno); int gb_operation_response_send(struct gb_operation *operation, int errno);
......
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