1 write to StreamPool
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http2\Http2Connection.cs (1)
189StreamPool = new PooledStreamStack<Http2Stream>(Math.Min(InitialStreamPoolSize, http2Limits.MaxStreamsPerConnection));
33 references to StreamPool
InMemory.FunctionalTests (28)
Http2\Http2ConnectionTests.cs (24)
196Assert.Equal(1, _connection.StreamPool.Count); 253Assert.Equal(1, _connection.StreamPool.Count); 254Assert.True(_connection.StreamPool.TryPeek(out var stream1)); 271Assert.Equal(1, _connection.StreamPool.Count); 272Assert.True(_connection.StreamPool.TryPeek(out var stream2)); 372Assert.Equal(1, _connection.StreamPool.Count); 417Assert.Equal(0, _connection.StreamPool.Count); 432Assert.Equal(1, _connection.StreamPool.Count); 448Assert.Equal(0, _connection.StreamPool.Count); 489Assert.Equal(2, _connection.StreamPool.Count); 516Assert.Equal(0, _connection.StreamPool.Count); 536Assert.Equal(1, _connection.StreamPool.Count); 537Assert.True(_connection.StreamPool.TryPeek(out var pooledStream)); 555Assert.Equal(0, _connection.StreamPool.Count); 565Assert.Equal(1, _connection.StreamPool.Count); 566Assert.True(_connection.StreamPool.TryPeek(out pooledStream)); 614Assert.Equal(0, _connection.StreamPool.Count); 646Assert.Equal(0, _connection.StreamPool.Count); 676Assert.Equal(0, _connection.StreamPool.Count); 690Assert.Equal(0, _connection.StreamPool.Count); 705Assert.Equal(1, _connection.StreamPool.Count); 707_connection.StreamPool.TryPeek(out var pooledStream); 712Assert.Equal(1, _connection.StreamPool.Count); 717Assert.Equal(0, _connection.StreamPool.Count);
Http2\Http2WebSocketTests.cs (4)
249Assert.Equal(1, _connection.StreamPool.Count); 250Assert.True(_connection.StreamPool.TryPeek(out var pooledStream)); 686Assert.Equal(1, _connection.StreamPool.Count); 687Assert.True(_connection.StreamPool.TryPeek(out var pooledStream));
Microsoft.AspNetCore.Server.Kestrel.Core (5)
Internal\Http2\Http2Connection.cs (5)
329StreamPool.RemoveExpired(TimeProvider.GetTimestamp()); 474while (StreamPool.TryPop(out var pooledStream)) 878if (StreamPool.TryPop(out var stream)) 1473if (stream.CanReuse && StreamPool.Count < MaxStreamPoolSize) 1480StreamPool.Push(stream);