aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorpavook <pavook@yandex-team.com>2024-08-22 16:26:27 +0300
committerpavook <pavook@yandex-team.com>2024-08-22 16:39:20 +0300
commit8520e043f2e12acdfd39d971ebeeacbe9e5ac3ca (patch)
tree55e2c5a3efebd951a92445ed5c7327c86479f655
parentf9fbb65f64b68c5de5cf257c04e06ac6aeaeb1e8 (diff)
downloadydb-8520e043f2e12acdfd39d971ebeeacbe9e5ac3ca.tar.gz
GLOBAL OTBIVKA FIX ୧༼ಠ益ಠ༽୨
Make all "otbivka" exactly 80 symbols. Command: ```bash sed -i 's#^//////////////\+$#////////////////////////////////////////////////////////////////////////////////#g' $(find yt \( -name '*.cpp' -or -name '*.h' -or -name '*.proto' \) -not -path 'yt/yt/experiments/private/tabletvis/imgui/*') ``` 30a0ba9f42ba1909d3cee11fe12bba14c7c8b039
-rw-r--r--yt/cpp/mapreduce/client/batch_request_impl.cpp2
-rw-r--r--yt/cpp/mapreduce/client/operation.cpp2
-rw-r--r--yt/cpp/mapreduce/client/retry_heavy_write_request.h4
-rw-r--r--yt/cpp/mapreduce/http/context.h2
-rw-r--r--yt/cpp/mapreduce/http/helpers.cpp4
-rw-r--r--yt/cpp/mapreduce/http/helpers.h4
-rw-r--r--yt/cpp/mapreduce/http/http.h2
-rw-r--r--yt/cpp/mapreduce/http/http_client.cpp8
-rw-r--r--yt/cpp/mapreduce/http/http_client.h8
-rw-r--r--yt/cpp/mapreduce/http/requests.h2
-rw-r--r--yt/cpp/mapreduce/http/retry_request.cpp4
-rw-r--r--yt/cpp/mapreduce/http/retry_request.h8
-rw-r--r--yt/cpp/mapreduce/interface/batch_request.h4
-rw-r--r--yt/cpp/mapreduce/interface/errors.cpp6
-rw-r--r--yt/cpp/mapreduce/interface/io.h2
-rw-r--r--yt/cpp/mapreduce/interface/job_counters.cpp8
-rw-r--r--yt/cpp/mapreduce/interface/job_counters.h2
-rw-r--r--yt/cpp/mapreduce/interface/job_statistics.cpp16
-rw-r--r--yt/cpp/mapreduce/interface/job_statistics.h12
-rw-r--r--yt/cpp/mapreduce/interface/operation.h10
-rw-r--r--yt/cpp/mapreduce/interface/ut/operation_ut.cpp6
-rw-r--r--yt/cpp/mapreduce/io/ut/end_of_stream_ut.cpp6
-rw-r--r--yt/cpp/mapreduce/io/ut/readers_ut.cpp6
-rw-r--r--yt/cpp/mapreduce/io/ut/yamr_table_reader_ut.cpp4
-rw-r--r--yt/cpp/mapreduce/io/yamr_table_reader.cpp4
-rw-r--r--yt/cpp/mapreduce/raw_client/raw_batch_request.cpp30
-rw-r--r--yt/cpp/mapreduce/raw_client/raw_requests.cpp2
-rw-r--r--yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp4
-rw-r--r--yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h4
-rw-r--r--yt/yt/client/api/queue_transaction_mixin.cpp2
-rw-r--r--yt/yt/client/api/rpc_proxy/address_helpers.h2
-rw-r--r--yt/yt/client/api/rpc_proxy/client_base.cpp2
-rw-r--r--yt/yt/client/api/rpc_proxy/table_mount_cache.cpp2
-rw-r--r--yt/yt/client/chaos_client/replication_card.h4
-rw-r--r--yt/yt/client/chaos_client/replication_card_cache.cpp2
-rw-r--r--yt/yt/client/driver/helpers.cpp2
-rw-r--r--yt/yt/client/driver/helpers.h2
-rw-r--r--yt/yt/client/driver/query_commands.cpp18
-rw-r--r--yt/yt/client/driver/query_commands.h18
-rw-r--r--yt/yt/client/query_tracker_client/public.h4
-rw-r--r--yt/yt/client/table_client/columnar_statistics.cpp4
-rw-r--r--yt/yt/client/table_client/config.cpp6
-rw-r--r--yt/yt/client/table_client/config.h4
-rw-r--r--yt/yt/client/table_client/schema.cpp2
-rw-r--r--yt/yt/client/tablet_client/table_mount_cache_detail.cpp2
-rw-r--r--yt/yt/client/tablet_client/table_mount_cache_detail.h2
-rw-r--r--yt/yt/client/transaction_client/noop_timestamp_provider.cpp2
-rw-r--r--yt/yt/client/transaction_client/noop_timestamp_provider.h2
-rw-r--r--yt/yt/client/unittests/farm_fingerprint_stability_ut.cpp4
-rw-r--r--yt/yt/core/actions/unittests/future_ut.cpp2
-rw-r--r--yt/yt/core/concurrency/async_stream.cpp2
-rw-r--r--yt/yt/core/concurrency/execution_stack.cpp2
-rw-r--r--yt/yt/core/logging/log_manager.cpp4
-rw-r--r--yt/yt/core/misc/concurrent_cache-inl.h2
-rw-r--r--yt/yt/core/misc/consistent_hashing_ring-inl.h2
-rw-r--r--yt/yt/core/misc/hazard_ptr.cpp20
-rw-r--r--yt/yt/core/misc/lock_free_hash_table-inl.h2
-rw-r--r--yt/yt/core/misc/memory_usage_tracker.h2
-rw-r--r--yt/yt/core/misc/mpsc_queue.h2
-rw-r--r--yt/yt/core/misc/mpsc_stack.h2
-rw-r--r--yt/yt/core/misc/relaxed_mpsc_queue-inl.h4
-rw-r--r--yt/yt/core/misc/slab_allocator.cpp14
-rw-r--r--yt/yt/core/misc/slab_allocator.h6
-rw-r--r--yt/yt/core/misc/spsc_queue-inl.h2
-rw-r--r--yt/yt/core/rpc/request_queue_provider.cpp2
-rw-r--r--yt/yt/core/rpc/request_queue_provider.h2
-rw-r--r--yt/yt/core/rpc/stream.h2
-rw-r--r--yt/yt/core/yson/string_filter.cpp10
-rw-r--r--yt/yt/core/yson/unittests/depth_limiting_yson_consumer_ut.cpp2
-rw-r--r--yt/yt/core/yson/unittests/ypath_designated_yson_consumer_ut.cpp2
-rw-r--r--yt/yt/core/yson/ypath_filtering_consumer.h2
-rw-r--r--yt/yt/core/ytree/interned_attributes-inl.h2
-rw-r--r--yt/yt/core/ytree/interned_attributes.cpp2
-rw-r--r--yt/yt/core/ytree/interned_attributes.h2
-rw-r--r--yt/yt/core/ytree/unittests/lazy_ypath_service_ut.cpp2
-rw-r--r--yt/yt/core/ytree/ypath_client.h2
-rw-r--r--yt/yt/core/ytree/yson_struct_detail.h2
-rw-r--r--yt/yt/core/ytree/yson_struct_public.h2
-rw-r--r--yt/yt/library/formats/arrow_writer.cpp2
-rw-r--r--yt/yt/library/numeric/unittests/piecewise_linear_function_ut.cpp2
80 files changed, 185 insertions, 185 deletions
diff --git a/yt/cpp/mapreduce/client/batch_request_impl.cpp b/yt/cpp/mapreduce/client/batch_request_impl.cpp
index 6afa5665f1..08ffec2bfc 100644
--- a/yt/cpp/mapreduce/client/batch_request_impl.cpp
+++ b/yt/cpp/mapreduce/client/batch_request_impl.cpp
@@ -32,7 +32,7 @@ using ::NThreading::TFuture;
using ::NThreading::TPromise;
using ::NThreading::NewPromise;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TBatchRequest::TBatchRequest(const TTransactionId& defaultTransaction, ::TIntrusivePtr<TClient> client)
: DefaultTransaction_(defaultTransaction)
diff --git a/yt/cpp/mapreduce/client/operation.cpp b/yt/cpp/mapreduce/client/operation.cpp
index f4df2e2dd7..0d5e892214 100644
--- a/yt/cpp/mapreduce/client/operation.cpp
+++ b/yt/cpp/mapreduce/client/operation.cpp
@@ -344,7 +344,7 @@ TSimpleOperationIo CreateSimpleOperationIo(
};
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TString GetJobStderrWithRetriesAndIgnoreErrors(
const IRequestRetryPolicyPtr& retryPolicy,
diff --git a/yt/cpp/mapreduce/client/retry_heavy_write_request.h b/yt/cpp/mapreduce/client/retry_heavy_write_request.h
index 052bbfb860..b3a6ec0f7c 100644
--- a/yt/cpp/mapreduce/client/retry_heavy_write_request.h
+++ b/yt/cpp/mapreduce/client/retry_heavy_write_request.h
@@ -8,7 +8,7 @@
namespace NYT {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class THeavyRequestRetrier
{
@@ -52,7 +52,7 @@ private:
TStreamFactory StreamFactory_;
};
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void RetryHeavyWriteRequest(
const IClientRetryPolicyPtr& clientRetryPolicy,
diff --git a/yt/cpp/mapreduce/http/context.h b/yt/cpp/mapreduce/http/context.h
index 3bae208279..f50c1b9732 100644
--- a/yt/cpp/mapreduce/http/context.h
+++ b/yt/cpp/mapreduce/http/context.h
@@ -9,7 +9,7 @@
namespace NYT {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TClientContext
{
diff --git a/yt/cpp/mapreduce/http/helpers.cpp b/yt/cpp/mapreduce/http/helpers.cpp
index 18f74b5958..0e34610ef1 100644
--- a/yt/cpp/mapreduce/http/helpers.cpp
+++ b/yt/cpp/mapreduce/http/helpers.cpp
@@ -9,7 +9,7 @@
namespace NYT {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TString CreateHostNameWithPort(const TString& hostName, const TClientContext& context)
{
@@ -100,6 +100,6 @@ void LogRequest(const THttpHeader& header, const TString& url, bool includeParam
GetLoggedAttributes(header, url, includeParameters, Max<size_t>()));
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/http/helpers.h b/yt/cpp/mapreduce/http/helpers.h
index 82ef799ca1..474813674e 100644
--- a/yt/cpp/mapreduce/http/helpers.h
+++ b/yt/cpp/mapreduce/http/helpers.h
@@ -8,7 +8,7 @@
namespace NYT {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TString CreateHostNameWithPort(const TString& name, const TClientContext& context);
@@ -24,6 +24,6 @@ TString GetLoggedAttributes(const THttpHeader& header, const TString& url, bool
void LogRequest(const THttpHeader& header, const TString& url, bool includeParameters, const TString& requestId, const TString& hostName);
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/http/http.h b/yt/cpp/mapreduce/http/http.h
index 8bfa00de1d..95595959ad 100644
--- a/yt/cpp/mapreduce/http/http.h
+++ b/yt/cpp/mapreduce/http/http.h
@@ -31,7 +31,7 @@ struct THeadersPtrWrapper;
} // NHttp
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
enum class EFrameType
{
diff --git a/yt/cpp/mapreduce/http/http_client.cpp b/yt/cpp/mapreduce/http/http_client.cpp
index 6dc24c6ef2..305d95b06c 100644
--- a/yt/cpp/mapreduce/http/http_client.cpp
+++ b/yt/cpp/mapreduce/http/http_client.cpp
@@ -102,7 +102,7 @@ void CheckErrorResponse(const TString& hostName, const TString& requestId, const
} // namespace
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TDefaultHttpResponse
: public IHttpResponse
@@ -188,7 +188,7 @@ public:
}
};
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TCoreRequestContext
{
@@ -586,7 +586,7 @@ private:
NHttp::IClientPtr Client_;
};
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
IHttpClientPtr CreateDefaultHttpClient()
{
@@ -598,6 +598,6 @@ IHttpClientPtr CreateCoreHttpClient(bool useTLS, const TConfigPtr& config)
return std::make_shared<TCoreHttpClient>(useTLS, config);
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NHttpClient
diff --git a/yt/cpp/mapreduce/http/http_client.h b/yt/cpp/mapreduce/http/http_client.h
index 859f0423cb..97321c4c9d 100644
--- a/yt/cpp/mapreduce/http/http_client.h
+++ b/yt/cpp/mapreduce/http/http_client.h
@@ -15,14 +15,14 @@
namespace NYT::NHttpClient {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct THttpConfig
{
TDuration SocketTimeout = TDuration::Zero();
};
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class IHttpResponse
{
@@ -65,12 +65,12 @@ public:
}
};
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
IHttpClientPtr CreateDefaultHttpClient();
IHttpClientPtr CreateCoreHttpClient(bool useTLS, const TConfigPtr& config);
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NHttpClient
diff --git a/yt/cpp/mapreduce/http/requests.h b/yt/cpp/mapreduce/http/requests.h
index 2c692475d1..a21cff5360 100644
--- a/yt/cpp/mapreduce/http/requests.h
+++ b/yt/cpp/mapreduce/http/requests.h
@@ -8,7 +8,7 @@
namespace NYT {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
bool ParseBoolFromResponse(const TString& response);
diff --git a/yt/cpp/mapreduce/http/retry_request.cpp b/yt/cpp/mapreduce/http/retry_request.cpp
index 63a36c2f78..307e310b5b 100644
--- a/yt/cpp/mapreduce/http/retry_request.cpp
+++ b/yt/cpp/mapreduce/http/retry_request.cpp
@@ -18,7 +18,7 @@
namespace NYT {
namespace NDetail {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static TResponseInfo Request(
const TClientContext& context,
@@ -147,7 +147,7 @@ TResponseInfo RetryRequestWithPolicy(
Y_ABORT("Retries must have either succeeded or thrown an exception");
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NDetail
} // namespace NYT
diff --git a/yt/cpp/mapreduce/http/retry_request.h b/yt/cpp/mapreduce/http/retry_request.h
index 2210e318f1..a6007d6eae 100644
--- a/yt/cpp/mapreduce/http/retry_request.h
+++ b/yt/cpp/mapreduce/http/retry_request.h
@@ -13,7 +13,7 @@
namespace NYT::NDetail {
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TResponseInfo
{
@@ -22,7 +22,7 @@ struct TResponseInfo
int HttpCode = 0;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TRequestConfig
{
@@ -30,7 +30,7 @@ struct TRequestConfig
bool IsHeavy = false;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
// Retry request with given `header' and `body' using `retryPolicy'.
// If `retryPolicy == nullptr' use default, currently `TAttemptLimitedRetryPolicy(TConfig::Get()->RetryCount)`.
@@ -47,6 +47,6 @@ TResponseInfo RequestWithoutRetry(
TMaybe<TStringBuf> body = {},
const TRequestConfig& config = TRequestConfig());
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NDetail
diff --git a/yt/cpp/mapreduce/interface/batch_request.h b/yt/cpp/mapreduce/interface/batch_request.h
index 3ea28f76fd..8056f8a1ed 100644
--- a/yt/cpp/mapreduce/interface/batch_request.h
+++ b/yt/cpp/mapreduce/interface/batch_request.h
@@ -9,7 +9,7 @@
namespace NYT {
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// Helper base of @ref NYT::IBatchRequest holding most of useful methods.
class IBatchRequestBase
@@ -217,6 +217,6 @@ public:
virtual void ExecuteBatch(const TExecuteBatchOptions& options = TExecuteBatchOptions()) = 0;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/interface/errors.cpp b/yt/cpp/mapreduce/interface/errors.cpp
index 49a7c7cfc1..ef3d2db4a3 100644
--- a/yt/cpp/mapreduce/interface/errors.cpp
+++ b/yt/cpp/mapreduce/interface/errors.cpp
@@ -16,7 +16,7 @@ namespace NYT {
using namespace NJson;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static void WriteErrorDescription(const TYtError& error, IOutputStream* out)
{
@@ -107,7 +107,7 @@ static TString DumpJobInfoForException(const TOperationId& operationId, const TV
return output;
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TYtError::TYtError()
: Code_(0)
@@ -396,7 +396,7 @@ void TErrorResponse::Setup()
*this << Error_.FullDescription();
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TOperationFailedError::TOperationFailedError(
EState state,
diff --git a/yt/cpp/mapreduce/interface/io.h b/yt/cpp/mapreduce/interface/io.h
index 1d7f5375a2..becde0def2 100644
--- a/yt/cpp/mapreduce/interface/io.h
+++ b/yt/cpp/mapreduce/interface/io.h
@@ -101,7 +101,7 @@ class TIOException
: public yexception
{ };
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// Interface representing YT file reader.
class IFileReader
diff --git a/yt/cpp/mapreduce/interface/job_counters.cpp b/yt/cpp/mapreduce/interface/job_counters.cpp
index 717982e216..2d0284e2b1 100644
--- a/yt/cpp/mapreduce/interface/job_counters.cpp
+++ b/yt/cpp/mapreduce/interface/job_counters.cpp
@@ -2,7 +2,7 @@
namespace NYT {
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
namespace {
ui64 CountTotal(const TNode& data)
@@ -31,7 +31,7 @@ namespace {
}
} // namespace
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TJobCounter::TJobCounter(TNode data)
: Data_(std::move(data))
@@ -58,7 +58,7 @@ ui64 TJobCounter::GetValue(const TStringBuf key) const
return 0;
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TJobCounters::TJobCounters(const TNode& counters)
: Total_(0)
@@ -159,6 +159,6 @@ ui64 TJobCounters::GetTotal() const
return Total_;
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/interface/job_counters.h b/yt/cpp/mapreduce/interface/job_counters.h
index 573cbe4784..24efddd7d0 100644
--- a/yt/cpp/mapreduce/interface/job_counters.h
+++ b/yt/cpp/mapreduce/interface/job_counters.h
@@ -69,6 +69,6 @@ private:
TJobCounter Blocked_;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/interface/job_statistics.cpp b/yt/cpp/mapreduce/interface/job_statistics.cpp
index 4ff8dde3cc..0ee952f510 100644
--- a/yt/cpp/mapreduce/interface/job_statistics.cpp
+++ b/yt/cpp/mapreduce/interface/job_statistics.cpp
@@ -17,7 +17,7 @@
namespace NYT {
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
template <>
i64 ConvertJobStatisticsEntry(i64 value)
@@ -31,7 +31,7 @@ TDuration ConvertJobStatisticsEntry(i64 value)
return TDuration::MilliSeconds(value);
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static TTaskName JobTypeToTaskName(EJobType jobType)
{
@@ -55,7 +55,7 @@ static TTaskName FixTaskName(TString taskName)
return taskName;
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TJobStatistics::TData
: public TThrRefBase
@@ -140,7 +140,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TJobStatistics::TFilter
: public TThrRefBase
@@ -149,7 +149,7 @@ struct TJobStatistics::TFilter
TVector<EJobState> JobStateFilter = {EJobState::Completed};
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
const TString TJobStatistics::CustomStatisticsNamePrefix_ = "custom/";
@@ -293,7 +293,7 @@ TMaybe<TJobStatistics::TDataEntry> TJobStatistics::GetStatisticsImpl(TStringBuf
return result;
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
namespace {
@@ -340,7 +340,7 @@ void WriteCustomStatisticsAny(TStringBuf path, const T& value)
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void WriteCustomStatistics(const TNode& statistics)
{
@@ -356,6 +356,6 @@ void WriteCustomStatistics(TStringBuf path, i64 value)
void FlushCustomStatisticsStream() {
GetStatisticsStream()->Flush();
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/interface/job_statistics.h b/yt/cpp/mapreduce/interface/job_statistics.h
index 4582d9e872..a41b48d5c6 100644
--- a/yt/cpp/mapreduce/interface/job_statistics.h
+++ b/yt/cpp/mapreduce/interface/job_statistics.h
@@ -16,7 +16,7 @@
namespace NYT {
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
///
/// @brief Convert i64 representation of statistics to other type.
@@ -28,7 +28,7 @@ namespace NYT {
template <typename T>
T ConvertJobStatisticsEntry(i64 value);
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// Class representing a collection of job statistics.
class TJobStatistics
@@ -160,7 +160,7 @@ private:
friend class TJobStatisticsEntry;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// Class representing single statistic.
template <typename T>
@@ -225,7 +225,7 @@ private:
friend class TJobStatistics;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
template <typename T>
TJobStatisticsEntry<T> TJobStatistics::GetStatisticsAs(TStringBuf name) const
@@ -239,7 +239,7 @@ TJobStatisticsEntry<T> TJobStatistics::GetCustomStatisticsAs(TStringBuf name) co
return TJobStatisticsEntry<T>(GetStatisticsImpl(CustomStatisticsNamePrefix_ + name));
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
///
/// @brief Write [custom statistics](https://ytsaurus.tech/docs/en/user-guide/data-processing/operations/jobs#user_stats).
@@ -263,6 +263,6 @@ void WriteCustomStatistics(const TNode& statistics);
/// @brief Flush [custom statistics stream](https://ytsaurus.tech/docs/en/user-guide/data-processing/operations/jobs#user_stats)
///
void FlushCustomStatisticsStream();
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/cpp/mapreduce/interface/operation.h b/yt/cpp/mapreduce/interface/operation.h
index 76b67138a3..9e17ca7e90 100644
--- a/yt/cpp/mapreduce/interface/operation.h
+++ b/yt/cpp/mapreduce/interface/operation.h
@@ -86,7 +86,7 @@ TStructuredTablePath Structured(TRichYPath richYPath);
template <typename TRow>
TTableStructure StructuredTableDescription();
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// Tag class marking that row stream is empty.
struct TVoidStructuredRowStream
@@ -117,7 +117,7 @@ using TStructuredRowStreamDescription = std::variant<
TProtobufStructuredRowStream
>;
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// Tag class marking that current binary should be used in operation.
struct TJobBinaryDefault
@@ -710,7 +710,7 @@ struct TJobProfilerSpec
FLUENT_FIELD_OPTION(int, SamplingFrequency);
};
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
/// @brief Specification of a disk that will be available in job.
///
@@ -2981,7 +2981,7 @@ struct TListJobsResult
TMaybe<i64> ArchiveJobCount;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
///
/// @brief Options for @ref NYT::IClient::GetJob.
@@ -3019,7 +3019,7 @@ struct TGetJobStderrOptions
/// @endcond
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
///
/// @brief Options for @ref NYT::IOperation::GetFailedJobInfo.
diff --git a/yt/cpp/mapreduce/interface/ut/operation_ut.cpp b/yt/cpp/mapreduce/interface/ut/operation_ut.cpp
index 81d03d0618..b28a33142a 100644
--- a/yt/cpp/mapreduce/interface/ut/operation_ut.cpp
+++ b/yt/cpp/mapreduce/interface/ut/operation_ut.cpp
@@ -14,7 +14,7 @@
using namespace NYT;
using namespace NYT::NUnitTesting;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TDummyInferenceContext
: public IOperationPreparationContext
@@ -62,7 +62,7 @@ private:
TVector<TTableSchema> InputSchemas_;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TEST(TPrepareOperationTest, BasicSchemas)
{
@@ -269,4 +269,4 @@ TEST(TPrepareOperationTest, Bug_r7349102)
builder.Finish();
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/io/ut/end_of_stream_ut.cpp b/yt/cpp/mapreduce/io/ut/end_of_stream_ut.cpp
index 3642aa1e45..449c966a3b 100644
--- a/yt/cpp/mapreduce/io/ut/end_of_stream_ut.cpp
+++ b/yt/cpp/mapreduce/io/ut/end_of_stream_ut.cpp
@@ -4,7 +4,7 @@
using namespace NYT;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TStringRawTableReader
: public TRawTableReader
@@ -39,7 +39,7 @@ private:
TStringStream Stream_;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TEndOfStreamTest
: public ::testing::TestWithParam<bool>
@@ -91,4 +91,4 @@ TEST_P(TEndOfStreamTest, Eos)
INSTANTIATE_TEST_SUITE_P(WithEos, TEndOfStreamTest, ::testing::Values(true));
INSTANTIATE_TEST_SUITE_P(WithoutEos, TEndOfStreamTest, ::testing::Values(false));
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/io/ut/readers_ut.cpp b/yt/cpp/mapreduce/io/ut/readers_ut.cpp
index 5068dbb6bc..5f4c71b6f4 100644
--- a/yt/cpp/mapreduce/io/ut/readers_ut.cpp
+++ b/yt/cpp/mapreduce/io/ut/readers_ut.cpp
@@ -17,7 +17,7 @@ using namespace NYT;
using namespace NYT::NDetail;
using namespace NSkiff;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TRetryEmulatingRawTableReader
: public TRawTableReader
@@ -73,7 +73,7 @@ private:
int DoReadCallCount_ = 0;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TEST(TReadersTest, YsonGood)
{
@@ -229,4 +229,4 @@ TEST(TReadersTest, ProtobufBad)
EXPECT_THROW(TLenvalProtoTableReader(proxy, { NYT::NTesting::TRow::descriptor() }).ReadRow(&row), yexception);
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/io/ut/yamr_table_reader_ut.cpp b/yt/cpp/mapreduce/io/ut/yamr_table_reader_ut.cpp
index d55a28b3e4..fc20be017f 100644
--- a/yt/cpp/mapreduce/io/ut/yamr_table_reader_ut.cpp
+++ b/yt/cpp/mapreduce/io/ut/yamr_table_reader_ut.cpp
@@ -10,7 +10,7 @@ void Out<std::tuple<TString, TString, TString>>(IOutputStream& out, const std::t
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TRowCollection
{
@@ -182,4 +182,4 @@ TEST(TYamrTableReaderTest, TestSkipRetry)
}
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/io/yamr_table_reader.cpp b/yt/cpp/mapreduce/io/yamr_table_reader.cpp
index 55f270a6b6..cb98767449 100644
--- a/yt/cpp/mapreduce/io/yamr_table_reader.cpp
+++ b/yt/cpp/mapreduce/io/yamr_table_reader.cpp
@@ -4,7 +4,7 @@
#include <yt/cpp/mapreduce/common/retry_lib.h>
#include <yt/cpp/mapreduce/raw_client/raw_requests.h>
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static void CheckedSkip(IInputStream* input, size_t byteCount)
{
@@ -12,7 +12,7 @@ static void CheckedSkip(IInputStream* input, size_t byteCount)
Y_ENSURE(skipped == byteCount, "Premature end of YaMR stream");
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
namespace NYT {
diff --git a/yt/cpp/mapreduce/raw_client/raw_batch_request.cpp b/yt/cpp/mapreduce/raw_client/raw_batch_request.cpp
index 4e60959059..1bd9532e4c 100644
--- a/yt/cpp/mapreduce/raw_client/raw_batch_request.cpp
+++ b/yt/cpp/mapreduce/raw_client/raw_batch_request.cpp
@@ -28,7 +28,7 @@ using NThreading::TFuture;
using NThreading::TPromise;
using NThreading::NewPromise;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static TString RequestInfo(const TNode& request)
{
@@ -58,7 +58,7 @@ static void EnsureType(const TMaybe<TNode>& node, TNode::EType type)
EnsureType(*node, type);
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
template <typename TReturnType>
class TResponseParserBase
@@ -86,7 +86,7 @@ protected:
TPromise<TReturnType> Result_;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TGetResponseParser
@@ -100,7 +100,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TVoidResponseParser
: public TResponseParserBase<void>
@@ -113,7 +113,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TListResponseParser
: public TResponseParserBase<TNode::TListType>
@@ -126,7 +126,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TExistsResponseParser
: public TResponseParserBase<bool>
@@ -139,7 +139,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TGuidResponseParser
: public TResponseParserBase<TGUID>
@@ -152,7 +152,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TCanonizeYPathResponseParser
: public TResponseParserBase<TRichYPath>
@@ -181,7 +181,7 @@ private:
TString PathPrefix_;
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TGetOperationResponseParser
: public TResponseParserBase<TOperationAttributes>
@@ -194,7 +194,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TTableColumnarStatisticsParser
: public TResponseParserBase<TVector<TTableColumnarStatistics>>
@@ -209,7 +209,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TTablePartitionsParser
: public TResponseParserBase<TMultiTablePartitions>
@@ -241,7 +241,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TYPathParser
: public TResponseParserBase<TYPath>
@@ -254,7 +254,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TCheckPermissionParser
: public TResponseParserBase<TCheckPermissionResponse>
@@ -267,7 +267,7 @@ public:
}
};
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TRawBatchRequest::TBatchItem::TBatchItem(TNode parameters, ::TIntrusivePtr<IResponseItemParser> responseParser)
: Parameters(std::move(parameters))
@@ -281,7 +281,7 @@ TRawBatchRequest::TBatchItem::TBatchItem(const TBatchItem& batchItem, TInstant n
, NextTry(nextTry)
{ }
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TRawBatchRequest::TRawBatchRequest(const TConfigPtr& config)
: Config_(config)
diff --git a/yt/cpp/mapreduce/raw_client/raw_requests.cpp b/yt/cpp/mapreduce/raw_client/raw_requests.cpp
index 6426ccecf4..2f9610a1ca 100644
--- a/yt/cpp/mapreduce/raw_client/raw_requests.cpp
+++ b/yt/cpp/mapreduce/raw_client/raw_requests.cpp
@@ -28,7 +28,7 @@
namespace NYT::NDetail::NRawClient {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void ExecuteBatch(
IRequestRetryPolicyPtr retryPolicy,
diff --git a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp b/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp
index 8392eaccdf..a638ac581d 100644
--- a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp
+++ b/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp
@@ -18,7 +18,7 @@ namespace NYT::NDetail::NRawClient {
using ::ToString;
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static void SetTransactionIdParam(TNode* node, const TTransactionId& transactionId)
{
@@ -105,7 +105,7 @@ void SerializeMasterReadOptions(TNode* node, const TMasterReadOptions<T>& option
}
}
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TNode SerializeParamsForCreate(
const TTransactionId& transactionId,
diff --git a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h b/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h
index dfe70bbcc5..a7ab35d91d 100644
--- a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h
+++ b/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h
@@ -5,7 +5,7 @@
namespace NYT::NDetail::NRawClient {
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TNode SerializeParamsForCreate(
const TTransactionId& transactionId,
@@ -224,6 +224,6 @@ TNode SerializeParamsForStartTransaction(
TDuration txTimeout,
const TStartTransactionOptions& options);
-////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NDetail::NRawClient
diff --git a/yt/yt/client/api/queue_transaction_mixin.cpp b/yt/yt/client/api/queue_transaction_mixin.cpp
index cbd93b5b74..ced6b678fd 100644
--- a/yt/yt/client/api/queue_transaction_mixin.cpp
+++ b/yt/yt/client/api/queue_transaction_mixin.cpp
@@ -9,7 +9,7 @@ namespace NYT::NApi {
using namespace NQueueClient;
using namespace NConcurrency;
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TQueueTransactionMixin::AdvanceConsumer(
const NYPath::TRichYPath& consumerPath,
diff --git a/yt/yt/client/api/rpc_proxy/address_helpers.h b/yt/yt/client/api/rpc_proxy/address_helpers.h
index c2f31764c6..c4ce50b5ad 100644
--- a/yt/yt/client/api/rpc_proxy/address_helpers.h
+++ b/yt/yt/client/api/rpc_proxy/address_helpers.h
@@ -47,6 +47,6 @@ std::optional<std::vector<TString>> GetBalancersOrNull(
EAddressType addressType,
const TString& network);
-///////////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NApi::NRpcProxy
diff --git a/yt/yt/client/api/rpc_proxy/client_base.cpp b/yt/yt/client/api/rpc_proxy/client_base.cpp
index 74aecebfa6..2711f8a37b 100644
--- a/yt/yt/client/api/rpc_proxy/client_base.cpp
+++ b/yt/yt/client/api/rpc_proxy/client_base.cpp
@@ -671,7 +671,7 @@ IFileWriterPtr TClientBase::CreateFileWriter(
return NRpcProxy::CreateFileWriter(std::move(req));
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
IJournalReaderPtr TClientBase::CreateJournalReader(
const TYPath& path,
diff --git a/yt/yt/client/api/rpc_proxy/table_mount_cache.cpp b/yt/yt/client/api/rpc_proxy/table_mount_cache.cpp
index 5e792836eb..9eed25eb95 100644
--- a/yt/yt/client/api/rpc_proxy/table_mount_cache.cpp
+++ b/yt/yt/client/api/rpc_proxy/table_mount_cache.cpp
@@ -19,7 +19,7 @@ using namespace NYPath;
using NYT::FromProto;
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TTableMountCache
: public TTableMountCacheBase
diff --git a/yt/yt/client/chaos_client/replication_card.h b/yt/yt/client/chaos_client/replication_card.h
index 7462e160ee..764c035c1e 100644
--- a/yt/yt/client/chaos_client/replication_card.h
+++ b/yt/yt/client/chaos_client/replication_card.h
@@ -80,7 +80,7 @@ struct TReplicationCard
DEFINE_REFCOUNTED_TYPE(TReplicationCard)
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TReplicationCardFetchOptions
{
@@ -97,7 +97,7 @@ struct TReplicationCardFetchOptions
void FormatValue(TStringBuilderBase* builder, const TReplicationCardFetchOptions& options, TStringBuf /*spec*/);
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void FormatValue(
TStringBuilderBase* builder,
diff --git a/yt/yt/client/chaos_client/replication_card_cache.cpp b/yt/yt/client/chaos_client/replication_card_cache.cpp
index 22d1706110..797b4dbc0c 100644
--- a/yt/yt/client/chaos_client/replication_card_cache.cpp
+++ b/yt/yt/client/chaos_client/replication_card_cache.cpp
@@ -7,7 +7,7 @@
namespace NYT::NChaosClient {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TReplicationCardCacheKey::operator size_t() const
{
diff --git a/yt/yt/client/driver/helpers.cpp b/yt/yt/client/driver/helpers.cpp
index 9ccf3675c2..25d44b985a 100644
--- a/yt/yt/client/driver/helpers.cpp
+++ b/yt/yt/client/driver/helpers.cpp
@@ -14,7 +14,7 @@ namespace NYT::NDriver {
using namespace NObjectClient;
using namespace NTracing;
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
bool operator==(const TEtag& lhs, const TEtag& rhs)
{
diff --git a/yt/yt/client/driver/helpers.h b/yt/yt/client/driver/helpers.h
index dca1a54e62..ef852d89f0 100644
--- a/yt/yt/client/driver/helpers.h
+++ b/yt/yt/client/driver/helpers.h
@@ -9,7 +9,7 @@
namespace NYT::NDriver {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TEtag
{
diff --git a/yt/yt/client/driver/query_commands.cpp b/yt/yt/client/driver/query_commands.cpp
index 024ee93c85..d73dce2825 100644
--- a/yt/yt/client/driver/query_commands.cpp
+++ b/yt/yt/client/driver/query_commands.cpp
@@ -20,7 +20,7 @@ using namespace NYson;
using namespace NTableClient;
using namespace NFormats;
-//////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TStartQueryCommand::Register(TRegistrar registrar)
{
@@ -91,7 +91,7 @@ void TStartQueryCommand::DoExecute(ICommandContextPtr context)
.EndMap());
}
-//////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TAbortQueryCommand::Register(TRegistrar registrar)
{
@@ -114,7 +114,7 @@ void TAbortQueryCommand::DoExecute(ICommandContextPtr context)
ProduceEmptyOutput(context);
}
-//////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TGetQueryResultCommand::Register(TRegistrar registrar)
{
@@ -137,7 +137,7 @@ void TGetQueryResultCommand::DoExecute(ICommandContextPtr context)
context->ProduceOutputValue(ConvertToYsonString(queryResult));
}
-//////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TReadQueryResultCommand::Register(TRegistrar registrar)
{
@@ -194,7 +194,7 @@ void TReadQueryResultCommand::DoExecute(ICommandContextPtr context)
.ThrowOnError();
}
-//////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TGetQueryCommand::Register(TRegistrar registrar)
{
@@ -223,7 +223,7 @@ void TGetQueryCommand::DoExecute(ICommandContextPtr context)
context->ProduceOutputValue(ConvertToYsonString(query));
}
-//////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TListQueriesCommand::Register(TRegistrar registrar)
{
@@ -318,7 +318,7 @@ void TListQueriesCommand::DoExecute(ICommandContextPtr context)
.EndMap());
}
-//////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TAlterQueryCommand::Register(TRegistrar registrar)
{
@@ -360,7 +360,7 @@ void TAlterQueryCommand::DoExecute(ICommandContextPtr context)
ProduceEmptyOutput(context);
}
-//////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TGetQueryTrackerInfoCommand::Register(TRegistrar registrar)
{
@@ -392,6 +392,6 @@ void TGetQueryTrackerInfoCommand::DoExecute(ICommandContextPtr context)
.EndMap());
}
-//////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NDriver
diff --git a/yt/yt/client/driver/query_commands.h b/yt/yt/client/driver/query_commands.h
index ec5279bdfb..789f7029b2 100644
--- a/yt/yt/client/driver/query_commands.h
+++ b/yt/yt/client/driver/query_commands.h
@@ -8,7 +8,7 @@
namespace NYT::NDriver {
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TStartQueryCommand
: public TTypedCommand<NApi::TStartQueryOptions>
@@ -25,7 +25,7 @@ private:
void DoExecute(ICommandContextPtr context) override;
};
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TAbortQueryCommand
: public TTypedCommand<NApi::TAbortQueryOptions>
@@ -41,7 +41,7 @@ private:
void DoExecute(ICommandContextPtr context) override;
};
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TGetQueryResultCommand
: public TTypedCommand<NApi::TGetQueryResultOptions>
@@ -58,7 +58,7 @@ private:
void DoExecute(ICommandContextPtr context) override;
};
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TReadQueryResultCommand
: public TTypedCommand<NApi::TReadQueryResultOptions>
@@ -75,7 +75,7 @@ private:
void DoExecute(ICommandContextPtr context) override;
};
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TGetQueryCommand
: public TTypedCommand<NApi::TGetQueryOptions>
@@ -91,7 +91,7 @@ private:
void DoExecute(ICommandContextPtr context) override;
};
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TListQueriesCommand
: public TTypedCommand<NApi::TListQueriesOptions>
@@ -105,7 +105,7 @@ private:
void DoExecute(ICommandContextPtr context) override;
};
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TAlterQueryCommand
: public TTypedCommand<NApi::TAlterQueryOptions>
@@ -121,7 +121,7 @@ private:
void DoExecute(ICommandContextPtr context) override;
};
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TGetQueryTrackerInfoCommand
: public TTypedCommand<NApi::TGetQueryTrackerInfoOptions>
@@ -135,6 +135,6 @@ private:
void DoExecute(ICommandContextPtr context) override;
};
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NDriver
diff --git a/yt/yt/client/query_tracker_client/public.h b/yt/yt/client/query_tracker_client/public.h
index bfaf0c8a89..22947d59db 100644
--- a/yt/yt/client/query_tracker_client/public.h
+++ b/yt/yt/client/query_tracker_client/public.h
@@ -6,7 +6,7 @@
namespace NYT::NQueryTrackerClient {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
YT_DEFINE_ERROR_ENUM(
((IncarnationMismatch) (3900))
@@ -41,6 +41,6 @@ DEFINE_STRING_SERIALIZABLE_ENUM(EQueryState,
(Failed)
);
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NQueryTrackerClient
diff --git a/yt/yt/client/table_client/columnar_statistics.cpp b/yt/yt/client/table_client/columnar_statistics.cpp
index a826e690ab..d483bd8c11 100644
--- a/yt/yt/client/table_client/columnar_statistics.cpp
+++ b/yt/yt/client/table_client/columnar_statistics.cpp
@@ -158,7 +158,7 @@ void UpdateColumnarStatistics(TColumnarStatistics& statistics, TRange<TRow> rows
} // namespace
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
bool TLargeColumnarStatistics::Empty() const
{
@@ -183,7 +183,7 @@ TLargeColumnarStatistics& TLargeColumnarStatistics::operator+=(const TLargeColum
return *this;
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TColumnarStatistics& TColumnarStatistics::operator+=(const TColumnarStatistics& other)
{
diff --git a/yt/yt/client/table_client/config.cpp b/yt/yt/client/table_client/config.cpp
index e07b03d6f8..a580572880 100644
--- a/yt/yt/client/table_client/config.cpp
+++ b/yt/yt/client/table_client/config.cpp
@@ -241,7 +241,7 @@ void TKeyPrefixFilterWriterConfig::Register(TRegistrar registrar)
});
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TDictionaryCompressionConfig::Register(TRegistrar registrar)
{
@@ -313,7 +313,7 @@ void TDictionaryCompressionConfig::Register(TRegistrar registrar)
});
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TDictionaryCompressionSessionConfig::Register(TRegistrar registrar)
{
@@ -325,7 +325,7 @@ void TDictionaryCompressionSessionConfig::Register(TRegistrar registrar)
.Default(64_MB);
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TBatchHunkReaderConfig::Register(TRegistrar registrar)
{
diff --git a/yt/yt/client/table_client/config.h b/yt/yt/client/table_client/config.h
index e9cebc18c1..e1bc37043d 100644
--- a/yt/yt/client/table_client/config.h
+++ b/yt/yt/client/table_client/config.h
@@ -310,7 +310,7 @@ public:
DEFINE_REFCOUNTED_TYPE(TBatchHunkReaderConfig)
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TTableReaderConfig
: public virtual NChunkClient::TMultiChunkReaderConfig
@@ -465,7 +465,7 @@ public:
DEFINE_REFCOUNTED_TYPE(TVersionedRowDigestConfig)
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TRowBatchReadOptions
{
diff --git a/yt/yt/client/table_client/schema.cpp b/yt/yt/client/table_client/schema.cpp
index b75e9275dc..9ac825fe12 100644
--- a/yt/yt/client/table_client/schema.cpp
+++ b/yt/yt/client/table_client/schema.cpp
@@ -35,7 +35,7 @@ using namespace NYTree;
using NYT::ToProto;
using NYT::FromProto;
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
namespace {
diff --git a/yt/yt/client/tablet_client/table_mount_cache_detail.cpp b/yt/yt/client/tablet_client/table_mount_cache_detail.cpp
index 2cc7c01f0c..2c37652904 100644
--- a/yt/yt/client/tablet_client/table_mount_cache_detail.cpp
+++ b/yt/yt/client/tablet_client/table_mount_cache_detail.cpp
@@ -19,7 +19,7 @@ using namespace NYTree;
static constexpr auto TabletCacheSweepPeriod = TDuration::Seconds(60);
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TTabletInfoOwnerCache::TTabletInfoOwnerCache(NLogging::TLogger logger)
: Logger(std::move(logger))
diff --git a/yt/yt/client/tablet_client/table_mount_cache_detail.h b/yt/yt/client/tablet_client/table_mount_cache_detail.h
index 2559a07702..274fd0e0c3 100644
--- a/yt/yt/client/tablet_client/table_mount_cache_detail.h
+++ b/yt/yt/client/tablet_client/table_mount_cache_detail.h
@@ -42,7 +42,7 @@ private:
void DropExpiredOwners(std::vector<TWeakPtr<TTableMountInfo>>* owners);
};
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TTableMountCacheBase
: public ITableMountCache
diff --git a/yt/yt/client/transaction_client/noop_timestamp_provider.cpp b/yt/yt/client/transaction_client/noop_timestamp_provider.cpp
index defa027534..e78a99809b 100644
--- a/yt/yt/client/transaction_client/noop_timestamp_provider.cpp
+++ b/yt/yt/client/transaction_client/noop_timestamp_provider.cpp
@@ -5,7 +5,7 @@
namespace NYT::NTransactionClient {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TNoopTimestampProvider
: public ITimestampProvider
diff --git a/yt/yt/client/transaction_client/noop_timestamp_provider.h b/yt/yt/client/transaction_client/noop_timestamp_provider.h
index e4cbc7fbd1..553aa4e035 100644
--- a/yt/yt/client/transaction_client/noop_timestamp_provider.h
+++ b/yt/yt/client/transaction_client/noop_timestamp_provider.h
@@ -4,7 +4,7 @@
namespace NYT::NTransactionClient {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
ITimestampProviderPtr CreateNoopTimestampProvider();
diff --git a/yt/yt/client/unittests/farm_fingerprint_stability_ut.cpp b/yt/yt/client/unittests/farm_fingerprint_stability_ut.cpp
index 421e8985ff..eabc7cdef7 100644
--- a/yt/yt/client/unittests/farm_fingerprint_stability_ut.cpp
+++ b/yt/yt/client/unittests/farm_fingerprint_stability_ut.cpp
@@ -6,7 +6,7 @@
namespace NYT::NTableClient {
namespace {
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
// The goal is to provide a sanity check for stability of FarmHash and FarmFingerprint functions
// for TUnversionedRow and TUnversionedValue.
@@ -93,7 +93,7 @@ INSTANTIATE_TEST_SUITE_P(
13952380479379003069ULL,
9998489714118868374ULL)));
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace
} // namespace NYT::NTableClient
diff --git a/yt/yt/core/actions/unittests/future_ut.cpp b/yt/yt/core/actions/unittests/future_ut.cpp
index 96ee01ade9..b2d90bea48 100644
--- a/yt/yt/core/actions/unittests/future_ut.cpp
+++ b/yt/yt/core/actions/unittests/future_ut.cpp
@@ -1717,7 +1717,7 @@ TEST_F(TFutureTest, CancelAppliedToUncancellable)
EXPECT_TRUE(future1.Get().IsOK());
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace
} // namespace NYT
diff --git a/yt/yt/core/concurrency/async_stream.cpp b/yt/yt/core/concurrency/async_stream.cpp
index e89cda52c9..1a226467bb 100644
--- a/yt/yt/core/concurrency/async_stream.cpp
+++ b/yt/yt/core/concurrency/async_stream.cpp
@@ -1052,6 +1052,6 @@ TFuture<void> ExpectEndOfStream(
}));
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NConcurrency
diff --git a/yt/yt/core/concurrency/execution_stack.cpp b/yt/yt/core/concurrency/execution_stack.cpp
index 4fd488de08..68e919666d 100644
--- a/yt/yt/core/concurrency/execution_stack.cpp
+++ b/yt/yt/core/concurrency/execution_stack.cpp
@@ -185,7 +185,7 @@ std::shared_ptr<TExecutionStack> CreateExecutionStack(EExecutionStackKind kind)
}
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static std::atomic<int> SmallFiberStackPoolSize = {1024};
static std::atomic<int> LargeFiberStackPoolSize = {1024};
diff --git a/yt/yt/core/logging/log_manager.cpp b/yt/yt/core/logging/log_manager.cpp
index 9f7952de55..3e558edeb2 100644
--- a/yt/yt/core/logging/log_manager.cpp
+++ b/yt/yt/core/logging/log_manager.cpp
@@ -358,7 +358,7 @@ using TThreadLocalQueue = TSpscQueue<TLoggerQueueItem>;
static constexpr uintptr_t ThreadQueueDestroyedSentinel = -1;
YT_DEFINE_THREAD_LOCAL(TThreadLocalQueue*, PerThreadQueue);
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TLocalQueueReclaimer
{
@@ -367,7 +367,7 @@ struct TLocalQueueReclaimer
YT_DEFINE_THREAD_LOCAL(TLocalQueueReclaimer, LocalQueueReclaimer);
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TLogManager::TImpl
: public ISensorProducer
diff --git a/yt/yt/core/misc/concurrent_cache-inl.h b/yt/yt/core/misc/concurrent_cache-inl.h
index 8af78fb940..614b5ef329 100644
--- a/yt/yt/core/misc/concurrent_cache-inl.h
+++ b/yt/yt/core/misc/concurrent_cache-inl.h
@@ -214,6 +214,6 @@ bool TConcurrentCache<T>::IsHead(const TIntrusivePtr<TLookupTable>& head) const
return Head_ == head.Get();
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/yt/core/misc/consistent_hashing_ring-inl.h b/yt/yt/core/misc/consistent_hashing_ring-inl.h
index 53044eb47b..5ff4ff1f66 100644
--- a/yt/yt/core/misc/consistent_hashing_ring-inl.h
+++ b/yt/yt/core/misc/consistent_hashing_ring-inl.h
@@ -8,7 +8,7 @@
namespace NYT {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
namespace NPrivate {
diff --git a/yt/yt/core/misc/hazard_ptr.cpp b/yt/yt/core/misc/hazard_ptr.cpp
index ea61b0e02e..ce78cbccf2 100644
--- a/yt/yt/core/misc/hazard_ptr.cpp
+++ b/yt/yt/core/misc/hazard_ptr.cpp
@@ -23,15 +23,15 @@ namespace NYT {
using namespace NConcurrency;
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static constexpr auto& Logger = LockFreeLogger;
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
namespace NDetail {
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
YT_DEFINE_THREAD_LOCAL(THazardPointerSet, HazardPointers);
@@ -165,14 +165,14 @@ private:
DECLARE_LEAKY_SINGLETON_FRIEND()
};
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
static void* HazardPointerManagerInitializer = [] {
THazardPointerManager::Get();
return nullptr;
}();
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
THazardPointerManager::THazardPointerManager()
{
@@ -413,14 +413,14 @@ void THazardPointerManager::AfterForkChild()
ThreadRegistryLock_.ReleaseWriter();
}
-//////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void InitHazardThreadState()
{
THazardPointerManager::Get()->InitThreadState();
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NDetail
@@ -434,14 +434,14 @@ void ReclaimHazardPointers(bool flush)
NYT::NDetail::THazardPointerManager::Get()->ReclaimHazardPointers(flush);
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
THazardPtrReclaimGuard::~THazardPtrReclaimGuard()
{
ReclaimHazardPointers();
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
THazardPtrReclaimOnContextSwitchGuard::THazardPtrReclaimOnContextSwitchGuard()
: NConcurrency::TContextSwitchGuard(
@@ -449,6 +449,6 @@ THazardPtrReclaimOnContextSwitchGuard::THazardPtrReclaimOnContextSwitchGuard()
nullptr)
{ }
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/yt/core/misc/lock_free_hash_table-inl.h b/yt/yt/core/misc/lock_free_hash_table-inl.h
index 09d04035fd..f81d925067 100644
--- a/yt/yt/core/misc/lock_free_hash_table-inl.h
+++ b/yt/yt/core/misc/lock_free_hash_table-inl.h
@@ -210,6 +210,6 @@ typename TLockFreeHashTable<T>::TStamp
return (fingerprint << 1) | 1ULL;
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/yt/core/misc/memory_usage_tracker.h b/yt/yt/core/misc/memory_usage_tracker.h
index 4b3887fa17..c5574ffd4e 100644
--- a/yt/yt/core/misc/memory_usage_tracker.h
+++ b/yt/yt/core/misc/memory_usage_tracker.h
@@ -41,7 +41,7 @@ struct IMemoryUsageTracker
DEFINE_REFCOUNTED_TYPE(IMemoryUsageTracker)
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct IReservingMemoryUsageTracker
: public IMemoryUsageTracker
diff --git a/yt/yt/core/misc/mpsc_queue.h b/yt/yt/core/misc/mpsc_queue.h
index a067495516..52962e1684 100644
--- a/yt/yt/core/misc/mpsc_queue.h
+++ b/yt/yt/core/misc/mpsc_queue.h
@@ -50,7 +50,7 @@ private:
void DeleteNodeList(TNode* node);
};
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/yt/core/misc/mpsc_stack.h b/yt/yt/core/misc/mpsc_stack.h
index e41b711e1d..f19d229910 100644
--- a/yt/yt/core/misc/mpsc_stack.h
+++ b/yt/yt/core/misc/mpsc_stack.h
@@ -43,7 +43,7 @@ private:
bool DoDequeueAll(bool reverse, F&& functor);
};
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/yt/core/misc/relaxed_mpsc_queue-inl.h b/yt/yt/core/misc/relaxed_mpsc_queue-inl.h
index 9fdf42e4df..1184c23e30 100644
--- a/yt/yt/core/misc/relaxed_mpsc_queue-inl.h
+++ b/yt/yt/core/misc/relaxed_mpsc_queue-inl.h
@@ -48,7 +48,7 @@ T* TRelaxedIntrusiveMpscQueue<T, Hook>::NodeFromHook(TRelaxedMpscQueueHook* hook
return static_cast<T*>(static_cast<void*>(static_cast<char*>(static_cast<void*>(hook)) - offset));
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
template <class T>
TRelaxedMpscQueue<T>::TNode::TNode(T&& value)
@@ -72,6 +72,6 @@ bool TRelaxedMpscQueue<T>::TryDequeue(T* value)
return true;
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NConcurrency
diff --git a/yt/yt/core/misc/slab_allocator.cpp b/yt/yt/core/misc/slab_allocator.cpp
index bba4c9afc7..cf4cb1d34e 100644
--- a/yt/yt/core/misc/slab_allocator.cpp
+++ b/yt/yt/core/misc/slab_allocator.cpp
@@ -10,7 +10,7 @@
namespace NYT {
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
namespace {
@@ -63,7 +63,7 @@ constexpr size_t SizeToSmallRank(size_t size)
} // namespace
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TArenaCounters
{
@@ -82,7 +82,7 @@ struct TArenaCounters
NProfiling::TGauge ArenaSize;
};
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TSmallArena final
: public TRefTracked<TSmallArena>
@@ -260,7 +260,7 @@ private:
DEFINE_REFCOUNTED_TYPE(TSmallArena);
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TLargeArena
: public TRefTracked<TLargeArena>
@@ -375,7 +375,7 @@ private:
std::atomic<size_t> AcquiredMemory_ = 0;
};
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
namespace {
@@ -416,7 +416,7 @@ uintptr_t* GetHeaderFromPtr(void* ptr)
} // namespace
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TSlabAllocator::TSlabAllocator(
const NProfiling::TProfiler& profiler,
@@ -518,7 +518,7 @@ void TSlabAllocator::Free(void* ptr)
}
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/yt/core/misc/slab_allocator.h b/yt/yt/core/misc/slab_allocator.h
index 878964c300..1550742b4b 100644
--- a/yt/yt/core/misc/slab_allocator.h
+++ b/yt/yt/core/misc/slab_allocator.h
@@ -12,12 +12,12 @@
namespace NYT {
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
DECLARE_REFCOUNTED_CLASS(TSmallArena);
class TLargeArena;
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TSlabAllocator
{
@@ -50,7 +50,7 @@ private:
std::unique_ptr<TLargeArena, TLargeArenaDeleter> LargeArena_;
};
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/yt/core/misc/spsc_queue-inl.h b/yt/yt/core/misc/spsc_queue-inl.h
index a567981c29..d4e359b31c 100644
--- a/yt/yt/core/misc/spsc_queue-inl.h
+++ b/yt/yt/core/misc/spsc_queue-inl.h
@@ -90,6 +90,6 @@ bool TSpscQueue<T>::IsEmpty() const
return Offset_ == count;
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
diff --git a/yt/yt/core/rpc/request_queue_provider.cpp b/yt/yt/core/rpc/request_queue_provider.cpp
index 07290519f0..4e621d8e30 100644
--- a/yt/yt/core/rpc/request_queue_provider.cpp
+++ b/yt/yt/core/rpc/request_queue_provider.cpp
@@ -4,7 +4,7 @@
namespace NYT::NRpc {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
void TRequestQueueProviderBase::ConfigureQueue(
TRequestQueue* queue,
diff --git a/yt/yt/core/rpc/request_queue_provider.h b/yt/yt/core/rpc/request_queue_provider.h
index 9f2b8baaf7..539ffcc258 100644
--- a/yt/yt/core/rpc/request_queue_provider.h
+++ b/yt/yt/core/rpc/request_queue_provider.h
@@ -4,7 +4,7 @@
namespace NYT::NRpc {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct IRequestQueueProvider
: public TRefCounted
diff --git a/yt/yt/core/rpc/stream.h b/yt/yt/core/rpc/stream.h
index 8678887c6f..93e54155a8 100644
--- a/yt/yt/core/rpc/stream.h
+++ b/yt/yt/core/rpc/stream.h
@@ -290,7 +290,7 @@ void HandleOutputStreamingRequest(
const NConcurrency::IAsyncZeroCopyOutputStreamPtr& output,
bool feedbackEnabled = false);
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NRpc
diff --git a/yt/yt/core/yson/string_filter.cpp b/yt/yt/core/yson/string_filter.cpp
index bbd3a0902e..dd4e2561ce 100644
--- a/yt/yt/core/yson/string_filter.cpp
+++ b/yt/yt/core/yson/string_filter.cpp
@@ -13,7 +13,7 @@ namespace NYT::NYson {
using namespace NYPath;
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
//! A class that is able to produce YSON strings from a "sparse" sequence of
//! YSON fragments equipped with YPath stacks defining their location in the YSON.
@@ -167,7 +167,7 @@ private:
}
};
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
//! A class that uses a sparse YSON builder to construct a YSON consisting of
//! fragments matching the given YPaths.
@@ -329,7 +329,7 @@ private:
}
};
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
//! Returns either an empty map, empty list or an original scalar value depending
//! on YSON value type. Topmost attributes are discarded.
@@ -369,7 +369,7 @@ TYsonString FilterYsonStringFallback(TYsonStringBuf yson)
}
}
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TYsonString FilterYsonString(
const std::vector<TYPath>& paths,
@@ -385,6 +385,6 @@ TYsonString FilterYsonString(
}
}
-////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace NYT::NYson
diff --git a/yt/yt/core/yson/unittests/depth_limiting_yson_consumer_ut.cpp b/yt/yt/core/yson/unittests/depth_limiting_yson_consumer_ut.cpp
index dcf58ba547..d3409c141a 100644
--- a/yt/yt/core/yson/unittests/depth_limiting_yson_consumer_ut.cpp
+++ b/yt/yt/core/yson/unittests/depth_limiting_yson_consumer_ut.cpp
@@ -352,7 +352,7 @@ TEST_F(TDepthLimitingYsonConsumerTest, MapFragment)
.EndList();
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace
} // namespace NYT::NYson
diff --git a/yt/yt/core/yson/unittests/ypath_designated_yson_consumer_ut.cpp b/yt/yt/core/yson/unittests/ypath_designated_yson_consumer_ut.cpp
index c2a291356f..8dbb3c08e8 100644
--- a/yt/yt/core/yson/unittests/ypath_designated_yson_consumer_ut.cpp
+++ b/yt/yt/core/yson/unittests/ypath_designated_yson_consumer_ut.cpp
@@ -236,7 +236,7 @@ TEST_F(TYPathDesignatedYsonConsumerTest, MissingSubtreeError)
}
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace
} // namespace NYT::NYson
diff --git a/yt/yt/core/yson/ypath_filtering_consumer.h b/yt/yt/core/yson/ypath_filtering_consumer.h
index 3e76dfd830..0833484eab 100644
--- a/yt/yt/core/yson/ypath_filtering_consumer.h
+++ b/yt/yt/core/yson/ypath_filtering_consumer.h
@@ -6,7 +6,7 @@
namespace NYT::NYson {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
DEFINE_ENUM(EYPathFilteringMode,
(Blacklist)
diff --git a/yt/yt/core/ytree/interned_attributes-inl.h b/yt/yt/core/ytree/interned_attributes-inl.h
index 7abb8eb665..262dc3cfef 100644
--- a/yt/yt/core/ytree/interned_attributes-inl.h
+++ b/yt/yt/core/ytree/interned_attributes-inl.h
@@ -6,7 +6,7 @@
namespace NYT::NYTree {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
constexpr TInternedAttributeKey::operator size_t() const
{
diff --git a/yt/yt/core/ytree/interned_attributes.cpp b/yt/yt/core/ytree/interned_attributes.cpp
index 1b3f39c5b2..392acf4d1a 100644
--- a/yt/yt/core/ytree/interned_attributes.cpp
+++ b/yt/yt/core/ytree/interned_attributes.cpp
@@ -5,7 +5,7 @@
namespace NYT::NYTree {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
namespace {
diff --git a/yt/yt/core/ytree/interned_attributes.h b/yt/yt/core/ytree/interned_attributes.h
index 351dd3b48c..b005ed5f54 100644
--- a/yt/yt/core/ytree/interned_attributes.h
+++ b/yt/yt/core/ytree/interned_attributes.h
@@ -6,7 +6,7 @@
namespace NYT::NYTree {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TInternedAttributeKey
{
diff --git a/yt/yt/core/ytree/unittests/lazy_ypath_service_ut.cpp b/yt/yt/core/ytree/unittests/lazy_ypath_service_ut.cpp
index 77a425bc3c..f52851b1b0 100644
--- a/yt/yt/core/ytree/unittests/lazy_ypath_service_ut.cpp
+++ b/yt/yt/core/ytree/unittests/lazy_ypath_service_ut.cpp
@@ -324,7 +324,7 @@ TEST(TLazyYPathServiceTest, RootAttributes)
EXPECT_EQ((std::vector<TString>{"attr1", "attr2"}), YPathList(service, "/@"));
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
} // namespace
} // namespace NYT::NYTree
diff --git a/yt/yt/core/ytree/ypath_client.h b/yt/yt/core/ytree/ypath_client.h
index e1b92a7689..0e163bb696 100644
--- a/yt/yt/core/ytree/ypath_client.h
+++ b/yt/yt/core/ytree/ypath_client.h
@@ -342,7 +342,7 @@ bool AreNodesEqual(
const INodePtr& rhs,
const TNodesEqualityOptions& options = {});
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
struct TNodeWalkOptions
{
diff --git a/yt/yt/core/ytree/yson_struct_detail.h b/yt/yt/core/ytree/yson_struct_detail.h
index 91700f89e7..d6061bc112 100644
--- a/yt/yt/core/ytree/yson_struct_detail.h
+++ b/yt/yt/core/ytree/yson_struct_detail.h
@@ -131,7 +131,7 @@ struct IYsonStructMeta
virtual ~IYsonStructMeta() = default;
};
-///////////////////////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TYsonStructMeta
: public IYsonStructMeta
diff --git a/yt/yt/core/ytree/yson_struct_public.h b/yt/yt/core/ytree/yson_struct_public.h
index 40d3db7319..c48cadceea 100644
--- a/yt/yt/core/ytree/yson_struct_public.h
+++ b/yt/yt/core/ytree/yson_struct_public.h
@@ -6,7 +6,7 @@
namespace NYT::NYTree {
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
DEFINE_ENUM(EUnrecognizedStrategy,
(Drop)
diff --git a/yt/yt/library/formats/arrow_writer.cpp b/yt/yt/library/formats/arrow_writer.cpp
index e540c15533..9c21cd9477 100644
--- a/yt/yt/library/formats/arrow_writer.cpp
+++ b/yt/yt/library/formats/arrow_writer.cpp
@@ -921,7 +921,7 @@ auto SerializeRecordBatch(
YT_VERIFY(current == dstRef.End());
});
}
-///////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
class TArrowWriter
: public TSchemalessFormatWriterBase
diff --git a/yt/yt/library/numeric/unittests/piecewise_linear_function_ut.cpp b/yt/yt/library/numeric/unittests/piecewise_linear_function_ut.cpp
index 3d4b832db2..7fde320ec0 100644
--- a/yt/yt/library/numeric/unittests/piecewise_linear_function_ut.cpp
+++ b/yt/yt/library/numeric/unittests/piecewise_linear_function_ut.cpp
@@ -751,7 +751,7 @@ TEST_F(TPiecewiseLinearFunctionTest, TestPointwiseMin)
}
}
-/////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////////
TEST_F(TPiecewiseLinearFunctionTest, TestCompose)
{