1 write to _buffer
System.IO.Compression (1)
System\IO\Compression\Zstandard\ZstandardStream.cs (1)
54_buffer = new ArrayBuffer(DefaultInternalBufferSize, usePool: true);
29 references to _buffer
System.IO.Compression (29)
System\IO\Compression\Zstandard\ZstandardStream.Compress.cs (2)
114Span<byte> output = _buffer.AvailableSpan; 175Memory<byte> output = _buffer.AvailableMemory;
System\IO\Compression\Zstandard\ZstandardStream.cs (2)
28[MemberNotNull(nameof(_buffer))] 229_buffer.Dispose();
System\IO\Compression\Zstandard\ZstandardStream.Decompress.cs (25)
65OperationStatus status = _decoder.Decompress(_buffer.ActiveSpan, destination, out int bytesConsumed, out bytesWritten); 66_buffer.Discard(bytesConsumed); 98if (_buffer.ActiveLength != 0) 106(status == OperationStatus.DestinationTooSmall && destination.IsEmpty && _buffer.ActiveLength == 0), $"{nameof(status)} == {status}, {nameof(destination.Length)} == {destination.Length}"); 162_buffer.EnsureAvailableSpace(1); 164int bytesRead = _stream.Read(_buffer.AvailableSpan); 180if (bytesRead > _buffer.AvailableLength) 185_buffer.Commit(bytesRead); 223if (_buffer.ActiveLength < ZstdFrameMagicLength) 230int needed = ZstdFrameMagicLength - _buffer.ActiveLength; 231_buffer.EnsureAvailableSpace(needed); 233? await _stream.ReadAtLeastAsync(_buffer.AvailableMemory.Slice(0, needed), needed, throwOnEndOfStream: false, cancellationToken: cancellationToken).ConfigureAwait(false) 234: _stream.ReadAtLeast(_buffer.AvailableSpan.Slice(0, needed), needed, throwOnEndOfStream: false); 238_buffer.Commit(peeked); 242if (_buffer.ActiveLength >= ZstdFrameMagicLength) 257_buffer.EnsureAvailableSpace(1); 258if (_decoder.Decompress(_buffer.ActiveSpan.Slice(0, ZstdFrameMagicLength), _buffer.AvailableSpan.Slice(0, 1), out int bytesConsumed, out _) == OperationStatus.NeedMoreData) 262_buffer.Discard(bytesConsumed); 336_buffer.EnsureAvailableSpace(1); 338int bytesRead = await _stream.ReadAsync(_buffer.AvailableMemory, cancellationToken).ConfigureAwait(false); 354if (bytesRead > _buffer.AvailableLength) 359_buffer.Commit(bytesRead); 434int unconsumedBytes = _buffer.ActiveLength; 439_buffer.Discard(unconsumedBytes);