This commit is contained in:
William Banfield
2021-09-30 13:53:08 -04:00
parent 530814991f
commit 6ccc2aef9e

View File

@@ -77,12 +77,14 @@ func TestSyncer_SyncAny(t *testing.T) {
require.Error(t, err)
// Adding a couple of peers should trigger snapshot discovery messages
rts.syncer.AddPeer(peerAID)
err = rts.syncer.AddPeer(peerAID)
require.NoError(t, err)
e := <-rts.snapshotOutCh
require.Equal(t, &ssproto.SnapshotsRequest{}, e.Message)
require.Equal(t, peerAID, e.To)
rts.syncer.AddPeer(peerBID)
require.NoError(t, err)
e = <-rts.snapshotOutCh
require.Equal(t, &ssproto.SnapshotsRequest{}, e.Message)
require.Equal(t, peerBID, e.To)