1 write to _readerQueue
System.ServiceModel.Primitives (1)
Internals\System\Runtime\InputQueue.cs (1)
29_readerQueue = new Queue<IQueueReader>();
25 references to _readerQueue
System.ServiceModel.Primitives (25)
Internals\System\Runtime\InputQueue.cs (25)
86_readerQueue.Enqueue(reader); 99_readerQueue.Enqueue(reader); 181_readerQueue.Enqueue(reader); 193_readerQueue.Enqueue(reader); 233_readerQueue.Enqueue(reader); 245_readerQueue.Enqueue(reader); 289if (_readerQueue.Count > 0) 292reader = _readerQueue.Dequeue(); 294if (_queueState == QueueState.Shutdown && _readerQueue.Count > 0 && _itemQueue.ItemCount == 0) 296outstandingReaders = new IQueueReader[_readerQueue.Count]; 297_readerQueue.CopyTo(outstandingReaders, 0); 298_readerQueue.Clear(); 428if (_readerQueue.Count > 0 && _itemQueue.ItemCount == 0) 430outstandingReaders = new IQueueReader[_readerQueue.Count]; 431_readerQueue.CopyTo(outstandingReaders, 0); 432_readerQueue.Clear(); 563while (_readerQueue.Count > 0) 565IQueueReader reader = _readerQueue.Dequeue(); 699if (_readerQueue.Count == 0) 705reader = _readerQueue.Dequeue(); 710if (_readerQueue.Count == 0) 770if (_readerQueue.Count == 0 && _waiterList.Count == 0) 813for (int i = _readerQueue.Count; i > 0; i--) 815IQueueReader temp = _readerQueue.Dequeue(); 822_readerQueue.Enqueue(temp);