Skip to content

Commit 8909f10

Browse files
authored
Merge 55dd325 into 99bd033
2 parents 99bd033 + 55dd325 commit 8909f10

File tree

10 files changed

+1069
-47
lines changed

10 files changed

+1069
-47
lines changed

ydb/core/driver_lib/run/kikimr_services_initializers.cpp

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1093,10 +1093,7 @@ void TSharedCacheInitializer::InitializeServices(
10931093
config->TotalAsyncQueueInFlyLimit = cfg.GetAsyncQueueInFlyLimit();
10941094
config->TotalScanQueueInFlyLimit = cfg.GetScanQueueInFlyLimit();
10951095
config->ReplacementPolicy = cfg.GetReplacementPolicy();
1096-
1097-
if (cfg.HasActivePagesReservationPercent()) {
1098-
config->ActivePagesReservationPercent = cfg.GetActivePagesReservationPercent();
1099-
}
1096+
config->ActivePagesReservationPercent = cfg.GetActivePagesReservationPercent();
11001097

11011098
TIntrusivePtr<::NMonitoring::TDynamicCounters> tabletGroup = GetServiceCounters(appData->Counters, "tablets");
11021099
TIntrusivePtr<::NMonitoring::TDynamicCounters> sausageGroup = tabletGroup->GetSubgroup("type", "S_CACHE");

ydb/core/protos/shared_cache.proto

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ option java_package = "ru.yandex.kikimr.proto";
33

44
enum TReplacementPolicy {
55
ThreeLeveledLRU = 0;
6+
S3FIFO = 1;
67
}
78

89
message TSharedCacheConfig {

ydb/core/tablet_flat/shared_cache_events.h

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
#include "defs.h"
44
#include "flat_bio_events.h"
55
#include "shared_handle.h"
6+
#include <ydb/core/protos/shared_cache.pb.h>
67

78
#include <util/generic/map.h>
89
#include <util/generic/set.h>
@@ -24,6 +25,7 @@ namespace NSharedCache {
2425
EvRequest,
2526
EvResult,
2627
EvUpdated,
28+
EvReplacementPolicySwitch,
2729

2830
EvEnd
2931

@@ -127,6 +129,16 @@ namespace NSharedCache {
127129

128130
THashMap<TLogoBlobID, TActions> Actions;
129131
};
132+
133+
struct TEvReplacementPolicySwitch : public TEventLocal<TEvReplacementPolicySwitch, EvReplacementPolicySwitch> {
134+
using TReplacementPolicy = NKikimrSharedCache::TReplacementPolicy;
135+
136+
TReplacementPolicy ReplacementPolicy;
137+
138+
TEvReplacementPolicySwitch(TReplacementPolicy replacementPolicy)
139+
: ReplacementPolicy(replacementPolicy)
140+
{}
141+
};
130142
}
131143
}
132144

0 commit comments

Comments
 (0)