diff options
-rw-r--r-- | include/linux/ceph/osd_client.h | 2 | ||||
-rw-r--r-- | net/ceph/osd_client.c | 8 |
2 files changed, 5 insertions, 5 deletions
diff --git a/include/linux/ceph/osd_client.h b/include/linux/ceph/osd_client.h index 94ec69672164..7490a03ac163 100644 --- a/include/linux/ceph/osd_client.h +++ b/include/linux/ceph/osd_client.h | |||
@@ -117,7 +117,7 @@ struct ceph_osd_request { | |||
117 | struct list_head r_req_lru_item; | 117 | struct list_head r_req_lru_item; |
118 | struct list_head r_osd_item; | 118 | struct list_head r_osd_item; |
119 | struct list_head r_linger_item; | 119 | struct list_head r_linger_item; |
120 | struct list_head r_linger_osd; | 120 | struct list_head r_linger_osd_item; |
121 | struct ceph_osd *r_osd; | 121 | struct ceph_osd *r_osd; |
122 | struct ceph_pg r_pgid; | 122 | struct ceph_pg r_pgid; |
123 | int r_pg_osds[CEPH_PG_MAX_SIZE]; | 123 | int r_pg_osds[CEPH_PG_MAX_SIZE]; |
diff --git a/net/ceph/osd_client.c b/net/ceph/osd_client.c index 05be0c181695..d5d2be3bd113 100644 --- a/net/ceph/osd_client.c +++ b/net/ceph/osd_client.c | |||
@@ -364,7 +364,7 @@ struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, | |||
364 | RB_CLEAR_NODE(&req->r_node); | 364 | RB_CLEAR_NODE(&req->r_node); |
365 | INIT_LIST_HEAD(&req->r_unsafe_item); | 365 | INIT_LIST_HEAD(&req->r_unsafe_item); |
366 | INIT_LIST_HEAD(&req->r_linger_item); | 366 | INIT_LIST_HEAD(&req->r_linger_item); |
367 | INIT_LIST_HEAD(&req->r_linger_osd); | 367 | INIT_LIST_HEAD(&req->r_linger_osd_item); |
368 | INIT_LIST_HEAD(&req->r_req_lru_item); | 368 | INIT_LIST_HEAD(&req->r_req_lru_item); |
369 | INIT_LIST_HEAD(&req->r_osd_item); | 369 | INIT_LIST_HEAD(&req->r_osd_item); |
370 | 370 | ||
@@ -916,7 +916,7 @@ static void __kick_osd_requests(struct ceph_osd_client *osdc, | |||
916 | * list at the end to keep things in tid order. | 916 | * list at the end to keep things in tid order. |
917 | */ | 917 | */ |
918 | list_for_each_entry_safe(req, nreq, &osd->o_linger_requests, | 918 | list_for_each_entry_safe(req, nreq, &osd->o_linger_requests, |
919 | r_linger_osd) { | 919 | r_linger_osd_item) { |
920 | /* | 920 | /* |
921 | * reregister request prior to unregistering linger so | 921 | * reregister request prior to unregistering linger so |
922 | * that r_osd is preserved. | 922 | * that r_osd is preserved. |
@@ -1218,7 +1218,7 @@ static void __register_linger_request(struct ceph_osd_client *osdc, | |||
1218 | ceph_osdc_get_request(req); | 1218 | ceph_osdc_get_request(req); |
1219 | list_add_tail(&req->r_linger_item, &osdc->req_linger); | 1219 | list_add_tail(&req->r_linger_item, &osdc->req_linger); |
1220 | if (req->r_osd) | 1220 | if (req->r_osd) |
1221 | list_add_tail(&req->r_linger_osd, | 1221 | list_add_tail(&req->r_linger_osd_item, |
1222 | &req->r_osd->o_linger_requests); | 1222 | &req->r_osd->o_linger_requests); |
1223 | } | 1223 | } |
1224 | 1224 | ||
@@ -1228,7 +1228,7 @@ static void __unregister_linger_request(struct ceph_osd_client *osdc, | |||
1228 | dout("__unregister_linger_request %p\n", req); | 1228 | dout("__unregister_linger_request %p\n", req); |
1229 | list_del_init(&req->r_linger_item); | 1229 | list_del_init(&req->r_linger_item); |
1230 | if (req->r_osd) { | 1230 | if (req->r_osd) { |
1231 | list_del_init(&req->r_linger_osd); | 1231 | list_del_init(&req->r_linger_osd_item); |
1232 | 1232 | ||
1233 | if (list_empty(&req->r_osd->o_requests) && | 1233 | if (list_empty(&req->r_osd->o_requests) && |
1234 | list_empty(&req->r_osd->o_linger_requests)) { | 1234 | list_empty(&req->r_osd->o_linger_requests)) { |