Reviewed-by: On Fri, 20 Jun 2014, Ilya Dryomov wrote:
> rbd_obj_request_wait() should cancel the underlying OSD request if > interrupted. Otherwise libceph will hold onto it indefinitely, causing > assert failures or leaking the original object request. > > Fixes: http://tracker.ceph.com/issues/6628 > > Signed-off-by: Ilya Dryomov <[email protected]> > --- > drivers/block/rbd.c | 20 ++++++++++++++++---- > 1 file changed, 16 insertions(+), 4 deletions(-) > > diff --git a/drivers/block/rbd.c b/drivers/block/rbd.c > index b2c98c1bc037..1701595648ce 100644 > --- a/drivers/block/rbd.c > +++ b/drivers/block/rbd.c > @@ -1558,13 +1558,25 @@ static void rbd_img_request_complete(struct > rbd_img_request *img_request) > rbd_img_request_put(img_request); > } > > -/* Caller is responsible for rbd_obj_request_destroy(obj_request) */ > - > +/* > + * Wait for an object request to complete. If interrupted, cancel the > + * underlying osd request. > + */ > static int rbd_obj_request_wait(struct rbd_obj_request *obj_request) > { > - dout("%s: obj %p\n", __func__, obj_request); > + int ret; > + > + dout("%s obj %p\n", __func__, obj_request); > > - return wait_for_completion_interruptible(&obj_request->completion); > + ret = wait_for_completion_interruptible(&obj_request->completion); > + if (ret < 0) { > + dout("%s obj %p interrupted\n", __func__, obj_request); > + ceph_osdc_cancel_request(obj_request->osd_req); > + return ret; > + } > + > + dout("%s obj %p done\n", __func__, obj_request); > + return 0; > } > > /* > -- > 1.7.10.4 > > -- > To unsubscribe from this list: send the line "unsubscribe ceph-devel" in > the body of a message to [email protected] > More majordomo info at http://vger.kernel.org/majordomo-info.html > > -- To unsubscribe from this list: send the line "unsubscribe ceph-devel" in the body of a message to [email protected] More majordomo info at http://vger.kernel.org/majordomo-info.html
