Skip to content

Commit 27a398f

Browse files
doroolegydbot
authored andcommitted
darwin has been fixed (#25188)
1 parent 01e1ad1 commit 27a398f

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

ydb/core/tx/columnshard/overload_manager/overload_manager_service.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,8 @@ std::atomic<EResourcesStatus> TOverloadManagerServiceOperator::ResourcesStatus{E
1919

2020
ui64 TOverloadManagerServiceOperator::GetShardWritesInFlyLimit() {
2121
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));
2424
DEFAULT_WRITES_IN_FLY_LIMIT.compare_exchange_strong(oldValue, newValue);
2525
}
2626
return (HasAppData() && AppDataVerified().ColumnShardConfig.HasWritingInFlightRequestsCountLimit()) ? AppDataVerified().ColumnShardConfig.GetWritingInFlightRequestsCountLimit()
@@ -29,8 +29,8 @@ ui64 TOverloadManagerServiceOperator::GetShardWritesInFlyLimit() {
2929

3030
ui64 TOverloadManagerServiceOperator::GetShardWritesSizeInFlyLimit() {
3131
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;
3434
DEFAULT_WRITES_SIZE_IN_FLY_LIMIT.compare_exchange_strong(oldValue, newValue);
3535
}
3636
return (HasAppData() && AppDataVerified().ColumnShardConfig.HasWritingInFlightRequestBytesLimit()) ?

ydb/core/tx/tx_proxy/rpc_long_tx.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,8 @@ ui64 GetMemoryInFlightLimit() {
2727
}
2828

2929
if (DEFAULT_MEMORY_IN_FLIGHT_LIMIT.load() == 0) {
30-
ui64 oldValue = 0;
31-
const ui64 newValue = NKqp::TStagePredictor::GetUsableThreads() * 10_MB;
30+
uint64_t oldValue = 0;
31+
const uint64_t newValue = NKqp::TStagePredictor::GetUsableThreads() * 10_MB;
3232
DEFAULT_MEMORY_IN_FLIGHT_LIMIT.compare_exchange_strong(oldValue, newValue);
3333
}
3434
return DEFAULT_MEMORY_IN_FLIGHT_LIMIT.load();

0 commit comments

Comments
 (0)