-
Notifications
You must be signed in to change notification settings - Fork 47
Open
Description
A stream muxer stress test i have fails when using muxado, it appears to hang after opening and closing a certain number of streams.
To reproduce:
go get -u github.com/whyrusleeping/go-smux-muxado
cd $GOPATH/src/github.com/whyrusleeping/go-smux-muxado && go test
To make the problem a little more visible, add this print line to jbenet/go-stream-muxer:
diff --git a/test/ttest.go b/test/ttest.go
index d7523b5..29ebb79 100644
--- a/test/ttest.go
+++ b/test/ttest.go
@@ -348,6 +348,7 @@ func SubtestStreamOpenStress(t *testing.T, tr smux.Transport) {
for i := 0; i < count*5; i++ {
select {
case <-recv:
+ fmt.Println("got stream: ", i)
case <-limit:
t.Fatal("timed out receiving streams")
}Metadata
Metadata
Assignees
Labels
No labels