diff --git a/bzz/hive.go b/bzz/hive.go index 9c49b68185..98033351e5 100644 --- a/bzz/hive.go +++ b/bzz/hive.go @@ -75,6 +75,7 @@ func (self *hive) stop() error { } func (self *hive) addPeer(p peer) { + dpaLogger.Debugf("hive: add peer %v", p) self.kad.AddNode(p) // self lookup req := &retrieveRequestMsgData{ @@ -85,6 +86,7 @@ func (self *hive) addPeer(p peer) { } func (self *hive) removePeer(p peer) { + dpaLogger.Debugf("hive: remove peer %v", p) self.kad.RemoveNode(p) self.ping <- false } diff --git a/bzz/protocol.go b/bzz/protocol.go index 72f163d750..40951e9c35 100644 --- a/bzz/protocol.go +++ b/bzz/protocol.go @@ -122,7 +122,7 @@ type storeRequestMsgData struct { 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]) } @@ -145,7 +145,7 @@ type retrieveRequestMsgData struct { 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) } @@ -288,7 +288,7 @@ func (self *bzzProtocol) handle() error { if err := msg.Decode(&req); err != nil { 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 { return self.protoError(ErrDecode, "protocol handler: req.Key == nil || req.Timeout == nil") } @@ -396,7 +396,7 @@ func (self *bzzProtocol) peerAddr() *peerAddr { // outgoing messages 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) if err != nil { dpaLogger.Errorf("EncodeMsg error: %v", err)