Commit 1d0326b1 authored by Ilya Dryomov's avatar Ilya Dryomov

libceph: rename ceph_osd_request::r_linger_osd to r_linger_osd_item

So that:

req->r_osd_item --> osd->o_requests list
req->r_linger_osd_item --> osd->o_linger_requests list
Signed-off-by: default avatarIlya Dryomov <ilya.dryomov@inktank.com>
Reviewed-by: default avatarAlex Elder <elder@linaro.org>
parent cd3de83f
...@@ -117,7 +117,7 @@ struct ceph_osd_request { ...@@ -117,7 +117,7 @@ struct ceph_osd_request {
struct list_head r_req_lru_item; struct list_head r_req_lru_item;
struct list_head r_osd_item; struct list_head r_osd_item;
struct list_head r_linger_item; struct list_head r_linger_item;
struct list_head r_linger_osd; struct list_head r_linger_osd_item;
struct ceph_osd *r_osd; struct ceph_osd *r_osd;
struct ceph_pg r_pgid; struct ceph_pg r_pgid;
int r_pg_osds[CEPH_PG_MAX_SIZE]; int r_pg_osds[CEPH_PG_MAX_SIZE];
......
...@@ -364,7 +364,7 @@ struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, ...@@ -364,7 +364,7 @@ struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc,
RB_CLEAR_NODE(&req->r_node); RB_CLEAR_NODE(&req->r_node);
INIT_LIST_HEAD(&req->r_unsafe_item); INIT_LIST_HEAD(&req->r_unsafe_item);
INIT_LIST_HEAD(&req->r_linger_item); INIT_LIST_HEAD(&req->r_linger_item);
INIT_LIST_HEAD(&req->r_linger_osd); INIT_LIST_HEAD(&req->r_linger_osd_item);
INIT_LIST_HEAD(&req->r_req_lru_item); INIT_LIST_HEAD(&req->r_req_lru_item);
INIT_LIST_HEAD(&req->r_osd_item); INIT_LIST_HEAD(&req->r_osd_item);
...@@ -916,7 +916,7 @@ static void __kick_osd_requests(struct ceph_osd_client *osdc, ...@@ -916,7 +916,7 @@ static void __kick_osd_requests(struct ceph_osd_client *osdc,
* list at the end to keep things in tid order. * list at the end to keep things in tid order.
*/ */
list_for_each_entry_safe(req, nreq, &osd->o_linger_requests, list_for_each_entry_safe(req, nreq, &osd->o_linger_requests,
r_linger_osd) { r_linger_osd_item) {
/* /*
* reregister request prior to unregistering linger so * reregister request prior to unregistering linger so
* that r_osd is preserved. * that r_osd is preserved.
...@@ -1218,7 +1218,7 @@ static void __register_linger_request(struct ceph_osd_client *osdc, ...@@ -1218,7 +1218,7 @@ static void __register_linger_request(struct ceph_osd_client *osdc,
ceph_osdc_get_request(req); ceph_osdc_get_request(req);
list_add_tail(&req->r_linger_item, &osdc->req_linger); list_add_tail(&req->r_linger_item, &osdc->req_linger);
if (req->r_osd) if (req->r_osd)
list_add_tail(&req->r_linger_osd, list_add_tail(&req->r_linger_osd_item,
&req->r_osd->o_linger_requests); &req->r_osd->o_linger_requests);
} }
...@@ -1228,7 +1228,7 @@ static void __unregister_linger_request(struct ceph_osd_client *osdc, ...@@ -1228,7 +1228,7 @@ static void __unregister_linger_request(struct ceph_osd_client *osdc,
dout("__unregister_linger_request %p\n", req); dout("__unregister_linger_request %p\n", req);
list_del_init(&req->r_linger_item); list_del_init(&req->r_linger_item);
if (req->r_osd) { if (req->r_osd) {
list_del_init(&req->r_linger_osd); list_del_init(&req->r_linger_osd_item);
if (list_empty(&req->r_osd->o_requests) && if (list_empty(&req->r_osd->o_requests) &&
list_empty(&req->r_osd->o_linger_requests)) { list_empty(&req->r_osd->o_linger_requests)) {
......
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