iSharkFly-Docs
/
packer-cn
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix test

This commit is contained in:
Megan Marsh 2018-12-14 13:59:26 -08:00
parent 52176ecf2d
commit f6070de070
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
packer/rpc/mux_broker_test.go
View File

@ -1,6 +1,7 @@
package rpc package rpc
import ( import (
"fmt"
"net" "net"
"testing" "testing"
@ -21,13 +22,13 @@ func TestMuxBroker(t *testing.T) {
go func() { go func() {
c, err := bc.Dial(5) c, err := bc.Dial(5)
if err != nil { if err != nil {
errChan <- fmt.Errorf("err dialing: %s", err) errChan <- fmt.Errorf("err dialing: %s", err.Error())
close(errChan) close(errChan)
return return
} }
if _, err := c.Write([]byte{42}); err != nil { if _, err := c.Write([]byte{42}); err != nil {
errChan <- fmt.Errorf("err writing: %s", err) errChan <- fmt.Errorf("err writing: %s", err.Error())
} }
close(errChan) close(errChan)
@ -51,8 +52,9 @@ func TestMuxBroker(t *testing.T) {
err, open := <-errChan err, open := <-errChan
if !open { if !open {
if err != nil { if err != nil {
t.Fatalf(err) t.Fatalf(err.Error())
} }
break
} }
} }
} }