coosld/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2026-03-06 16:58:11 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

bugfixes to prev commit

Browse Source
This commit is contained in:
Juan Batiz-Benet 2014-10-09 04:53:02 -07:00
parent 972c0f7b4b
commit 555bc871fc
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
net/mux/mux_test.go
View File

@ -9,7 +9,6 @@ import (
mh "github.com/jbenet/go-ipfs/Godeps/_workspace/src/github.com/jbenet/go-multihash"
msg "github.com/jbenet/go-ipfs/net/message"
peer "github.com/jbenet/go-ipfs/peer"
u "github.com/jbenet/go-ipfs/util"
context "github.com/jbenet/go-ipfs/Godeps/_workspace/src/code.google.com/p/go.net/context"
)
@ -167,6 +166,7 @@ func TestSimultMuxer(t *testing.T) {
}
// log.Debug("got %v", string(data))
_ = data
counts[pid][1][1]++
case <-ctx.Done():
@ -181,6 +181,7 @@ func TestSimultMuxer(t *testing.T) {
case m := <-mux1.Protocols[pid].GetPipe().Incoming:
counts[pid][0][1]++
// log.Debug("got %v", string(m.Data()))
_ = m
case <-ctx.Done():
return
}

2
routing/dht/Message.go
View File

@ -41,7 +41,7 @@ func peersToPBPeers(peers []*peer.Peer) []*Message_Peer {
func (m *Message) GetClusterLevel() int {
level := m.GetClusterLevelRaw() - 1
if level < 0 {
log.Error("GetClusterLevel: no routing level specified, assuming 0")
log.Debug("GetClusterLevel: no routing level specified, assuming 0")
level = 0
}
return int(level)