summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSage Weil <sage@inktank.com>2013-10-01 12:40:36 -0700
committerSage Weil <sage@inktank.com>2013-10-01 12:40:36 -0700
commit399f1d53f7f441992f48aa72139cd628c4ad4f29 (patch)
treeeb249dbcdbf0de6d8f3c02b534d6a47a367ad188
parenta9df335b12a093c31f947d5ca98883de9c2a5cf9 (diff)
parent334f655c27557e5189480a940672cbc2cda435a2 (diff)
downloadceph-399f1d53f7f441992f48aa72139cd628c4ad4f29.tar.gz
Merge pull request #669 from ceph/wip-6443
ReplicatedPG: don't bless C_OSD_SendMessageOnConn Reviewed-by: Sage Weil <sage@inktank.com>
-rw-r--r--src/osd/ReplicatedPG.cc10
1 files changed, 4 insertions, 6 deletions
diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc
index fcaca434ba8..a661aa7f786 100644
--- a/src/osd/ReplicatedPG.cc
+++ b/src/osd/ReplicatedPG.cc
@@ -1602,9 +1602,8 @@ void ReplicatedBackend::_do_push(OpRequestRef op)
reply->compute_cost(cct);
t->register_on_complete(
- get_parent()->bless_context(
- new C_OSD_SendMessageOnConn(
- osd, reply, m->get_connection())));
+ new C_OSD_SendMessageOnConn(
+ osd, reply, m->get_connection()));
get_parent()->queue_transaction(t);
}
@@ -1670,9 +1669,8 @@ void ReplicatedBackend::_do_pull_response(OpRequestRef op)
reply->compute_cost(cct);
t->register_on_complete(
- get_parent()->bless_context(
- new C_OSD_SendMessageOnConn(
- osd, reply, m->get_connection())));
+ new C_OSD_SendMessageOnConn(
+ osd, reply, m->get_connection()));
}
get_parent()->queue_transaction(t);