if (orig_ops)
break; // commit what we have
+ if (logger)
+ logger->inc(l_os_j_full);
+
if (wait_on_full) {
dout(20) << "prepare_multi_write full on first entry, need to wait" << dendl;
} else {
plb.add_fl_avg(l_os_apply_lat, "apply_latency");
plb.add_u64(l_os_committing, "committing");
+ plb.add_u64_counter(l_os_commit, "commitcycle");
+ plb.add_fl_avg(l_os_commit_len, "commitcycle_interval");
+ plb.add_fl_avg(l_os_commit_lat, "commitcycle_latency");
+ plb.add_u64_counter(l_os_j_full, "journal_full");
+
logger = plb.create_perf_counters();
}
}
utime_t done = ceph_clock_now(g_ceph_context);
- done -= start;
- dout(10) << "sync_entry commit took " << done << dendl;
+ utime_t lat = done - start;
+ utime_t dur = done - startwait;
+ dout(10) << "sync_entry commit took " << lat << ", interval was " << dur << dendl;
+
+ logger->inc(l_os_commit);
+ logger->finc(l_os_commit_lat, lat);
+ logger->finc(l_os_commit_len, dur);
+
commit_finish();
logger->set(l_os_committing, 0);