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

osd: add get_mnow() interface to OSDService, PG, PeeringState

Browse Source 
Single helper to provide a monotonic time offset from startup_time.

Signed-off-by: Sage Weil <sage@redhat.com>
This commit is contained in:
Sage Weil 2019-07-18 14:27:54 -05:00
parent 37a79dd209
commit c5a7cb0a7d
5 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/osd/OSD.cc
View File

@ -321,6 +321,10 @@ void OSDService::dump_live_pgids()
#endif #endif
ceph::signedspan OSDService::get_mnow()
{
return ceph::mono_clock::now() - osd->startup_time;
}
void OSDService::identify_splits_and_merges( void OSDService::identify_splits_and_merges(
OSDMapRef old_map, OSDMapRef old_map,

2
src/osd/OSD.h
View File

@ -138,6 +138,8 @@ public:
} }
} }
ceph::signedspan get_mnow();
private: private:
// -- superblock -- // -- superblock --
ceph::mutex publish_lock, pre_publish_lock; // pre-publish orders before publish ceph::mutex publish_lock, pre_publish_lock; // pre-publish orders before publish

5
src/osd/PG.cc
View File

@ -1800,6 +1800,11 @@ void PG::send_pg_created(pg_t pgid)
osd->send_pg_created(pgid); osd->send_pg_created(pgid);
} }
ceph::signedspan PG::get_mnow()
{
return osd->get_mnow();
}
void PG::rebuild_missing_set_with_deletes(PGLog &pglog) void PG::rebuild_missing_set_with_deletes(PGLog &pglog)
{ {
pglog.rebuild_missing_set_with_deletes( pglog.rebuild_missing_set_with_deletes(

2
src/osd/PG.h
View File

@ -478,6 +478,8 @@ public:
void send_pg_created(pg_t pgid) override; void send_pg_created(pg_t pgid) override;
ceph::signedspan get_mnow() override;
void rebuild_missing_set_with_deletes(PGLog &pglog) override; void rebuild_missing_set_with_deletes(PGLog &pglog) override;
void queue_peering_event(PGPeeringEventRef evt); void queue_peering_event(PGPeeringEventRef evt);

2
src/osd/PeeringState.h
View File

@ -124,6 +124,8 @@ public:
/// Send pg_created to mon /// Send pg_created to mon
virtual void send_pg_created(pg_t pgid) = 0; virtual void send_pg_created(pg_t pgid) = 0;
virtual ceph::signedspan get_mnow() = 0;
// ============ Flush state ================== // ============ Flush state ==================
/** /**
* try_flush_or_schedule_async() * try_flush_or_schedule_async()