1 instantiation of QueueItem
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\ConnectionPool\RequestQueue.cs (1)
124
Enqueue(new
QueueItem
{ Request = request, Waiter = waiter });
17 references to QueueItem
System.Net.Http (17)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http1.cs (2)
245
RequestQueue<HttpConnection>.
QueueItem
queueItem = _http11RequestQueue.PeekNextRequestForConnectionAttempt();
250
private async Task InjectNewHttp11ConnectionAsync(RequestQueue<HttpConnection>.
QueueItem
queueItem)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http2.cs (2)
167
RequestQueue<Http2Connection?>.
QueueItem
queueItem = _http2RequestQueue.PeekNextRequestForConnectionAttempt();
172
private async Task InjectNewHttp2ConnectionAsync(RequestQueue<Http2Connection?>.
QueueItem
queueItem)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http3.cs (2)
233
RequestQueue<Http3Connection?>.
QueueItem
queueItem = _http3RequestQueue.PeekNextRequestForConnectionAttempt();
241
private async Task InjectNewHttp3ConnectionAsync(RequestQueue<Http3Connection?>.
QueueItem
queueItem)
System\Net\Http\SocketsHttpHandler\ConnectionPool\RequestQueue.cs (11)
20
private
QueueItem
[] _array;
28
_array = Array.Empty<
QueueItem
>();
35
private void Enqueue(
QueueItem
queueItem)
48
private
QueueItem
Dequeue()
53
QueueItem
[] array = _array;
55
QueueItem
queueItem = array[head];
69
private bool TryPeek(out
QueueItem
queueItem)
93
var newArray = new
QueueItem
[Math.Max(4, _array.Length * 2)];
129
while (TryPeek(out
QueueItem
queueItem) && queueItem.Waiter.Task.IsCompleted)
158
if (TryPeek(out
QueueItem
queueItem) && queueItem.Waiter == waiter)
164
public
QueueItem
PeekNextRequestForConnectionAttempt()