(t *testing.T, rp string)
| 106 | } |
| 107 | |
| 108 | func testPingPong(t *testing.T, rp string) { |
| 109 | clientConn, serverConn := newConnPair(rp, nil, nil) |
| 110 | clientMsg := []byte("Client Message") |
| 111 | if n, err := clientConn.Write(clientMsg); n != len(clientMsg) || err != nil { |
| 112 | t.Fatalf("Client Write() = %v, %v; want %v, <nil>", n, err, len(clientMsg)) |
| 113 | } |
| 114 | rcvClientMsg := make([]byte, len(clientMsg)) |
| 115 | if n, err := serverConn.Read(rcvClientMsg); n != len(rcvClientMsg) || err != nil { |
| 116 | t.Fatalf("Server Read() = %v, %v; want %v, <nil>", n, err, len(rcvClientMsg)) |
| 117 | } |
| 118 | if !reflect.DeepEqual(clientMsg, rcvClientMsg) { |
| 119 | t.Fatalf("Client Write()/Server Read() = %v, want %v", rcvClientMsg, clientMsg) |
| 120 | } |
| 121 | |
| 122 | serverMsg := []byte("Server Message") |
| 123 | if n, err := serverConn.Write(serverMsg); n != len(serverMsg) || err != nil { |
| 124 | t.Fatalf("Server Write() = %v, %v; want %v, <nil>", n, err, len(serverMsg)) |
| 125 | } |
| 126 | rcvServerMsg := make([]byte, len(serverMsg)) |
| 127 | if n, err := clientConn.Read(rcvServerMsg); n != len(rcvServerMsg) || err != nil { |
| 128 | t.Fatalf("Client Read() = %v, %v; want %v, <nil>", n, err, len(rcvServerMsg)) |
| 129 | } |
| 130 | if !reflect.DeepEqual(serverMsg, rcvServerMsg) { |
| 131 | t.Fatalf("Server Write()/Client Read() = %v, want %v", rcvServerMsg, serverMsg) |
| 132 | } |
| 133 | } |
| 134 | |
| 135 | func (s) TestPingPong(t *testing.T) { |
| 136 | for _, rp := range recordProtocols { |
no test coverage detected