Compare commits

...

1 commit

Author SHA1 Message Date
3781479a85 [#660] writecache: Fix remaining addr2key uses
Some checks failed
DCO action / DCO (pull_request) Successful in 3m55s
Vulncheck / Vulncheck (pull_request) Successful in 4m30s
Build / Build Components (1.21) (pull_request) Successful in 5m32s
Build / Build Components (1.20) (pull_request) Successful in 5m48s
Tests and linters / Tests (1.21) (pull_request) Failing after 6m58s
Tests and linters / Staticcheck (pull_request) Successful in 7m9s
Tests and linters / Lint (pull_request) Successful in 8m7s
Tests and linters / Tests with -race (pull_request) Successful in 10m11s
Tests and linters / Tests (1.20) (pull_request) Successful in 10m25s
Signed-off-by: Alejandro Lopez <a.lopez@yadro.com>
2023-08-29 15:27:40 +03:00
2 changed files with 6 additions and 5 deletions

View file

@ -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"),
)

View file

@ -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})
}))
},
},