diff options
| author | Mike Snitzer <snitzer@redhat.com> | 2018-01-06 03:17:20 +0100 |
|---|---|---|
| committer | Mike Snitzer <snitzer@redhat.com> | 2018-01-17 15:16:15 +0100 |
| commit | d5ffebdd797a7c1c89576267640f671db2a668fc (patch) | |
| tree | 6796c229b8b8db0014e9d797bfe882c2b26a1a60 /drivers/md/dm-kcopyd.c | |
| parent | dm snapshot: use mutex instead of rw_semaphore (diff) | |
| download | linux-d5ffebdd797a7c1c89576267640f671db2a668fc.tar.xz linux-d5ffebdd797a7c1c89576267640f671db2a668fc.zip | |
dm: backfill missing calls to mutex_destroy()
Signed-off-by: Mike Snitzer <snitzer@redhat.com>
Diffstat (limited to 'drivers/md/dm-kcopyd.c')
| -rw-r--r-- | drivers/md/dm-kcopyd.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/drivers/md/dm-kcopyd.c b/drivers/md/dm-kcopyd.c index eb45cc3df31d..e6e7c686646d 100644 --- a/drivers/md/dm-kcopyd.c +++ b/drivers/md/dm-kcopyd.c @@ -477,8 +477,10 @@ static int run_complete_job(struct kcopyd_job *job) * If this is the master job, the sub jobs have already * completed so we can free everything. */ - if (job->master_job == job) + if (job->master_job == job) { + mutex_destroy(&job->lock); mempool_free(job, kc->job_pool); + } fn(read_err, write_err, context); if (atomic_dec_and_test(&kc->nr_jobs)) @@ -750,6 +752,7 @@ int dm_kcopyd_copy(struct dm_kcopyd_client *kc, struct dm_io_region *from, * followed by SPLIT_COUNT sub jobs. */ job = mempool_alloc(kc->job_pool, GFP_NOIO); + mutex_init(&job->lock); /* * set up for the read. @@ -811,7 +814,6 @@ int dm_kcopyd_copy(struct dm_kcopyd_client *kc, struct dm_io_region *from, if (job->source.count <= SUB_JOB_SIZE) dispatch_job(job); else { - mutex_init(&job->lock); job->progress = 0; split_job(job); } |