diff --git a/eden/mononoke/newfilenodes/src/reader.rs b/eden/mononoke/newfilenodes/src/reader.rs index ac53fae2e4..e1c140ed9f 100644 --- a/eden/mononoke/newfilenodes/src/reader.rs +++ b/eden/mononoke/newfilenodes/src/reader.rs @@ -39,7 +39,9 @@ define_stats! { prefix = "mononoke.filenodes"; gets: timeseries(Sum), gets_master: timeseries(Sum), + gets_disabled: timeseries(Sum), range_gets: timeseries(Sum), + range_gets_disabled: timeseries(Sum), path_gets: timeseries(Sum), get_local_cache_misses: timeseries(Sum), range_local_cache_misses: timeseries(Sum), @@ -336,6 +338,7 @@ async fn select_filenode_from_sql( recorder: &PerfCounterRecorder<'_>, ) -> Result>, ErrorKind> { if tunables().get_filenodes_disabled() { + STATS::gets_disabled.add_value(1); return Ok(FilenodeResult::Disabled); } @@ -420,6 +423,7 @@ async fn select_history_from_sql( recorder: &PerfCounterRecorder<'_>, ) -> Result, Error> { if tunables().get_filenodes_disabled() { + STATS::range_gets_disabled.add_value(1); return Ok(FilenodeResult::Disabled); } diff --git a/eden/mononoke/newfilenodes/src/writer.rs b/eden/mononoke/newfilenodes/src/writer.rs index 592d9be0fe..ba8a668a9c 100644 --- a/eden/mononoke/newfilenodes/src/writer.rs +++ b/eden/mononoke/newfilenodes/src/writer.rs @@ -24,6 +24,7 @@ use futures::compat::Future01CompatExt; define_stats! { prefix = "mononoke.filenodes"; adds: timeseries(Rate, Sum, Count), + adds_disabled: timeseries(Rate, Sum, Count), } #[derive(Debug, Eq, DeriveError, PartialEq)] @@ -91,6 +92,7 @@ impl FilenodesWriter { replace: bool, ) -> Result, Error> { if tunables().get_filenodes_disabled() { + STATS::adds_disabled.add_value(1); return Ok(FilenodeResult::Disabled); }