From a7c9534512a97f038838ded4d32913e15f0e05da Mon Sep 17 00:00:00 2001 From: Felix Lange Date: Sun, 4 Jan 2015 00:14:56 +0100 Subject: [PATCH] p2p: remove debugging printf calls --- p2p/peer.go | 2 -- p2p/protocol.go | 5 +---- 2 files changed, 1 insertion(+), 6 deletions(-) diff --git a/p2p/peer.go b/p2p/peer.go index 37b69df3af..72e225c244 100644 --- a/p2p/peer.go +++ b/p2p/peer.go @@ -463,7 +463,6 @@ func (r *eofSignal) Read(buf []byte) (int, error) { func (peer *Peer) PeerList() []interface{} { peers := peer.otherPeers() - fmt.Printf("address length: %v\n", len(peers)) ds := make([]interface{}, 0, len(peers)) for _, p := range peers { p.infolock.Lock() @@ -482,6 +481,5 @@ func (peer *Peer) PeerList() []interface{} { // if ourAddr != nil && !ourAddr.IP.IsLoopback() && !ourAddr.IP.IsUnspecified() { ds = append(ds, ourAddr) } - fmt.Printf("address length: %v\n", len(ds)) return ds } diff --git a/p2p/protocol.go b/p2p/protocol.go index 381f09dfc5..dd8cbc4ecd 100644 --- a/p2p/protocol.go +++ b/p2p/protocol.go @@ -2,7 +2,6 @@ package p2p import ( "bytes" - "fmt" "time" ) @@ -171,8 +170,6 @@ func (bp *baseProtocol) handle(rw MsgReadWriter) error { case getPeersMsg: peers := bp.peer.PeerList() - fmt.Printf("get Peers Msg: peers length:%v\n", len(peers)) - // this is dangerous. the spec says that we should _delay_ // sending the response if no new information is available. // this means that would need to send a response later when @@ -186,7 +183,7 @@ func (bp *baseProtocol) handle(rw MsgReadWriter) error { case peersMsg: var peers []*peerAddr if err := msg.Decode(&peers); err != nil { - return newPeerError(errInvalidMsg, "msg %v : %v", msg, err) + return err } for _, addr := range peers { bp.peer.Debugf("received peer suggestion: %v", addr)