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

crimson/osd: implement ShardServices::get_hb_stamps()

Browse Source 
PeeringState::proc_lease() requires a valid hb_stamps[0], which is in
turned maintained by `pl`.

Signed-off-by: Kefu Chai <kchai@redhat.com>
This commit is contained in:
Kefu Chai 2019-09-30 16:20:37 +08:00
parent b031ecda44
commit 3138e195fa
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/crimson/osd/shard_services.cc
View File

@ -239,8 +239,11 @@ seastar::future<> ShardServices::osdmap_subscribe(version_t epoch, bool force_re
HeartbeatStampsRef ShardServices::get_hb_stamps(int peer)
{
#warning writeme
return HeartbeatStampsRef();
auto [stamps, added] = heartbeat_stamps.try_emplace(peer);
if (added) {
stamps->second = ceph::make_ref<HeartbeatStamps>(peer);
}
return stamps->second;
}
};

1
src/crimson/osd/shard_services.h
View File

@ -157,6 +157,7 @@ public:
return ceph::mono_clock::now() - startup_time;
}
HeartbeatStampsRef get_hb_stamps(int peer);
std::map<int, HeartbeatStampsRef> heartbeat_stamps;
};