File tree Expand file tree Collapse file tree 1 file changed +7
-2
lines changed
Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change @@ -234,10 +234,12 @@ public void StartQueuedSessions()
234234 private void QueueProcessImpl ( )
235235 {
236236 List < SessionHolder > waiting ;
237+ bool useTaskSet = true ;
237238
238239 if ( _sessionGroup != null )
239240 {
240241 waiting = _sessionGroup . WaitingSessions ;
242+ useTaskSet = false ;
241243 }
242244 else
243245 {
@@ -246,7 +248,7 @@ private void QueueProcessImpl()
246248
247249 foreach ( var sessionHolder in waiting )
248250 {
249- if ( _taskSet . Add ( sessionHolder . Id ) )
251+ if ( ! useTaskSet || _taskSet . Add ( sessionHolder . Id ) )
250252 {
251253 _taskQueue . Enqueue ( sessionHolder ) ;
252254 }
@@ -313,7 +315,10 @@ private void StartManagedSession(SessionHolder sessionHolder)
313315 Remove ( sessionHolder . Id ) ;
314316 }
315317
316- StartQueuedSessions ( ) ;
318+ if ( _sessionGroup == null )
319+ {
320+ StartQueuedSessions ( ) ;
321+ }
317322 } ) ;
318323 }
319324 }
You can’t perform that action at this time.
0 commit comments