Browse Source

Configurable refresh

Loweel 4 years ago
parent
commit
3e2bb7b4cc
2 changed files with 3 additions and 3 deletions
  1. 1 1
      main.go
  2. 2 2
      matrix.go

+ 1 - 1
main.go

@@ -39,7 +39,7 @@ func main() {
 
 	ProxyFlow.refreshtime, err = time.ParseDuration(os.Getenv("REFRESHTIME"))
 	if err != nil {
-		ProxyFlow.refreshtime = time.Duration(24 * time.Hour)
+		ProxyFlow.refreshtime = time.Duration(48 * time.Hour)
 	}
 
 	proxy := httputil.NewSingleHostReverseProxy(remote)

+ 2 - 2
matrix.go

@@ -246,9 +246,9 @@ func (c *ByClassifier) readStatsTokens() {
 //CleanMEH cleans periodically the spurious tokens.
 func (c *ByClassifier) CleanMEH() {
 
-	log.Println("Clean MEH Thread running...")
+	log.Println("Clean MEH Thread running each: ", ProxyFlow.refreshtime)
 
-	for a := range time.Tick(HTTPFlow.refreshtime) {
+	for a := range time.Tick(ProxyFlow.refreshtime) {
 
 		c.MEH.Range(func(key interface{}, value interface{}) bool {
 			c.MEH.Delete(key)