TDeque to std::deque

client/ydb_coordination/coordination.cpp

@@ -309,7 +309,7 @@ class TSessionContext : public TThrRefBase {
         TIntrusivePtr<TSemaphoreOp> LastSentOp;
         TIntrusivePtr<TSemaphoreOp> LastAckedOp;
         THashMap<ui64, TIntrusivePtr<TSemaphoreOp>> WaitingOps;
-        TDeque<TIntrusivePtr<TSemaphoreOp>> OpQueue;
+        std::deque<TIntrusivePtr<TSemaphoreOp>> OpQueue;
         bool Restoring = false;
 
         bool IsEmpty() const {
@@ -874,9 +874,9 @@ class TSessionContext : public TThrRefBase {
         bool notifyExpired = false;
         TPromise<TSessionResult> sessionPromise;
         TResultPromise<void> reconnectPromise;
-        TDeque<TResultPromise<bool>> abortedSemaphoreOps;
-        TDeque<TResultPromise<bool>> failedSemaphoreOps;
-        TDeque<THolder<TSimpleOp>> failedSimpleOps;
+        std::deque<TResultPromise<bool>> abortedSemaphoreOps;
+        std::deque<TResultPromise<bool>> failedSemaphoreOps;
+        std::deque<THolder<TSimpleOp>> failedSimpleOps;
         TResultPromise<void> closePromise;
 
         {
@@ -1010,7 +1010,7 @@ class TSessionContext : public TThrRefBase {
             sessionPromise.SetValue(TSessionResult(status));
         }
 
-        if (abortedSemaphoreOps) {
+        if (!abortedSemaphoreOps.empty()) {
             auto aborted = MakeStatus(EStatus::ABORTED,
                 "Operation superseded by another request, true result has been lost");
             for (auto& promise : abortedSemaphoreOps) {
@@ -1765,7 +1765,7 @@ class TSessionContext : public TThrRefBase {
 
     THashMap<std::string, TSemaphoreState> Semaphores;
     THashMap<ui64, TSemaphoreState*> SemaphoreByReqId;
-    TDeque<THolder<TSimpleOp>> PendingRequests;
+    std::deque<THolder<TSimpleOp>> PendingRequests;
     THashMap<ui64, THolder<TSimpleOp>> SentRequests;
     TResultPromise<void> ReconnectPromise;
 

client/ydb_persqueue_core/ut/ut_utils/ut_utils.h

@@ -109,7 +109,7 @@ struct TYDBClientEventLoop : public ::NPersQueue::IClientEventLoop {
             std::optional<TContinuationToken> continueToken;
             NThreading::TFuture<void> waitEventFuture = writer->WaitEvent();
             THashMap<ui64, NThreading::TPromise<::NPersQueue::TWriteResult>> ackPromiseBySequenceNumber;
-            TDeque<NThreading::TPromise<::NPersQueue::TWriteResult>> ackPromiseQueue;
+            std::deque<NThreading::TPromise<::NPersQueue::TWriteResult>> ackPromiseQueue;
             while (!MustStop) {
                 if (!continueToken) {
                     Log << TLOG_INFO << "Wait for writer event";

library/cpp/blockcodecs/core/codecs.cpp

@@ -59,7 +59,7 @@ namespace {
             Registry[Tmp.back()] = Registry[to];
         }
 
-        TDeque<std::string> Tmp;
+        std::deque<std::string> Tmp;
         TNullCodec Null;
         std::vector<TCodecPtr> Codecs;
         typedef THashMap<std::string_view, ICodec*> TRegistry;

library/cpp/coroutine/engine/stack/stack_storage.h

@@ -30,8 +30,8 @@ namespace NCoro::NStack {
         void ReleaseMemory(char* alignedStackMemory, size_t pagesToKeep) noexcept;
 
     private:
-        TDeque<void*> Released_; //!< stacks memory with released RSS memory
-        TDeque<void*> Full_;     //!< stacks memory with RSS memory
+        std::deque<void*> Released_; //!< stacks memory with released RSS memory
+        std::deque<void*> Full_;     //!< stacks memory with RSS memory
         size_t StackSize_ = 0;
         size_t RssPagesToKeep_ = 0;
         const size_t ReleaseRate_ = 1;

library/cpp/dbg_output/dumpers.h

@@ -106,7 +106,7 @@ struct TDumper<std::array<T, N>>: public TSeqDumper {
 };
 
 template <class T, class A>
-struct TDumper<TDeque<T, A>>: public TSeqDumper {
+struct TDumper<std::deque<T, A>>: public TSeqDumper {
 };
 
 template <class T, class A>

library/cpp/dbg_output/engine.h

@@ -4,6 +4,7 @@
 
 #include <string>
 #include <utility>
+#include <deque>
 
 template <class T>
 struct TDumper {

library/cpp/http/io/compression.h

@@ -5,6 +5,7 @@
 #include <util/generic/deque.h>
 #include <util/generic/hash.h>
 
+
 class TCompressionCodecFactory {
 public:
     using TDecoderConstructor = std::function<THolder<IInputStream>(IInputStream*)>;
@@ -44,7 +45,7 @@ class TCompressionCodecFactory {
         TEncoderConstructor Encoder;
     };
 
-    TDeque<std::string> Strings_;
+    std::deque<std::string> Strings_;
     THashMap<std::string_view, TCodec> Codecs_;
     std::vector<std::string_view> BestCodecs_;
 };

library/cpp/http/io/headers.h

@@ -53,7 +53,7 @@ class THttpInputHeader {
 
 /// Контейнер для хранения HTTP-заголовков
 class THttpHeaders {
-    using THeaders = TDeque<THttpInputHeader>;
+    using THeaders = std::deque<THttpInputHeader>;
 
 public:
     using TConstIterator = THeaders::const_iterator;

library/cpp/json/writer/json_value.h

@@ -35,7 +35,7 @@ namespace NJson {
 
     public:
         typedef THashMap<std::string, TJsonValue> TMapType;
-        typedef TDeque<TJsonValue> TArray;
+        typedef std::deque<TJsonValue> TArray;
 
         TJsonValue() noexcept = default;
         TJsonValue(EJsonValueType type);

library/cpp/resource/registry.cpp

@@ -102,7 +102,7 @@ namespace {
             return D_.at(idx).first;
         }
 
-        typedef TDeque<TDescriptor> TDescriptors;
+        typedef std::deque<TDescriptor> TDescriptors;
         TDescriptors D_;
     };
 }

tools/enum_parser/enum_serialization_runtime/serialized_enum_ut.cpp

@@ -74,8 +74,8 @@ Y_UNIT_TEST_SUITE(TestSerializedEnum) {
         const std::vector<ETestEnum> typedValues = {ETestEnum::One, ETestEnum::Two, ETestEnum::Three, ETestEnum::Zero, ETestEnum::Zero, ETestEnum::Zero, ETestEnum::Eleven, ETestEnum::Zero, ETestEnum::Zero, ETestEnum::Zero, ETestEnum::Zero, ETestEnum::Zero, ETestEnum::Two};
         UNIT_ASSERT_EQUAL(typedValues, view.Materialize());
 
-        const TDeque<ETestEnum> typedValuesDeque{typedValues.begin(), typedValues.end()};
-        UNIT_ASSERT_EQUAL(typedValuesDeque, view.Materialize<TDeque>());
+        const std::deque<ETestEnum> typedValuesDeque{typedValues.begin(), typedValues.end()};
+        UNIT_ASSERT_EQUAL(typedValuesDeque, view.Materialize<std::deque>());
     }
 
     Y_UNIT_TEST(MappedDictView) {

util/generic/deque.h

@@ -8,7 +8,7 @@
 #include <memory>
 #include <initializer_list>
 
-template <class T, class A>
+/*template <class T, class A>
 class TDeque: public std::deque<T, TReboundAllocator<A, T>> {
     using TBase = std::deque<T, TReboundAllocator<A, T>>;
 
@@ -22,4 +22,4 @@ class TDeque: public std::deque<T, TReboundAllocator<A, T>> {
     inline explicit operator bool() const noexcept {
         return !this->empty();
     }
-};
+};*/

util/generic/deque_ut.cpp

@@ -27,7 +27,7 @@ class TDequeTest: public TTestBase {
 UNIT_TEST_SUITE_REGISTRATION(TDequeTest);
 
 void TDequeTest::TestConstructorsAndAssignments() {
-    using container = TDeque<int>;
+    using container = std::deque<int>;
 
     container c1;
     c1.push_back(100);
@@ -66,7 +66,7 @@ void TDequeTest::TestConstructorsAndAssignments() {
 }
 
 void TDequeTest::TestDeque1() {
-    TDeque<int> d;
+    std::deque<int> d;
     UNIT_ASSERT(!d);
 
     d.push_back(4);
@@ -89,8 +89,8 @@ void TDequeTest::TestDeque1() {
     UNIT_ASSERT(d[2] == 25);
 
     //Some compile time tests:
-    TDeque<int>::iterator dit = d.begin();
-    TDeque<int>::const_iterator cdit(d.begin());
+    std::deque<int>::iterator dit = d.begin();
+    std::deque<int>::const_iterator cdit(d.begin());
 
     UNIT_ASSERT((dit - cdit) == 0);
     UNIT_ASSERT((cdit - dit) == 0);
@@ -100,14 +100,14 @@ void TDequeTest::TestDeque1() {
 }
 
 void TDequeTest::TestInsert() {
-    TDeque<int> d;
+    std::deque<int> d;
     d.push_back(0);
     d.push_back(1);
     d.push_back(2);
 
     UNIT_ASSERT(d.size() == 3);
 
-    TDeque<int>::iterator dit;
+    std::deque<int>::iterator dit;
 
     //Insertion before begin:
     dit = d.insert(d.begin(), 3);
@@ -177,8 +177,8 @@ void TDequeTest::TestInsert() {
 }
 
 void TDequeTest::TestAt() {
-    TDeque<int> d;
-    TDeque<int> const& cd = d;
+    std::deque<int> d;
+    std::deque<int> const& cd = d;
 
     d.push_back(10);
     UNIT_ASSERT(d.at(0) == 10);
@@ -189,12 +189,12 @@ void TDequeTest::TestAt() {
 
 void TDequeTest::TestAutoRef() {
     int i;
-    TDeque<int> ref;
+    std::deque<int> ref;
     for (i = 0; i < 5; ++i) {
         ref.push_back(i);
     }
 
-    TDeque<TDeque<int>> d_d_int(1, ref);
+    std::deque<std::deque<int>> d_d_int(1, ref);
     d_d_int.push_back(d_d_int[0]);
     d_d_int.push_back(ref);
     d_d_int.push_back(d_d_int[0]);
@@ -207,7 +207,7 @@ void TDequeTest::TestAutoRef() {
 }
 
 void TDequeTest::TestErase() {
-    TDeque<int> dint;
+    std::deque<int> dint;
     dint.push_back(3);
     dint.push_front(2);
     dint.push_back(4);
@@ -216,7 +216,7 @@ void TDequeTest::TestErase() {
     dint.push_front(0);
     dint.push_back(6);
 
-    TDeque<int>::iterator it(dint.begin() + 1);
+    std::deque<int>::iterator it(dint.begin() + 1);
     UNIT_ASSERT(*it == 1);
 
     dint.erase(dint.begin());

util/generic/fwd.h

@@ -4,6 +4,7 @@
 
 #include <iosfwd>
 #include <vector>
+#include <deque>
 
 //misc
 class TBuffer;
@@ -36,8 +37,8 @@ template <class TValue, class TCmp>
 class TRbTree;
 
 //containers
-template <class T, class A = std::allocator<T>>
-class TDeque;
+//template <class T, class A = std::allocator<T>>
+//class TDeque;
 
 template <class Key, class T, class HashFcn = THash<Key>, class EqualKey = TEqualTo<Key>, class Alloc = std::allocator<Key>>
 class THashMap;
@@ -57,7 +58,7 @@ class TSet;
 template <class K, class L = TLess<K>, class A = std::allocator<K>>
 class TMultiSet;
 
-template <class T, class S = TDeque<T>>
+template <class T, class S = std::deque<T>>
 class TStack;
 
 template <size_t BitCount, typename TChunkType = ui64>

util/system/atexit.cpp

@@ -72,7 +72,7 @@ namespace {
     private:
         TAdaptiveLock Lock_;
         std::atomic<bool> FinishStarted_;
-        TDeque<TFunc> Store_;
+        std::deque<TFunc> Store_;
         std::priority_queue<TFunc*, std::vector<TFunc*>, TCmp> Items_;
     };
 

util/system/context_ut.cpp

@@ -22,7 +22,7 @@ Y_UNIT_TEST_SUITE(TestContext) {
             char Buf[1000000];
         };
 
-        static TDeque<TW> w;
+        static std::deque<TW> w;
 
         auto& tw = w.emplace_back(&f);
 

util/ysaveload.h

@@ -373,10 +373,6 @@ template <class TChar>
 class TSerializer<std::basic_string<TChar>>: public TVectorSerializer<std::basic_string<TChar>> {
 };
 
-template <class T, class A>
-class TSerializer<TDeque<T, A>>: public TVectorSerializer<TDeque<T, A>> {
-};
-
 template <class T, class A>
 class TSerializer<std::deque<T, A>>: public TVectorSerializer<std::deque<T, A>> {
 };

ydb/library/yql/public/issue/yql_issue_message.cpp

@@ -17,7 +17,7 @@ using namespace NIssue::NProto;
 template<typename TIssueMessage>
 TIssue IssueFromMessage(const TIssueMessage& issueMessage) {
     TIssue topIssue;
-    TDeque<std::pair<TIssue*, const TIssueMessage*>> queue;
+    std::deque<std::pair<TIssue*, const TIssueMessage*>> queue;
     queue.push_front(std::make_pair(&topIssue, &issueMessage));
     while (!queue.empty()) {
         TIssue& issue = *queue.back().first;
@@ -58,7 +58,7 @@ void IssuesFromMessage(const ::google::protobuf::RepeatedPtrField<TIssueMessage>
 
 template<typename TIssueMessage>
 void IssueToMessage(const TIssue& topIssue, TIssueMessage* issueMessage) {
-    TDeque<std::pair<const TIssue*, TIssueMessage*>> queue;
+    std::deque<std::pair<const TIssue*, TIssueMessage*>> queue;
     queue.push_front(std::make_pair(&topIssue, issueMessage));
     while (!queue.empty()) {
         const TIssue& issue = *queue.back().first;