From 832fb355fa3148e31d88d257c9d1fa26b80247db Mon Sep 17 00:00:00 2001
From: GoEdgeLab <goedgecloud@gmail.com>
Date: Wed, 16 Mar 2022 15:24:35 +0800
Subject: [PATCH] =?UTF-8?q?=E8=8A=82=E7=82=B9=E5=8F=AF=E4=BB=A5=E5=8D=95?=
 =?UTF-8?q?=E7=8B=AC=E8=AE=BE=E7=BD=AE=E7=BC=93=E5=AD=98=E7=9B=AE=E5=BD=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/caches/manager.go | 6 ++++++
 internal/nodes/node.go     | 1 +
 2 files changed, 7 insertions(+)

diff --git a/internal/caches/manager.go b/internal/caches/manager.go
index de69ab6..d2d9a3a 100644
--- a/internal/caches/manager.go
+++ b/internal/caches/manager.go
@@ -25,6 +25,7 @@ func init() {
 type Manager struct {
 	// 全局配置
 	MaxDiskCapacity   *shared.SizeCapacity
+	DiskDir           string
 	MaxMemoryCapacity *shared.SizeCapacity
 
 	policyMap  map[int64]*serverconfigs.HTTPCachePolicy // policyId => []*Policy
@@ -49,6 +50,11 @@ func (this *Manager) UpdatePolicies(newPolicies []*serverconfigs.HTTPCachePolicy
 
 	newPolicyIds := []int64{}
 	for _, policy := range newPolicies {
+		// 使用节点单独的缓存目录
+		if len(this.DiskDir) > 0 {
+			policy.UpdateDiskDir(this.DiskDir)
+		}
+
 		newPolicyIds = append(newPolicyIds, policy.Id)
 	}
 
diff --git a/internal/nodes/node.go b/internal/nodes/node.go
index bbeec22..463fe18 100644
--- a/internal/nodes/node.go
+++ b/internal/nodes/node.go
@@ -796,6 +796,7 @@ func (this *Node) onReload(config *nodeconfigs.NodeConfig) {
 	// 缓存策略
 	caches.SharedManager.MaxDiskCapacity = config.MaxCacheDiskCapacity
 	caches.SharedManager.MaxMemoryCapacity = config.MaxCacheMemoryCapacity
+	caches.SharedManager.DiskDir = config.CacheDiskDir
 	if len(config.HTTPCachePolicies) > 0 {
 		caches.SharedManager.UpdatePolicies(config.HTTPCachePolicies)
 	} else {