2023-06-22 11:55:30 +00:00
|
|
|
package writecachebbolt
|
2021-04-06 10:56:06 +00:00
|
|
|
|
|
|
|
import (
|
2023-04-12 14:01:29 +00:00
|
|
|
"context"
|
2021-04-06 10:56:06 +00:00
|
|
|
"errors"
|
2021-09-14 16:20:31 +00:00
|
|
|
"fmt"
|
2021-04-06 10:56:06 +00:00
|
|
|
"os"
|
|
|
|
|
2023-04-12 14:35:10 +00:00
|
|
|
"git.frostfs.info/TrueCloudLab/frostfs-node/internal/logs"
|
2023-03-07 13:38:26 +00:00
|
|
|
"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/blobstor/common"
|
|
|
|
"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/blobstor/fstree"
|
|
|
|
storagelog "git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/internal/log"
|
2023-06-22 11:55:30 +00:00
|
|
|
"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/writecache"
|
2023-03-07 13:38:26 +00:00
|
|
|
"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/util"
|
|
|
|
apistatus "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/client/status"
|
|
|
|
oid "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/object/id"
|
2021-04-06 10:56:06 +00:00
|
|
|
"go.etcd.io/bbolt"
|
|
|
|
"go.uber.org/zap"
|
|
|
|
)
|
|
|
|
|
|
|
|
// store represents persistent storage with in-memory LRU cache
|
|
|
|
// for flushed items on top of it.
|
|
|
|
type store struct {
|
2023-05-10 14:43:49 +00:00
|
|
|
db *bbolt.DB
|
2021-04-06 10:56:06 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
const dbName = "small.bolt"
|
|
|
|
|
2022-06-28 13:42:50 +00:00
|
|
|
func (c *cache) openStore(readOnly bool) error {
|
2021-09-14 16:20:31 +00:00
|
|
|
err := util.MkdirAllX(c.path, os.ModePerm)
|
|
|
|
if err != nil {
|
2021-04-06 10:56:06 +00:00
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
2023-03-21 10:38:44 +00:00
|
|
|
c.db, err = OpenDB(c.path, readOnly, c.openFile)
|
2021-04-06 10:56:06 +00:00
|
|
|
if err != nil {
|
2021-09-14 16:20:31 +00:00
|
|
|
return fmt.Errorf("could not open database: %w", err)
|
|
|
|
}
|
|
|
|
|
2022-06-16 15:21:10 +00:00
|
|
|
c.db.MaxBatchSize = c.maxBatchSize
|
|
|
|
c.db.MaxBatchDelay = c.maxBatchDelay
|
|
|
|
|
2022-07-05 04:55:46 +00:00
|
|
|
if !readOnly {
|
|
|
|
err = c.db.Update(func(tx *bbolt.Tx) error {
|
|
|
|
_, err := tx.CreateBucketIfNotExists(defaultBucket)
|
|
|
|
return err
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return fmt.Errorf("could not create default bucket: %w", err)
|
|
|
|
}
|
2021-04-06 10:56:06 +00:00
|
|
|
}
|
|
|
|
|
2022-10-28 10:09:38 +00:00
|
|
|
c.fsTree = fstree.New(
|
|
|
|
fstree.WithPath(c.path),
|
|
|
|
fstree.WithPerm(os.ModePerm),
|
|
|
|
fstree.WithDepth(1),
|
|
|
|
fstree.WithDirNameLen(1),
|
|
|
|
fstree.WithNoSync(c.noSync))
|
2022-11-17 08:58:56 +00:00
|
|
|
if err := c.fsTree.Open(readOnly); err != nil {
|
|
|
|
return fmt.Errorf("could not open FSTree: %w", err)
|
|
|
|
}
|
2021-04-06 10:56:06 +00:00
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2022-08-31 09:20:43 +00:00
|
|
|
func (c *cache) deleteFromDB(keys []string) []string {
|
2021-04-06 10:56:06 +00:00
|
|
|
if len(keys) == 0 {
|
2022-08-31 09:20:43 +00:00
|
|
|
return keys
|
2021-04-06 10:56:06 +00:00
|
|
|
}
|
2022-03-17 08:03:58 +00:00
|
|
|
|
2022-08-31 09:20:43 +00:00
|
|
|
var errorIndex int
|
|
|
|
err := c.db.Batch(func(tx *bbolt.Tx) error {
|
|
|
|
b := tx.Bucket(defaultBucket)
|
|
|
|
for errorIndex = range keys {
|
|
|
|
if err := b.Delete([]byte(keys[errorIndex])); err != nil {
|
2021-04-06 10:56:06 +00:00
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
})
|
2022-08-31 09:20:43 +00:00
|
|
|
for i := 0; i < errorIndex; i++ {
|
2021-12-08 10:14:57 +00:00
|
|
|
c.objCounters.DecDB()
|
2023-06-22 11:55:30 +00:00
|
|
|
c.metrics.Evict(writecache.StorageTypeDB)
|
2022-12-20 12:29:05 +00:00
|
|
|
storagelog.Write(c.log,
|
|
|
|
storagelog.AddressField(keys[i]),
|
|
|
|
storagelog.StorageTypeField(wcStorageType),
|
|
|
|
storagelog.OpField("db DELETE"),
|
|
|
|
)
|
2021-12-08 10:14:57 +00:00
|
|
|
}
|
2022-08-31 09:20:43 +00:00
|
|
|
if err != nil {
|
2023-04-12 14:35:10 +00:00
|
|
|
c.log.Error(logs.WritecacheCantRemoveObjectsFromTheDatabase, zap.Error(err))
|
2022-08-31 09:20:43 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
copy(keys, keys[errorIndex:])
|
|
|
|
return keys[:len(keys)-errorIndex]
|
2021-04-06 10:56:06 +00:00
|
|
|
}
|
|
|
|
|
2023-05-10 14:43:49 +00:00
|
|
|
func (c *cache) deleteFromDisk(ctx context.Context, keys []string) []string {
|
2022-08-31 09:20:43 +00:00
|
|
|
if len(keys) == 0 {
|
|
|
|
return keys
|
|
|
|
}
|
2021-04-06 10:56:06 +00:00
|
|
|
|
2022-08-31 09:20:43 +00:00
|
|
|
var copyIndex int
|
2022-05-31 17:00:41 +00:00
|
|
|
var addr oid.Address
|
|
|
|
|
2021-04-06 10:56:06 +00:00
|
|
|
for i := range keys {
|
2022-08-31 09:20:43 +00:00
|
|
|
if err := addr.DecodeString(keys[i]); err != nil {
|
2023-04-12 14:35:10 +00:00
|
|
|
c.log.Error(logs.WritecacheCantParseAddress, zap.String("address", keys[i]))
|
2021-04-06 10:56:06 +00:00
|
|
|
continue
|
|
|
|
}
|
|
|
|
|
2023-05-10 14:43:49 +00:00
|
|
|
_, err := c.fsTree.Delete(ctx, common.DeletePrm{Address: addr})
|
2022-07-08 07:09:48 +00:00
|
|
|
if err != nil && !errors.As(err, new(apistatus.ObjectNotFound)) {
|
2023-04-12 14:35:10 +00:00
|
|
|
c.log.Error(logs.WritecacheCantRemoveObjectFromWritecache, zap.Error(err))
|
2022-08-31 09:20:43 +00:00
|
|
|
|
|
|
|
// Save the key for the next iteration.
|
|
|
|
keys[copyIndex] = keys[i]
|
|
|
|
copyIndex++
|
2021-04-06 10:56:06 +00:00
|
|
|
continue
|
2021-09-06 14:28:55 +00:00
|
|
|
} else if err == nil {
|
2022-12-20 12:29:05 +00:00
|
|
|
storagelog.Write(c.log,
|
|
|
|
storagelog.AddressField(keys[i]),
|
|
|
|
storagelog.StorageTypeField(wcStorageType),
|
|
|
|
storagelog.OpField("fstree DELETE"),
|
|
|
|
)
|
2023-06-22 11:55:30 +00:00
|
|
|
c.metrics.Evict(writecache.StorageTypeFSTree)
|
2021-09-08 09:32:20 +00:00
|
|
|
c.objCounters.DecFS()
|
2021-04-06 10:56:06 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2022-08-31 09:20:43 +00:00
|
|
|
return keys[:copyIndex]
|
2021-04-06 10:56:06 +00:00
|
|
|
}
|