forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-23 05:06:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

added some debug logs

Browse source
This commit is contained in:
zelig 2015-05-18 20:30:40 +01:00
parent b652c9594f
commit 614b76baf7
2 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
bzz/hive.go
View file

@ -75,6 +75,7 @@ func (self *hive) stop() error {
} }
func (self *hive) addPeer(p peer) { func (self *hive) addPeer(p peer) {
dpaLogger.Debugf("hive: add peer %v", p)
self.kad.AddNode(p) self.kad.AddNode(p)
// self lookup // self lookup
req := &retrieveRequestMsgData{ req := &retrieveRequestMsgData{
@ -85,6 +86,7 @@ func (self *hive) addPeer(p peer) {
} }
func (self *hive) removePeer(p peer) { func (self *hive) removePeer(p peer) {
dpaLogger.Debugf("hive: remove peer %v", p)
self.kad.RemoveNode(p) self.kad.RemoveNode(p)
self.ping <- false self.ping <- false
} }

8
bzz/protocol.go
View file

@ -122,7 +122,7 @@ type storeRequestMsgData struct {
peer peer peer peer
} }
func (self *storeRequestMsgData) String() string { func (self storeRequestMsgData) String() string {
return fmt.Sprintf("From: %v, Key: %x; ID: %v, requestTimeout: %v, storageTimeout: %v, SData %x", self.peer.Addr(), self.Key[:4], self.Id, self.requestTimeout, self.storageTimeout, self.SData[:10]) return fmt.Sprintf("From: %v, Key: %x; ID: %v, requestTimeout: %v, storageTimeout: %v, SData %x", self.peer.Addr(), self.Key[:4], self.Id, self.requestTimeout, self.storageTimeout, self.SData[:10])
} }
@ -145,7 +145,7 @@ type retrieveRequestMsgData struct {
peer peer // protocol registers the requester peer peer // protocol registers the requester
} }
func (self *retrieveRequestMsgData) String() string { func (self retrieveRequestMsgData) String() string {
return fmt.Sprintf("From: %v, Key: %x; ID: %v, MaxSize: %v, MaxPeers: %v", self.peer.Addr(), self.Key[:4], self.Id, self.MaxSize, self.MaxPeers) return fmt.Sprintf("From: %v, Key: %x; ID: %v, MaxSize: %v, MaxPeers: %v", self.peer.Addr(), self.Key[:4], self.Id, self.MaxSize, self.MaxPeers)
} }
@ -288,7 +288,7 @@ func (self *bzzProtocol) handle() error {
if err := msg.Decode(&req); err != nil { if err := msg.Decode(&req); err != nil {
return self.protoError(ErrDecode, "->msg %v: %v", msg, err) return self.protoError(ErrDecode, "->msg %v: %v", msg, err)
} }
dpaLogger.Debugf("Request message: %v", req) dpaLogger.Debugf("Receiving retrieve request: %v", req)
if req.Key == nil { if req.Key == nil {
return self.protoError(ErrDecode, "protocol handler: req.Key == nil || req.Timeout == nil") return self.protoError(ErrDecode, "protocol handler: req.Key == nil || req.Timeout == nil")
} }
@ -396,7 +396,7 @@ func (self *bzzProtocol) peerAddr() *peerAddr {
// outgoing messages // outgoing messages
func (self *bzzProtocol) retrieve(req *retrieveRequestMsgData) { func (self *bzzProtocol) retrieve(req *retrieveRequestMsgData) {
dpaLogger.Debugf("Request message: %v", req) dpaLogger.Debugf("Sending retrieve request: %v", req)
err := p2p.Send(self.rw, retrieveRequestMsg, req) err := p2p.Send(self.rw, retrieveRequestMsg, req)
if err != nil { if err != nil {
dpaLogger.Errorf("EncodeMsg error: %v", err) dpaLogger.Errorf("EncodeMsg error: %v", err)