deblan-mirror/nextcloud-spreed-signaling
deblan-mirror/nextcloud-spreed-signaling
1
0
Fork 0
mirror of https://github.com/strukturag/nextcloud-spreed-signaling synced 2026-03-14 14:35:44 +01:00
Code Issues Releases Wiki Activity

Don't use hardcoded sleeps when waiting for NATS disconnect / reconnect.

Browse source
This commit is contained in:
Joachim Bauch 2025-04-16 15:09:03 +02:00
commit 83e50d030e
No known key found for this signature in database
GPG key ID: 77C1D22D53E15F02
1 changed files with 9 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

12
natsclient_test.go
View file

@ -174,7 +174,7 @@ func TestNatsClient_MaxReconnects(t *testing.T) {
ensureNoGoroutinesLeak(t, func(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
reconnectWait := 5 * time.Millisecond
reconnectWait := time.Millisecond
server, port, client := CreateLocalNatsClientForTest(t,
nats.ReconnectWait(reconnectWait),
nats.ReconnectJitter(0, 0),
@ -188,12 +188,18 @@ func TestNatsClient_MaxReconnects(t *testing.T) {
server.WaitForShutdown()
// The NATS client tries to reconnect a maximum of 100 times by default.
time.Sleep(time.Second + (100 * reconnectWait))
time.Sleep(100 * reconnectWait)
for i := 0; i < 1000 && c.conn.IsConnected(); i++ {
time.Sleep(time.Millisecond)
}
require.False(c.conn.IsConnected(), "should be disconnected after server shutdown")
server, _ = startLocalNatsServerPort(t, port)
time.Sleep(time.Second)
// Wait for automatic reconnection
for i := 0; i < 1000 && !c.conn.IsConnected(); i++ {
time.Sleep(time.Millisecond)
}
require.True(c.conn.IsConnected(), "not connected after restart")
assert.Equal(server.ID(), c.conn.ConnectedServerId())
})