Function TestTakeLinearizabilityTestResultOverflow

fbclock/daemon/state_test.go:148–163

(t *testing.T)

	s.pushLinearizabilityTestResult(r3)

	got := s.takeLinearizabilityTestResult(2)
	require.Len(t, got, 2)
	require.Contains(t, got, linearizability.TestResult(r3))
	require.Contains(t, got, linearizability.TestResult(r2))
}

func TestAggregateDataPointsMaxEmpty(t *testing.T) {
	s := newDaemonState(5)
	got := s.aggregateDataPointsMax(5)
	require.Equal(t, &DataPoint{}, got)
}

func TestAggregateDataPointsMaxSingleEntry(t *testing.T) {
	s := newDaemonState(5)
	dp := &DataPoint{
		MasterOffsetNS:    -500.0,
		PathDelayNS:       -200.0,
		FreqAdjustmentPPB: 300.0,
	}