diff --git a/api/viid_upload.go b/api/viid_upload.go index f45ccc9..9caecae 100644 --- a/api/viid_upload.go +++ b/api/viid_upload.go @@ -4,6 +4,7 @@ import ( "ZhenTuLocalPassiveAdapter/logger" "context" "fmt" + "go.uber.org/zap" "golang.org/x/sync/errgroup" ) diff --git a/fs/s3_adapter.go b/fs/s3_adapter.go index 84c1a98..a40af2c 100644 --- a/fs/s3_adapter.go +++ b/fs/s3_adapter.go @@ -203,7 +203,11 @@ func init() { func cleanupCache() { var keysToDelete []interface{} s3Cache.Range(func(key, value interface{}) bool { - item := value.(cacheItem) + // 类型检查:跳过非 cacheItem 类型的值(例如 lock_xxx 对应的 *sync.Mutex) + item, ok := value.(cacheItem) + if !ok { + return true + } if time.Now().After(item.expires) { keysToDelete = append(keysToDelete, key) }