From c63b03681233714316c3b7c508d5c321d119287f Mon Sep 17 00:00:00 2001
From: Jared Wasinger <j-wasinger@hotmail.com>
Date: Wed, 4 Apr 2018 02:47:22 +0000
Subject: [PATCH] pss: remove expired entries from forward cache

---
 swarm/pss/pss.go | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/swarm/pss/pss.go b/swarm/pss/pss.go
index 1b88c95db2..fed71a389b 100644
--- a/swarm/pss/pss.go
+++ b/swarm/pss/pss.go
@@ -756,6 +756,17 @@ func (self *Pss) forward(msg *PssMsg) {
 // 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
 func (self *Pss) addFwdCache(msg *PssMsg) error {
 	var entry pssCacheEntry