RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-24 19:47:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

crimson: pass real connection in OpsExecuter::do_op_watch_subop_watch()

Browse Source 
Signed-off-by: Radoslaw Zarzynski <rzarzyns@redhat.com>
This commit is contained in:
Radoslaw Zarzynski 2019-12-11 10:13:12 +01:00
parent 11d678ac7d
commit 61ea32441d
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/crimson/osd/ops_executer.cc
View File

@ -131,10 +131,12 @@ OpsExecuter::watch_errorator::future<> OpsExecuter::do_op_watch_subop_watch(
{
struct connect_ctx_t {
ObjectContext::watch_key_t key;
crimson::net::ConnectionRef conn;
watch_info_t info;
connect_ctx_t(const OSDOp& osd_op, const MOSDOp& msg)
: key(osd_op.op.watch.cookie, msg.get_reqid().name),
conn(msg.get_connection()),
info(create_watch_info(osd_op, msg)) {
}
};
@ -159,7 +161,7 @@ OpsExecuter::watch_errorator::future<> OpsExecuter::do_op_watch_subop_watch(
} else {
logger().info("op_effect: found existing watcher: {}", ctx.key);
}
return it->second->connect(nullptr /* conn */, true /* will_ping */);
return it->second->connect(std::move(ctx.conn), true /* will_ping */);
});
}