mirror of
https://github.com/edk2-porting/linux-next.git
synced 2024-12-27 14:43:58 +08:00
e8d585b2f6
'destroy_workqueue()' already drains the queue before destroying it, so there is no need to flush it explicitly. Remove the redundant 'flush_workqueue()' calls. This was generated with coccinelle: @@ expression E; @@ - flush_workqueue(E); destroy_workqueue(E); Acked-by: Namjae Jeon <linkinjeon@kernel.org> Signed-off-by: Christophe JAILLET <christophe.jaillet@wanadoo.fr> Signed-off-by: Steve French <stfrench@microsoft.com>
80 lines
1.7 KiB
C
80 lines
1.7 KiB
C
// SPDX-License-Identifier: GPL-2.0-or-later
|
|
/*
|
|
* Copyright (C) 2019 Samsung Electronics Co., Ltd.
|
|
*/
|
|
|
|
#include <linux/list.h>
|
|
#include <linux/mm.h>
|
|
#include <linux/slab.h>
|
|
#include <linux/workqueue.h>
|
|
|
|
#include "server.h"
|
|
#include "connection.h"
|
|
#include "ksmbd_work.h"
|
|
#include "mgmt/ksmbd_ida.h"
|
|
|
|
static struct kmem_cache *work_cache;
|
|
static struct workqueue_struct *ksmbd_wq;
|
|
|
|
struct ksmbd_work *ksmbd_alloc_work_struct(void)
|
|
{
|
|
struct ksmbd_work *work = kmem_cache_zalloc(work_cache, GFP_KERNEL);
|
|
|
|
if (work) {
|
|
work->compound_fid = KSMBD_NO_FID;
|
|
work->compound_pfid = KSMBD_NO_FID;
|
|
INIT_LIST_HEAD(&work->request_entry);
|
|
INIT_LIST_HEAD(&work->async_request_entry);
|
|
INIT_LIST_HEAD(&work->fp_entry);
|
|
INIT_LIST_HEAD(&work->interim_entry);
|
|
}
|
|
return work;
|
|
}
|
|
|
|
void ksmbd_free_work_struct(struct ksmbd_work *work)
|
|
{
|
|
WARN_ON(work->saved_cred != NULL);
|
|
|
|
kvfree(work->response_buf);
|
|
kvfree(work->aux_payload_buf);
|
|
kfree(work->tr_buf);
|
|
kvfree(work->request_buf);
|
|
if (work->async_id)
|
|
ksmbd_release_id(&work->conn->async_ida, work->async_id);
|
|
kmem_cache_free(work_cache, work);
|
|
}
|
|
|
|
void ksmbd_work_pool_destroy(void)
|
|
{
|
|
kmem_cache_destroy(work_cache);
|
|
}
|
|
|
|
int ksmbd_work_pool_init(void)
|
|
{
|
|
work_cache = kmem_cache_create("ksmbd_work_cache",
|
|
sizeof(struct ksmbd_work), 0,
|
|
SLAB_HWCACHE_ALIGN, NULL);
|
|
if (!work_cache)
|
|
return -ENOMEM;
|
|
return 0;
|
|
}
|
|
|
|
int ksmbd_workqueue_init(void)
|
|
{
|
|
ksmbd_wq = alloc_workqueue("ksmbd-io", 0, 0);
|
|
if (!ksmbd_wq)
|
|
return -ENOMEM;
|
|
return 0;
|
|
}
|
|
|
|
void ksmbd_workqueue_destroy(void)
|
|
{
|
|
destroy_workqueue(ksmbd_wq);
|
|
ksmbd_wq = NULL;
|
|
}
|
|
|
|
bool ksmbd_queue_work(struct ksmbd_work *work)
|
|
{
|
|
return queue_work(ksmbd_wq, &work->work);
|
|
}
|