Commit 9cbb1d72 authored by Alex Elder's avatar Alex Elder Committed by Sage Weil

libceph: don't require r_num_pages for bio requests

There is a check in the completion path for osd requests that
ensures the number of pages allocated is enough to hold the amount
of incoming data expected.

For bio requests coming from rbd the "number of pages" is not really
meaningful (although total length would be).  So stop requiring that
nr_pages be supplied for bio requests.  This is done by checking
whether the pages pointer is null before checking the value of
nr_pages.

Note that this value is passed on to the messenger, but there it's
only used for debugging--it's never used for validation.

While here, change another spot that used r_pages in a debug message
inappropriately, and also invalidate the r_con_filling_msg pointer
after dropping a reference to it.

This resolves:
    http://tracker.ceph.com/issues/3875Signed-off-by: default avatarAlex Elder <elder@inktank.com>
Reviewed-by: default avatarJosh Durgin <josh.durgin@inktank.com>
parent 1e32d34c
...@@ -1342,8 +1342,6 @@ static struct ceph_osd_request *rbd_osd_req_create( ...@@ -1342,8 +1342,6 @@ static struct ceph_osd_request *rbd_osd_req_create(
case OBJ_REQUEST_BIO: case OBJ_REQUEST_BIO:
rbd_assert(obj_request->bio_list != NULL); rbd_assert(obj_request->bio_list != NULL);
osd_req->r_bio = obj_request->bio_list; osd_req->r_bio = obj_request->bio_list;
/* osd client requires "num pages" even for bio */
osd_req->r_num_pages = calc_pages_for(offset, length);
break; break;
case OBJ_REQUEST_PAGES: case OBJ_REQUEST_PAGES:
osd_req->r_pages = obj_request->pages; osd_req->r_pages = obj_request->pages;
......
...@@ -137,10 +137,11 @@ void ceph_osdc_release_request(struct kref *kref) ...@@ -137,10 +137,11 @@ void ceph_osdc_release_request(struct kref *kref)
if (req->r_request) if (req->r_request)
ceph_msg_put(req->r_request); ceph_msg_put(req->r_request);
if (req->r_con_filling_msg) { if (req->r_con_filling_msg) {
dout("%s revoking pages %p from con %p\n", __func__, dout("%s revoking msg %p from con %p\n", __func__,
req->r_pages, req->r_con_filling_msg); req->r_reply, req->r_con_filling_msg);
ceph_msg_revoke_incoming(req->r_reply); ceph_msg_revoke_incoming(req->r_reply);
req->r_con_filling_msg->ops->put(req->r_con_filling_msg); req->r_con_filling_msg->ops->put(req->r_con_filling_msg);
req->r_con_filling_msg = NULL;
} }
if (req->r_reply) if (req->r_reply)
ceph_msg_put(req->r_reply); ceph_msg_put(req->r_reply);
...@@ -1981,7 +1982,7 @@ static struct ceph_msg *get_reply(struct ceph_connection *con, ...@@ -1981,7 +1982,7 @@ static struct ceph_msg *get_reply(struct ceph_connection *con,
if (data_len > 0) { if (data_len > 0) {
int want = calc_pages_for(req->r_page_alignment, data_len); int want = calc_pages_for(req->r_page_alignment, data_len);
if (unlikely(req->r_num_pages < want)) { if (req->r_pages && unlikely(req->r_num_pages < want)) {
pr_warning("tid %lld reply has %d bytes %d pages, we" pr_warning("tid %lld reply has %d bytes %d pages, we"
" had only %d pages ready\n", tid, data_len, " had only %d pages ready\n", tid, data_len,
want, req->r_num_pages); want, req->r_num_pages);
......
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