|
@ -523,7 +523,7 @@ FOR_LOOP: |
|
|
break FOR_LOOP |
|
|
break FOR_LOOP |
|
|
} |
|
|
} |
|
|
if msgBytes != nil { |
|
|
if msgBytes != nil { |
|
|
c.Logger.Debug("Received bytes", "chID", pkt.ChannelID, "msgBytes", msgBytes) |
|
|
|
|
|
|
|
|
c.Logger.Debug("Received bytes", "chID", pkt.ChannelID, "msgBytes", fmt.Sprintf("%X", msgBytes)) |
|
|
// NOTE: This means the reactor.Receive runs in the same thread as the p2p recv routine
|
|
|
// NOTE: This means the reactor.Receive runs in the same thread as the p2p recv routine
|
|
|
c.onReceive(pkt.ChannelID, msgBytes) |
|
|
c.onReceive(pkt.ChannelID, msgBytes) |
|
|
} |
|
|
} |
|
|