Memory

Forms\InputFile\BrowserFileStream.cs (1)

68=> ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

ResponseBufferingStream.cs (1)

116await WriteAsync(new Memory<byte>(buffer, offset, count), cancellationToken);

Core\HttpRequestStream.cs (1)

48return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

75ValueTask<int> vt = ReadAsyncInternal(new Memory<byte>(buffer, offset, count), default); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

Internal\Http\HttpRequestStream.cs (1)

49return ReadAsyncWrapper(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

75ValueTask<int> vt = ReadAsyncInternal(new Memory<byte>(buffer, offset, count), default); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

HttpRequestStreamReader.cs (2)

224var memory = new Memory<char>(buffer, index, count); 297var source = new Memory<char>(_charBuffer, _charBufferIndex, charsRemaining);

src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)

91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);

Normalizer\SentencePieceNormalizer.cs (2)

357normalizedPrefix = new Memory<byte>(_replacementBytes, 0, 3); 377normalizedPrefix = new Memory<byte>(_normalized, longestValue, normalizedLength - longestValue);

ServerSentEvents\ArrayBuffer.cs (2)

92public readonly Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 97public readonly Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);

System\Collections\Immutable\ImmutableArray_1.Builder.cs (1)

1102internal Memory<T> AsMemory() => new(_elements, 0, _count);

src\runtime\src\libraries\Common\src\System\IO\SubReadStream.cs (1)

212return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\Formats\Tar\GnuSparseStream.cs (1)

196return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\runtime\src\libraries\Common\src\System\IO\SubReadStream.cs (1)

212return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)

91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);

System\IO\Compression\DeflateZLib\DeflateStream.cs (2)

426return ReadAsyncMemory(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask(); 479int n = await _stream.ReadAsync(new Memory<byte>(_buffer, 0, _buffer.Length), cancellationToken).ConfigureAwait(false);

System\IO\Compression\Zstandard\ZstandardStream.Decompress.cs (1)

299return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\IO\Compression\dec\BrotliStream.Decompress.cs (1)

132return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

90return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\IO\Pipes\PipeStream.Unix.cs (1)

79return ReadAsyncCore(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\IO\Ports\SerialStream.Unix.cs (1)

449Memory<byte> buffer = new Memory<byte>(array, offset, count);

src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)

91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);

src\runtime\src\libraries\Common\src\System\Net\MultiArrayBuffer.cs (1)

359return new Memory<byte>(_blocks[GetBlockIndex(_start) + blockIndex], (int)startInBlock, (int)(endInBlock - startInBlock));

System\Net\Http\HttpBaseStream.cs (1)

54return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\Net\Http\MultipartContent.cs (1)

513return ReadAsyncPrivate(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\Net\Http\Json\LengthLimitReadStream.cs (1)

42ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)

91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);

src\runtime\src\libraries\Common\src\System\Net\MultiArrayBuffer.cs (1)

359return new Memory<byte>(_blocks[GetBlockIndex(_start) + blockIndex], (int)startInBlock, (int)(endInBlock - startInBlock));

System\Net\Quic\QuicStream.Stream.cs (2)

126int readLength = ReadAsync(new Memory<byte>(rentedBuffer, 0, buffer.Length), cts?.Token ?? default).AsTask().GetAwaiter().GetResult(); 146return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\Net\HttpWebResponse.cs (1)

410return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)

91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);

System\Net\Security\NegotiateStream.cs (3)

306ValueTask<int> vt = ReadAsync<SyncReadWriteAdapter>(new Memory<byte>(buffer, offset, count), default(CancellationToken)); 321return ReadAsync<AsyncReadWriteAdapter>(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask(); 389readBytes = await ReadAllAsync(InnerStream, new Memory<byte>(_readBuffer, 0, readBytes), allowZeroRead: false, cancellationToken).ConfigureAwait(false);

System\Net\Security\SslStream.cs (2)

811ValueTask<int> vt = ReadAsyncInternal<SyncReadWriteAdapter>(new Memory<byte>(buffer, offset, count), default(CancellationToken)); 895return ReadAsyncInternal<AsyncReadWriteAdapter>(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)

91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);

System\Net\Sockets\NetworkStream.cs (1)

575new Memory<byte>(buffer, offset, count),

System\Net\Sockets\SocketAsyncEventArgs.Unix.cs (1)

62CompleteAcceptOperation(acceptedFd, new Memory<byte>(_acceptBuffer, 0, socketAddressLen), socketError);

System\Net\Sockets\SocketPal.Unix.cs (3)

1284return handle.AsyncContext.Receive(new Memory<byte>(buffer, offset, count), socketFlags, handle.ReceiveTimeout, out bytesTransferred); 1314errorCode = handle.AsyncContext.ReceiveMessageFrom(new Memory<byte>(buffer, offset, count), ref socketFlags, socketAddress.Buffer, out socketAddressLen, isIPv4, isIPv6, handle.ReceiveTimeout, out ipPacketInformation, out bytesTransferred); 1359return handle.AsyncContext.ReceiveFrom(new Memory<byte>(buffer, offset, count), ref socketFlags, socketAddress, out socketAddressLen, handle.ReceiveTimeout, out bytesTransferred);

System\Net\WebSockets\ManagedWebSocket.cs (1)

1566await SendFrameAsync(MessageOpcode.Close, endOfMessage: true, disableCompression: true, new Memory<byte>(buffer, 0, count), cancellationToken).ConfigureAwait(false);

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\BufferedStream.cs (2)

624new Memory<byte>(buffer, offset + bytesFromBuffer, count - bytesFromBuffer), 716_readLen = await _stream.ReadAsync(new Memory<byte>(_buffer, 0, _bufferSize), cancellationToken).ConfigureAwait(false);

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\BufferedFileStreamStrategy.cs (2)

285ValueTask<int> readResult = ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken); 446_readLen = await _strategy.ReadAsync(new Memory<byte>(_buffer, 0, _bufferSize), cancellationToken).ConfigureAwait(false);

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\OSFileStreamStrategy.cs (1)

269ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\StreamReader.cs (3)

1100return ReadAsyncInternalWithGuard(new Memory<char>(buffer, index, count), CancellationToken.None); 1103Task<int> task = ReadAsyncInternal(new Memory<char>(buffer, index, count), CancellationToken.None).AsTask(); 1178int len = await tmpStream.ReadAsync(new Memory<byte>(tmpByteBuffer, tmpBytePos, tmpByteBuffer.Length - tmpBytePos), cancellationToken).ConfigureAwait(false);

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\TextReader.cs (2)

271return ReadAsyncInternal(new Memory<char>(buffer, index, count), default).AsTask(); 301return ReadBlockAsyncInternal(new Memory<char>(buffer, index, count), default).AsTask();

src\runtime\src\libraries\System.Private.CoreLib\src\System\Memory.cs (1)

181public static implicit operator Memory<T>(ArraySegment<T> segment) => new Memory<T>(segment.Array, segment.Offset, segment.Count);

src\runtime\src\libraries\System.Private.CoreLib\src\System\MemoryExtensions.cs (5)

3875public static Memory<T> AsMemory<T>(this T[]? array, int start, int length) => new Memory<T>(array, start, length); 3894return new Memory<T>(array, start, length); 3900public static Memory<T> AsMemory<T>(this ArraySegment<T> segment) => new Memory<T>(segment.Array, segment.Offset, segment.Count); 3918return new Memory<T>(segment.Array, segment.Offset + start, segment.Count - start); 3940return new Memory<T>(segment.Array, segment.Offset + start, length);

src\runtime\src\libraries\System.Private.CoreLib\src\System\Text\TranscodingStream.cs (1)

364return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\Security\Cryptography\CryptoStream.cs (2)

351await _stream.ReadAsync(new Memory<byte>(tempInputBuffer, _inputBufferIndex, numWholeBlocksInBytes - _inputBufferIndex), cancellationToken).ConfigureAwait(false) : 428await _stream.ReadAsync(new Memory<byte>(_inputBuffer, _inputBufferIndex, _inputBlockSize - _inputBufferIndex), cancellationToken).ConfigureAwait(false) :

System\ServiceModel\Channels\Connection.cs (8)

193return Connection.WriteAsync(new Memory<byte>(buffer, offset, count), Immediate, TimeoutHelper.FromMilliseconds(WriteTimeout)).AsTask(); 198Connection.WriteAsync(new Memory<byte>(buffer, offset, count), Immediate, TimeoutHelper.FromMilliseconds(WriteTimeout)).GetAwaiter().GetResult(); 204Memory<byte> memBuffer = new Memory<byte>(sharedBuffer, 0, buffer.Length); 223return Connection.WriteAsync(new Memory<byte>(buffer, offset, count), Immediate, TimeoutHelper.FromMilliseconds(WriteTimeout)) 232return Connection.ReadAsync(new Memory<byte>(buffer, offset, count), TimeoutHelper.FromMilliseconds(ReadTimeout)).AsTask(); 243Memory<byte> memBuffer = new Memory<byte>(sharedBuffer, 0, buffer.Length); 260return Connection.ReadAsync(new Memory<byte>(buffer, offset, count), TimeoutHelper.FromMilliseconds(ReadTimeout)).GetAwaiter().GetResult(); 265return Connection.ReadAsync(new Memory<byte>(buffer, offset, count), timeout).GetAwaiter().GetResult();

System\ServiceModel\Channels\FramingChannels.cs (2)

381int size = await connection.ReadAsync(new Memory<byte>(faultBuffer,0, 407size = await connection.ReadAsync(new Memory<byte>(faultBuffer, 0,

System\ServiceModel\Channels\FramingEncoders.cs (2)

235IntEncoder.Encode(messageFrame.Count, new Memory<byte>(buffer, offset, spaceNeeded - 1)); 319IntEncoder.Encode(messageFrame.Count, new Memory<byte>(buffer, offset, spaceNeeded));

System\ServiceModel\Channels\SessionConnectionReader.cs (2)

115bytesRead = await _connection.ReadAsync(new Memory<byte>(EnvelopeBuffer, EnvelopeOffset, _connection.ConnectionBufferSize), timeoutHelper.RemainingTime()); 122bytesRead = await _connection.ReadAsync(new Memory<byte>(_buffer, 0, _connection.ConnectionBufferSize), timeoutHelper.RemainingTime());

System\ServiceModel\Channels\SingletonConnectionReader.cs (6)

155size = await Connection.ReadAsync(new Memory<byte>(buffer, 0, Connection.ConnectionBufferSize), timeoutHelper.RemainingTime()); 484int bytesRead = await ReadCoreAsync(new Memory<byte>(buffer, offset, bytesToRead)); 518int bytesRead = await ReadCoreAsync(new Memory<byte>(buffer, offset, IntEncoder.MaxEncodedSize)); 593envelopeStartBytes.CopyTo(new Memory<byte>(messageData.Array, messageData.Offset - envelopeStartBytes.Length, envelopeStartBytes.Length)); 594await connection.WriteAsync(new Memory<byte>(messageData.Array, messageData.Offset - envelopeStartBytes.Length, 659WriteAsync(new Memory<byte>(buffer, offset, count)).GetAwaiter().GetResult();

System\ServiceModel\Channels\TimeoutStream.cs (2)

79return await ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken); 122await WriteAsync(new Memory<byte>(buffer, offset, count), cancellationToken);

src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)

91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);