File tree 1 file changed +4
-4
lines changed
ydb/public/sdk/cpp/client/ydb_persqueue_core/impl
1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -800,16 +800,16 @@ class TReadSessionEventsQueue: public TBaseSessionEventsQueue<TAReadSessionSetti
800
800
801
801
bool Close (const TASessionClosedEvent<UseMigrationProtocol>& event, TDeferredActions<UseMigrationProtocol>& deferred) {
802
802
TWaiter waiter;
803
- TVector<TRawPartitionStreamEventQueue<UseMigrationProtocol>> defferedDelete ;
803
+ TVector<TRawPartitionStreamEventQueue<UseMigrationProtocol>> deferredDelete ;
804
804
with_lock (TParent::Mutex) {
805
805
if (TParent::Closed) {
806
806
return false ;
807
807
}
808
- defferedDelete .reserve (TParent::Events.size ());
808
+ deferredDelete .reserve (TParent::Events.size ());
809
809
while (!TParent::Events.empty ()) {
810
810
auto & event = TParent::Events.front ();
811
811
if (!event.IsEmpty ()) {
812
- defferedDelete .push_back (event.PartitionStream ->ExtractQueue ());
812
+ deferredDelete .push_back (event.PartitionStream ->ExtractQueue ());
813
813
}
814
814
TParent::Events.pop ();
815
815
}
@@ -819,7 +819,7 @@ class TReadSessionEventsQueue: public TBaseSessionEventsQueue<TAReadSessionSetti
819
819
}
820
820
821
821
// Delayed deletion is necessary to avoid deadlock with PushEvent
822
- defferedDelete .clear ();
822
+ deferredDelete .clear ();
823
823
824
824
TReadSessionEventInfo<UseMigrationProtocol> info (event);
825
825
ApplyHandler (info, deferred);
You can’t perform that action at this time.
0 commit comments