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 @@ -790,16 +790,16 @@ class TReadSessionEventsQueue: public TBaseSessionEventsQueue<TAReadSessionSetti
790
790
791
791
bool Close (const TASessionClosedEvent<UseMigrationProtocol>& event, TDeferredActions<UseMigrationProtocol>& deferred) {
792
792
TWaiter waiter;
793
- TVector<TRawPartitionStreamEventQueue<UseMigrationProtocol>> defferedDelete ;
793
+ TVector<TRawPartitionStreamEventQueue<UseMigrationProtocol>> deferredDelete ;
794
794
with_lock (TParent::Mutex) {
795
795
if (TParent::Closed) {
796
796
return false ;
797
797
}
798
- defferedDelete .reserve (TParent::Events.size ());
798
+ deferredDelete .reserve (TParent::Events.size ());
799
799
while (!TParent::Events.empty ()) {
800
800
auto & event = TParent::Events.front ();
801
801
if (!event.IsEmpty ()) {
802
- defferedDelete .push_back (event.PartitionStream ->ExtractQueue ());
802
+ deferredDelete .push_back (event.PartitionStream ->ExtractQueue ());
803
803
}
804
804
TParent::Events.pop ();
805
805
}
@@ -809,7 +809,7 @@ class TReadSessionEventsQueue: public TBaseSessionEventsQueue<TAReadSessionSetti
809
809
}
810
810
811
811
// Delayed deletion is necessary to avoid deadlock with PushEvent
812
- defferedDelete .clear ();
812
+ deferredDelete .clear ();
813
813
814
814
TReadSessionEventInfo<UseMigrationProtocol> info (event);
815
815
ApplyHandler (info, deferred);
You can’t perform that action at this time.
0 commit comments