mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-22 04:36:42 +00:00
p2p: remove debugging printf calls
This commit is contained in:
parent
1869e5fd7a
commit
a7c9534512
2 changed files with 1 additions and 6 deletions
|
|
@ -463,7 +463,6 @@ func (r *eofSignal) Read(buf []byte) (int, error) {
|
||||||
|
|
||||||
func (peer *Peer) PeerList() []interface{} {
|
func (peer *Peer) PeerList() []interface{} {
|
||||||
peers := peer.otherPeers()
|
peers := peer.otherPeers()
|
||||||
fmt.Printf("address length: %v\n", len(peers))
|
|
||||||
ds := make([]interface{}, 0, len(peers))
|
ds := make([]interface{}, 0, len(peers))
|
||||||
for _, p := range peers {
|
for _, p := range peers {
|
||||||
p.infolock.Lock()
|
p.infolock.Lock()
|
||||||
|
|
@ -482,6 +481,5 @@ func (peer *Peer) PeerList() []interface{} {
|
||||||
// if ourAddr != nil && !ourAddr.IP.IsLoopback() && !ourAddr.IP.IsUnspecified() {
|
// if ourAddr != nil && !ourAddr.IP.IsLoopback() && !ourAddr.IP.IsUnspecified() {
|
||||||
ds = append(ds, ourAddr)
|
ds = append(ds, ourAddr)
|
||||||
}
|
}
|
||||||
fmt.Printf("address length: %v\n", len(ds))
|
|
||||||
return ds
|
return ds
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -2,7 +2,6 @@ package p2p
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
"fmt"
|
|
||||||
"time"
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
@ -171,8 +170,6 @@ func (bp *baseProtocol) handle(rw MsgReadWriter) error {
|
||||||
|
|
||||||
case getPeersMsg:
|
case getPeersMsg:
|
||||||
peers := bp.peer.PeerList()
|
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_
|
// this is dangerous. the spec says that we should _delay_
|
||||||
// sending the response if no new information is available.
|
// sending the response if no new information is available.
|
||||||
// this means that would need to send a response later when
|
// this means that would need to send a response later when
|
||||||
|
|
@ -186,7 +183,7 @@ func (bp *baseProtocol) handle(rw MsgReadWriter) error {
|
||||||
case peersMsg:
|
case peersMsg:
|
||||||
var peers []*peerAddr
|
var peers []*peerAddr
|
||||||
if err := msg.Decode(&peers); err != nil {
|
if err := msg.Decode(&peers); err != nil {
|
||||||
return newPeerError(errInvalidMsg, "msg %v : %v", msg, err)
|
return err
|
||||||
}
|
}
|
||||||
for _, addr := range peers {
|
for _, addr := range peers {
|
||||||
bp.peer.Debugf("received peer suggestion: %v", addr)
|
bp.peer.Debugf("received peer suggestion: %v", addr)
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue