MCPcopy
hub / github.com/gorilla/websocket / TestEOFWithinFrame

Function TestEOFWithinFrame

conn_test.go:380–413  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

378}
379
380func TestEOFWithinFrame(t *testing.T) {
381 const bufSize = 64
382
383 for n := 0; ; n++ {
384 var b bytes.Buffer
385 wc := newTestConn(nil, &b, false)
386 rc := newTestConn(&b, nil, true)
387
388 w, _ := wc.NextWriter(BinaryMessage)
389 w.Write(make([]byte, bufSize))
390 w.Close()
391
392 if n >= b.Len() {
393 break
394 }
395 b.Truncate(n)
396
397 op, r, err := rc.NextReader()
398 if err == errUnexpectedEOF {
399 continue
400 }
401 if op != BinaryMessage || err != nil {
402 t.Fatalf("%d: NextReader() returned %d, %v", n, op, err)
403 }
404 _, err = io.Copy(ioutil.Discard, r)
405 if err != errUnexpectedEOF {
406 t.Fatalf("%d: io.Copy() returned %v, want %v", n, err, errUnexpectedEOF)
407 }
408 _, _, err = rc.NextReader()
409 if err != errUnexpectedEOF {
410 t.Fatalf("%d: NextReader() returned %v, want %v", n, err, errUnexpectedEOF)
411 }
412 }
413}
414
415func TestEOFBeforeFinalFrame(t *testing.T) {
416 const bufSize = 512

Callers

nothing calls this directly

Calls 5

newTestConnFunction · 0.85
NextWriterMethod · 0.80
NextReaderMethod · 0.80
WriteMethod · 0.45
CloseMethod · 0.45

Tested by

no test coverage detected