bdev/compress: function rename
Old name was misleading due to earlier changes Change-Id: Ic04223db983e98c9703a43e6778b0094f99bc81d Signed-off-by: paul luse <paul.e.luse@intel.com> Reviewed-on: https://review.gerrithub.io/c/spdk/spdk/+/463341 Reviewed-by: Jim Harris <james.r.harris@intel.com> Reviewed-by: Shuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com> Reviewed-by: Darek Stojaczyk <dariusz.stojaczyk@intel.com> Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
This commit is contained in:
parent
faf9ad6a6d
commit
9b639aa9a4
@ -1238,7 +1238,7 @@ comp_bdev_ch_create_cb(void *io_device, void *ctx_buf)
|
|||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
_clear_qp_and_put_channel(struct vbdev_compress *comp_bdev)
|
_channel_cleanup(struct vbdev_compress *comp_bdev)
|
||||||
{
|
{
|
||||||
/* Note: comp_bdevs can share a device_qp if they are
|
/* Note: comp_bdevs can share a device_qp if they are
|
||||||
* on the same thread so we leave the device_qp element
|
* on the same thread so we leave the device_qp element
|
||||||
@ -1257,7 +1257,7 @@ _comp_bdev_ch_destroy_cb(void *arg)
|
|||||||
|
|
||||||
pthread_mutex_lock(&comp_bdev->reduce_lock);
|
pthread_mutex_lock(&comp_bdev->reduce_lock);
|
||||||
if (comp_bdev->ch_count == 0) {
|
if (comp_bdev->ch_count == 0) {
|
||||||
_clear_qp_and_put_channel(comp_bdev);
|
_channel_cleanup(comp_bdev);
|
||||||
}
|
}
|
||||||
pthread_mutex_unlock(&comp_bdev->reduce_lock);
|
pthread_mutex_unlock(&comp_bdev->reduce_lock);
|
||||||
}
|
}
|
||||||
@ -1279,7 +1279,7 @@ comp_bdev_ch_destroy_cb(void *io_device, void *ctx_buf)
|
|||||||
spdk_thread_send_msg(comp_bdev->reduce_thread,
|
spdk_thread_send_msg(comp_bdev->reduce_thread,
|
||||||
_comp_bdev_ch_destroy_cb, comp_bdev);
|
_comp_bdev_ch_destroy_cb, comp_bdev);
|
||||||
} else {
|
} else {
|
||||||
_clear_qp_and_put_channel(comp_bdev);
|
_channel_cleanup(comp_bdev);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
pthread_mutex_unlock(&comp_bdev->reduce_lock);
|
pthread_mutex_unlock(&comp_bdev->reduce_lock);
|
||||||
|
Loading…
Reference in New Issue
Block a user