diff options
author | pavook <pavook@yandex-team.com> | 2024-08-22 16:26:27 +0300 |
---|---|---|
committer | pavook <pavook@yandex-team.com> | 2024-08-22 16:39:20 +0300 |
commit | 8520e043f2e12acdfd39d971ebeeacbe9e5ac3ca (patch) | |
tree | 55e2c5a3efebd951a92445ed5c7327c86479f655 | |
parent | f9fbb65f64b68c5de5cf257c04e06ac6aeaeb1e8 (diff) | |
download | ydb-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
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) { |