File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
ydb/public/sdk/cpp/client/ydb_persqueue_core/impl Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -790,16 +790,16 @@ class TReadSessionEventsQueue: public TBaseSessionEventsQueue<TAReadSessionSetti
790790
791791 bool Close (const TASessionClosedEvent<UseMigrationProtocol>& event, TDeferredActions<UseMigrationProtocol>& deferred) {
792792 TWaiter waiter;
793- TVector<TRawPartitionStreamEventQueue<UseMigrationProtocol>> defferedDelete ;
793+ TVector<TRawPartitionStreamEventQueue<UseMigrationProtocol>> deferredDelete ;
794794 with_lock (TParent::Mutex) {
795795 if (TParent::Closed) {
796796 return false ;
797797 }
798- defferedDelete .reserve (TParent::Events.size ());
798+ deferredDelete .reserve (TParent::Events.size ());
799799 while (!TParent::Events.empty ()) {
800800 auto & event = TParent::Events.front ();
801801 if (!event.IsEmpty ()) {
802- defferedDelete .push_back (event.PartitionStream ->ExtractQueue ());
802+ deferredDelete .push_back (event.PartitionStream ->ExtractQueue ());
803803 }
804804 TParent::Events.pop ();
805805 }
@@ -809,7 +809,7 @@ class TReadSessionEventsQueue: public TBaseSessionEventsQueue<TAReadSessionSetti
809809 }
810810
811811 // Delayed deletion is necessary to avoid deadlock with PushEvent
812- defferedDelete .clear ();
812+ deferredDelete .clear ();
813813
814814 TReadSessionEventInfo<UseMigrationProtocol> info (event);
815815 ApplyHandler (info, deferred);
You can’t perform that action at this time.
0 commit comments