Adapt to new server structure for routes

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2023-07-11 14:45:29 -07:00
parent 11e5e049cf
commit bd2753d9f6

View File

@@ -3777,9 +3777,11 @@ func TestRouteNoLeakOnSlowConsumer(t *testing.T) {
// This should result in an effectively immediate write timeout,
// which will surface as a slow consumer.
s1.mu.Lock()
for _, cli := range s1.routes {
cli.out.wdl = time.Nanosecond
cli.sendRTTPing()
for _, cl := range s1.routes {
for _, cli := range cl {
cli.out.wdl = time.Nanosecond
cli.sendRTTPing()
}
}
s1.mu.Unlock()