"errors"
"math/rand"
"net"
+ "time"
"github.com/tendermint/go-wire"
"github.com/tendermint/tmlibs/flowrate"
func (p *P2PPeer) postMan() {
for msgBytes := range p.msgCh {
msgType, msg, _ := decodeMessage(msgBytes)
+ time.Sleep(10 * time.Millisecond)
p.remoteNode.processMsg(p.srcPeer, msgType, msg)
}
}