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)
195Assert.Equal(1, _connection.StreamPool.Count); 252Assert.Equal(1, _connection.StreamPool.Count); 253Assert.True(_connection.StreamPool.TryPeek(out var stream1)); 270Assert.Equal(1, _connection.StreamPool.Count); 271Assert.True(_connection.StreamPool.TryPeek(out var stream2)); 371Assert.Equal(1, _connection.StreamPool.Count); 416Assert.Equal(0, _connection.StreamPool.Count); 429Assert.Equal(1, _connection.StreamPool.Count); 445Assert.Equal(0, _connection.StreamPool.Count); 486Assert.Equal(2, _connection.StreamPool.Count); 513Assert.Equal(0, _connection.StreamPool.Count); 531Assert.Equal(1, _connection.StreamPool.Count); 532Assert.True(_connection.StreamPool.TryPeek(out var pooledStream)); 550Assert.Equal(0, _connection.StreamPool.Count); 558Assert.Equal(1, _connection.StreamPool.Count); 559Assert.True(_connection.StreamPool.TryPeek(out pooledStream)); 607Assert.Equal(0, _connection.StreamPool.Count); 639Assert.Equal(0, _connection.StreamPool.Count); 669Assert.Equal(0, _connection.StreamPool.Count); 683Assert.Equal(0, _connection.StreamPool.Count); 696Assert.Equal(1, _connection.StreamPool.Count); 698_connection.StreamPool.TryPeek(out var pooledStream); 703Assert.Equal(1, _connection.StreamPool.Count); 708Assert.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)) 1460if (stream.CanReuse && StreamPool.Count < MaxStreamPoolSize) 1467StreamPool.Push(stream);