Skip to content

Commit

Permalink
More fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
vvd170501 committed Dec 31, 2024
1 parent 248e3a3 commit 0716373
Show file tree
Hide file tree
Showing 5 changed files with 11 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -204,7 +204,7 @@ class TFormatHadlerFixture : public TBaseFixture {

public:
static TCallback EmptyCheck() {
return [&](TQueue<std::pair<TRope, TVector<ui64>>>&& data) {};
return [&](TQueue<std::pair<TRope, TVector<ui64>>>&& /* data */) {};
}

static TCallback OneBatchCheck(std::function<void(TRope&& messages, TVector<ui64>&& offsets)> callback) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -356,7 +356,7 @@ Y_UNIT_TEST_SUITE(TestPurecalcFilter) {
MakeFilter(
{{"a1", "[DataType; String]"}},
"where a2 ... 50",
[&](ui64 offset) {}
[&](ui64 /* offset */) {}
);
}
}
Expand Down Expand Up @@ -411,11 +411,11 @@ Y_UNIT_TEST_SUITE(TestFilterSet) {
CheckSuccess(MakeFilter(
{{"a1", "[DataType; String]"}},
"where a1 = \"str1\"",
[&](ui64 offset) {}
[&](ui64 /* offset */) {}
));

CheckError(
FiltersSet->AddFilter(MakeIntrusive<TFilterSetConsumer>(FilterIds.back(), TVector<ui64>(), TVector<TSchemaColumn>(), TString(), [&](ui64 offset) {}, CompileError)),
FiltersSet->AddFilter(MakeIntrusive<TFilterSetConsumer>(FilterIds.back(), TVector<ui64>(), TVector<TSchemaColumn>(), TString(), [&](ui64 /* offset */) {}, CompileError)),
EStatusId::INTERNAL_ERROR,
"Failed to create new filter, filter with id [0:0:0] already exists"
);
Expand All @@ -426,7 +426,7 @@ Y_UNIT_TEST_SUITE(TestFilterSet) {
MakeFilter(
{{"a1", "[DataType; String]"}},
"where a2 ... 50",
[&](ui64 offset) {}
[&](ui64 /* offset */) {}
);
}
}
Expand Down
6 changes: 3 additions & 3 deletions ydb/core/kqp/ut/olap/indexes_ut.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -485,7 +485,7 @@ Y_UNIT_TEST_SUITE(KqpOlapIndexes) {
ui32 requestsCount = 300;
for (ui32 i = 0; i < requestsCount; ++i) {
const ui32 idx = RandomNumber<ui32>(uids.size());
const auto query = [](const TString& res, const TString& uid, const ui32 level) {
const auto query = [](const TString& res, const TString& /* uid */, const ui32 /* level */) {
TStringBuilder sb;
sb << "SELECT COUNT(*) FROM `/Root/olapStore/olapTable`" << Endl;
sb << "WHERE" << Endl;
Expand All @@ -502,7 +502,7 @@ Y_UNIT_TEST_SUITE(KqpOlapIndexes) {
ui32 requestsCount = 300;
for (ui32 i = 0; i < requestsCount; ++i) {
const ui32 idx = RandomNumber<ui32>(uids.size());
const auto query = [](const TString& res, const TString& uid, const ui32 level) {
const auto query = [](const TString& res, const TString& /* uid */, const ui32 /* level */) {
TStringBuilder sb;
sb << "SELECT COUNT(*) FROM `/Root/olapStore/olapTable`" << Endl;
sb << "WHERE" << Endl;
Expand All @@ -520,7 +520,7 @@ Y_UNIT_TEST_SUITE(KqpOlapIndexes) {
ui32 requestsCount = 300;
for (ui32 i = 0; i < requestsCount; ++i) {
const ui32 idx = RandomNumber<ui32>(uids.size());
const auto query = [](const TString& res, const TString& uid, const ui32 level) {
const auto query = [](const TString& res, const TString& /* uid */, const ui32 /* level */) {
TStringBuilder sb;
sb << "SELECT COUNT(*) FROM `/Root/olapStore/olapTable`" << Endl;
sb << "WHERE" << Endl;
Expand Down
4 changes: 2 additions & 2 deletions ydb/core/statistics/service/ut/ut_http_request.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -39,13 +39,13 @@ void ProbeTest(bool isServerless) {
const auto sender = runtime.AllocateEdgeActor();

bool firstStatsToSA = false;
auto statsObserver1 = runtime.AddObserver<TEvStatistics::TEvSchemeShardStats>([&](auto& ev){
auto statsObserver1 = runtime.AddObserver<TEvStatistics::TEvSchemeShardStats>([&](auto& /* ev */){
firstStatsToSA = true;
});
runtime.WaitFor("TEvSchemeShardStats 1", [&]{ return firstStatsToSA; });

bool secondStatsToSA = false;
auto statsObserver2 = runtime.AddObserver<TEvStatistics::TEvSchemeShardStats>([&](auto& ev){
auto statsObserver2 = runtime.AddObserver<TEvStatistics::TEvSchemeShardStats>([&](auto& /* ev */){
secondStatsToSA = true;
});
runtime.WaitFor("TEvSchemeShardStats 2", [&]{ return secondStatsToSA; });
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -207,7 +207,7 @@ void ScanIndexStats(TTestBasicRuntime& runtime, TActorId& sender, const std::vec
ForwardToTablet(runtime, TTestTxConfig::TxTablet0, sender, scan.release());
}

void ProposeCommit(TTestBasicRuntime& runtime, TActorId& sender, ui64 shardId, ui64 txId, const std::vector<ui64>& writeIds, const ui64 lockId) {
void ProposeCommit(TTestBasicRuntime& runtime, TActorId& sender, ui64 shardId, ui64 txId, const std::vector<ui64>& /* writeIds */, const ui64 lockId) {
auto write = std::make_unique<NEvents::TDataEvents::TEvWrite>(txId, NKikimrDataEvents::TEvWrite::MODE_PREPARE);
auto* lock = write->Record.MutableLocks()->AddLocks();
lock->SetLockId(lockId);
Expand Down

0 comments on commit 0716373

Please sign in to comment.