diff --git a/pkg/local_object_storage/writecache/writecachebadger/delete.go b/pkg/local_object_storage/writecache/writecachebadger/delete.go index f3737109..afab7854 100644 --- a/pkg/local_object_storage/writecache/writecachebadger/delete.go +++ b/pkg/local_object_storage/writecache/writecachebadger/delete.go @@ -39,10 +39,10 @@ func (c *cache) Delete(ctx context.Context, addr oid.Address) error { return writecache.ErrReadOnly } - saddr := addr.EncodeToString() + key := addr2key(addr) err := c.db.Update(func(tx *badger.Txn) error { - it, err := tx.Get([]byte(saddr)) + it, err := tx.Get(key[:]) if err != nil { if err == badger.ErrKeyNotFound { return logicerr.Wrap(new(apistatus.ObjectNotFound)) @@ -51,10 +51,10 @@ func (c *cache) Delete(ctx context.Context, addr oid.Address) error { } if it.ValueSize() > 0 { storageType = writecache.StorageTypeDB - err := tx.Delete([]byte(saddr)) + err := tx.Delete(key[:]) if err == nil { storagelog.Write(c.log, - storagelog.AddressField(saddr), + storagelog.AddressField(addr.EncodeToString()), storagelog.StorageTypeField(wcStorageType), storagelog.OpField("db DELETE"), ) diff --git a/pkg/local_object_storage/writecache/writecachebadger/flush_test.go b/pkg/local_object_storage/writecache/writecachebadger/flush_test.go index 19bc1561..855d2214 100644 --- a/pkg/local_object_storage/writecache/writecachebadger/flush_test.go +++ b/pkg/local_object_storage/writecache/writecachebadger/flush_test.go @@ -52,8 +52,9 @@ func TestFlush(t *testing.T) { Desc: "db, invalid object", InjectFn: func(t *testing.T, wc writecache.Cache) { c := wc.(*cache) + key := addr2key(oidtest.Address()) require.NoError(t, c.db.Update(func(tx *badger.Txn) error { - return tx.Set([]byte(oidtest.Address().EncodeToString()), []byte{1, 2, 3}) + return tx.Set(key[:], []byte{1, 2, 3}) })) }, },