logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-07 15:23:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

a little bit more time to avoid races with restoring mutated config variables

Browse Source
This commit is contained in:
vyzo 2020-04-22 20:05:33 +03:00
parent 37e1a81100
commit a50deb04c0
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
gossipsub_spam_test.go
View File

@ -321,7 +321,7 @@ func TestGossipsubAttackGRAFTDuringBackoff(t *testing.T) {
originalGossipSubPruneBackoffPenalty := GossipSubPruneBackoffPenalty originalGossipSubPruneBackoffPenalty := GossipSubPruneBackoffPenalty
GossipSubPruneBackoffPenalty = 500 * time.Millisecond GossipSubPruneBackoffPenalty = 500 * time.Millisecond
defer func() { defer func() {
time.Sleep(time.Second) time.Sleep(time.Second + 100*time.Millisecond)
GossipSubPruneBackoff = originalGossipSubPruneBackoff GossipSubPruneBackoff = originalGossipSubPruneBackoff
GossipSubPruneBackoffPenalty = originalGossipSubPruneBackoffPenalty GossipSubPruneBackoffPenalty = originalGossipSubPruneBackoffPenalty
GossipSubGraftFloodThreshold = originalGossipSubGraftFloodThreshold GossipSubGraftFloodThreshold = originalGossipSubGraftFloodThreshold

6
gossipsub_test.go
View File

@ -272,7 +272,7 @@ func TestGossipsubFanoutMaintenance(t *testing.T) {
func TestGossipsubFanoutExpiry(t *testing.T) { func TestGossipsubFanoutExpiry(t *testing.T) {
GossipSubFanoutTTL = 1 * time.Second GossipSubFanoutTTL = 1 * time.Second
defer func() { defer func() {
time.Sleep(time.Second) time.Sleep(time.Second + 100*time.Millisecond)
GossipSubFanoutTTL = 60 * time.Second GossipSubFanoutTTL = 60 * time.Second
}() }()
@ -1000,7 +1000,7 @@ func TestGossipsubDirectPeers(t *testing.T) {
originalGossipSubDirectConnectTicks := GossipSubDirectConnectTicks originalGossipSubDirectConnectTicks := GossipSubDirectConnectTicks
GossipSubDirectConnectTicks = 2 GossipSubDirectConnectTicks = 2
defer func() { defer func() {
time.Sleep(time.Second) time.Sleep(time.Second + 100*time.Millisecond)
GossipSubDirectConnectTicks = originalGossipSubDirectConnectTicks GossipSubDirectConnectTicks = originalGossipSubDirectConnectTicks
}() }()
@ -1286,7 +1286,7 @@ func TestGossipsubOpportunisticGrafting(t *testing.T) {
originalGossipSubOpportunisticGraftTicks := GossipSubOpportunisticGraftTicks originalGossipSubOpportunisticGraftTicks := GossipSubOpportunisticGraftTicks
GossipSubOpportunisticGraftTicks = 2 GossipSubOpportunisticGraftTicks = 2
defer func() { defer func() {
time.Sleep(time.Second) time.Sleep(time.Second + 100*time.Millisecond)
GossipSubPruneBackoff = originalGossipSubPruneBackoff GossipSubPruneBackoff = originalGossipSubPruneBackoff
GossipSubGraftFloodThreshold = originalGossipSubGraftFloodThreshold GossipSubGraftFloodThreshold = originalGossipSubGraftFloodThreshold
GossipSubOpportunisticGraftTicks = originalGossipSubOpportunisticGraftTicks GossipSubOpportunisticGraftTicks = originalGossipSubOpportunisticGraftTicks