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

format. Add separate tick for cache cleaning

Browse source
This commit is contained in:
Jared Wasinger 2018-04-04 21:26:14 +00:00
parent c63b036812
commit 8054d2f3a6
1 changed files with 10 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
swarm/pss/pss.go
View file

@ -177,7 +177,10 @@ func (self *Pss) Start(srv *p2p.Server) error {
go func() { go func() {
for { for {
tickC := time.Tick(defaultCleanInterval) tickC := time.Tick(defaultCleanInterval)
cacheTickC := time.Tick(cacheTTL)
select { select {
case <-cacheTickC:
self.cleanFwdCache()
case <-tickC: case <-tickC:
self.cleanKeys() self.cleanKeys()
case <-self.quitC: case <-self.quitC:
@ -758,13 +761,13 @@ func (self *Pss) forward(msg *PssMsg) {
// remove expired entries from forward cache // remove expired entries from forward cache
func (self *Pss) cleanFwdCache() { func (self *Pss) cleanFwdCache() {
self.fwdCacheMu.Lock() self.fwdCacheMu.Lock()
defer self.fwdCacheMu.Unlock() defer self.fwdCacheMu.Unlock()
for k,v := range self.fwdCache { for k, v := range self.fwdCache {
if v.expiresAt.Before(time.Now()) { if v.expiresAt.Before(time.Now()) {
delete(self.fwdCache[k]) delete(self.fwdCache[k])
} }
} }
} }
// add a message to the cache // add a message to the cache