Compare commits
1
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ce24b177d6 |
@@ -438,35 +438,20 @@ func TestPingPong(t *testing.T) {
|
|||||||
// TestQuietClientAnsweringPingStaysConnected checks that a
|
// TestQuietClientAnsweringPingStaysConnected checks that a
|
||||||
// registered client that sends nothing is sent a PING each
|
// registered client that sends nothing is sent a PING each
|
||||||
// time the ping interval passes, and stays connected as long
|
// time the ping interval passes, and stays connected as long
|
||||||
// as it answers each one, whether with a PONG or with another
|
// as it answers each one.
|
||||||
// line.
|
|
||||||
func TestQuietClientAnsweringPingStaysConnected(t *testing.T) {
|
func TestQuietClientAnsweringPingStaysConnected(t *testing.T) {
|
||||||
t.Parallel()
|
t.Parallel()
|
||||||
|
|
||||||
tests := []struct {
|
env := newTestEnvWithShortPings(t)
|
||||||
name string
|
client := env.dial(t)
|
||||||
answer string
|
client.register("answers")
|
||||||
}{
|
|
||||||
{name: "PONG", answer: "PONG :" + testServerName},
|
for range 3 {
|
||||||
{name: "PING of its own", answer: "PING :answer"},
|
client.readUntil(isServerPing)
|
||||||
|
client.send("PONG :" + testServerName)
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, tt := range tests {
|
client.sendAndExpect("PING :still here", "PONG")
|
||||||
t.Run(tt.name, func(t *testing.T) {
|
|
||||||
t.Parallel()
|
|
||||||
|
|
||||||
env := newTestEnvWithShortPings(t)
|
|
||||||
client := env.dial(t)
|
|
||||||
client.register("answers")
|
|
||||||
|
|
||||||
for range 3 {
|
|
||||||
client.readUntil(isServerPing)
|
|
||||||
client.send(tt.answer)
|
|
||||||
}
|
|
||||||
|
|
||||||
client.sendAndExpect("PING :still here", "still here")
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// TestQuietClientNotAnsweringPingIsClosed checks that a
|
// TestQuietClientNotAnsweringPingIsClosed checks that a
|
||||||
|
|||||||
Reference in new issue
Block a user