add early timecache check for already validated messages

This commit is contained in:
vyzo 2019-01-22 00:47:12 +02:00
parent 67eece2526
commit 4b55053bfb
1 changed files with 6 additions and 0 deletions

View File

@ -625,6 +625,12 @@ func (p *PubSub) pushMsg(vals []*topicVal, src peer.ID, msg *Message) {
return
}
// have we already seen and validated this message?
id := msgID(msg.Message)
if p.seenMessage(id) {
return
}
if len(vals) > 0 || msg.Signature != nil {
// validation is asynchronous and globally throttled with the throttleValidate semaphore.
// the purpose of the global throttle is to bound the goncurrency possible from incoming