fluencelabs/go-libp2p-kad-dht
1
0
Fork 0
mirror of https://github.com/fluencelabs/go-libp2p-kad-dht synced 2025-07-01 21:51:37 +00:00
Code Issues Projects Releases Wiki Activity

reuse streams in the dht networking code

Browse Source 
License: MIT
Signed-off-by: Jeromy <why@ipfs.io>
This commit is contained in:
Jeromy
2016-06-06 17:35:56 -07:00
parent 755b24cff1
commit 031024b1c5
3 changed files with 129 additions and 65 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ext_test.go
View File

@ -2,7 +2,6 @@ package dht
import (
"io"
"io/ioutil"
"math/rand"
"testing"
"time"
@ -40,8 +39,7 @@ func TestGetFailures(t *testing.T) {
// Reply with failures to every message
hosts[1].SetStreamHandler(ProtocolDHT, func(s inet.Stream) {
defer s.Close()
io.Copy(ioutil.Discard, s)
s.Close()
})
// This one should time out
@ -51,7 +49,7 @@ func TestGetFailures(t *testing.T) {
err = merr[0]
}
if err.Error() != "process closing" {
if err != io.EOF {
t.Fatal("Got different error than we expected", err)
}
} else {