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

Fix for flapper

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2020-05-22 14:38:04 -07:00
parent 413884d87f
commit ea31c6638f
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/reload_test.go
View File

@@ -4230,6 +4230,7 @@ func TestConfigReloadAccounts(t *testing.T) {
// Below tests use connection names so that they can be checked for.
// The test subscribes to ACC only. This avoids receiving own messages.
subscribe := func(name string) (*nats.Conn, *nats.Subscription, *nats.Subscription) {
t.Helper()
c, err := nats.Connect(urlSys, nats.Name(name))
if err != nil {
t.Fatalf("Error on connect: %v", err)
@@ -4242,9 +4243,11 @@ func TestConfigReloadAccounts(t *testing.T) {
if err != nil {
t.Fatalf("Error on subscribe DISCONNECT: %v", err)
}
c.Flush()
return c, subCon, subDis
}
recv := func(name string, sub *nats.Subscription) {
t.Helper()
if msg, err := sub.NextMsg(1 * time.Second); err != nil {
t.Fatalf("%s Error on next: %v", name, err)
} else {
@@ -4256,6 +4259,7 @@ func TestConfigReloadAccounts(t *testing.T) {
}
}
triggerSysEvent := func(name string, subs []*nats.Subscription) {
t.Helper()
ncs1, err := nats.Connect(urlUsr, nats.Name(name))
if err != nil {
t.Fatalf("Error on connect: %v", err)
@@ -4263,6 +4267,10 @@ func TestConfigReloadAccounts(t *testing.T) {
ncs1.Close()
for _, sub := range subs {
recv(name, sub)
// Make sure they are empty.
if pending, _, _ := sub.Pending(); pending != 0 {
t.Fatalf("Expected no pending, got %d for %+v", pending, sub)
}
}
}