apps/mochi-mqtt
1
0
Fork 0
mirror of https://github.com/mochi-mqtt/server.git synced 2025-10-13 11:53:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

only check final outcome due to races

Browse Source
This commit is contained in:
mochi
2022-04-10 19:46:12 +01:00
parent 5cb8a081a1
commit 94aeacf0cb
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/server_test.go
View File

@@ -894,7 +894,6 @@ func TestServerEstablishConnectionClearBuffersAfterUse(t *testing.T) {
if err != nil { if err != nil {
panic(err) panic(err)
} }
require.Equal(t, int64(2), s.bytepool.InUse())
recv <- buf recv <- buf
}() }()
@@ -903,7 +902,7 @@ func TestServerEstablishConnectionClearBuffersAfterUse(t *testing.T) {
require.ErrorIs(t, errx, ErrClientDisconnect) require.ErrorIs(t, errx, ErrClientDisconnect)
w.Close() w.Close()
time.Sleep(time.Millisecond * 50) time.Sleep(time.Millisecond * 100)
clw, ok := s.Clients.Get("mochi") clw, ok := s.Clients.Get("mochi")
require.True(t, ok) require.True(t, ok)