diff --git a/pkg/local_object_storage/writecache/writecachebadger/flush.go b/pkg/local_object_storage/writecache/writecachebadger/flush.go index 8630026c..7f41920b 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 25d1900d..9ff54bee 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 } }