File tree Expand file tree Collapse file tree 2 files changed +6
-6
lines changed
columnshard/overload_manager Expand file tree Collapse file tree 2 files changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -19,8 +19,8 @@ std::atomic<EResourcesStatus> TOverloadManagerServiceOperator::ResourcesStatus{E
19
19
20
20
ui64 TOverloadManagerServiceOperator::GetShardWritesInFlyLimit () {
21
21
if (DEFAULT_WRITES_IN_FLY_LIMIT.load () == 0 ) {
22
- ui64 oldValue = 0 ;
23
- const ui64 newValue = std::max (NKqp::TStagePredictor::GetUsableThreads () * 10000 , ui32 (100000 ));
22
+ uint64_t oldValue = 0 ;
23
+ const uint64_t newValue = std::max (NKqp::TStagePredictor::GetUsableThreads () * 10000 , ui32 (100000 ));
24
24
DEFAULT_WRITES_IN_FLY_LIMIT.compare_exchange_strong (oldValue, newValue);
25
25
}
26
26
return (HasAppData () && AppDataVerified ().ColumnShardConfig .HasWritingInFlightRequestsCountLimit ()) ? AppDataVerified ().ColumnShardConfig .GetWritingInFlightRequestsCountLimit ()
@@ -29,8 +29,8 @@ ui64 TOverloadManagerServiceOperator::GetShardWritesInFlyLimit() {
29
29
30
30
ui64 TOverloadManagerServiceOperator::GetShardWritesSizeInFlyLimit () {
31
31
if (DEFAULT_WRITES_SIZE_IN_FLY_LIMIT.load () == 0 ) {
32
- ui64 oldValue = 0 ;
33
- const ui64 newValue = NKqp::TStagePredictor::GetUsableThreads () * 20_MB;
32
+ uint64_t oldValue = 0 ;
33
+ const uint64_t newValue = NKqp::TStagePredictor::GetUsableThreads () * 20_MB;
34
34
DEFAULT_WRITES_SIZE_IN_FLY_LIMIT.compare_exchange_strong (oldValue, newValue);
35
35
}
36
36
return (HasAppData () && AppDataVerified ().ColumnShardConfig .HasWritingInFlightRequestBytesLimit ()) ?
Original file line number Diff line number Diff line change @@ -26,8 +26,8 @@ ui64 GetMemoryInFlightLimit() {
26
26
}
27
27
28
28
if (DEFAULT_MEMORY_IN_FLIGHT_LIMIT.load () == 0 ) {
29
- ui64 oldValue = 0 ;
30
- const ui64 newValue = NKqp::TStagePredictor::GetUsableThreads () * 10_MB;
29
+ uint64_t oldValue = 0 ;
30
+ const uint64_t newValue = NKqp::TStagePredictor::GetUsableThreads () * 10_MB;
31
31
DEFAULT_MEMORY_IN_FLIGHT_LIMIT.compare_exchange_strong (oldValue, newValue);
32
32
}
33
33
return DEFAULT_MEMORY_IN_FLIGHT_LIMIT.load ();
You can’t perform that action at this time.
0 commit comments