Commit c4ca2b0b authored by Petr Mladek's avatar Petr Mladek Committed by Herbert Xu

crypto: engine - Handle the kthread worker using the new API

Use the new API to create and destroy the crypto engine kthread
worker. The API hides some implementation details.

In particular, kthread_create_worker() allocates and initializes
struct kthread_worker. It runs the kthread the right way
and stores task_struct into the worker structure.

kthread_destroy_worker() flushes all pending works, stops
the kthread and frees the structure.

This patch does not change the existing behavior except for
dynamically allocating struct kthread_worker and storing
only the pointer of this structure.

It is compile tested only because I did not find an easy
way how to run the code. Well, it should be pretty safe
given the nature of the change.
Signed-off-by: default avatarPetr Mladek <pmladek@suse.com>
Signed-off-by: default avatarHerbert Xu <herbert@gondor.apana.org.au>
parent 103600ab
...@@ -47,7 +47,7 @@ static void crypto_pump_requests(struct crypto_engine *engine, ...@@ -47,7 +47,7 @@ static void crypto_pump_requests(struct crypto_engine *engine,
/* If another context is idling then defer */ /* If another context is idling then defer */
if (engine->idling) { if (engine->idling) {
kthread_queue_work(&engine->kworker, &engine->pump_requests); kthread_queue_work(engine->kworker, &engine->pump_requests);
goto out; goto out;
} }
...@@ -58,7 +58,7 @@ static void crypto_pump_requests(struct crypto_engine *engine, ...@@ -58,7 +58,7 @@ static void crypto_pump_requests(struct crypto_engine *engine,
/* Only do teardown in the thread */ /* Only do teardown in the thread */
if (!in_kthread) { if (!in_kthread) {
kthread_queue_work(&engine->kworker, kthread_queue_work(engine->kworker,
&engine->pump_requests); &engine->pump_requests);
goto out; goto out;
} }
...@@ -189,7 +189,7 @@ int crypto_transfer_cipher_request(struct crypto_engine *engine, ...@@ -189,7 +189,7 @@ int crypto_transfer_cipher_request(struct crypto_engine *engine,
ret = ablkcipher_enqueue_request(&engine->queue, req); ret = ablkcipher_enqueue_request(&engine->queue, req);
if (!engine->busy && need_pump) if (!engine->busy && need_pump)
kthread_queue_work(&engine->kworker, &engine->pump_requests); kthread_queue_work(engine->kworker, &engine->pump_requests);
spin_unlock_irqrestore(&engine->queue_lock, flags); spin_unlock_irqrestore(&engine->queue_lock, flags);
return ret; return ret;
...@@ -231,7 +231,7 @@ int crypto_transfer_hash_request(struct crypto_engine *engine, ...@@ -231,7 +231,7 @@ int crypto_transfer_hash_request(struct crypto_engine *engine,
ret = ahash_enqueue_request(&engine->queue, req); ret = ahash_enqueue_request(&engine->queue, req);
if (!engine->busy && need_pump) if (!engine->busy && need_pump)
kthread_queue_work(&engine->kworker, &engine->pump_requests); kthread_queue_work(engine->kworker, &engine->pump_requests);
spin_unlock_irqrestore(&engine->queue_lock, flags); spin_unlock_irqrestore(&engine->queue_lock, flags);
return ret; return ret;
...@@ -284,7 +284,7 @@ void crypto_finalize_cipher_request(struct crypto_engine *engine, ...@@ -284,7 +284,7 @@ void crypto_finalize_cipher_request(struct crypto_engine *engine,
req->base.complete(&req->base, err); req->base.complete(&req->base, err);
kthread_queue_work(&engine->kworker, &engine->pump_requests); kthread_queue_work(engine->kworker, &engine->pump_requests);
} }
EXPORT_SYMBOL_GPL(crypto_finalize_cipher_request); EXPORT_SYMBOL_GPL(crypto_finalize_cipher_request);
...@@ -321,7 +321,7 @@ void crypto_finalize_hash_request(struct crypto_engine *engine, ...@@ -321,7 +321,7 @@ void crypto_finalize_hash_request(struct crypto_engine *engine,
req->base.complete(&req->base, err); req->base.complete(&req->base, err);
kthread_queue_work(&engine->kworker, &engine->pump_requests); kthread_queue_work(engine->kworker, &engine->pump_requests);
} }
EXPORT_SYMBOL_GPL(crypto_finalize_hash_request); EXPORT_SYMBOL_GPL(crypto_finalize_hash_request);
...@@ -345,7 +345,7 @@ int crypto_engine_start(struct crypto_engine *engine) ...@@ -345,7 +345,7 @@ int crypto_engine_start(struct crypto_engine *engine)
engine->running = true; engine->running = true;
spin_unlock_irqrestore(&engine->queue_lock, flags); spin_unlock_irqrestore(&engine->queue_lock, flags);
kthread_queue_work(&engine->kworker, &engine->pump_requests); kthread_queue_work(engine->kworker, &engine->pump_requests);
return 0; return 0;
} }
...@@ -422,11 +422,8 @@ struct crypto_engine *crypto_engine_alloc_init(struct device *dev, bool rt) ...@@ -422,11 +422,8 @@ struct crypto_engine *crypto_engine_alloc_init(struct device *dev, bool rt)
crypto_init_queue(&engine->queue, CRYPTO_ENGINE_MAX_QLEN); crypto_init_queue(&engine->queue, CRYPTO_ENGINE_MAX_QLEN);
spin_lock_init(&engine->queue_lock); spin_lock_init(&engine->queue_lock);
kthread_init_worker(&engine->kworker); engine->kworker = kthread_create_worker(0, "%s", engine->name);
engine->kworker_task = kthread_run(kthread_worker_fn, if (IS_ERR(engine->kworker)) {
&engine->kworker, "%s",
engine->name);
if (IS_ERR(engine->kworker_task)) {
dev_err(dev, "failed to create crypto request pump task\n"); dev_err(dev, "failed to create crypto request pump task\n");
return NULL; return NULL;
} }
...@@ -434,7 +431,7 @@ struct crypto_engine *crypto_engine_alloc_init(struct device *dev, bool rt) ...@@ -434,7 +431,7 @@ struct crypto_engine *crypto_engine_alloc_init(struct device *dev, bool rt)
if (engine->rt) { if (engine->rt) {
dev_info(dev, "will run requests pump with realtime priority\n"); dev_info(dev, "will run requests pump with realtime priority\n");
sched_setscheduler(engine->kworker_task, SCHED_FIFO, &param); sched_setscheduler(engine->kworker->task, SCHED_FIFO, &param);
} }
return engine; return engine;
...@@ -455,8 +452,7 @@ int crypto_engine_exit(struct crypto_engine *engine) ...@@ -455,8 +452,7 @@ int crypto_engine_exit(struct crypto_engine *engine)
if (ret) if (ret)
return ret; return ret;
kthread_flush_worker(&engine->kworker); kthread_destroy_worker(engine->kworker);
kthread_stop(engine->kworker_task);
return 0; return 0;
} }
......
...@@ -43,8 +43,7 @@ ...@@ -43,8 +43,7 @@
* @prepare_hash_request: do some prepare if need before handle the current request * @prepare_hash_request: do some prepare if need before handle the current request
* @unprepare_hash_request: undo any work done by prepare_hash_request() * @unprepare_hash_request: undo any work done by prepare_hash_request()
* @hash_one_request: do hash for current request * @hash_one_request: do hash for current request
* @kworker: thread struct for request pump * @kworker: kthread worker struct for request pump
* @kworker_task: pointer to task for request pump kworker thread
* @pump_requests: work struct for scheduling work to the request pump * @pump_requests: work struct for scheduling work to the request pump
* @priv_data: the engine private data * @priv_data: the engine private data
* @cur_req: the current request which is on processing * @cur_req: the current request which is on processing
...@@ -78,8 +77,7 @@ struct crypto_engine { ...@@ -78,8 +77,7 @@ struct crypto_engine {
int (*hash_one_request)(struct crypto_engine *engine, int (*hash_one_request)(struct crypto_engine *engine,
struct ahash_request *req); struct ahash_request *req);
struct kthread_worker kworker; struct kthread_worker *kworker;
struct task_struct *kworker_task;
struct kthread_work pump_requests; struct kthread_work pump_requests;
void *priv_data; void *priv_data;
......
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