aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/raw_client
diff options
context:
space:
mode:
authorpavook <pavook@yandex-team.com>2024-08-22 16:26:27 +0300
committerpavook <pavook@yandex-team.com>2024-08-22 16:39:20 +0300
commit8520e043f2e12acdfd39d971ebeeacbe9e5ac3ca (patch)
tree55e2c5a3efebd951a92445ed5c7327c86479f655 /yt/cpp/mapreduce/raw_client
parentf9fbb65f64b68c5de5cf257c04e06ac6aeaeb1e8 (diff)
downloadydb-8520e043f2e12acdfd39d971ebeeacbe9e5ac3ca.tar.gz
GLOBAL OTBIVKA FIX ୧༼ಠ益ಠ༽୨
Make all "otbivka" exactly 80 symbols. Command: ```bash sed -i 's#^//////////////\+$#////////////////////////////////////////////////////////////////////////////////#g' $(find yt \( -name '*.cpp' -or -name '*.h' -or -name '*.proto' \) -not -path 'yt/yt/experiments/private/tabletvis/imgui/*') ``` 30a0ba9f42ba1909d3cee11fe12bba14c7c8b039
Diffstat (limited to 'yt/cpp/mapreduce/raw_client')
-rw-r--r--yt/cpp/mapreduce/raw_client/raw_batch_request.cpp30
-rw-r--r--yt/cpp/mapreduce/raw_client/raw_requests.cpp2
-rw-r--r--yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp4
-rw-r--r--yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h4
4 files changed, 20 insertions, 20 deletions
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