feat(distribution): reset cache before starting

igoogolx · Oct 19, 2023 · db9cf3b · db9cf3b
1 parent 65b3a47
commit db9cf3b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/internal/cfg/distribution/cache.go b/internal/cfg/distribution/cache.go
@@ -8,6 +8,11 @@ import (
 var dnsDomainCache, _ = lru.New(4 * 1024)
 var dnsRuleCache, _ = lru.New(4 * 1024)
 
+func ResetCache() {
+	dnsDomainCache.Purge()
+	dnsRuleCache.Purge()
+}
+
 func GetCachedDnsItem(ip string) (string, constants.DnsType, bool) {
 	rawCachedDomain, ok := dnsDomainCache.Get(ip)
 	if !ok {

diff --git a/internal/cfg/distribution/distribution.go b/internal/cfg/distribution/distribution.go
@@ -104,6 +104,7 @@ func New(
 	tunInterfaceName string,
 	defaultInterfaceName string,
 ) (Config, error) {
+	ResetCache()
 	rEngine, err := ruleEngine.New(ruleId, rules)
 	if err != nil {
 		return Config{}, err