summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSage Weil <sage@newdream.net>2009-02-19 14:30:16 -0800
committerSage Weil <sage@newdream.net>2009-02-19 14:30:16 -0800
commit15b2d60d49393dd1c287b47e808cd60cae6eaa0d (patch)
treef485898aef09376870bd5f045dcf8c51d29575fa
parent76ec1b6fbb0873dc8d6df29b5b69d3dabc7e34d9 (diff)
downloadceph-15b2d60d49393dd1c287b47e808cd60cae6eaa0d.tar.gz
kclient: initialize request list_heads
-rw-r--r--src/kernel/mds_client.c3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/kernel/mds_client.c b/src/kernel/mds_client.c
index 876b47e4c7a..69f09abfbf0 100644
--- a/src/kernel/mds_client.c
+++ b/src/kernel/mds_client.c
@@ -848,10 +848,12 @@ ceph_mdsc_create_request(struct ceph_mds_client *mdsc, int op,
return ERR_PTR(-ENOMEM);
req->r_started = jiffies;
req->r_resend_mds = -1;
+ INIT_LIST_HEAD(&req->r_listener_item);
req->r_fmode = -1;
atomic_set(&req->r_ref, 1); /* one for request_tree, one for caller */
init_completion(&req->r_completion);
init_completion(&req->r_safe_completion);
+ INIT_LIST_HEAD(&req->r_unsafe_item);
req->r_op = op;
if (dentry)
@@ -1313,7 +1315,6 @@ void ceph_mdsc_handle_reply(struct ceph_mds_client *mdsc, struct ceph_msg *msg)
if (head->safe) {
req->r_got_safe = true;
__unregister_listener(req);
- req->r_got_safe = true;
complete(&req->r_safe_completion);
if (req->r_got_unsafe) {