diff options
| author | pavook <[email protected]> | 2024-08-22 16:26:27 +0300 |
|---|---|---|
| committer | pavook <[email protected]> | 2024-08-22 16:39:20 +0300 |
| commit | 8520e043f2e12acdfd39d971ebeeacbe9e5ac3ca (patch) | |
| tree | 55e2c5a3efebd951a92445ed5c7327c86479f655 /yt/cpp | |
| parent | f9fbb65f64b68c5de5cf257c04e06ac6aeaeb1e8 (diff) | |
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
Diffstat (limited to 'yt/cpp')
29 files changed, 88 insertions, 88 deletions
diff --git a/yt/cpp/mapreduce/client/batch_request_impl.cpp b/yt/cpp/mapreduce/client/batch_request_impl.cpp index 6afa5665f12..08ffec2bfcd 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 f4df2e2dd72..0d5e8922148 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 052bbfb860b..b3a6ec0f7c2 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 3bae208279b..f50c1b97326 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 18f74b59584..0e34610ef1a 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 82ef799ca1f..474813674ef 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 8bfa00de1dc..95595959ad4 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 6dc24c6ef2f..305d95b06cc 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 859f0423cb4..97321c4c9d3 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 2c692475d1c..a21cff53600 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 63a36c2f78a..307e310b5b9 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 2210e318f10..a6007d6eae3 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 3ea28f76fd5..8056f8a1edd 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 49a7c7cfc10..ef3d2db4a31 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 1d7f5375a22..becde0def2f 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 717982e216a..2d0284e2b1b 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 573cbe47844..24efddd7d0b 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 4ff8dde3cca..0ee952f510c 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 4582d9e872e..a41b48d5c66 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 76b67138a32..9e17ca7e905 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 81d03d06186..b28a33142a1 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 3642aa1e45c..449c966a3ba 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 5068dbb6bc1..5f4c71b6f44 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 d55a28b3e4e..fc20be017f9 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 55f270a6b66..cb987674495 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 4e609590590..1bd9532e4ca 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 6426ccecf4c..2f9610a1ca3 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 8392eaccdf3..a638ac581dc 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 dfe70bbcc55..a7ab35d91d6 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 |
