gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 11:48:43 -07:00
Code Issues Packages Projects Releases Wiki Activity

Make tests a bit more stable

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2018-12-03 15:45:06 -08:00
parent 69d89f75e7
commit b2d8421e21
1 changed files with 14 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
server/events_test.go
View File

@@ -375,10 +375,13 @@ func TestSystemAccountConnectionLimits(t *testing.T) {
defer ncb1.Close()
}
total := sa.NumClients() + sb.NumClients()
if total > int(nac.Limits.Conn) {
t.Fatalf("Expected only %d connections, was allowed to connect %d", nac.Limits.Conn, total)
}
checkFor(t, 1*time.Second, 50*time.Millisecond, func() error {
total := sa.NumClients() + sb.NumClients()
if total > int(nac.Limits.Conn) {
return fmt.Errorf("Expected only %d connections, was allowed to connect %d", nac.Limits.Conn, total)
}
return nil
})
}
// Test that the remote accounting works when a server is started some time later.
@@ -527,7 +530,7 @@ func TestSystemAccountConnectionLimitsServerShutdownForced(t *testing.T) {
sa.mu.Unlock()
// We should eventually be able to connect.
checkFor(t, 5*time.Second, 50*time.Millisecond, func() error {
checkFor(t, 2*time.Second, 50*time.Millisecond, func() error {
if c, err := nats.Connect(urlA, createUserCreds(t, sa, akp)); err != nil {
return err
} else {
@@ -649,9 +652,12 @@ func TestAccountConnsLimitExceededAfterUpdate(t *testing.T) {
}
// We should have max here.
if total := s.NumClients(); total != acc.MaxActiveConnections() {
t.Fatalf("Expected %d connections, got %d", acc.MaxActiveConnections(), total)
}
checkFor(t, 2*time.Second, 50*time.Millisecond, func() error {
if total := s.NumClients(); total != acc.MaxActiveConnections() {
return fmt.Errorf("Expected %d connections, got %d", acc.MaxActiveConnections(), total)
}
return nil
})
// Now change limits to make current connections over the limit.
nac = jwt.NewAccountClaims(pub)