mirror of https://github.com/status-im/consul.git
Revert "ae: add test for resume triggering SyncChanges"
This reverts commit cd0262744d
.
This commit is contained in:
parent
cab3b17292
commit
e0e96496f1
|
@ -27,7 +27,7 @@ func TestAE_scaleFactor(t *testing.T) {
|
|||
}
|
||||
}
|
||||
|
||||
func TestAE_Pause_nestedPauseResume(t *testing.T) {
|
||||
func TestAE_nestedPauseResume(t *testing.T) {
|
||||
t.Parallel()
|
||||
l := NewStateSyner(nil, 0, nil, nil)
|
||||
if l.Paused() != false {
|
||||
|
@ -59,21 +59,7 @@ func TestAE_Pause_nestedPauseResume(t *testing.T) {
|
|||
l.Resume()
|
||||
}
|
||||
|
||||
func TestAE_Pause_ResumeTriggersSyncChanges(t *testing.T) {
|
||||
l := NewStateSyner(nil, 0, nil, nil)
|
||||
l.Pause()
|
||||
l.Resume()
|
||||
select {
|
||||
case <-l.SyncChanges.Notif():
|
||||
// expected
|
||||
case <-l.SyncFull.Notif():
|
||||
t.Fatal("resume triggered SyncFull instead of SyncChanges")
|
||||
default:
|
||||
t.Fatal("resume did not trigger SyncFull")
|
||||
}
|
||||
}
|
||||
|
||||
func TestAE_Pause_ifNotPausedRun(t *testing.T) {
|
||||
func TestAE_ifNotPausedRun(t *testing.T) {
|
||||
l := NewStateSyner(nil, 0, nil, nil)
|
||||
|
||||
errCalled := errors.New("f called")
|
||||
|
|
Loading…
Reference in New Issue