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