From b84ed51ce54fd09bfb15e11d484f1ea212080a01 Mon Sep 17 00:00:00 2001 From: Sydonian <794346190@qq.com> Date: Wed, 24 May 2023 10:28:56 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E6=88=90=E8=8A=82=E7=82=B9=E6=A3=80?= =?UTF-8?q?=E6=9F=A5Cache=E7=9A=84=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/event/update_cache.go | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/internal/event/update_cache.go b/internal/event/update_cache.go index b3ac62f..8d9598d 100644 --- a/internal/event/update_cache.go +++ b/internal/event/update_cache.go @@ -1,7 +1,7 @@ package event import ( - tskcst "gitlink.org.cn/cloudream/common/consts/event" + evtcst "gitlink.org.cn/cloudream/common/consts/event" "gitlink.org.cn/cloudream/common/utils/logger" mysql "gitlink.org.cn/cloudream/db/sql" ) @@ -47,7 +47,7 @@ func (t *UpdateCache) TryMerge(other Event) bool { func (t *UpdateCache) Execute(execCtx ExecuteContext) { for _, entry := range t.Entries { switch entry.Operation { - case tskcst.UPDATE_CACHE_OP_UNTEMP: + case evtcst.UPDATE_CACHE_UNTEMP: err := mysql.Cache.DeleteTemp(execCtx.Args.DB.SQLCtx(), entry.FileHash, t.NodeID) if err != nil { @@ -55,6 +55,14 @@ func (t *UpdateCache) Execute(execCtx ExecuteContext) { WithField("NodeID", t.NodeID). Warnf("delete temp cache failed, err: %s", err.Error()) } + + case evtcst.UPDATE_CACHE_CREATE_TEMP: + err := mysql.Cache.CreateTemp(execCtx.Args.DB.SQLCtx(), entry.FileHash, t.NodeID) + if err != nil { + logger.WithField("FileHash", entry.FileHash). + WithField("NodeID", t.NodeID). + Warnf("create temp cache failed, err: %s", err.Error()) + } } } }