mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-11 18:35:46 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

fix(tiering): rename v2 + max_file_size (#3004)

Browse source 
* fix: rename + max_file_size

Signed-off-by: Vladislav Oleshko <vlad@dragonflydb.io>
This commit is contained in:
Vladislav 2024-05-03 21:36:18 +03:00 • committed by GitHub
parent 6b480237be
commit 9e3748421b
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
14 changed files with 124 additions and 88 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/server/db_slice.cc
View file

@ -984,7 +984,7 @@ void DbSlice::PreUpdate(DbIndex db_ind, Iterator it, std::string_view key) {
// Note: we don't delete offloaded values before updates, because a read-modify operation (like
// append) can be applied instead of a full overwrite. Deleting is reponsibility of the commands
if (it.IsOccupied() && it->second.HasIoPending()) {
owner_->tiered_storage_v2()->CancelStash(db_ind, key, &it->second);
owner_->tiered_storage()->CancelStash(db_ind, key, &it->second);
}
it.GetInnerIt().SetVersion(NextVersion());
@ -1438,8 +1438,8 @@ void DbSlice::PerformDeletion(Iterator del_it, ExpIterator exp_it, DbTable* tabl
DbTableStats& stats = table->stats;
const PrimeValue& pv = del_it->second;
if (pv.IsExternal() && shard_owner()->tiered_storage_v2()) {
shard_owner()->tiered_storage_v2()->Delete(&del_it->second);
if (pv.IsExternal() && shard_owner()->tiered_storage()) {
shard_owner()->tiered_storage()->Delete(&del_it->second);
}
size_t value_heap_size = pv.MallocUsed();