unistack-org/micro
4
0
Fork 3
Code Issues 18 Pull Requests 1 Actions Packages Projects Releases 264 Wiki Activity

go 1.4 doesn't like closed connection, check we closed the listener

Browse Source
This commit is contained in:
Asim 2016-03-14 18:20:38 +00:00
parent 77177508ce
commit fe1fde8c59
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
transport/http_transport_test.go
View File

@ -52,6 +52,8 @@ func TestHTTPTransportCommunication(t *testing.T) {
defer l.Close() defer l.Close()
fn := func(sock transport.Socket) { fn := func(sock transport.Socket) {
defer sock.Close()
for { for {
var m transport.Message var m transport.Message
if err := sock.Recv(&m); err != nil { if err := sock.Recv(&m); err != nil {
@ -66,10 +68,16 @@ func TestHTTPTransportCommunication(t *testing.T) {
} }
} }
done := make(chan bool)
go func() { go func() {
if err := l.Accept(fn); err != nil { if err := l.Accept(fn); err != nil {
select {
case <-done:
default:
t.Errorf("Unexpected accept err: %v", err) t.Errorf("Unexpected accept err: %v", err)
} }
}
}() }()
c, err := tr.Dial(l.Addr()) c, err := tr.Dial(l.Addr())
@ -98,4 +106,6 @@ func TestHTTPTransportCommunication(t *testing.T) {
if string(rm.Body) != string(m.Body) { if string(rm.Body) != string(m.Body) {
t.Errorf("Expected %v, got %v", m.Body, rm.Body) t.Errorf("Expected %v, got %v", m.Body, rm.Body)
} }
close(done)
} }