BufferSegment

System\IO\Pipelines\Pipe.cs (1)

System\IO\Pipelines\StreamPipeReader.cs (1)

System\IO\Pipelines\StreamPipeWriter.cs (1)

System\IO\Pipelines\BufferSegment.cs (6)

14private BufferSegment? _next; 40public BufferSegment? NextSegment 107public void SetNext(BufferSegment segment) 125internal static long GetLength(BufferSegment startSegment, int startIndex, BufferSegment endSegment, int endIndex) 131internal static long GetLength(long startPosition, BufferSegment endSegment, int endIndex)

System\IO\Pipelines\BufferSegmentStack.cs (7)

25public bool TryPop([NotNullWhen(true)] out BufferSegment? result) 43public void Push(BufferSegment item) 61private void PushWithResize(BufferSegment item) 82private readonly BufferSegment _value; 83private SegmentAsValueType(BufferSegment value) => _value = value; 84public static implicit operator SegmentAsValueType(BufferSegment s) => new SegmentAsValueType(s); 85public static implicit operator BufferSegment(SegmentAsValueType s) => s._value;

System\IO\Pipelines\Pipe.cs (25)

66private BufferSegment? _readHead; 72private BufferSegment? _readTail; 77private BufferSegment? _writingHead; 181BufferSegment newSegment = AllocateSegment(sizeHint); 210BufferSegment newSegment = AllocateSegment(sizeHint); 220private BufferSegment AllocateSegment(int sizeHint) 222BufferSegment newSegment = CreateSegmentUnsynchronized(); 229private void RentMemory(BufferSegment segment, int sizeHint) 268private BufferSegment CreateSegmentUnsynchronized() 270if (_bufferSegmentPool.TryPop(out BufferSegment? segment)) 278private void ReturnSegmentUnsynchronized(BufferSegment segment) 461AdvanceReader((BufferSegment?)consumed.GetObject(), consumed.GetInteger(), (BufferSegment?)examined.GetObject(), examined.GetInteger()); 464private void AdvanceReader(BufferSegment? consumedSegment, int consumedIndex, BufferSegment? examinedSegment, int examinedIndex) 467if (consumedSegment != null && examinedSegment != null && BufferSegment.GetLength(consumedSegment, consumedIndex, examinedSegment, examinedIndex) < 0) 472BufferSegment? returnStart = null; 473BufferSegment? returnEnd = null; 489long examinedBytes = BufferSegment.GetLength(_lastExaminedIndex, examinedSegment, examinedIndex); 522BufferSegment? nextBlock = returnEnd!.NextSegment; 577BufferSegment? next = returnStart.NextSegment; 885BufferSegment? segment = _readHead ?? _readTail; 888BufferSegment returnSegment = segment; 968BufferSegment? head = _readHead; 1120BufferSegment newSegment = AllocateSegment(0);

System\IO\Pipelines\StreamPipeReader.cs (21)

20private BufferSegment? _readHead; 23private BufferSegment? _readTail; 89AdvanceTo((BufferSegment?)consumed.GetObject(), consumed.GetInteger(), (BufferSegment?)examined.GetObject(), examined.GetInteger()); 92private void AdvanceTo(BufferSegment? consumedSegment, int consumedIndex, BufferSegment? examinedSegment, int examinedIndex) 104BufferSegment returnStart = _readHead; 105BufferSegment? returnEnd = consumedSegment; 107long consumedBytes = BufferSegment.GetLength(returnStart, _readIndex, consumedSegment, consumedIndex); 138BufferSegment? nextBlock = returnEnd.NextSegment; 152BufferSegment next = returnStart.NextSegment!; 187BufferSegment? segment = _readHead; 190BufferSegment returnSegment = segment; 326BufferSegment? segment = _readHead; 392BufferSegment? segment = _readHead; 488BufferSegment nextSegment = AllocateSegment(minimumSize); 495private BufferSegment AllocateSegment(int? minimumSize = null) 497BufferSegment nextSegment = CreateSegmentUnsynchronized(); 527private BufferSegment CreateSegmentUnsynchronized() 529if (_bufferSegmentPool.TryPop(out BufferSegment? segment)) 537private void ReturnSegmentUnsynchronized(BufferSegment segment)

System\IO\Pipelines\StreamPipeWriter.cs (13)

19private BufferSegment? _head; 20private BufferSegment? _tail; 124BufferSegment newSegment = AllocateSegment(sizeHint); 144BufferSegment newSegment = AllocateSegment(sizeHint); 152private BufferSegment AllocateSegment(int sizeHint) 155BufferSegment newSegment = CreateSegmentUnsynchronized(); 184private BufferSegment CreateSegmentUnsynchronized() 186if (_bufferSegmentPool.TryPop(out BufferSegment? segment)) 194private void ReturnSegmentUnsynchronized(BufferSegment segment) 316BufferSegment? segment = _head; 319BufferSegment returnSegment = segment; 388BufferSegment? segment = _head; 391BufferSegment returnSegment = segment;