forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-22 20:56:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

message debug

Browse source
This commit is contained in:
zsfelfoldi 2015-02-12 16:45:18 +01:00
parent 77ab911aae
commit 9c5b1dbf0c
2 changed files with 7 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
bzz/protocol.go
View file

@ -189,8 +189,10 @@ func (self *bzzProtocol) handle() error {
retrieveRequestMsg // 0x03 retrieveRequestMsg // 0x03
peersMsg // 0x04 peersMsg // 0x04
*/ */
switch msg.Code { switch msg.Code {
case statusMsg: case statusMsg:
dpaLogger.Warnf("Status message: %#v", msg)
return self.protoError(ErrExtraStatusMsg, "") return self.protoError(ErrExtraStatusMsg, "")
case storeRequestMsg: case storeRequestMsg:
@ -206,6 +208,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.Warnf("Request message: %#v", req)
req.peer = peer{bzzProtocol: self} req.peer = peer{bzzProtocol: self}
self.netStore.addRetrieveRequest(&req) self.netStore.addRetrieveRequest(&req)
@ -275,6 +278,7 @@ func (self *bzzProtocol) handleStatus() (err error) {
// outgoing messages // outgoing messages
func (self *bzzProtocol) retrieve(req *retrieveRequestMsgData) { func (self *bzzProtocol) retrieve(req *retrieveRequestMsgData) {
dpaLogger.Warnf("Request message: %#v", req)
p2p.EncodeMsg(self.rw, retrieveRequestMsg, req) p2p.EncodeMsg(self.rw, retrieveRequestMsg, req)
} }

3
p2p/peer.go
View file

@ -299,6 +299,9 @@ func (p *Peer) dispatch(msg Msg, protoDone chan struct{}) (wait bool, err error)
// optimization: msg is small enough, read all // optimization: msg is small enough, read all
// of it and move on to the next message // of it and move on to the next message
buf, err := ioutil.ReadAll(msg.Payload) buf, err := ioutil.ReadAll(msg.Payload)
if len(buf) > 0 {
p.Warnf("Received message %x", buf)
}
if err != nil { if err != nil {
return false, err return false, err
} }