personal_interest_mirrors/nebula
1
0
Fork 0
mirror of https://github.com/slackhq/nebula.git synced 2025-11-22 08:24:25 +01:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

don't wait forever

Browse Source
This commit is contained in:
JackDoan
2025-09-10 11:47:45 -05:00
parent 0721dde24b
commit 241b0a6d7f
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
e2e/tunnels_test.go
View File

@@ -124,11 +124,11 @@ func TestCertUpgrade(t *testing.T) {
panic(err) panic(err)
} }
r.Logf("reload new v2 config") r.Logf("reload new v2-only config")
err = myC.ReloadConfigString(string(cb)) err = myC.ReloadConfigString(string(cb))
assert.NoError(t, err) assert.NoError(t, err)
r.Logf("yay") r.Log("yay, spin until their sees it")
r.Log("spin until their sees it") waitStart := time.Now()
for { for {
assertTunnel(t, myVpnIpNet[0].Addr(), theirVpnIpNet[0].Addr(), myControl, theirControl, r) assertTunnel(t, myVpnIpNet[0].Addr(), theirVpnIpNet[0].Addr(), myControl, theirControl, r)
c := theirControl.GetHostInfoByVpnAddr(myVpnIpNet[0].Addr(), false) c := theirControl.GetHostInfoByVpnAddr(myVpnIpNet[0].Addr(), false)
@@ -141,6 +141,10 @@ func TestCertUpgrade(t *testing.T) {
break break
} }
} }
since := time.Since(waitStart)
if since > time.Second*10 {
t.Fatal("Cert should be new by now")
}
time.Sleep(time.Second) time.Sleep(time.Second)
} }