|
@@ -174,6 +174,7 @@ func (c *ByClassifier) enroll() {
|
|
|
|
|
|
log.Println("Classifier populated...")
|
|
|
go c.CleanThread()
|
|
|
+ go c.CleanMEH()
|
|
|
log.Println("Janitor Started")
|
|
|
|
|
|
}
|
|
@@ -241,3 +242,21 @@ func (c *ByClassifier) readStatsTokens() {
|
|
|
}
|
|
|
|
|
|
}
|
|
|
+
|
|
|
+//CleanMEH cleans periodically the spurious tokens.
|
|
|
+func (c *ByClassifier) CleanMEH() {
|
|
|
+
|
|
|
+ fmt.Println("Clean MEH Thread running...")
|
|
|
+
|
|
|
+ for a := range time.Tick(24 * time.Hour) {
|
|
|
+
|
|
|
+ c.MEH.Range(func(key interface{}, value interface{}) bool {
|
|
|
+ c.MEH.Delete(key)
|
|
|
+ return true
|
|
|
+ })
|
|
|
+
|
|
|
+ log.Println("MEH Cleaned at:", a)
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+}
|