(t *testing.T, rp string)
| 139 | } |
| 140 | |
| 141 | func testSmallReadBuffer(t *testing.T, rp string) { |
| 142 | clientConn, serverConn := newConnPair(rp, nil, nil) |
| 143 | msg := []byte("Very Important Message") |
| 144 | if n, err := clientConn.Write(msg); err != nil { |
| 145 | t.Fatalf("Write() = %v, %v; want %v, <nil>", n, err, len(msg)) |
| 146 | } |
| 147 | rcvMsg := make([]byte, len(msg)) |
| 148 | n := 2 // Arbitrary index to break rcvMsg in two. |
| 149 | rcvMsg1 := rcvMsg[:n] |
| 150 | rcvMsg2 := rcvMsg[n:] |
| 151 | if n, err := serverConn.Read(rcvMsg1); n != len(rcvMsg1) || err != nil { |
| 152 | t.Fatalf("Read() = %v, %v; want %v, <nil>", n, err, len(rcvMsg1)) |
| 153 | } |
| 154 | if n, err := serverConn.Read(rcvMsg2); n != len(rcvMsg2) || err != nil { |
| 155 | t.Fatalf("Read() = %v, %v; want %v, <nil>", n, err, len(rcvMsg2)) |
| 156 | } |
| 157 | if !reflect.DeepEqual(msg, rcvMsg) { |
| 158 | t.Fatalf("Write()/Read() = %v, want %v", rcvMsg, msg) |
| 159 | } |
| 160 | } |
| 161 | |
| 162 | func (s) TestSmallReadBuffer(t *testing.T) { |
| 163 | for _, rp := range recordProtocols { |
no test coverage detected