aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorbabenko <babenko@yandex-team.com>2025-01-21 10:20:34 +0300
committerbabenko <babenko@yandex-team.com>2025-01-21 10:38:32 +0300
commit06abd617f752a201ed29a300ebb676f1ceae0205 (patch)
tree6c9e7fafa414b028466222470e5aa4fff7f27b9e
parent5d7f675908d15c5303c0e9a62d5c84c3ee8ea3b6 (diff)
downloadydb-06abd617f752a201ed29a300ebb676f1ceae0205.tar.gz
Normalize spaces around colon in range-for loops
commit_hash:409544db6e9f929539bbea4d0103214a51c176c5
-rw-r--r--yt/yt/client/api/rpc_proxy/client_impl.cpp2
-rw-r--r--yt/yt/client/api/rpc_proxy/helpers.cpp26
-rw-r--r--yt/yt/client/formats/config.cpp2
-rw-r--r--yt/yt/client/table_client/merge_table_schemas.cpp2
-rw-r--r--yt/yt/core/misc/arithmetic_formula.cpp4
-rw-r--r--yt/yt/core/misc/unittests/consistent_hashing_ut.cpp4
-rw-r--r--yt/yt/core/rpc/unittests/viable_peer_registry_ut.cpp2
-rw-r--r--yt/yt/core/yson/unittests/protobuf_yson_ut.cpp4
-rw-r--r--yt/yt/library/formats/protobuf.cpp8
9 files changed, 27 insertions, 27 deletions
diff --git a/yt/yt/client/api/rpc_proxy/client_impl.cpp b/yt/yt/client/api/rpc_proxy/client_impl.cpp
index 824d11488e2..ee2fdbc2d30 100644
--- a/yt/yt/client/api/rpc_proxy/client_impl.cpp
+++ b/yt/yt/client/api/rpc_proxy/client_impl.cpp
@@ -1709,7 +1709,7 @@ TFuture<std::vector<TColumnarStatistics>> TClient::GetColumnarStatistics(
auto req = proxy.GetColumnarStatistics();
SetTimeoutOptions(*req, options);
- for (const auto& subPath: path) {
+ for (const auto& subPath : path) {
req->add_paths(ConvertToYsonString(subPath).ToString());
}
diff --git a/yt/yt/client/api/rpc_proxy/helpers.cpp b/yt/yt/client/api/rpc_proxy/helpers.cpp
index d5703d97392..41f88cbcbf7 100644
--- a/yt/yt/client/api/rpc_proxy/helpers.cpp
+++ b/yt/yt/client/api/rpc_proxy/helpers.cpp
@@ -279,19 +279,19 @@ void ToProto(
if (result.PoolTreeCounts) {
auto* poolTreeCounts = proto->mutable_pool_tree_counts()->mutable_entries();
- for (const auto& entry: *result.PoolTreeCounts) {
+ for (const auto& entry : *result.PoolTreeCounts) {
(*poolTreeCounts)[entry.first] = entry.second;
}
}
if (result.PoolCounts) {
- for (const auto& entry: *result.PoolCounts) {
+ for (const auto& entry : *result.PoolCounts) {
auto* newPoolCount = proto->mutable_pool_counts()->add_entries();
newPoolCount->set_pool(entry.first);
newPoolCount->set_count(entry.second);
}
}
if (result.UserCounts) {
- for (const auto& entry: *result.UserCounts) {
+ for (const auto& entry : *result.UserCounts) {
auto* newUserCount = proto->mutable_user_counts()->add_entries();
newUserCount->set_user(entry.first);
newUserCount->set_count(entry.second);
@@ -299,7 +299,7 @@ void ToProto(
}
if (result.StateCounts) {
- for (const auto& state: TEnumTraits<NScheduler::EOperationState>::GetDomainValues()) {
+ for (const auto& state : TEnumTraits<NScheduler::EOperationState>::GetDomainValues()) {
if ((*result.StateCounts)[state] != 0) {
auto* newStateCount = proto->mutable_state_counts()->add_entries();
newStateCount->set_state(ConvertOperationStateToProto(state));
@@ -308,7 +308,7 @@ void ToProto(
}
}
if (result.TypeCounts) {
- for (const auto& type: TEnumTraits<NScheduler::EOperationType>::GetDomainValues()) {
+ for (const auto& type : TEnumTraits<NScheduler::EOperationType>::GetDomainValues()) {
if ((*result.TypeCounts)[type] != 0) {
auto* newTypeCount = proto->mutable_type_counts()->add_entries();
newTypeCount->set_type(ConvertOperationTypeToProto(type));
@@ -341,7 +341,7 @@ void FromProto(
if (proto.has_pool_counts()) {
result->PoolCounts.emplace();
- for (const auto& poolCount: proto.pool_counts().entries()) {
+ for (const auto& poolCount : proto.pool_counts().entries()) {
auto pool = poolCount.pool();
YT_VERIFY((*result->PoolCounts)[pool] == 0);
(*result->PoolCounts)[pool] = poolCount.count();
@@ -351,7 +351,7 @@ void FromProto(
}
if (proto.has_user_counts()) {
result->UserCounts.emplace();
- for (const auto& userCount: proto.user_counts().entries()) {
+ for (const auto& userCount : proto.user_counts().entries()) {
auto user = userCount.user();
YT_VERIFY((*result->UserCounts)[user] == 0);
(*result->UserCounts)[user] = userCount.count();
@@ -363,7 +363,7 @@ void FromProto(
if (proto.has_state_counts()) {
result->StateCounts.emplace();
std::fill(result->StateCounts->begin(), result->StateCounts->end(), 0);
- for (const auto& stateCount: proto.state_counts().entries()) {
+ for (const auto& stateCount : proto.state_counts().entries()) {
auto state = ConvertOperationStateFromProto(stateCount.state());
YT_VERIFY(result->StateCounts->IsValidIndex(state));
YT_VERIFY((*result->StateCounts)[state] == 0);
@@ -375,7 +375,7 @@ void FromProto(
if (proto.has_type_counts()) {
result->TypeCounts.emplace();
std::fill(result->TypeCounts->begin(), result->TypeCounts->end(), 0);
- for (const auto& typeCount: proto.type_counts().entries()) {
+ for (const auto& typeCount : proto.type_counts().entries()) {
auto type = ConvertOperationTypeFromProto(typeCount.type());
YT_VERIFY(result->TypeCounts->IsValidIndex(type));
YT_VERIFY((*result->TypeCounts)[type] == 0);
@@ -1170,7 +1170,7 @@ void ToProto(
const NApi::TListJobsStatistics& statistics)
{
protoStatistics->mutable_state_counts()->clear_entries();
- for (const auto& state: TEnumTraits<NJobTrackerClient::EJobState>::GetDomainValues()) {
+ for (const auto& state : TEnumTraits<NJobTrackerClient::EJobState>::GetDomainValues()) {
if (statistics.StateCounts[state] != 0) {
auto* newStateCount = protoStatistics->mutable_state_counts()->add_entries();
newStateCount->set_state(ConvertJobStateToProto(state));
@@ -1179,7 +1179,7 @@ void ToProto(
}
protoStatistics->mutable_type_counts()->clear_entries();
- for (const auto& type: TEnumTraits<NJobTrackerClient::EJobType>::GetDomainValues()) {
+ for (const auto& type : TEnumTraits<NJobTrackerClient::EJobType>::GetDomainValues()) {
if (statistics.TypeCounts[type] != 0) {
auto* newTypeCount = protoStatistics->mutable_type_counts()->add_entries();
newTypeCount->set_type(ConvertJobTypeToProto(type));
@@ -1193,7 +1193,7 @@ void FromProto(
const NProto::TListJobsStatistics& protoStatistics)
{
std::fill(statistics->StateCounts.begin(), statistics->StateCounts.end(), 0);
- for (const auto& stateCount: protoStatistics.state_counts().entries()) {
+ for (const auto& stateCount : protoStatistics.state_counts().entries()) {
auto state = ConvertJobStateFromProto(stateCount.state());
YT_VERIFY(statistics->StateCounts.IsValidIndex(state));
YT_VERIFY(statistics->StateCounts[state] == 0);
@@ -1201,7 +1201,7 @@ void FromProto(
}
std::fill(statistics->TypeCounts.begin(), statistics->TypeCounts.end(), 0);
- for (const auto& typeCount: protoStatistics.type_counts().entries()) {
+ for (const auto& typeCount : protoStatistics.type_counts().entries()) {
auto type = ConvertJobTypeFromProto(typeCount.type());
YT_VERIFY(statistics->TypeCounts.IsValidIndex(type));
YT_VERIFY(statistics->TypeCounts[type] == 0);
diff --git a/yt/yt/client/formats/config.cpp b/yt/yt/client/formats/config.cpp
index ed4ee65a73d..eff67b828da 100644
--- a/yt/yt/client/formats/config.cpp
+++ b/yt/yt/client/formats/config.cpp
@@ -272,7 +272,7 @@ void TProtobufTableConfig::Register(TRegistrar registrar)
registrar.Postprocessor([] (TThis* config) {
bool hasOtherColumns = false;
- for (const auto& column: config->Columns) {
+ for (const auto& column : config->Columns) {
if (column->ProtoType == EProtobufType::OtherColumns) {
if (hasOtherColumns) {
THROW_ERROR_EXCEPTION("Multiple \"other_columns\" in protobuf config are not allowed");
diff --git a/yt/yt/client/table_client/merge_table_schemas.cpp b/yt/yt/client/table_client/merge_table_schemas.cpp
index d41e58baf53..ef7d10fcfc9 100644
--- a/yt/yt/client/table_client/merge_table_schemas.cpp
+++ b/yt/yt/client/table_client/merge_table_schemas.cpp
@@ -100,7 +100,7 @@ TTableSchemaPtr MergeTableSchemas(
auto getDeletedColumnsStableNames = [] (const std::vector<TDeletedColumn>& deletedColumns) {
THashSet<TColumnStableName> stableNames;
- for (const auto& column: deletedColumns) {
+ for (const auto& column : deletedColumns) {
stableNames.insert(column.StableName());
}
return stableNames;
diff --git a/yt/yt/core/misc/arithmetic_formula.cpp b/yt/yt/core/misc/arithmetic_formula.cpp
index d4231991ec1..54404cd6667 100644
--- a/yt/yt/core/misc/arithmetic_formula.cpp
+++ b/yt/yt/core/misc/arithmetic_formula.cpp
@@ -868,7 +868,7 @@ void TArithmeticFormula::Load(TStreamLoadContext& context)
TBooleanFormulaTags::TBooleanFormulaTags(THashSet<std::string> tags)
: Tags_(std::move(tags))
{
- for (const auto& key: Tags_) {
+ for (const auto& key : Tags_) {
PreparedTags_[key] = 1;
}
}
@@ -955,7 +955,7 @@ std::string TBooleanFormula::GetFormula() const
bool TBooleanFormula::IsSatisfiedBy(const std::vector<std::string>& value) const
{
THashMap<std::string, i64> values;
- for (const auto& key: value) {
+ for (const auto& key : value) {
values[key] = 1;
}
return Impl_->Eval(values, EEvaluationContext::Boolean);
diff --git a/yt/yt/core/misc/unittests/consistent_hashing_ut.cpp b/yt/yt/core/misc/unittests/consistent_hashing_ut.cpp
index 8c95d6e961d..2f96372a61c 100644
--- a/yt/yt/core/misc/unittests/consistent_hashing_ut.cpp
+++ b/yt/yt/core/misc/unittests/consistent_hashing_ut.cpp
@@ -313,7 +313,7 @@ double GetPercentageInconsistentFiles(
auto countDisplaced = [&] (const std::vector<std::pair<EQueryType, std::pair<TString, int>>>& queries) {
std::map<TCrpItemWithToken, TCompactVector<TString, 1>> serversBefore;
- for (const auto& file: files) {
+ for (const auto& file : files) {
auto candidates = ring.GetServersForFile(file.first, file.second);
candidates.resize(std::min(static_cast<size_t>(file.second), candidateCount));
serversBefore[file] = candidates;
@@ -339,7 +339,7 @@ double GetPercentageInconsistentFiles(
}
int result = 0;
- for (const auto& elem: files) {
+ for (const auto& elem : files) {
auto candidates = ring.GetServersForFile(elem.first, elem.second);
candidates.resize(std::min(static_cast<size_t>(elem.second), candidateCount));
result += (serversBefore[elem] != candidates);
diff --git a/yt/yt/core/rpc/unittests/viable_peer_registry_ut.cpp b/yt/yt/core/rpc/unittests/viable_peer_registry_ut.cpp
index cad9357c471..9df0436e169 100644
--- a/yt/yt/core/rpc/unittests/viable_peer_registry_ut.cpp
+++ b/yt/yt/core/rpc/unittests/viable_peer_registry_ut.cpp
@@ -190,7 +190,7 @@ IViablePeerRegistryPtr CreateTestRegistry(
std::vector<std::string> AddressesFromChannels(const std::vector<IChannelPtr>& channels)
{
std::vector<std::string> result;
- for (const auto& channel: channels) {
+ for (const auto& channel : channels) {
result.push_back(channel->GetEndpointDescription());
}
return result;
diff --git a/yt/yt/core/yson/unittests/protobuf_yson_ut.cpp b/yt/yt/core/yson/unittests/protobuf_yson_ut.cpp
index c70e71828bd..6c24070f16c 100644
--- a/yt/yt/core/yson/unittests/protobuf_yson_ut.cpp
+++ b/yt/yt/core/yson/unittests/protobuf_yson_ut.cpp
@@ -1023,7 +1023,7 @@ TEST(TYsonToProtobufTest, Entities)
TEST(TYsonToProtobufTest, ValidUtf8StringCheck)
{
- for (auto configOption: {EUtf8Check::Disable, EUtf8Check::LogOnFail, EUtf8Check::ThrowOnFail}) {
+ for (auto configOption : {EUtf8Check::Disable, EUtf8Check::LogOnFail, EUtf8Check::ThrowOnFail}) {
for (auto option: std::vector<std::optional<EUtf8Check>>{
std::nullopt, EUtf8Check::Disable, EUtf8Check::LogOnFail, EUtf8Check::ThrowOnFail})
{
@@ -2675,7 +2675,7 @@ TEST(TPackedRepeatedProtobufTest, TestSerializeDeserialize)
TEST(TEnumYsonStorageTypeTest, TestDeserializeSerialize)
{
- for (auto storageType: {EEnumYsonStorageType::String, EEnumYsonStorageType::Int}) {
+ for (auto storageType : {EEnumYsonStorageType::String, EEnumYsonStorageType::Int}) {
auto config = New<TProtobufInteropConfig>();
config->DefaultEnumYsonStorageType = storageType;
SetProtobufInteropConfig(config);
diff --git a/yt/yt/library/formats/protobuf.cpp b/yt/yt/library/formats/protobuf.cpp
index 648f4c27eb1..46f87d4b15d 100644
--- a/yt/yt/library/formats/protobuf.cpp
+++ b/yt/yt/library/formats/protobuf.cpp
@@ -895,7 +895,7 @@ void TProtobufFormatDescriptionBase<TProtobufWriterType>::InitEmbeddedColumn(
{
auto embeddingIndex = tableType->AddEmbedding(parentEmbeddingIndex, columnConfig);
- for (auto& fieldConfig: columnConfig->Type->Fields) {
+ for (auto& fieldConfig : columnConfig->Type->Fields) {
InitColumn(fieldIndex, tableSchema, typeBuilder, tableType, fieldConfig, parent, embeddingIndex);
}
}
@@ -924,7 +924,7 @@ void TProtobufFormatDescriptionBase<TProtobufParserType>::InitEmbeddedColumn(
std::move(child), //KMP
fieldIndex);
- for (auto& fieldConfig: columnConfig->Type->Fields) {
+ for (auto& fieldConfig : columnConfig->Type->Fields) {
InitColumn(fieldIndex, tableSchema, typeBuilder, tableType, fieldConfig, childPtr->Type, parentEmbeddingIndex);
}
}
@@ -1600,7 +1600,7 @@ static int Process(
const std::unique_ptr<TProtobufParserFieldDescription>& child)
{
if (child->Type->ProtoType == EProtobufType::EmbeddedMessage) {
- for (const auto& grandChild: child->Type->Children) {
+ for (const auto& grandChild : child->Type->Children) {
globalChildIndex = Process(ids, globalChildIndex, nameTable, child->Type, grandChild);
}
} else {
@@ -1620,7 +1620,7 @@ std::vector<std::pair<ui16, TProtobufParserFieldDescription*>> TProtobufParserFo
std::vector<std::pair<ui16, TProtobufParserFieldDescription*>> ids;
int globalChildIndex = 0;
- for (const auto& child: TableType_->Children) {
+ for (const auto& child : TableType_->Children) {
globalChildIndex = Process(ids, globalChildIndex, nameTable, TableType_, child);
}