|
@@ -11,6 +11,11 @@ import (
|
|
|
"testing"
|
|
"testing"
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
|
|
+// PSIPHON
|
|
|
|
|
+// =======
|
|
|
|
|
+// See comment in channel.go
|
|
|
|
|
+var testChannelWindowSize = getChannelWindowSize("")
|
|
|
|
|
+
|
|
|
func muxPair() (*mux, *mux) {
|
|
func muxPair() (*mux, *mux) {
|
|
|
a, b := memPipe()
|
|
a, b := memPipe()
|
|
|
|
|
|
|
@@ -139,7 +144,7 @@ func TestMuxChannelOverflow(t *testing.T) {
|
|
|
|
|
|
|
|
wDone := make(chan int, 1)
|
|
wDone := make(chan int, 1)
|
|
|
go func() {
|
|
go func() {
|
|
|
- if _, err := writer.Write(make([]byte, channelWindowSize)); err != nil {
|
|
|
|
|
|
|
+ if _, err := writer.Write(make([]byte, testChannelWindowSize)); err != nil {
|
|
|
t.Errorf("could not fill window: %v", err)
|
|
t.Errorf("could not fill window: %v", err)
|
|
|
}
|
|
}
|
|
|
writer.Write(make([]byte, 1))
|
|
writer.Write(make([]byte, 1))
|
|
@@ -171,7 +176,7 @@ func TestMuxChannelCloseWriteUnblock(t *testing.T) {
|
|
|
|
|
|
|
|
wDone := make(chan int, 1)
|
|
wDone := make(chan int, 1)
|
|
|
go func() {
|
|
go func() {
|
|
|
- if _, err := writer.Write(make([]byte, channelWindowSize)); err != nil {
|
|
|
|
|
|
|
+ if _, err := writer.Write(make([]byte, testChannelWindowSize)); err != nil {
|
|
|
t.Errorf("could not fill window: %v", err)
|
|
t.Errorf("could not fill window: %v", err)
|
|
|
}
|
|
}
|
|
|
if _, err := writer.Write(make([]byte, 1)); err != io.EOF {
|
|
if _, err := writer.Write(make([]byte, 1)); err != io.EOF {
|
|
@@ -193,7 +198,7 @@ func TestMuxConnectionCloseWriteUnblock(t *testing.T) {
|
|
|
|
|
|
|
|
wDone := make(chan int, 1)
|
|
wDone := make(chan int, 1)
|
|
|
go func() {
|
|
go func() {
|
|
|
- if _, err := writer.Write(make([]byte, channelWindowSize)); err != nil {
|
|
|
|
|
|
|
+ if _, err := writer.Write(make([]byte, testChannelWindowSize)); err != nil {
|
|
|
t.Errorf("could not fill window: %v", err)
|
|
t.Errorf("could not fill window: %v", err)
|
|
|
}
|
|
}
|
|
|
if _, err := writer.Write(make([]byte, 1)); err != io.EOF {
|
|
if _, err := writer.Write(make([]byte, 1)); err != io.EOF {
|