mirror of
https://github.com/golang/net.git
synced 2026-03-31 18:37:08 +09:00
b7f5d985f9
Make the pipe code take an interface as the backing store. Now a pipe is something that's goroutine-safe and does the Cond waits but its underlying data is now an interface: anything that's a ReaderWriter with a Len method (such as a *bytes.Buffer), or a fixedBuffer (renamed in this CL from 'buffer'). This opens the ground to having a non-fixed buffer used with pipe. This also moves the CloseWithError code up into the pipe code, out of fixedBuffer. Change-Id: Ia3b853e8aa8920807b705ff4e41bed934a8c67b7 Reviewed-on: https://go-review.googlesource.com/16312 Reviewed-by: Blake Mizerany <blake.mizerany@gmail.com>
129 lines
2.3 KiB
Go
129 lines
2.3 KiB
Go
// Copyright 2014 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package http2
|
|
|
|
import (
|
|
"reflect"
|
|
"testing"
|
|
)
|
|
|
|
var bufferReadTests = []struct {
|
|
buf fixedBuffer
|
|
read, wn int
|
|
werr error
|
|
wp []byte
|
|
wbuf fixedBuffer
|
|
}{
|
|
{
|
|
fixedBuffer{[]byte{'a', 0}, 0, 1},
|
|
5, 1, nil, []byte{'a'},
|
|
fixedBuffer{[]byte{'a', 0}, 0, 0},
|
|
},
|
|
{
|
|
fixedBuffer{[]byte{0, 'a'}, 1, 2},
|
|
5, 1, nil, []byte{'a'},
|
|
fixedBuffer{[]byte{0, 'a'}, 0, 0},
|
|
},
|
|
{
|
|
fixedBuffer{[]byte{'a', 'b'}, 0, 2},
|
|
1, 1, nil, []byte{'a'},
|
|
fixedBuffer{[]byte{'a', 'b'}, 1, 2},
|
|
},
|
|
{
|
|
fixedBuffer{[]byte{}, 0, 0},
|
|
5, 0, errReadEmpty, []byte{},
|
|
fixedBuffer{[]byte{}, 0, 0},
|
|
},
|
|
}
|
|
|
|
func TestBufferRead(t *testing.T) {
|
|
for i, tt := range bufferReadTests {
|
|
read := make([]byte, tt.read)
|
|
n, err := tt.buf.Read(read)
|
|
if n != tt.wn {
|
|
t.Errorf("#%d: wn = %d want %d", i, n, tt.wn)
|
|
continue
|
|
}
|
|
if err != tt.werr {
|
|
t.Errorf("#%d: werr = %v want %v", i, err, tt.werr)
|
|
continue
|
|
}
|
|
read = read[:n]
|
|
if !reflect.DeepEqual(read, tt.wp) {
|
|
t.Errorf("#%d: read = %+v want %+v", i, read, tt.wp)
|
|
}
|
|
if !reflect.DeepEqual(tt.buf, tt.wbuf) {
|
|
t.Errorf("#%d: buf = %+v want %+v", i, tt.buf, tt.wbuf)
|
|
}
|
|
}
|
|
}
|
|
|
|
var bufferWriteTests = []struct {
|
|
buf fixedBuffer
|
|
write, wn int
|
|
werr error
|
|
wbuf fixedBuffer
|
|
}{
|
|
{
|
|
buf: fixedBuffer{
|
|
buf: []byte{},
|
|
},
|
|
wbuf: fixedBuffer{
|
|
buf: []byte{},
|
|
},
|
|
},
|
|
{
|
|
buf: fixedBuffer{
|
|
buf: []byte{1, 'a'},
|
|
},
|
|
write: 1,
|
|
wn: 1,
|
|
wbuf: fixedBuffer{
|
|
buf: []byte{0, 'a'},
|
|
w: 1,
|
|
},
|
|
},
|
|
{
|
|
buf: fixedBuffer{
|
|
buf: []byte{'a', 1},
|
|
r: 1,
|
|
w: 1,
|
|
},
|
|
write: 2,
|
|
wn: 2,
|
|
wbuf: fixedBuffer{
|
|
buf: []byte{0, 0},
|
|
w: 2,
|
|
},
|
|
},
|
|
{
|
|
buf: fixedBuffer{
|
|
buf: []byte{},
|
|
},
|
|
write: 5,
|
|
werr: errWriteFull,
|
|
wbuf: fixedBuffer{
|
|
buf: []byte{},
|
|
},
|
|
},
|
|
}
|
|
|
|
func TestBufferWrite(t *testing.T) {
|
|
for i, tt := range bufferWriteTests {
|
|
n, err := tt.buf.Write(make([]byte, tt.write))
|
|
if n != tt.wn {
|
|
t.Errorf("#%d: wrote %d bytes; want %d", i, n, tt.wn)
|
|
continue
|
|
}
|
|
if err != tt.werr {
|
|
t.Errorf("#%d: error = %v; want %v", i, err, tt.werr)
|
|
continue
|
|
}
|
|
if !reflect.DeepEqual(tt.buf, tt.wbuf) {
|
|
t.Errorf("#%d: buf = %+v; want %+v", i, tt.buf, tt.wbuf)
|
|
}
|
|
}
|
|
}
|