Function TestRunPeerListUpdater

client/driver_test.go:337–368

(t *testing.T)

}

func TestRunPeerListUpdater(t *testing.T) {
	Convey("test peersUpdaterRunning", t, func() {
		var stopTestService func()
		var err error

		err = runPeerListUpdater()
		So(err, ShouldNotBeNil)

		stopTestService, _, err = startTestService()
		So(err, ShouldBeNil)
		defer stopTestService()

		// normal case
		err = runPeerListUpdater()
		So(err, ShouldBeNil)

		// only one goroutine will be started
		err = runPeerListUpdater()
		So(err, ShouldBeNil)

		var priv *asymmetric.PrivateKey
		priv, err = kms.GetLocalPrivateKey()
		So(err, ShouldBeNil)
		dbID := proto.DatabaseID("db")

		_, err = getPeers(dbID, priv)
		So(err, ShouldBeNil)

		time.Sleep(1 * time.Second)
		stopPeersUpdater()
	})
}