RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-03 01:22:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

osd: l_osd_agent_{wake,skip,flush,evict}

Browse Source 
Signed-off-by: Sage Weil <sage@inktank.com>
This commit is contained in:
Sage Weil 2014-02-17 12:23:44 -08:00
parent dbec1096f4
commit d1a185bd4b
3 changed files with 22 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/osd/OSD.cc
View File

@ -1444,6 +1444,11 @@ void OSD::create_logger()
osd_plb.add_u64_counter(l_osd_tier_dirty, "tier_dirty");
osd_plb.add_u64_counter(l_osd_tier_clean, "tier_clean");
osd_plb.add_u64_counter(l_osd_agent_wake, "agent_wake");
osd_plb.add_u64_counter(l_osd_agent_skip, "agent_skip");
osd_plb.add_u64_counter(l_osd_agent_flush, "agent_flush");
osd_plb.add_u64_counter(l_osd_agent_evict, "agent_evict");
logger = osd_plb.create_perf_counters();
cct->get_perfcounters_collection()->add(logger);
}

5
src/osd/OSD.h
View File

@ -134,6 +134,11 @@ enum {
l_osd_tier_dirty,
l_osd_tier_clean,
l_osd_agent_wake,
l_osd_agent_skip,
l_osd_agent_flush,
l_osd_agent_evict,
l_osd_last,
};

12
src/osd/ReplicatedPG.cc
View File

@ -10274,6 +10274,8 @@ void ReplicatedPG::agent_work(int start_max)
return;
}
osd->logger->inc(l_osd_agent_wake);
dout(10) << __func__
<< " max " << start_max
<< ", flush " << agent_state->get_flush_mode_name()
@ -10305,29 +10307,35 @@ void ReplicatedPG::agent_work(int start_max)
++p) {
if (is_degraded_object(*p)) {
dout(20) << __func__ << " skip (degraded) " << *p << dendl;
osd->logger->inc(l_osd_agent_skip);
continue;
}
ObjectContextRef obc = get_object_context(*p, false, NULL);
if (!obc) {
// we didn't flush; we may miss something here.
dout(20) << __func__ << " no obc for " << *p << ", skipping" << dendl;
osd->logger->inc(l_osd_agent_skip);
continue;
}
if (!obc->obs.exists) {
dout(20) << __func__ << " " << obc->obs.oi.soid << " dne, skipping"
<< dendl;
osd->logger->inc(l_osd_agent_skip);
continue;
}
if (scrubber.write_blocked_by_scrub(obc->obs.oi.soid)) {
dout(20) << __func__ << " scrubbing, skipping " << obc->obs.oi << dendl;
osd->logger->inc(l_osd_agent_skip);
continue;
}
if (obc->obs.oi.soid.nspace == cct->_conf->osd_hit_set_namespace) {
dout(20) << __func__ << " skip (hit set) " << obc->obs.oi << dendl;
osd->logger->inc(l_osd_agent_skip);
continue;
}
if (obc->is_blocked()) {
dout(20) << __func__ << " skip (blocked) " << obc->obs.oi << dendl;
osd->logger->inc(l_osd_agent_skip);
continue;
}
@ -10335,6 +10343,7 @@ void ReplicatedPG::agent_work(int start_max)
if (base_pool->is_erasure() &&
obc->obs.oi.test_flag(object_info_t::FLAG_OMAP)) {
dout(20) << __func__ << " skip (omap to EC) " << obc->obs.oi << dendl;
osd->logger->inc(l_osd_agent_skip);
continue;
}
@ -10410,6 +10419,8 @@ bool ReplicatedPG::agent_maybe_flush(ObjectContextRef& obc)
ctx->on_finish = new C_AgentFlushStartStop(this, obc->obs.oi.soid);
start_flush(ctx, false);
osd->logger->inc(l_osd_agent_flush);
return true;
}
@ -10489,6 +10500,7 @@ bool ReplicatedPG::agent_maybe_evict(ObjectContextRef& obc)
finish_ctx(ctx, pg_log_entry_t::DELETE);
simple_repop_submit(repop);
osd->logger->inc(l_osd_tier_evict);
osd->logger->inc(l_osd_agent_evict);
return true;
}