X-Git-Url: http://git.osdn.net/view?p=bytom%2Fvapor.git;a=blobdiff_plain;f=netsync%2Fchainmgr%2Ftool_test.go;h=63b6a2f58496c0583359ddd17c28004c64be5463;hp=b9d661fd049925ceb3aebede6bcf1e2e42b08bd5;hb=5819de48d26c0812b18e97c52582985cfff9fe5d;hpb=487513a390cd39a9a9881371cf6d3ac16d44bf43 diff --git a/netsync/chainmgr/tool_test.go b/netsync/chainmgr/tool_test.go index b9d661fd..63b6a2f5 100644 --- a/netsync/chainmgr/tool_test.go +++ b/netsync/chainmgr/tool_test.go @@ -4,6 +4,7 @@ import ( "errors" "math/rand" "net" + "time" "github.com/tendermint/go-wire" "github.com/tendermint/tmlibs/flowrate" @@ -84,6 +85,7 @@ func (p *P2PPeer) setAsync(b bool) { 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) } }