From ccfc8ca6c228c503bab23f363bc9886f33eb63df Mon Sep 17 00:00:00 2001 From: Sydonian <794346190@qq.com> Date: Wed, 14 Jun 2023 16:10:04 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BB=99scanner=E7=9A=84Event=E5=8A=A0?= =?UTF-8?q?=E9=94=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/distlock/reqbuilder/metadata_cache.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/pkg/distlock/reqbuilder/metadata_cache.go b/pkg/distlock/reqbuilder/metadata_cache.go index 0638a0f..ca6b6a1 100644 --- a/pkg/distlock/reqbuilder/metadata_cache.go +++ b/pkg/distlock/reqbuilder/metadata_cache.go @@ -13,27 +13,27 @@ func (b *MetadataLockReqBuilder) Cache() *MetadataCacheLockReqBuilder { return &MetadataCacheLockReqBuilder{MetadataLockReqBuilder: b} } -func (b *MetadataCacheLockReqBuilder) ReadOne(objectID int) *MetadataCacheLockReqBuilder { +func (b *MetadataCacheLockReqBuilder) ReadOne(nodeID int, fileHash string) *MetadataCacheLockReqBuilder { b.locks = append(b.locks, distlock.Lock{ Path: b.makePath("Cache"), Name: lockprovider.METADATA_ELEMENT_READ_LOCK, - Target: *lockprovider.NewStringLockTarget().Add(objectID), + Target: *lockprovider.NewStringLockTarget().Add(nodeID, fileHash), }) return b } -func (b *MetadataCacheLockReqBuilder) WriteOne(objectID int) *MetadataCacheLockReqBuilder { +func (b *MetadataCacheLockReqBuilder) WriteOne(nodeID int, fileHash string) *MetadataCacheLockReqBuilder { b.locks = append(b.locks, distlock.Lock{ Path: b.makePath("Cache"), Name: lockprovider.METADATA_ELEMENT_WRITE_LOCK, - Target: *lockprovider.NewStringLockTarget().Add(objectID), + Target: *lockprovider.NewStringLockTarget().Add(nodeID, fileHash), }) return b } -func (b *MetadataCacheLockReqBuilder) CreateOne() *MetadataCacheLockReqBuilder { +func (b *MetadataCacheLockReqBuilder) CreateOne(nodeID int, fileHash string) *MetadataCacheLockReqBuilder { b.locks = append(b.locks, distlock.Lock{ Path: b.makePath("Cache"), Name: lockprovider.METADATA_ELEMENT_CREATE_LOCK, - Target: *lockprovider.NewStringLockTarget(), + Target: *lockprovider.NewStringLockTarget().Add(nodeID, fileHash), }) return b }