File tree Expand file tree Collapse file tree 3 files changed +1
-16
lines changed
ydb/core/blobstorage/backpressure Expand file tree Collapse file tree 3 files changed +1
-16
lines changed Original file line number Diff line number Diff line change 17
17
#include <ydb/library/actors/core/actor_bootstrapped.h>
18
18
#include <ydb/library/actors/core/mailbox.h>
19
19
#include <ydb/library/actors/core/mon.h>
20
- #include <library/cpp/containers/intrusive_rb_tree/rb_tree.h>
21
20
#include <ydb/library/actors/wilson/wilson_span.h>
22
21
#include <google/protobuf/message.h>
Original file line number Diff line number Diff line change @@ -339,7 +339,6 @@ TBlobStorageQueue::TItemList::iterator TBlobStorageQueue::EraseItem(TItemList& q
339
339
TItemList::iterator nextIter = std::next (it);
340
340
if (Queues.Unused .size () < MaxUnusedItems) {
341
341
Queues.Unused .splice (Queues.Unused .end (), queue, it);
342
- it->TSenderNode ::UnLink ();
343
342
it->Event .Discard ();
344
343
} else {
345
344
queue.erase (it);
Original file line number Diff line number Diff line change @@ -31,16 +31,7 @@ class TBlobStorageQueue {
31
31
}
32
32
};
33
33
34
- template <typename TDerived>
35
- struct TSenderNode : public TRbTreeItem <TSenderNode<TDerived>, TCompare<TActorId>> {
36
- const TActorId& GetKey () const {
37
- return static_cast <const TDerived&>(*this ).Event .GetSender ();
38
- }
39
- };
40
-
41
- struct TItem
42
- : public TSenderNode<TItem>
43
- {
34
+ struct TItem {
44
35
EItemQueue Queue;
45
36
TCostModel::TMessageCostEssence CostEssence;
46
37
NWilson::TSpan Span;
@@ -103,10 +94,7 @@ class TBlobStorageQueue {
103
94
{}
104
95
};
105
96
106
- using TSenderMap = TRbTree<TSenderNode<TItem>, TCompare<TActorId>>;
107
-
108
97
TQueues Queues;
109
- TSenderMap SenderToItems;
110
98
THashMap<std::pair<ui64, ui64>, TItemList::iterator> InFlightLookup;
111
99
112
100
ui64 WindowSize;
@@ -233,7 +221,6 @@ class TBlobStorageQueue {
233
221
234
222
newIt->Iterator = newIt;
235
223
SetItemQueue (*newIt, EItemQueue::Waiting);
236
- SenderToItems.Insert (&*newIt);
237
224
238
225
// count item
239
226
++*QueueItemsPut;
You can’t perform that action at this time.
0 commit comments