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); 431Assert.Equal(1, _connection.StreamPool.Count); 447Assert.Equal(0, _connection.StreamPool.Count); 488Assert.Equal(2, _connection.StreamPool.Count); 515Assert.Equal(0, _connection.StreamPool.Count); 535Assert.Equal(1, _connection.StreamPool.Count); 536Assert.True(_connection.StreamPool.TryPeek(out var pooledStream)); 554Assert.Equal(0, _connection.StreamPool.Count); 564Assert.Equal(1, _connection.StreamPool.Count); 565Assert.True(_connection.StreamPool.TryPeek(out pooledStream)); 613Assert.Equal(0, _connection.StreamPool.Count); 645Assert.Equal(0, _connection.StreamPool.Count); 675Assert.Equal(0, _connection.StreamPool.Count); 689Assert.Equal(0, _connection.StreamPool.Count); 704Assert.Equal(1, _connection.StreamPool.Count); 706_connection.StreamPool.TryPeek(out var pooledStream); 711Assert.Equal(1, _connection.StreamPool.Count); 716Assert.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)) 1464if (stream.CanReuse && StreamPool.Count < MaxStreamPoolSize) 1471StreamPool.Push(stream);