Compare commits
1
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
babb3f385d |
@@ -438,20 +438,35 @@ 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.
|
// as it answers each one, whether with a PONG or with another
|
||||||
|
// line.
|
||||||
func TestQuietClientAnsweringPingStaysConnected(t *testing.T) {
|
func TestQuietClientAnsweringPingStaysConnected(t *testing.T) {
|
||||||
t.Parallel()
|
t.Parallel()
|
||||||
|
|
||||||
env := newTestEnvWithShortPings(t)
|
tests := []struct {
|
||||||
client := env.dial(t)
|
name string
|
||||||
client.register("answers")
|
answer string
|
||||||
|
}{
|
||||||
for range 3 {
|
{name: "PONG", answer: "PONG :" + testServerName},
|
||||||
client.readUntil(isServerPing)
|
{name: "PING of its own", answer: "PING :answer"},
|
||||||
client.send("PONG :" + testServerName)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
client.sendAndExpect("PING :still here", "PONG")
|
for _, tt := range tests {
|
||||||
|
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