fix: caching deadline duration

ythtwang · Jan 12, 2019 · 8542596 · 8542596
1 parent db5ff83
commit 8542596
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/pkg/proxy/filter_caching.go b/pkg/proxy/filter_caching.go
@@ -67,8 +67,11 @@ func (f *CachingFilter) Post(c filter.Context) (statusCode int, err error) {
 	}
 
 	f.cache.Add(id, genCachedValue(c))
-	f.tw.Schedule(time.Second*time.Duration(c.DispatchNode().Cache.Deadline),
-		f.removeCache, id)
+	if c.DispatchNode().Cache.Deadline > 0 {
+		f.tw.Schedule(time.Duration(c.DispatchNode().Cache.Deadline),
+			f.removeCache, id)
+	}
+
 	return f.BaseFilter.Post(c)
 }