forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-18 01:43:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

pss: remove expired entries from forward cache

Browse source
This commit is contained in:
Jared Wasinger 2018-04-04 02:47:22 +00:00
parent c9283b79f9
commit c63b036812
1 changed files with 11 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
swarm/pss/pss.go
View file

@ -756,6 +756,17 @@ func (self *Pss) forward(msg *PssMsg) {
// SECTION: Caching // SECTION: Caching
///////////////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////////////////
// remove expired entries from forward cache
func (self *Pss) cleanFwdCache() {
self.fwdCacheMu.Lock()
defer self.fwdCacheMu.Unlock()
for k,v := range self.fwdCache {
if v.expiresAt.Before(time.Now()) {
delete(self.fwdCache[k])
}
}
}
// add a message to the cache // add a message to the cache
func (self *Pss) addFwdCache(msg *PssMsg) error { func (self *Pss) addFwdCache(msg *PssMsg) error {
var entry pssCacheEntry var entry pssCacheEntry