fix errors

This commit is contained in:
Jared Wasinger 2018-04-05 00:15:41 +00:00
parent 8054d2f3a6
commit 83355516c3

View file

@ -177,7 +177,7 @@ 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) cacheTickC := time.Tick(self.cacheTTL)
select { select {
case <-cacheTickC: case <-cacheTickC:
self.cleanFwdCache() self.cleanFwdCache()
@ -765,7 +765,7 @@ func (self *Pss) cleanFwdCache() {
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)
} }
} }
} }