From 345a1a69a228cce3810199eb1b51396b89d0db93 Mon Sep 17 00:00:00 2001
From: Alejandro Lopez <a.lopez@yadro.com>
Date: Tue, 22 Aug 2023 10:51:42 +0300
Subject: [PATCH] [#635] Use internal key type when deleting from badger wc
Signed-off-by: Alejandro Lopez <a.lopez@yadro.com>
---
pkg/local_object_storage/writecache/writecachebadger/flush.go | 2 +-
.../writecache/writecachebadger/storage.go | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/pkg/local_object_storage/writecache/writecachebadger/flush.go b/pkg/local_object_storage/writecache/writecachebadger/flush.go
index 8630026cd..7f41920ba 100644
--- a/pkg/local_object_storage/writecache/writecachebadger/flush.go
+++ b/pkg/local_object_storage/writecache/writecachebadger/flush.go
@@ -173,7 +173,7 @@ func (c *cache) workerFlushSmall() {
continue
}
- c.deleteFromDB([]string{objectCore.AddressOf(obj).EncodeToString()})
+ c.deleteFromDB([]internalKey{addr2key(objectCore.AddressOf(obj))})
}
}
diff --git a/pkg/local_object_storage/writecache/writecachebadger/storage.go b/pkg/local_object_storage/writecache/writecachebadger/storage.go
index 25d1900d1..9ff54bee0 100644
--- a/pkg/local_object_storage/writecache/writecachebadger/storage.go
+++ b/pkg/local_object_storage/writecache/writecachebadger/storage.go
@@ -58,7 +58,7 @@ func (c *cache) openStore(readOnly bool) error {
return nil
}
-func (c *cache) deleteFromDB(keys []string) []string {
+func (c *cache) deleteFromDB(keys []internalKey) []internalKey {
if len(keys) == 0 {
return keys
}
@@ -67,7 +67,7 @@ func (c *cache) deleteFromDB(keys []string) []string {
var errorIndex int
for errorIndex = range keys {
- if err := wb.Delete([]byte(keys[errorIndex])); err != nil {
+ if err := wb.Delete(keys[errorIndex][:]); err != nil {
break
}
}