1 write to StreamPool
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
Internal\QuicConnectionContext.cs (1)
45StreamPool = new PooledStreamStack<QuicStreamContext>(InitialStreamPoolSize);
28 references to StreamPool
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (4)
Internal\QuicConnectionContext.cs (4)
107StreamPool.TryPop(out context); 269if (stream.CanReuse && StreamPool.Count < MaxStreamPoolSize) 272StreamPool.Push(stream); 295StreamPool.RemoveExpired(now);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (24)
QuicConnectionContextTests.cs (19)
326Assert.Equal(0, quicConnectionContext.StreamPool.Count); 349Assert.Equal(0, quicConnectionContext.StreamPool.Count); 369Assert.Equal(0, quicConnectionContext.StreamPool.Count); 394Assert.Equal(0, quicConnectionContext.StreamPool.Count); 414Assert.Equal(0, quicConnectionContext.StreamPool.Count); 441Assert.Equal(0, quicConnectionContext.StreamPool.Count); 463Assert.Equal(0, quicConnectionContext.StreamPool.Count); 498Assert.Equal(0, quicConnectionContext.StreamPool.Count); 521Assert.Equal(0, quicConnectionContext.StreamPool.Count); 525Assert.Equal(1, quicConnectionContext.StreamPool.Count); 526QuicStreamContext pooledStream = quicConnectionContext.StreamPool._array[0]; 533Assert.Equal(1, quicConnectionContext.StreamPool.Count); 537Assert.Equal(1, quicConnectionContext.StreamPool.Count); 538pooledStream = quicConnectionContext.StreamPool._array[0]; 547Assert.Equal(1, quicConnectionContext.StreamPool.Count); 552Assert.Equal(0, quicConnectionContext.StreamPool.Count); 575Assert.Equal(0, quicConnectionContext.StreamPool.Count); 598Assert.Equal(100, quicConnectionContext.StreamPool.Count); 735Assert.Equal(1, quicConnectionContext.StreamPool.Count);
QuicStreamContextTests.cs (5)
49Assert.Equal(1, quicConnectionContext.StreamPool.Count); 97Assert.Equal(0, quicConnectionContext.StreamPool.Count); 156Assert.Equal(0, quicConnectionContext.StreamPool.Count); 224Assert.Equal(1, quicConnectionContext.StreamPool.Count); 247Assert.Equal(1, quicConnectionContext.StreamPool.Count);