Skip to content

Commit

Permalink
drop time_since_ingress_ns counter
Browse files Browse the repository at this point in the history
Summary: `time_since_ingress_ns` is a derivative from `ingress_time_ns`. Let's not send duplicated data

Reviewed By: pmazzini

Differential Revision: D51034408

fbshipit-source-id: f94b5f32a053aa8a4507fc5235e8d9abcc55aa87
  • Loading branch information
leoleovich authored and facebook-github-bot committed Nov 7, 2023
1 parent 283f4bf commit 2453569
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 7 deletions.
2 changes: 0 additions & 2 deletions fbclock/daemon/daemon.go
Original file line number Diff line number Diff line change
Expand Up @@ -137,7 +137,6 @@ func New(cfg *Config, stats StatsServer, l Logger) (*Daemon, error) {
s.stats.SetCounter("m_ns", 0)
s.stats.SetCounter("w_ns", 0)
s.stats.SetCounter("drift_ppb", 0)
s.stats.SetCounter("time_since_ingress_ns", 0)
// error counters
s.stats.SetCounter("data_error", 0)
s.stats.SetCounter("phc_error", 0)
Expand Down Expand Up @@ -276,7 +275,6 @@ func (s *Daemon) doWork(shm *fbclock.Shm, data *DataPoint) error {
it := s.state.ingressTimeNS()
if it > 0 {
timeSinceIngress := phcTime.UnixNano() - it
s.stats.SetCounter("time_since_ingress_ns", timeSinceIngress)
log.Debugf("Time since ingress: %dns", timeSinceIngress)
} else {
log.Warningf("No data for time since ingress")
Expand Down
6 changes: 1 addition & 5 deletions fbclock/daemon/daemon_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -494,7 +494,6 @@ func TestDaemonDoWork(t *testing.T) {
require.Error(t, err, "not enough data should give us error when calculating shm state")
// not enough data for those
require.Equal(t, int64(0), stats.counters["ingress_time_ns"])
require.Equal(t, int64(0), stats.counters["time_since_ingress_ns"])
require.Equal(t, int64(0), stats.counters["master_offset_ns"])
require.Equal(t, int64(0), stats.counters["path_delay_ns"])
require.Equal(t, int64(0), stats.counters["freq_adj_ppb"])
Expand Down Expand Up @@ -525,7 +524,6 @@ func TestDaemonDoWork(t *testing.T) {
require.NoError(t, err, "not enough data should give us error when calculating shm state, which we log and continue")
// check exported stats
require.Equal(t, int64(tme), stats.counters["ingress_time_ns"])
require.Equal(t, int64(time.Microsecond), stats.counters["time_since_ingress_ns"])
require.Equal(t, int64(d.MasterOffsetNS), stats.counters["master_offset_ns"])
require.Equal(t, int64(d.PathDelayNS), stats.counters["path_delay_ns"])
require.Equal(t, int64(d.FreqAdjustmentPPB), stats.counters["freq_adj_ppb"])
Expand Down Expand Up @@ -558,7 +556,6 @@ func TestDaemonDoWork(t *testing.T) {
require.NoError(t, err)
// check that we have proper stats reported
require.Equal(t, int64(startTime+61*time.Second), stats.counters["ingress_time_ns"], "ingress_time_ns after good data")
require.Equal(t, int64(time.Second), stats.counters["time_since_ingress_ns"], "time_since_ingress_ns after good data")
require.Equal(t, int64(d.MasterOffsetNS), stats.counters["master_offset_ns"], "master_offset_ns after good data")
require.Equal(t, int64(d.PathDelayNS), stats.counters["path_delay_ns"], "path_delay_ns after good data")
require.Equal(t, int64(d.FreqAdjustmentPPB), stats.counters["freq_adj_ppb"], "freq_adj_ppb after good data")
Expand Down Expand Up @@ -597,13 +594,12 @@ func TestDaemonDoWork(t *testing.T) {
require.Error(t, err, "data point fails sanity check")
// check that we have proper stats reported
require.Equal(t, int64(0), stats.counters["ingress_time_ns"], "ingress_time_ns after bad data")
require.Equal(t, int64(2*time.Second), stats.counters["time_since_ingress_ns"], "time_since_ingress_ns after bad data")
require.Equal(t, int64(d.MasterOffsetNS), stats.counters["master_offset_ns"], "master_offset_ns after bad data")
require.Equal(t, int64(d.PathDelayNS), stats.counters["path_delay_ns"], "path_delay_ns after bad data")
require.Equal(t, int64(d.FreqAdjustmentPPB), stats.counters["freq_adj_ppb"], "freq_adj_ppb after bad data")
require.Equal(t, int64(48), stats.counters["m_ns"], "m_ns after bad data")
require.Equal(t, int64(48), stats.counters["w_ns"], "w_ns after bad data")
require.Equal(t, int64(64), stats.counters["drift_ppb"], "w_ns after bad data")
require.Equal(t, int64(64), stats.counters["drift_ppb"], "drift_ppb after bad data")
require.Equal(t, int64(23), stats.counters["master_offset_ns.60.abs_max"], "master_offset_ns.60.abs_max after bad data")
require.Equal(t, int64(213), stats.counters["path_delay_ns.60.abs_max"], "path_delay_ns.60.abs_max after bad data")
require.Equal(t, int64(212159), stats.counters["freq_adj_ppb.60.abs_max"], "freq_adj_ppb.60.abs_max after bad data")
Expand Down

0 comments on commit 2453569

Please sign in to comment.