ArraySegment

Terminal\TerminalWebSocketProxy.cs (1)

397await ws.SendAsync(new ArraySegment<byte>(buffer, 0, read),

src\aspnetcore\src\Shared\CommandLineUtils\CommandLine\CommandLineApplication.cs (1)

596command.RemainingArguments.AddRange(new ArraySegment<string>(args, index, args.Length - index));

src\aspnetcore\src\Shared\CommandLineUtils\CommandLine\CommandLineApplication.cs (1)

596command.RemainingArguments.AddRange(new ArraySegment<string>(args, index, args.Length - index));

src\aspnetcore\src\Shared\CommandLineUtils\CommandLine\CommandLineApplication.cs (1)

596command.RemainingArguments.AddRange(new ArraySegment<string>(args, index, args.Length - index));

src\aspnetcore\src\Shared\CommandLineUtils\CommandLine\CommandLineApplication.cs (1)

596command.RemainingArguments.AddRange(new ArraySegment<string>(args, index, args.Length - index));

FrameworkFork\System.Runtime.Serialization\System\Xml\EncodingStreamWrapper.cs (3)

497seg = new ArraySegment<byte>(buffer, offset, count); 502seg = new ArraySegment<byte>(buffer, offset, count); 526seg = new ArraySegment<byte>(s_validatingUTF8.GetBytes(GetEncoding(declEnc).GetChars(buffer, offset, count)));

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\BinaryMessageEncoder.cs (3)

434return new ArraySegment<byte>(buffer, newOffset, newSize); 513return new ArraySegment<byte>(buffer, newOffset, newSize); 1440messageData.Open(new ArraySegment<byte>(buffer, offset, size), bufferManager);

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\BufferedMessageData.cs (1)

76_buffer = new ArraySegment<byte>();

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\BufferedMessageWriter.cs (1)

58return new ArraySegment<byte>(buffer, initialOffset, size - initialOffset);

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\FramingChannels.cs (1)

216return new ArraySegment<byte>(startBytes, 0, startSize);

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

231return new ArraySegment<byte>(buffer, messageFrame.Offset - spaceNeeded, messageFrame.Count + spaceNeeded); 315return new ArraySegment<byte>(buffer, offset, messageFrame.Count + spaceNeeded);

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpResponseMessageHelper.cs (2)

205var messageBuffer = new ArraySegment<byte>(_factory.BufferManager.TakeBuffer(bufferSize), 0, bufferSize); 228return await DecodeBufferedMessageAsync(new ArraySegment<byte>(buffer, 0, offset), inputStream);

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\MessageEncoder.cs (1)

89return new ArraySegment<byte>(buffer, 0, offset);

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\MessageEncoderCompressionHandler.cs (2)

55buffer = new ArraySegment<byte>(decompressedBytes, buffer.Offset, length - buffer.Offset); 75buffer = new ArraySegment<byte>(compressedBytes, buffer.Offset, length - buffer.Offset);

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\SessionConnectionReader.cs (1)

391message = _messageEncoder.ReadMessage(new ArraySegment<byte>(EnvelopeBuffer, 0, EnvelopeSize), _bufferManager);

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (10)

src\aspnetcore\src\Shared\CommandLineUtils\CommandLine\CommandLineApplication.cs (1)

596command.RemainingArguments.AddRange(new ArraySegment<string>(args, index, args.Length - index));

src\aspnetcore\src\Shared\CommandLineUtils\CommandLine\CommandLineApplication.cs (1)

596command.RemainingArguments.AddRange(new ArraySegment<string>(args, index, args.Length - index));

CustomTextMessageEncoder.cs (1)

97ArraySegment<byte> byteArray = new ArraySegment<byte>(totalBytes, messageOffset, messageLength);

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (4)

202bytes = new ArraySegment<byte>(Array.Empty<byte>()); 221bytes = new ArraySegment<byte>(Array.Empty<byte>()); 241? new ArraySegment<byte>(buffer) 242: new ArraySegment<byte>(Array.Empty<byte>());

src\aspnetcore\src\Shared\CommandLineUtils\CommandLine\CommandLineApplication.cs (1)

596command.RemainingArguments.AddRange(new ArraySegment<string>(args, index, args.Length - index));

RenderTree\ArrayBuilderSegment.cs (2)

55=> ((IEnumerable<T>)new ArraySegment<T>(Array, _offset, _count)).GetEnumerator(); 58=> ((IEnumerable)new ArraySegment<T>(Array, _offset, _count)).GetEnumerator();

Rendering\Buffering\BufferedTextWriter.cs (1)

29=> _currentOutput.Add(new TextChunk(new ArraySegment<char>(buffer, index, count), _charArraySegmentBuilder));

Circuits\RemoteRenderer.cs (1)

222var segment = new ArraySegment<byte>(pending.Data.Buffer, 0, pending.Data.Count);

ComponentHub.cs (1)

550yield return new ArraySegment<byte>(buffer, 0, bytesRead);

src\aspnetcore\src\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\BufferWriter.cs (1)

83_segment = new ArraySegment<byte>(array);

IpcCommon.cs (1)

46args = new ArraySegment<JsonElement>(parsed, 1, parsed.Length - 1);

ArraySegmentExtensions.cs (1)

27_ = new ArraySegment<T>(arraySegment.Array!, arraySegment.Offset, arraySegment.Count);

AuthenticatedEncryption\AuthenticatedEncryptorExtensions.cs (4)

47var protectedData = encryptor.Encrypt(new ArraySegment<byte>(plaintextAsBytes), new ArraySegment<byte>(aad)); 48var roundTrippedData = encryptor.Decrypt(new ArraySegment<byte>(protectedData), new ArraySegment<byte>(aad));

AuthenticatedEncryption\ConfigurationModel\SecretExtensions.cs (1)

29secret.WriteSecretIntoBuffer(new ArraySegment<byte>(unprotectedSecretRawBytes));

Cng\DpapiSecretSerializerHelper.cs (2)

52secret.WriteSecretIntoBuffer(new ArraySegment<byte>(plaintextSecret)); 128secret.WriteSecretIntoBuffer(new ArraySegment<byte>(plaintextSecret));

KeyManagement\KeyRingBasedDataProtector.cs (4)

119plaintext: new ArraySegment<byte>(plaintext), 120additionalAuthenticatedData: new ArraySegment<byte>(aad), 286ArraySegment<byte> ciphertext = new ArraySegment<byte>(protectedData, sizeof(uint) + sizeof(Guid), protectedData.Length - (sizeof(uint) + sizeof(Guid))); // chop off magic header + encryptor id 287ArraySegment<byte> additionalAuthenticatedData = new ArraySegment<byte>(_aadTemplate.GetAadForKey(keyIdFromPayload, isProtecting: false));

Managed\ManagedAuthenticatedEncryptor.cs (3)

601var EMPTY_ARRAY_SEGMENT = new ArraySegment<byte>(EMPTY_ARRAY); 643rgbKey: new ArraySegment<byte>(tempKeys, 0, _symmetricAlgorithmSubkeyLengthInBytes).AsStandaloneArray(), 655using (var hashAlg = CreateValidationAlgorithm(new ArraySegment<byte>(tempKeys, _symmetricAlgorithmSubkeyLengthInBytes, _validationAlgorithmSubkeyLengthInBytes).AsStandaloneArray()))

Secret.cs (2)

41: this(new ArraySegment<byte>(value)) 88secret.WriteSecretIntoBuffer(new ArraySegment<byte>(tempPlaintextBuffer));

XmlEncryption\XmlEncryptionExtensions.cs (2)

172return new Secret(new ArraySegment<byte>(underlyingBuffer, 0, checked((int)memoryStream.Length))); 191secret.WriteSecretIntoBuffer(new ArraySegment<byte>(plaintextSecret));

Latency\AddServerTimingHeaderMiddlewareTests.cs (1)

26ArraySegment<Checkpoint> checkpoints = new(new[] { checkpoint });

Latency\Internal\MockLatencyData.cs (3)

13private readonly ArraySegment<Checkpoint> _checkpoints = new(new[] 20private readonly ArraySegment<Measure> _measures = new(new[] 27private readonly ArraySegment<Tag> _tags = new(new[]

Latency\LatencyContextControlExtensionsTests.cs (1)

37var chkSegment = new ArraySegment<Checkpoint>(checkpoints);

WebSockets\OwinWebSocketAdapter.cs (1)

144await ReceiveAsync(new ArraySegment<byte>(buffer), cancellationToken);

Helpers.cs (2)

22return new ArraySegment<byte>(Encoding.ASCII.GetBytes(size.ToString("X", CultureInfo.InvariantCulture) + "\r\n")); 84return new ArraySegment<byte>(header, offset, header.Length - offset);

RequestProcessing\ResponseBody.cs (4)

112private unsafe void FlushInternal(bool endOfRequest, ArraySegment<byte> data = new ArraySegment<byte>()) 309return FlushInternalAsync(new ArraySegment<byte>(), cancellationToken); 537var data = new ArraySegment<byte>(buffer, offset, count); 589var data = new ArraySegment<byte>(buffer, offset, count);

RequestProcessing\ResponseStreamAsyncResult.cs (2)

59var chunkHeaderBuffer = new ArraySegment<byte>(); 118var chunkHeaderBuffer = new ArraySegment<byte>();

Proxying\SpaProxy.cs (2)

283var resultTask = source.ReceiveAsync(new ArraySegment<byte>(buffer), cancellationToken); 310await destination.SendAsync(new ArraySegment<byte>(buffer, 0, result.Count), result.MessageType, result.EndOfMessage, cancellationToken);

Util\EventedStreamReader.cs (1)

92OnChunk(new ArraySegment<char>(buf, 0, chunkLength));

TestWebSocket.cs (4)

63result = await ReceiveAsync(new ArraySegment<byte>(data), cancellationToken); 146receiveMessage.Buffer = new ArraySegment<byte>(receiveMessage.Buffer.Array!, receiveMessage.Buffer.Offset + count, receiveMessage.Buffer.Count - count); 231Buffer = new ArraySegment<byte>(Array.Empty<byte>()); 292message.Buffer = new ArraySegment<byte>(array);

BufferedReadStream.cs (1)

55get { return new ArraySegment<byte>(_buffer, _bufferOffset, _bufferCount); }

Evaluation\Expander\WellKnownFunctions.cs (1)

401returnVal = IntrinsicFunctions.GetRegistryValueFromView(arg0, arg1, args[2], new ArraySegment<object>(args, 3, args.Length - 3));

Evaluation\IntrinsicFunctions.cs (2)

245return GetRegistryValueFromView(keyName, valueName, defaultValue, new ArraySegment<object>(views)); 270views = new ArraySegment<object>(DefaultRegistryViews);

DiaSymReader\Utilities\ComMemoryStream.cs (1)

98yield return new ArraySegment<byte>(chunk, 0, bytesToCopy);

EncodedStringText.cs (4)

202bytes = new ArraySegment<byte>(Array.Empty<byte>()); 221bytes = new ArraySegment<byte>(Array.Empty<byte>()); 241? new ArraySegment<byte>(buffer) 242: new ArraySegment<byte>(Array.Empty<byte>());

ReferenceManager\CommonReferenceManager.Binding.cs (3)

308referenceBindingsToProcess.Push((resolvedReference, new ArraySegment<AssemblyReferenceBinding>(referenceBinding))); 412new ArraySegment<AssemblyReferenceBinding>(bindingsOfAssemblyBeingBuilt, bindingIndex, moduleBindingsCount))); 431new ArraySegment<AssemblyReferenceBinding>(referenceBindings[explicitReferenceMapping.Index + 1])));

Text\SourceText.cs (1)

280var embeddedTextBlob = canBeEmbedded ? EmbeddedText.CreateBlob(new ArraySegment<byte>(buffer, 0, length)) : default(ImmutableArray<byte>);

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (4)

202bytes = new ArraySegment<byte>(Array.Empty<byte>()); 221bytes = new ArraySegment<byte>(Array.Empty<byte>()); 241? new ArraySegment<byte>(buffer) 242: new ArraySegment<byte>(Array.Empty<byte>());

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (4)

202bytes = new ArraySegment<byte>(Array.Empty<byte>()); 221bytes = new ArraySegment<byte>(Array.Empty<byte>()); 241? new ArraySegment<byte>(buffer) 242: new ArraySegment<byte>(Array.Empty<byte>());

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (4)

202bytes = new ArraySegment<byte>(Array.Empty<byte>()); 221bytes = new ArraySegment<byte>(Array.Empty<byte>()); 241? new ArraySegment<byte>(buffer) 242: new ArraySegment<byte>(Array.Empty<byte>());

Parser\SlidingTextWindow.cs (2)

110_characterWindow = new ArraySegment<char>(s_windowPool.Allocate()); 142_characterWindow = new(_characterWindow.Array!, 0, amountToRead);

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (4)

202bytes = new ArraySegment<byte>(Array.Empty<byte>()); 221bytes = new ArraySegment<byte>(Array.Empty<byte>()); 241? new ArraySegment<byte>(buffer) 242: new ArraySegment<byte>(Array.Empty<byte>());

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (4)

202bytes = new ArraySegment<byte>(Array.Empty<byte>()); 221bytes = new ArraySegment<byte>(Array.Empty<byte>()); 241? new ArraySegment<byte>(buffer) 242: new ArraySegment<byte>(Array.Empty<byte>());

DataFrame.cs (1)

355ArraySegment<int> segment = new ArraySegment<int>(shuffleArray, 0, shuffleLowerLimit);

Extensions\SymUnmanagedExtensions.Document.cs (2)

121return new ArraySegment<byte>(blob, sizeof(int), bytesRead - sizeof(int)); 147return new ArraySegment<byte>(uncompressedBytes);

Utilities\ComMemoryStream.cs (1)

104yield return new ArraySegment<byte>(chunk, 0, bytesToCopy);

src\RpmBuilder.cs (1)

550signatureEntries.Add(new(RpmSignatureTag.ReservedSpace, RpmHeaderEntryType.Binary, new ArraySegment<byte>(new byte[4128])));

src\RpmHeader.cs (1)

149entries.Add(new Entry(entry.Tag, entry.Type, new ArraySegment<byte>(store, entry.Offset, entry.Count)));

BlockingMemoryStream.cs (2)

36_remaining = new ArraySegment<byte>(tmp, 0, tmp.Length); 50_remaining = new ArraySegment<byte>(_remaining.Array, _remaining.Offset + count, _remaining.Count - count);

src\sdk\src\Dotnet.Watch\AspireService\AspireServerService.cs (1)

406await connection.Socket.SendAsync(new ArraySegment<byte>(messageBytes), WebSocketMessageType.Text, endOfMessage: true, cancelTokenSource.Token);

src\sdk\src\Dotnet.Watch\HotReloadClient\WebSocketClientTransport.cs (2)

186new ArraySegment<byte>(_sendBuffer.GetBuffer(), 0, (int)_sendBuffer.Length), 207result = await _clientSocket.ReceiveAsync(new ArraySegment<byte>(buffer), cancellationToken);

ChatCompletion\ChatResponseExtensions.cs (1)

337segment = new(current.Data.ToArray());

Contents\DataContent.cs (1)

244array = new(Data.ToArray());

Internal\BufferChunk.cs (1)

87internal ArraySegment<byte> AsArraySegment() => Length == 0 ? default! : new(OversizedArray!, Offset, Length);

Internal\HybridCachePayload.cs (1)

300payload = new(source.Array!, start, payloadLength);

PayloadTests.cs (11)

SqlParameterCollectionExtensions.cs (1)

35value = new([], 0, 0);

SqlServerCache.cs (4)

177_dbOperations.SetCacheItem(key, new(value), options); 210await _dbOperations.SetCacheItemAsync(key, new(value), options, token).ConfigureAwait(false); 239return new([], 0, 0); 252return new(lease, 0, length);

DependencyContextJsonReader.cs (1)

113return new ArraySegment<byte>(rented, 0, written);

src\sdk\src\Dotnet.Watch\HotReloadAgent.Host\WebSocketTransport.cs (2)

81new ArraySegment<byte>(_sendBuffer.GetBuffer(), 0, (int)_sendBuffer.Length), 104result = await _webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), cancellationToken).ConfigureAwait(false);

Latency\Internal\HttpClientLatencyLogEnricherTest.cs (3)

22var checkpoints = new ArraySegment<Checkpoint>(new[] { new Checkpoint("a", default, default), new Checkpoint("b", default, default) }); 39var checkpoints = new ArraySegment<Checkpoint>(new[] { new Checkpoint("a", default, default), new Checkpoint("b", default, default) }); 59var checkpoints = new ArraySegment<Checkpoint>(new[] { new Checkpoint("a", default, default), new Checkpoint("b", default, default) });

Resolver\DnsResolver.cs (3)

710DnsDataReader responseReader = new DnsDataReader(new ArraySegment<byte>(buffer, 0, length), true); 758responseReader = new DnsDataReader(new ArraySegment<byte>(buffer, 0, packetLength), true); 823DnsDataReader responseReader = new DnsDataReader(new ArraySegment<byte>(buffer, 2, responseLength), true);

Resolver\DnsDataReaderTests.cs (1)

60DnsDataReader reader = new DnsDataReader(new ArraySegment<byte>(buffer, 0, i));

Resolver\LoopbackDnsServer.cs (2)

60int bytesWritten = await ProcessRequestCore((IPEndPoint)result.RemoteEndPoint, new ArraySegment<byte>(buffer, 0, result.ReceivedBytes), action, buffer.AsMemory(0, 512)); 103int bytesWritten = await ProcessRequestCore((IPEndPoint)tcpClient.RemoteEndPoint!, new ArraySegment<byte>(buffer, 2, length), action, buffer.AsMemory(2));

Latency\Internal\CheckpointTracker.cs (1)

77public ArraySegment<Checkpoint> Checkpoints => new(_checkpoints, 0, _numCheckpoints);

Latency\Internal\MeasureTracker.cs (1)

132return new(_measures, 1, _numMeasures);

Latency\Internal\TagCollection.cs (1)

70public ArraySegment<Tag> Tags => new(_tags, 0, _numTags);

Latency\NullLatencyContext.cs (3)

13private readonly ArraySegment<Checkpoint> _checkpoints = new(Array.Empty<Checkpoint>()); 14private readonly ArraySegment<Tag> _tags = new(Array.Empty<Tag>()); 15private readonly ArraySegment<Measure> _measures = new(Array.Empty<Measure>());

Latency\LatencyDataTests.cs (6)

25ArraySegment<Checkpoint> checkpoints = new ArraySegment<Checkpoint>(LatencyDataTests.GetCheckpoints(num)); 26ArraySegment<Measure> measures = new ArraySegment<Measure>(GetMeasures(num)); 27ArraySegment<Tag> tags = new ArraySegment<Tag>(GetTags(num)); 44ArraySegment<Checkpoint> checkpoints = new ArraySegment<Checkpoint>(LatencyDataTests.GetCheckpoints(num), 1, numCheckpoints); 45ArraySegment<Measure> measures = new ArraySegment<Measure>(GetMeasures(num), 2, numMeasures); 46ArraySegment<Tag> tags = new ArraySegment<Tag>(GetTags(num), 3, numTags);

Latency\Internal\LatencyConsoleExporterTests.cs (9)

167ArraySegment<Checkpoint> checkpoints = new(new[] 174ArraySegment<Measure> measures = new(new[] 181ArraySegment<Tag> tags = new(new[] 193ArraySegment<Checkpoint> checkpoints = new(new[] 200ArraySegment<Measure> measures = new(new[] 207ArraySegment<Tag> tags = new(new[] 219ArraySegment<Checkpoint> checkpoints = new(Array.Empty<Checkpoint>()); 220ArraySegment<Measure> measures = new(Array.Empty<Measure>()); 221ArraySegment<Tag> tags = new(Array.Empty<Tag>());

System\Collections\Generic\CollectionExtensions.cs (1)

24return new List<T>(new ArraySegment<T>(array, 0, count));

System\Value.cs (8)

782? new(byteArray, _union.Segment.Offset, _union.Segment.Count) 783: new(byteArray, 0, 0); 798? new(charArray, _union.Segment.Offset, _union.Segment.Count) 799: new(charArray, 0, 0); 1003? (T)(object)new ArraySegment<char>(chars, _union.Segment.Offset, _union.Segment.Count) 1004: (T)(object)new ArraySegment<char>(chars, 0, 0); 1010? (T)(object)new ArraySegment<byte>(bytes, _union.Segment.Offset, _union.Segment.Count) 1011: (T)(object)new ArraySegment<byte>(bytes, 0, 0);

CircularMemoryStream.cs (1)

74handler(this, new ArraySegment<byte>(_buffer, offset: 0, count: (int)Position));

System\Windows\Nrbf\SerializationRecordExtensions.cs (1)

366return new List<T>(new ArraySegment<T>(array, 0, count));

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (4)

202bytes = new ArraySegment<byte>(Array.Empty<byte>()); 221bytes = new ArraySegment<byte>(Array.Empty<byte>()); 241? new ArraySegment<byte>(buffer) 242: new ArraySegment<byte>(Array.Empty<byte>());

CommandLine\CommandLineApplication.cs (1)

590command.RemainingArguments.AddRange(new ArraySegment<string>(args, index, args.Length - index));

System\Diagnostics\Process.Multiplexing.cs (1)

498return new ArraySegment<byte>(buffer, 0, bytesRead);

System\Formats\Nrbf\Utils\TypeNameHelpers.cs (1)

215return new ArraySegment<char>(rented, 0, length);

System\Buffers\ReadOnlySequence.Helpers.cs (1)

550segment = new ArraySegment<T>((T[])_startObject, startIndex, GetIndex(_endInteger) - startIndex);

src\runtime\src\libraries\Common\src\System\Text\UrlBase64Encoding.cs (1)

77return new ArraySegment<char>(urlEncoded, 0, written);

System\Net\Security\SslStreamCertificateContext.Linux.cs (1)

312ArraySegment<byte> encoded = new ArraySegment<byte>(rentedBytes, 0, encodingSize);

System\Net\Sockets\Socket.cs (2)

2601return TaskToAsyncResult.Begin(ReceiveAsync(new ArraySegment<byte>(buffer, offset, size), socketFlags, fromNetworkStream: false, default).AsTask(), callback, state); 2610Task<int> t = ReceiveAsync(new ArraySegment<byte>(buffer, offset, size), socketFlags, fromNetworkStream: false, default).AsTask();

System\Net\Sockets\UDPClient.cs (3)

578return _clientSocket.SendAsync(new ArraySegment<byte>(datagram, 0, bytes), SocketFlags.None); 583return _clientSocket.SendToAsync(new ArraySegment<byte>(datagram, 0, bytes), SocketFlags.None, endPoint); 625new ArraySegment<byte>(_buffer, 0, MaxUDPSize),

System\Net\WebSockets\WebSocket.cs (4)

46WebSocketReceiveResult r = await ReceiveAsync(new ArraySegment<byte>(array, 0, buffer.Length), cancellationToken).ConfigureAwait(false); 76await SendAsync(new ArraySegment<byte>(array, 0, buffer.Length), messageType, endOfMessage, cancellationToken).ConfigureAwait(false); 117return new ArraySegment<byte>(new byte[Math.Max(receiveBufferSize, sendBufferSize)]); 123return new ArraySegment<byte>(new byte[receiveBufferSize]);

src\runtime\src\libraries\System.Private.CoreLib\src\System\ArraySegment.cs (4)

37public static ArraySegment<T> Empty { get; } = new ArraySegment<T>(new T[0]); 140return new ArraySegment<T>(_array!, _offset + index, _count - index); 152return new ArraySegment<T>(_array!, _offset + index, count); 173public static implicit operator ArraySegment<T>(T[] array) => array != null ? new ArraySegment<T>(array) : default;

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

192buffer = new ArraySegment<byte>(_buffer, offset: _origin, count: _length - _origin);

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

150return ReadSpan(new Span<byte>(buffer, offset, count), new ArraySegment<byte>(buffer, offset, count)); 469WriteSpan(new ReadOnlySpan<byte>(buffer, offset, count), new ArraySegment<byte>(buffer, offset, count));

src\runtime\src\libraries\System.Private.CoreLib\src\System\Runtime\InteropServices\MemoryMarshal.cs (2)

331segment = new ArraySegment<T>(Unsafe.As<T[]>(obj), index & ReadOnlyMemory<T>.RemoveFlagsBitMask, length); 342segment = new ArraySegment<T>(tempArraySegment.Array!, tempArraySegment.Offset + index, length);

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

268return new ArraySegment<byte>(bytes, 0, byteCount); 584ArraySegment<char> decodedChars = new ArraySegment<char>(scratchChars, 0, charsWritten);

System\Runtime\Serialization\Json\JsonEncodingStreamWrapper.cs (2)

139return new ArraySegment<byte>(buffer, offset, count); 144new ArraySegment<byte>(DataContractSerializer.ValidatingUTF8.GetBytes(GetEncoding(dataEnc).GetChars(buffer, offset, count)));

System\Xml\EncodingStreamWrapper.cs (3)

459seg = new ArraySegment<byte>(buffer, offset, count); 464seg = new ArraySegment<byte>(buffer, offset, count); 488seg = new ArraySegment<byte>(DataContractSerializer.ValidatingUTF8.GetBytes(GetEncoding(declEnc).GetChars(buffer, offset, count)));

System\Collections\Generic\CollectionExtensions.cs (1)

24return new List<T>(new ArraySegment<T>(array, 0, count));

System\Value.cs (8)

782? new(byteArray, _union.Segment.Offset, _union.Segment.Count) 783: new(byteArray, 0, 0); 798? new(charArray, _union.Segment.Offset, _union.Segment.Count) 799: new(charArray, 0, 0); 1003? (T)(object)new ArraySegment<char>(chars, _union.Segment.Offset, _union.Segment.Count) 1004: (T)(object)new ArraySegment<char>(chars, 0, 0); 1010? (T)(object)new ArraySegment<byte>(bytes, _union.Segment.Offset, _union.Segment.Count) 1011: (T)(object)new ArraySegment<byte>(bytes, 0, 0);

System\Reflection\Metadata\Blob.cs (1)

21public ArraySegment<byte> GetBytes() => new ArraySegment<byte>(Buffer, Start, Length);

System\Runtime\InteropServices\JavaScript\Marshaling\JSMarshalerArgument.Byte.cs (1)

128value = new ArraySegment<byte>(array, byteOffset, slot.Length);

System\Runtime\InteropServices\JavaScript\Marshaling\JSMarshalerArgument.Double.cs (1)

134value = new ArraySegment<double>(array, byteOffset / sizeof(double), slot.Length);

System\Runtime\InteropServices\JavaScript\Marshaling\JSMarshalerArgument.Int32.cs (1)

128value = new ArraySegment<int>(array, byteOffset / sizeof(int), slot.Length);

System\Runtime\InteropServices\JavaScript\Marshaling\JSMarshalerArgument.Single.cs (1)

134value = new ArraySegment<float>(array, byteOffset / sizeof(float), slot.Length);

src\runtime\src\libraries\Common\src\Interop\Windows\BCrypt\Interop.BCryptExportKey.cs (1)

45return new ArraySegment<byte>(rented, 0, numBytesNeeded);

src\runtime\src\libraries\Common\src\System\Security\Cryptography\KeyFormatHelper.Encrypted.cs (1)

393return new ArraySegment<byte>(decrypted, 0, decryptedBytes);

src\runtime\src\libraries\Common\src\System\Security\Cryptography\X509Certificates\X509CertificateLoader.Pkcs12.cs (1)

1319return new ArraySegment<byte>(ret, 0, written);

System\Security\Cryptography\CngHelpers.cs (1)

221return new ArraySegment<byte>(rsaBlob, 0, blobSize);

System\Security\Cryptography\X509Certificates\CertificateRequest.cs (2)

1117return new ArraySegment<byte>(newSerialNumber, 0, serialNumber.Length + 1); 1130return new ArraySegment<byte>(newSerialNumber, 0, contentLength);

src\runtime\src\libraries\Common\src\System\Security\Cryptography\KeyFormatHelper.Encrypted.cs (1)

393return new ArraySegment<byte>(decrypted, 0, decryptedBytes);

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

210var messageBuffer = new ArraySegment<byte>(_factory.BufferManager.TakeBuffer(bufferSize), 0, bufferSize); 234return await DecodeBufferedMessageAsync(new ArraySegment<byte>(buffer, 0, offset), inputStream, timeoutHelper);

System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (10)

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

236return new ArraySegment<byte>(buffer, messageFrame.Offset - spaceNeeded, messageFrame.Count + spaceNeeded); 320return new ArraySegment<byte>(buffer, offset, messageFrame.Count + spaceNeeded);

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

277message = _messageEncoder.ReadMessage(new ArraySegment<byte>(EnvelopeBuffer, 0, EnvelopeSize), _bufferManager);

System\ServiceModel\Channels\BinaryMessageEncoder.cs (3)

424return new ArraySegment<byte>(buffer, newOffset, newSize); 503return new ArraySegment<byte>(buffer, newOffset, newSize); 1438messageData.Open(new ArraySegment<byte>(buffer, offset, size), bufferManager);

System\ServiceModel\Channels\BufferedMessageData.cs (1)

69Buffer = new ArraySegment<byte>();

System\ServiceModel\Channels\BufferedMessageWriter.cs (1)

67return new ArraySegment<byte>(buffer, initialOffset, size - initialOffset);

System\ServiceModel\Channels\MessageEncoder.cs (1)

92return new ArraySegment<byte>(buffer, 0, offset);

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

55buffer = new ArraySegment<byte>(decompressedBytes, buffer.Offset, length - buffer.Offset); 75buffer = new ArraySegment<byte>(compressedBytes, buffer.Offset, length - buffer.Offset);

System\Text\Json\Document\JsonDocument.cs (1)

829rented = new ArraySegment<byte>(rent, 0, written);

System\Text\Json\Document\JsonDocument.Parse.cs (2)

856return new ArraySegment<byte>(rented, 0, written); 938return new ArraySegment<byte>(rented, 0, written);

FrameworkFork\Microsoft.Xml\Xml\Serialization\Types.cs (1)

999return t.GetTypeInfo().IsGenericType && (t.GetGenericTypeDefinition() == typeof(ArraySegment<>));

FrameworkFork\System.Runtime.Serialization\System\Runtime\Serialization\ClassDataContract.cs (1)

398return t.GetTypeInfo().IsGenericType && (t.GetGenericTypeDefinition() == typeof(ArraySegment<>));

FrameworkFork\System.Runtime.Serialization\System\Runtime\Serialization\CollectionDataContract.cs (1)

990return t.GetTypeInfo().IsGenericType && (t.GetGenericTypeDefinition() == typeof(ArraySegment<>));

FrameworkFork\System.Runtime.Serialization\System\Xml\EncodingStreamWrapper.cs (2)

470internal static ArraySegment<byte> ProcessBuffer(byte[] buffer, int offset, int count, Encoding encoding) 478ArraySegment<byte> seg;

FrameworkFork\System.Runtime.Serialization\System\Xml\XmlBinaryWriter.cs (2)

1035ArraySegment<byte> arraySegment; 1106ArraySegment<byte> arraySegment;

FrameworkFork\System.Runtime.Serialization\System\Xml\XmlUTF8TextReader.cs (1)

575ArraySegment<byte> seg = EncodingStreamWrapper.ProcessBuffer(buffer, offset, count, encoding);

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\BinaryMessageEncoder.cs (8)

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\BufferedMessageData.cs (3)

12private ArraySegment<byte> _buffer; 25public ArraySegment<byte> Buffer 179public void Open(ArraySegment<byte> buffer, BufferManager bufferManager)

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\BufferedMessageWriter.cs (1)

27public ArraySegment<byte> WriteMessage(Message message, BufferManager bufferManager, int initialOffset, int maxSizeQuota)

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\Connection.cs (1)

767internal static void ValidateBufferBounds(ArraySegment<byte> buffer)

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\FramingChannels.cs (8)

79ArraySegment<byte> messageData; 99protected override AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, Action<object> callback, object state) 111protected override ArraySegment<byte> EncodeMessage(Message message) 113ArraySegment<byte> messageData = MessageEncoder.WriteMessage(message, 194private ArraySegment<byte> CreatePreamble() 241private async Task<IConnection> SendPreambleAsync(IConnection connection, ArraySegment<byte> preamble, TimeSpan timeout) 282private IConnection SendPreamble(IConnection connection, ArraySegment<byte> preamble, ref TimeoutHelper timeoutHelper) 415private ArraySegment<byte> _preamble;

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\FramingEncoders.cs (4)

218public static ArraySegment<byte> EncodeMessageFrame(ArraySegment<byte> messageFrame) 303public static ArraySegment<byte> EncodeMessageFrame(ArraySegment<byte> messageFrame)

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpResponseMessageHelper.cs (2)

205var messageBuffer = new ArraySegment<byte>(_factory.BufferManager.TakeBuffer(bufferSize), 0, bufferSize); 258private async Task<Message> DecodeBufferedMessageAsync(ArraySegment<byte> buffer, Stream inputStream)

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\Message.cs (1)

1405ArraySegment<byte> Buffer { get; }

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\MessageBuffer.cs (1)

187ArraySegment<byte> buffer = _messageData.Buffer;

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\MessageContent.cs (2)

205private ArraySegment<byte> _buffer; 261_buffer = default(ArraySegment<byte>);

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\MessageEncoder.cs (8)

42public virtual Task<Message> ReadMessageAsync(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 49public Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager) 55public abstract Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType); 58internal async Task<ArraySegment<byte>> BufferMessageStreamAsync(Stream stream, BufferManager bufferManager, int maxBufferSize) 115public ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager) 117ArraySegment<byte> arraySegment = WriteMessage(message, maxMessageSize, bufferManager, 0); 121public abstract ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, 130public virtual Task<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize,

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\MessageEncoderCompressionHandler.cs (2)

17internal static void DecompressBuffer(ref ArraySegment<byte> buffer, BufferManager bufferManager, CompressionFormat compressionFormat, long maxReceivedMessageSize) 59internal static void CompressBuffer(ref ArraySegment<byte> buffer, BufferManager bufferManager, CompressionFormat compressionFormat)

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\TextMessageEncoder.cs (5)

401public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 461public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 471public override Task<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 496ArraySegment<byte> messageData = messageWriter.WriteMessage(message, bufferManager, messageOffset, maxMessageSize); 716ArraySegment<byte> buffer = this.Buffer;

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (3)

488protected abstract AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, Action<object> callback, object state); 496protected abstract ArraySegment<byte> EncodeMessage(Message message); 542ArraySegment<byte> messageData;

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (6)

186protected override AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, Action<object> callback, object state) 282ArraySegment<byte> messageData = EncodeMessage(message); 323protected override ArraySegment<byte> EncodeMessage(Message message) 849ArraySegment<byte> bytes = new ArraySegment<byte>(buffer, 0, count); 891private ArraySegment<byte> _initialReadBuffer; 906ArraySegment<byte> initialBuffer,

FrameworkFork\System.ServiceModel\System\ServiceModel\Diagnostics\MessageLogger.cs (1)

61internal static void LogMessage(ArraySegment<byte> arraySegment, MessageLoggingSource messageLoggingSource)

FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\XmlSerializerOperationFormatter.cs (1)

209ArraySegment<byte> memoryBuffer;

FrameworkFork\System.ServiceModel\System\ServiceModel\Security\EncryptedData.cs (2)

18private ArraySegment<byte> _buffer; 78public void SetUpEncryption(SymmetricAlgorithm algorithm, ArraySegment<byte> buffer)

FrameworkFork\System.ServiceModel\System\ServiceModel\Security\RequestSecurityToken.cs (1)

27private ArraySegment<byte> _cachedWriteBuffer;

FrameworkFork\System.ServiceModel\System\ServiceModel\Security\RequestSecurityTokenResponse.cs (1)

35private ArraySegment<byte> _cachedWriteBuffer;

CustomTextMessageEncoder.cs (4)

60public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 78public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 80ArraySegment<byte> messageBuffer; 97ArraySegment<byte> byteArray = new ArraySegment<byte>(totalBytes, messageOffset, messageLength);

TextTests.4.1.0.cs (1)

115ArraySegment<byte> returnedByteArraySegment;

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (3)

163if (TryGetBytesFromStream(data, out ArraySegment<byte> bytes) && bytes.Offset == 0 && bytes.Array is object) 186internal static bool TryGetBytesFromStream(Stream data, out ArraySegment<byte> bytes) 213out ArraySegment<byte> bytes)

src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (3)

69if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 164if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 231if (!MemoryMarshal.TryGetArray<T>(memory, out var segment))

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Extensions\Symbols\ITypeSymbolExtensions.cs (1)

745or nameof(ArraySegment<>)

VTableExportPEBuilder.cs (1)

213var bytes = blob.GetBytes();

Compiler\CryptographicHashProvider.cs (2)

225internal static ImmutableArray<byte> ComputeHash(HashAlgorithmName algorithmName, IEnumerable<ArraySegment<byte>> bytes) 229foreach (var segment in bytes)

Compiler\DependencyAnalysis\ReadyToRun\NibbleWriter.cs (1)

156ArraySegment<byte> blobSegment = blob.GetBytes();

RenderTree\ArrayBuilderExtensions.cs (1)

21/// <returns>The <see cref="ArraySegment{T}"/>.</returns>

Rendering\Buffering\TextChunk.cs (1)

35public TextChunk(ArraySegment<char> value, StringBuilder charArraySegmentScope)

BlazorPack\BlazorPackHubProtocolWorker.cs (1)

99case ArraySegment<byte> bytes:

Circuits\RemoteRenderer.cs (1)

222var segment = new ArraySegment<byte>(pending.Data.Buffer, 0, pending.Data.Count);

ComponentHub.cs (1)

529public async IAsyncEnumerable<ArraySegment<byte>> SendDotNetStreamToJS(long streamId)

src\aspnetcore\src\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\BufferWriter.cs (1)

33private ArraySegment<byte> _segment;

IpcCommon.cs (3)

19public static bool TryDeserializeIncoming(string message, out IncomingMessageType messageType, out ArraySegment<JsonElement> args) 22public static bool TryDeserializeOutgoing(string message, out OutgoingMessageType messageType, out ArraySegment<JsonElement> args) 37private static bool TryDeserialize<T>(string message, out T messageType, out ArraySegment<JsonElement> args)

IpcReceiver.cs (1)

35if (IpcCommon.TryDeserializeIncoming(message, out var messageType, out var args))

ArraySegmentExtensions.cs (2)

10public static byte[] AsStandaloneArray(this ArraySegment<byte> arraySegment) 23public static void Validate<T>(this ArraySegment<T> arraySegment)

AuthenticatedEncryption\AuthenticatedEncryptorExtensions.cs (2)

11public static byte[] Encrypt(this IAuthenticatedEncryptor encryptor, ArraySegment<byte> plaintext, ArraySegment<byte> additionalAuthenticatedData, uint preBufferSize, uint postBufferSize)

AuthenticatedEncryption\IAuthenticatedEncryptor.cs (4)

22byte[] Decrypt(ArraySegment<byte> ciphertext, ArraySegment<byte> additionalAuthenticatedData); 34byte[] Encrypt(ArraySegment<byte> plaintext, ArraySegment<byte> additionalAuthenticatedData);

AuthenticatedEncryption\IAuthenticatedEncryptorFactory.cs (4)

20/// be considered equivalent, e.g., the payload returned by one's <see cref="IAuthenticatedEncryptor.Encrypt(ArraySegment{byte}, ArraySegment{byte})"/> 21/// method should be consumable by the other's <see cref="IAuthenticatedEncryptor.Decrypt(ArraySegment{byte}, ArraySegment{byte})"/> method.

AuthenticatedEncryption\IOptimizedAuthenticatedEncryptor.cs (2)

40byte[] Encrypt(ArraySegment<byte> plaintext, ArraySegment<byte> additionalAuthenticatedData, uint preBufferSize, uint postBufferSize);

AuthenticatedEncryption\ISpanAuthenticatedEncryptor.cs (4)

32/// This method provides an optimized, streaming alternative to <see cref="IAuthenticatedEncryptor.Encrypt(System.ArraySegment{byte}, System.ArraySegment{byte})"/>. 51/// This method provides an optimized, streaming alternative to <see cref="IAuthenticatedEncryptor.Decrypt(System.ArraySegment{byte}, System.ArraySegment{byte})"/>.

Cng\CbcAuthenticatedEncryptor.cs (8)

185public byte[] Decrypt(ArraySegment<byte> ciphertext, ArraySegment<byte> additionalAuthenticatedData) 256private int GetEncryptedSize(ArraySegment<byte> plaintext) 382public byte[] Encrypt(ArraySegment<byte> plaintext, ArraySegment<byte> additionalAuthenticatedData) 385public byte[] Encrypt(ArraySegment<byte> plaintext, ArraySegment<byte> additionalAuthenticatedData, uint preBufferSize, uint postBufferSize) 444private uint GetCbcEncryptedOutputSizeWithPadding(ArraySegment<byte> plaintext)

Cng\CngGcmAuthenticatedEncryptor.cs (6)

152public byte[] Decrypt(ArraySegment<byte> ciphertext, ArraySegment<byte> additionalAuthenticatedData) 302public byte[] Encrypt(ArraySegment<byte> plaintext, ArraySegment<byte> additionalAuthenticatedData) 305public byte[] Encrypt(ArraySegment<byte> plaintext, ArraySegment<byte> additionalAuthenticatedData, uint preBufferSize, uint postBufferSize)

ISecret.cs (1)

25void WriteSecretIntoBuffer(ArraySegment<byte> buffer);

KeyManagement\KeyRingBasedDataProtector.cs (2)

286ArraySegment<byte> ciphertext = new ArraySegment<byte>(protectedData, sizeof(uint) + sizeof(Guid), protectedData.Length - (sizeof(uint) + sizeof(Guid))); // chop off magic header + encryptor id 287ArraySegment<byte> additionalAuthenticatedData = new ArraySegment<byte>(_aadTemplate.GetAadForKey(keyIdFromPayload, isProtecting: false));

Managed\AesGcmAuthenticatedEncryptor.cs (6)

156public byte[] Decrypt(ArraySegment<byte> ciphertext, ArraySegment<byte> additionalAuthenticatedData) 188public byte[] Encrypt(ArraySegment<byte> plaintext, ArraySegment<byte> additionalAuthenticatedData) 191public byte[] Encrypt(ArraySegment<byte> plaintext, ArraySegment<byte> additionalAuthenticatedData, uint preBufferSize, uint postBufferSize)

Managed\ManagedAuthenticatedEncryptor.cs (5)

290public byte[] Encrypt(ArraySegment<byte> plaintext, ArraySegment<byte> additionalAuthenticatedData) 471public byte[] Decrypt(ArraySegment<byte> protectedPayload, ArraySegment<byte> additionalAuthenticatedData) 601var EMPTY_ARRAY_SEGMENT = new ArraySegment<byte>(EMPTY_ARRAY);

Secret.cs (3)

28public Secret(ArraySegment<byte> value) 119private static SecureLocalAllocHandle Protect(ArraySegment<byte> plaintext) 235public void WriteSecretIntoBuffer(ArraySegment<byte> buffer)

Latency\AddServerTimingHeaderMiddlewareTests.cs (1)

26ArraySegment<Checkpoint> checkpoints = new(new[] { checkpoint });

Latency\Internal\MockLatencyData.cs (3)

13private readonly ArraySegment<Checkpoint> _checkpoints = new(new[] 20private readonly ArraySegment<Measure> _measures = new(new[] 27private readonly ArraySegment<Tag> _tags = new(new[]

Latency\LatencyContextControlExtensionsTests.cs (1)

37var chkSegment = new ArraySegment<Checkpoint>(checkpoints);

WebSockets\OwinWebSocketAdapter.cs (4)

15Func<ArraySegment<byte> /* data */, 21Func<ArraySegment<byte> /* data */, 102public override async Task<WebSocketReceiveResult> ReceiveAsync(ArraySegment<byte> buffer, CancellationToken cancellationToken) 125public override Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken)

WebSockets\WebSocketAdapter.cs (5)

15Func<ArraySegment<byte> /* data */, 25Func<ArraySegment<byte> /* data */, 60internal Task SendAsync(ArraySegment<byte> buffer, int messageType, bool endOfMessage, CancellationToken cancel) 76internal async Task<WebSocketReceiveTuple> ReceiveAsync(ArraySegment<byte> buffer, CancellationToken cancel) 97private Task RedirectSendToCloseAsync(ArraySegment<byte> buffer, CancellationToken cancel)

Helpers.cs (2)

14internal static ArraySegment<byte> GetChunkHeader(long size) 33internal static ArraySegment<byte> GetChunkHeader(int size)

RequestProcessing\ResponseBody.cs (7)

112private unsafe void FlushInternal(bool endOfRequest, ArraySegment<byte> data = new ArraySegment<byte>()) 183private unsafe void BuildDataChunks(scoped ref UnmanagedBufferAllocator allocator, bool endOfRequest, ArraySegment<byte> data, out Span<HTTP_DATA_CHUNK> dataChunks, out Span<GCHandle> pins) 237var chunkHeaderBuffer = Helpers.GetChunkHeader(data.Count); 271ArraySegment<byte> buffer, 313private unsafe Task FlushInternalAsync(ArraySegment<byte> data, CancellationToken cancellationToken) 537var data = new ArraySegment<byte>(buffer, offset, count); 589var data = new ArraySegment<byte>(buffer, offset, count);

RequestProcessing\ResponseStreamAsyncResult.cs (4)

38internal ResponseStreamAsyncResult(ResponseBody responseStream, ArraySegment<byte> data, bool chunked, 59var chunkHeaderBuffer = new ArraySegment<byte>(); 118var chunkHeaderBuffer = new ArraySegment<byte>(); 157private static void SetDataChunk(HTTP_DATA_CHUNK[] chunks, ref int chunkIndex, object[] objectsToPin, ref int pinIndex, ArraySegment<byte> segment)

src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticPoolBlock.cs (1)

164protected override bool TryGetArray(out ArraySegment<byte> segment)

src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticPoolBlock.cs (1)

164protected override bool TryGetArray(out ArraySegment<byte> segment)

src\aspnetcore\src\Shared\ServerInfrastructure\BufferExtensions.cs (3)

52public static ArraySegment<byte> GetArray(this Memory<byte> buffer) 57public static ArraySegment<byte> GetArray(this ReadOnlyMemory<byte> memory) 59if (!MemoryMarshal.TryGetArray(memory, out var result))

src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticPoolBlock.cs (1)

164protected override bool TryGetArray(out ArraySegment<byte> segment)

src\aspnetcore\src\Shared\ServerInfrastructure\BufferExtensions.cs (3)

52public static ArraySegment<byte> GetArray(this Memory<byte> buffer) 57public static ArraySegment<byte> GetArray(this ReadOnlyMemory<byte> memory) 59if (!MemoryMarshal.TryGetArray(memory, out var result))

src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticPoolBlock.cs (1)

164protected override bool TryGetArray(out ArraySegment<byte> segment)

src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticPoolBlock.cs (1)

164protected override bool TryGetArray(out ArraySegment<byte> segment)

Internal\BufferExtensions.cs (3)

10public static ArraySegment<byte> GetArray(this Memory<byte> memory) 15public static ArraySegment<byte> GetArray(this ReadOnlyMemory<byte> memory) 17if (!MemoryMarshal.TryGetArray(memory, out var result))

Internal\SocketSender.cs (2)

14private List<ArraySegment<byte>>? _bufferList; 83_bufferList = new List<ArraySegment<byte>>();

Internal\RedisProtocol.cs (1)

243var isArray = MemoryMarshal.TryGetArray(serializedMessage.Serialized, out var array);

Util\EventedStreamReader.cs (2)

15public delegate void OnReceivedChunkHandler(ArraySegment<char> chunk); 115private void OnChunk(ArraySegment<char> chunk)

TestWebSocket.cs (5)

110public override async Task<WebSocketReceiveResult> ReceiveAsync(ArraySegment<byte> buffer, CancellationToken cancellationToken) 154public override Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) 194private static void ValidateSegment(ArraySegment<byte> buffer) 220public Message(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage) 240public ArraySegment<byte> Buffer { get; set; }

ServiceFakesHostExtensions.cs (1)

75return ArraySegment<Uri>.Empty;

BufferedReadStream.cs (1)

53public ArraySegment<byte> BufferedData

MultipartReaderStream.cs (3)

178var bufferedData = _innerStream.BufferedData; 262var bufferedData = _innerStream.BufferedData; 341private static bool SubMatch(ArraySegment<byte> segment1, ReadOnlySpan<byte> matchBytes, out int matchOffset, out int matchCount)

Evaluation\IntrinsicFunctions.cs (1)

251public static object GetRegistryValueFromView(string keyName, string valueName, object defaultValue, ArraySegment<object> views)

src\msbuild\artifacts\.packages\microsoft.codeanalysis.collections\5.0.0-1.25277.114\contentFiles\cs\net9.0\Segmented\SegmentedArray.cs (3)

69if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 164if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 231if (!MemoryMarshal.TryGetArray<T>(memory, out var segment))

CommandLine\CommonCompiler.cs (1)

404ArraySegment<byte> bytes;

CryptographicHashProvider.cs (1)

225internal static ImmutableArray<byte> ComputeHash(HashAlgorithmName algorithmName, IEnumerable<ArraySegment<byte>> bytes)

DiaSymReader\Utilities\ComMemoryStream.cs (1)

75public IEnumerable<ArraySegment<byte>> GetChunks()

DiaSymReader\Writer\SymUnmanagedWriter.cs (1)

27public abstract IEnumerable<ArraySegment<byte>> GetUnderlyingData();

DiaSymReader\Writer\SymUnmanagedWriterImpl.cs (1)

128public override IEnumerable<ArraySegment<byte>> GetUnderlyingData()

EmbeddedText.cs (2)

175public static EmbeddedText FromBytes(string filePath, ArraySegment<byte> bytes, SourceHashAlgorithm checksumAlgorithm = SourceHashAlgorithm.Sha1) 264internal static ImmutableArray<byte> CreateBlob(ArraySegment<byte> bytes)

EncodedStringText.cs (3)

163if (TryGetBytesFromStream(data, out ArraySegment<byte> bytes) && bytes.Offset == 0 && bytes.Array is object) 186internal static bool TryGetBytesFromStream(Stream data, out ArraySegment<byte> bytes) 213out ArraySegment<byte> bytes)

InternalUtilities\IncrementalHashExtensions.cs (3)

22internal static void AppendData(this IncrementalHash hash, IEnumerable<ArraySegment<byte>> blobs) 24foreach (var blob in blobs) 30internal static void AppendData(this IncrementalHash hash, ArraySegment<byte> segment)

ReferenceManager\CommonReferenceManager.Binding.cs (2)

242var referenceBindingsToProcess = ArrayBuilder<(MetadataReference, ArraySegment<AssemblyReferenceBinding>)>.GetInstance(); 395[Out] ArrayBuilder<(MetadataReference, ArraySegment<AssemblyReferenceBinding>)> result)

src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (3)

69if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 164if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 231if (!MemoryMarshal.TryGetArray<T>(memory, out var segment))

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (3)

163if (TryGetBytesFromStream(data, out ArraySegment<byte> bytes) && bytes.Offset == 0 && bytes.Array is object) 186internal static bool TryGetBytesFromStream(Stream data, out ArraySegment<byte> bytes) 213out ArraySegment<byte> bytes)

src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (3)

69if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 164if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 231if (!MemoryMarshal.TryGetArray<T>(memory, out var segment))

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Extensions\Symbols\ITypeSymbolExtensions.cs (1)

745or nameof(ArraySegment<>)

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (3)

163if (TryGetBytesFromStream(data, out ArraySegment<byte> bytes) && bytes.Offset == 0 && bytes.Array is object) 186internal static bool TryGetBytesFromStream(Stream data, out ArraySegment<byte> bytes) 213out ArraySegment<byte> bytes)

src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (3)

69if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 164if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 231if (!MemoryMarshal.TryGetArray<T>(memory, out var segment))

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Extensions\Symbols\ITypeSymbolExtensions.cs (1)

745or nameof(ArraySegment<>)

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (3)

163if (TryGetBytesFromStream(data, out ArraySegment<byte> bytes) && bytes.Offset == 0 && bytes.Array is object) 186internal static bool TryGetBytesFromStream(Stream data, out ArraySegment<byte> bytes) 213out ArraySegment<byte> bytes)

src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (3)

69if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 164if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 231if (!MemoryMarshal.TryGetArray<T>(memory, out var segment))

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Extensions\Symbols\ITypeSymbolExtensions.cs (1)

745or nameof(ArraySegment<>)

Parser\SlidingTextWindow.cs (3)

88private ArraySegment<char> _characterWindow; 170/// + <see cref="_characterWindow"/>'s <see cref="ArraySegment{T}.Count"/>. 470public static ArraySegment<char> GetCharacterWindow(in SlidingTextWindow window) => window._characterWindow;

src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (3)

69if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 164if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 231if (!MemoryMarshal.TryGetArray<T>(memory, out var segment))

Symbols\ITypeSymbolExtensions.cs (1)

745or nameof(ArraySegment<>)

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (3)

163if (TryGetBytesFromStream(data, out ArraySegment<byte> bytes) && bytes.Offset == 0 && bytes.Array is object) 186internal static bool TryGetBytesFromStream(Stream data, out ArraySegment<byte> bytes) 213out ArraySegment<byte> bytes)

src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (3)

69if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 164if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 231if (!MemoryMarshal.TryGetArray<T>(memory, out var segment))

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Extensions\Symbols\ITypeSymbolExtensions.cs (1)

745or nameof(ArraySegment<>)

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (3)

163if (TryGetBytesFromStream(data, out ArraySegment<byte> bytes) && bytes.Offset == 0 && bytes.Array is object) 186internal static bool TryGetBytesFromStream(Stream data, out ArraySegment<byte> bytes) 213out ArraySegment<byte> bytes)

src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (3)

69if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 164if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 231if (!MemoryMarshal.TryGetArray<T>(memory, out var segment))

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Extensions\Symbols\ITypeSymbolExtensions.cs (1)

745or nameof(ArraySegment<>)

DataFrame.cs (1)

355ArraySegment<int> segment = new ArraySegment<int>(shuffleArray, 0, shuffleLowerLimit);

PrimitiveDataFrameColumn.Sort.cs (1)

66bool isArray = MemoryMarshal.TryGetArray(typedBuffer, out ArraySegment<T> arraySegment);

Extensions\SymUnmanagedExtensions.Document.cs (3)

90/// default(<see cref="ArraySegment{T}"/>) if the document doesn't have embedded source, 93public static ArraySegment<byte> GetEmbeddedSource(this ISymUnmanagedDocument document) 103return default(ArraySegment<byte>);

Utilities\ComMemoryStream.cs (1)

81public IEnumerable<ArraySegment<byte>> GetChunks()

Writer\SymUnmanagedWriter.cs (1)

24public abstract IEnumerable<ArraySegment<byte>> GetUnderlyingData();

Writer\SymUnmanagedWriterImpl.cs (1)

125public override IEnumerable<ArraySegment<byte>> GetUnderlyingData()

src\RpmHeader.cs (6)

56builder.AppendLine($"\t\t{((ArraySegment<byte>)entry.Value).Count} bytes"); 57builder.AppendLine($"\t\t{BitConverter.ToString(((ArraySegment<byte>)entry.Value).Array!, ((ArraySegment<byte>)entry.Value).Offset, ((ArraySegment<byte>)entry.Value).Count)}"); 257ArraySegment<byte> binary = (ArraySegment<byte>)entry.Value;

BlockingMemoryStream.cs (1)

14private ArraySegment<byte> _remaining;

ChatCompletion\ChatResponseExtensions.cs (1)

335if (!MemoryMarshal.TryGetArray(current.Data, out var segment))

Contents\DataContent.cs (2)

242if (!MemoryMarshal.TryGetArray(Data, out ArraySegment<byte> array)) 295string base64 = MemoryMarshal.TryGetArray(data, out ArraySegment<byte> segment) ?

Files\HostedFileClientExtensions.cs (1)

41MemoryStream stream = MemoryMarshal.TryGetArray(content.Data, out ArraySegment<byte> arraySegment) ?

parent\parent\parent\eng\MSBuild\parent\parent\src\LegacySupport\FilePolyfills\FilePolyfills.cs (1)

61if (MemoryMarshal.TryGetArray(bytes, out ArraySegment<byte> segment) &&

SpeechToText\SpeechToTextClientExtensions.cs (2)

50var audioSpeechStream = MemoryMarshal.TryGetArray(audioSpeechContent.Data, out var array) ? 72var audioSpeechStream = MemoryMarshal.TryGetArray(audioSpeechContent.Data, out var array) ?

Embeddings\EmbeddingTests.cs (1)

35Assert.True(MemoryMarshal.TryGetArray(e.Vector, out ArraySegment<float> array));

parent\parent\parent\eng\MSBuild\parent\parent\src\LegacySupport\FilePolyfills\FilePolyfills.cs (1)

61if (MemoryMarshal.TryGetArray(bytes, out ArraySegment<byte> segment) &&

OpenAIImageGenerator.cs (1)

61imageStream = MemoryMarshal.TryGetArray(dataContent.Data, out var array) ?

Internal\BufferChunk.cs (1)

87internal ArraySegment<byte> AsArraySegment() => Length == 0 ? default! : new(OversizedArray!, Offset, Length);

Internal\DefaultHybridCache.StampedeStateT.cs (1)

227result.AsArraySegment(), Key.Key, CacheItem.Tags, Cache, out ArraySegment<byte> payload, out TimeSpan remainingTime,

Internal\HybridCachePayload.cs (2)

173public static HybridCachePayloadParseResult TryParse(ArraySegment<byte> source, string key, TagSet knownTags, DefaultHybridCache cache, 174out ArraySegment<byte> payload, out TimeSpan remainingTime, out PayloadFlags flags, out ushort entropy, out TagSet pendingTags, out Exception? fault)

DistributedCacheTests.cs (2)

335Assert.True(MemoryMarshal.TryGetArray(payload.First, out var segment)); 385protected override bool TryGetArray(out ArraySegment<byte> segment)

PayloadTests.cs (9)

DatabaseOperations.cs (3)

131public void SetCacheItem(string key, ArraySegment<byte> value, DistributedCacheEntryOptions options) 169public async Task SetCacheItemAsync(string key, ArraySegment<byte> value, DistributedCacheEntryOptions options, CancellationToken token = default(CancellationToken)) 325if (MemoryMarshal.TryGetArray<byte>(memory, out var segment))

IDatabaseOperations.cs (2)

30void SetCacheItem(string key, ArraySegment<byte> value, DistributedCacheEntryOptions options); 32Task SetCacheItemAsync(string key, ArraySegment<byte> value, DistributedCacheEntryOptions options, CancellationToken token = default(CancellationToken));

SqlParameterCollectionExtensions.cs (1)

25public static SqlParameterCollection AddCacheItemValue(this SqlParameterCollection parameters, ArraySegment<byte> value)

SqlServerCache.cs (2)

234private static ArraySegment<byte> Linearize(in ReadOnlySequence<byte> value, out byte[]? lease) 244if (value.IsSingleSegment && MemoryMarshal.TryGetArray(value.First, out var segment))

DependencyContextJsonReader.cs (2)

26ArraySegment<byte> buffer = ReadToEnd(stream); 53private static ArraySegment<byte> ReadToEnd(Stream stream)

Latency\Internal\HttpClientLatencyLogEnricherTest.cs (3)

22var checkpoints = new ArraySegment<Checkpoint>(new[] { new Checkpoint("a", default, default), new Checkpoint("b", default, default) }); 39var checkpoints = new ArraySegment<Checkpoint>(new[] { new Checkpoint("a", default, default), new Checkpoint("b", default, default) }); 59var checkpoints = new ArraySegment<Checkpoint>(new[] { new Checkpoint("a", default, default), new Checkpoint("b", default, default) });

BlobAppendReferenceWrapper.cs (1)

31public async Task AppendAsync(ArraySegment<byte> data, CancellationToken cancellationToken)

BlobLoggerProvider.cs (1)

80var tryGetBuffer = stream.TryGetBuffer(out var buffer);

ICloudAppendBlob.cs (1)

20Task AppendAsync(ArraySegment<byte> data, CancellationToken cancellationToken);

EventSourceLogger.cs (1)

292string result = stream.TryGetBuffer(out ArraySegment<byte> buffer)

Resolver\DnsDataReader.cs (2)

12public ArraySegment<byte> MessageBuffer { get; private set; } 16public DnsDataReader(ArraySegment<byte> buffer, bool returnToPool = false)

Resolver\DnsResolver.cs (5)

282static bool TryReadTarget(in DnsResourceRecord record, ArraySegment<byte> messageBytes, out EncodedDomainName target) 292var gotArray = MemoryMarshal.TryGetArray(record.Data, out ArraySegment<byte> segment); 552Response = new DnsResponse(ArraySegment<byte>.Empty, header, queryStartedTime, queryStartedTime, null!, null!, null!), 565Response = new DnsResponse(ArraySegment<byte>.Empty, header, queryStartedTime, queryStartedTime, null!, null!, null!), 579Response = new DnsResponse(ArraySegment<byte>.Empty, header, queryStartedTime, queryStartedTime, null!, null!, null!),

Resolver\DnsResponse.cs (2)

16public ArraySegment<byte> RawMessageBytes { get; private set; } 18public DnsResponse(ArraySegment<byte> rawData, DnsMessageHeader header, DateTime createdAt, DateTime expiration, List<DnsResourceRecord> answers, List<DnsResourceRecord> authorities, List<DnsResourceRecord> additionals)

Resolver\LoopbackDnsServer.cs (1)

32private static async Task<int> ProcessRequestCore(IPEndPoint remoteEndPoint, ArraySegment<byte> message, Func<LoopbackDnsResponseBuilder, IPEndPoint, Task> action, Memory<byte> responseBuffer)

Latency\Internal\CheckpointTracker.cs (1)

77public ArraySegment<Checkpoint> Checkpoints => new(_checkpoints, 0, _numCheckpoints);

Latency\Internal\MeasureTracker.cs (1)

123public ArraySegment<Measure> Measures

Latency\Internal\TagCollection.cs (1)

70public ArraySegment<Tag> Tags => new(_tags, 0, _numTags);

Latency\LatencyData.cs (6)

15private readonly ArraySegment<Tag> _tags; 16private readonly ArraySegment<Checkpoint> _checkpoints; 17private readonly ArraySegment<Measure> _measures; 27public LatencyData(ArraySegment<Tag> tags, ArraySegment<Checkpoint> checkpoints, ArraySegment<Measure> measures, long durationTimestamp, long durationTimestampFrequency)

Latency\NullLatencyContext.cs (3)

13private readonly ArraySegment<Checkpoint> _checkpoints = new(Array.Empty<Checkpoint>()); 14private readonly ArraySegment<Tag> _tags = new(Array.Empty<Tag>()); 15private readonly ArraySegment<Measure> _measures = new(Array.Empty<Measure>());

Latency\LatencyDataTests.cs (6)

25ArraySegment<Checkpoint> checkpoints = new ArraySegment<Checkpoint>(LatencyDataTests.GetCheckpoints(num)); 26ArraySegment<Measure> measures = new ArraySegment<Measure>(GetMeasures(num)); 27ArraySegment<Tag> tags = new ArraySegment<Tag>(GetTags(num)); 44ArraySegment<Checkpoint> checkpoints = new ArraySegment<Checkpoint>(LatencyDataTests.GetCheckpoints(num), 1, numCheckpoints); 45ArraySegment<Measure> measures = new ArraySegment<Measure>(GetMeasures(num), 2, numMeasures); 46ArraySegment<Tag> tags = new ArraySegment<Tag>(GetTags(num), 3, numTags);

Latency\Internal\CheckpointTrackerTests.cs (1)

75var c = ct.Checkpoints;

Latency\Internal\LatencyConsoleExporterTests.cs (9)

167ArraySegment<Checkpoint> checkpoints = new(new[] 174ArraySegment<Measure> measures = new(new[] 181ArraySegment<Tag> tags = new(new[] 193ArraySegment<Checkpoint> checkpoints = new(new[] 200ArraySegment<Measure> measures = new(new[] 207ArraySegment<Tag> tags = new(new[] 219ArraySegment<Checkpoint> checkpoints = new(Array.Empty<Checkpoint>()); 220ArraySegment<Measure> measures = new(Array.Empty<Measure>()); 221ArraySegment<Tag> tags = new(Array.Empty<Tag>());

Utilities\HybridMemoryStream.cs (1)

173ArraySegment<byte> buffer;

DataLoadSave\Binary\BinaryLoader.cs (2)

1811ArraySegment<byte> buffer; 1892ArraySegment<byte> buf;

DataLoadSave\Binary\BinarySaver.cs (3)

230ArraySegment<byte> buffer; 373ArraySegment<byte> buffer; 427ArraySegment<byte> buffer;

DataLoadSave\Binary\Codecs.cs (1)

892ArraySegment<byte> buffer;

SentencepieceModel.cs (1)

298memoryStream.TryGetBuffer(out ArraySegment<byte> segment))

System\Value.cs (20)

src\runtime\src\libraries\shims\mscorlib\ref\mscorlib.cs (1)

53[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.ArraySegment<>))]

netstandard.cs (1)

46[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.ArraySegment<>))]

CircularMemoryStream.cs (1)

16internal event EventHandler<ArraySegment<byte>>? OnFlush;

HashObjectWriter.cs (1)

261private void OnFlush(object? sender, ArraySegment<byte> bytes)

src\roslyn\src\Compilers\Core\Portable\EncodedStringText.cs (3)

163if (TryGetBytesFromStream(data, out ArraySegment<byte> bytes) && bytes.Offset == 0 && bytes.Array is object) 186internal static bool TryGetBytesFromStream(Stream data, out ArraySegment<byte> bytes) 213out ArraySegment<byte> bytes)

src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (3)

69if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 164if (!MemoryMarshal.TryGetArray<T>(memory, out var segment)) 231if (!MemoryMarshal.TryGetArray<T>(memory, out var segment))

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Extensions\Symbols\ITypeSymbolExtensions.cs (1)

745or nameof(ArraySegment<>)

System\Diagnostics\Process.Multiplexing.cs (9)

src\runtime\src\libraries\Common\src\System\Security\Cryptography\CryptoPool.cs (1)

15internal static void Return(ArraySegment<byte> arraySegment, int clearSize = ClearAll)

System\Formats\Nrbf\Utils\TypeNameHelpers.cs (2)

132ArraySegment<char> assemblyQualifiedName = RentAssemblyQualifiedName(rawName, libraryRecord.RawLibraryName); 205private static ArraySegment<char> RentAssemblyQualifiedName(string typeName, string libraryName)

System\Buffers\ReadOnlySequence.cs (1)

153else if (MemoryMarshal.TryGetArray(memory, out ArraySegment<T> segment))

System\Buffers\ReadOnlySequence.Helpers.cs (1)

539internal bool TryGetArray(out ArraySegment<T> segment)

System\Runtime\InteropServices\SequenceMarshal.cs (1)

31public static bool TryGetArray<T>(ReadOnlySequence<T> sequence, out ArraySegment<T> segment)

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

95internal static void ValidateArraySegment(ArraySegment<byte> arraySegment, string parameterName)

System\Net\Managed\HttpListenerContext.Managed.cs (1)

92public Task<HttpListenerWebSocketContext> AcceptWebSocketAsync(string? subProtocol, int receiveBufferSize, TimeSpan keepAliveInterval, ArraySegment<byte> internalBuffer)

System\Net\Managed\WebSockets\HttpWebSocket.Managed.cs (2)

167ArraySegment<byte> buffer, 172ArraySegment<byte> buffer,

System\Net\HttpWebRequest.cs (1)

1273ArraySegment<byte> buffer = requestBufferingStream.GetBuffer();

System\Net\RequestBufferingStream.cs (2)

104public ArraySegment<byte> GetBuffer() 106ArraySegment<byte> bytes;

src\runtime\src\libraries\Common\src\System\Security\Cryptography\CryptoPool.cs (1)

15internal static void Return(ArraySegment<byte> arraySegment, int clearSize = ClearAll)

src\runtime\src\libraries\Common\src\System\Text\UrlBase64Encoding.cs (1)

14internal static ArraySegment<char> RentEncode(ReadOnlySpan<byte> input)

System\Net\Security\SslStreamCertificateContext.Linux.cs (3)

312ArraySegment<byte> encoded = new ArraySegment<byte>(rentedBytes, 0, encodingSize); 314ArraySegment<char> rentedChars = UrlBase64Encoding.RentEncode(encoded); 387private static string MakeUrl(string baseUri, ArraySegment<char> encodedRequest)

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

16public static void ValidateSegment(ArraySegment<byte> segment)

System\Net\Sockets\Socket.cs (10)

System\Net\Sockets\Socket.Tasks.cs (17)

System\Net\Sockets\SocketAsyncContext.Unix.cs (12)

System\Net\Sockets\SocketAsyncEventArgs.cs (6)

27private IList<ArraySegment<byte>>? _bufferList; 28private List<ArraySegment<byte>>? _bufferListInternal; 123bool success = MemoryMarshal.TryGetArray(_buffer, out ArraySegment<byte> arraySegment); 147public IList<ArraySegment<byte>>? BufferList 169_bufferListInternal = new List<ArraySegment<byte>>(bufferCount); 178ArraySegment<byte> buffer = value[i];

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

System\Net\Sockets\SocketTaskExtensions.cs (7)

47public static Task<int> ReceiveAsync(this Socket socket, ArraySegment<byte> buffer, SocketFlags socketFlags) => 53public static Task<int> ReceiveAsync(this Socket socket, IList<ArraySegment<byte>> buffers, SocketFlags socketFlags) => 56public static Task<SocketReceiveFromResult> ReceiveFromAsync(this Socket socket, ArraySegment<byte> buffer, SocketFlags socketFlags, EndPoint remoteEndPoint) => 59public static Task<SocketReceiveMessageFromResult> ReceiveMessageFromAsync(this Socket socket, ArraySegment<byte> buffer, SocketFlags socketFlags, EndPoint remoteEndPoint) => 63public static Task<int> SendAsync(this Socket socket, ArraySegment<byte> buffer, SocketFlags socketFlags) => 69public static Task<int> SendAsync(this Socket socket, IList<ArraySegment<byte>> buffers, SocketFlags socketFlags) => 73public static Task<int> SendToAsync(this Socket socket, ArraySegment<byte> buffer, SocketFlags socketFlags, EndPoint remoteEP) =>

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

95internal static void ValidateArraySegment(ArraySegment<byte> arraySegment, string parameterName)

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

297public override Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) 351public override Task<WebSocketReceiveResult> ReceiveAsync(ArraySegment<byte> buffer, CancellationToken cancellationToken)

System\Net\WebSockets\WebSocket.cs (7)

28public abstract Task<WebSocketReceiveResult> ReceiveAsync(ArraySegment<byte> buffer, 30public abstract Task SendAsync(ArraySegment<byte> buffer, 37if (MemoryMarshal.TryGetArray(buffer, out ArraySegment<byte> arraySegment)) 57MemoryMarshal.TryGetArray(buffer, out ArraySegment<byte> arraySegment) ? 113public static ArraySegment<byte> CreateClientBuffer(int receiveBufferSize, int sendBufferSize) 120public static ArraySegment<byte> CreateServerBuffer(int receiveBufferSize) 186TimeSpan keepAliveInterval, bool useZeroMaskingKey, ArraySegment<byte> internalBuffer)

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

95internal static void ValidateArraySegment(ArraySegment<byte> arraySegment, string parameterName)

System\Net\WebSockets\BrowserWebSockets\BrowserWebSocket.cs (4)

154public override Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) 174public override Task<WebSocketReceiveResult> ReceiveAsync(ArraySegment<byte> buffer, CancellationToken cancellationToken) 369private async Task SendAsyncCore(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) 420private async Task<WebSocketReceiveResult> ReceiveAsyncCore(ArraySegment<byte> buffer, CancellationToken cancellationToken)

System\Net\WebSockets\BrowserWebSockets\ClientWebSocketOptions.cs (1)

145public void SetBuffer(int receiveBufferSize, int sendBufferSize, ArraySegment<byte> buffer)

System\Net\WebSockets\ClientWebSocket.cs (2)

141public override Task SendAsync(ArraySegment<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) => 150public override Task<WebSocketReceiveResult> ReceiveAsync(ArraySegment<byte> buffer, CancellationToken cancellationToken) =>

src\runtime\src\libraries\System.Private.CoreLib\src\System\ArraySegment.cs (12)

37public static ArraySegment<T> Empty { get; } = new ArraySegment<T>(new T[0]); 112public void CopyTo(ArraySegment<T> destination) 126obj is ArraySegment<T> other && Equals(other); 128public bool Equals(ArraySegment<T> obj) => 131public ArraySegment<T> Slice(int index) 143public ArraySegment<T> Slice(int index, int count) 169public static bool operator ==(ArraySegment<T> a, ArraySegment<T> b) => a.Equals(b); 171public static bool operator !=(ArraySegment<T> a, ArraySegment<T> b) => !(a == b); 173public static implicit operator ArraySegment<T>(T[] array) => array != null ? new ArraySegment<T>(array) : default; 288internal Enumerator(ArraySegment<T> arraySegment)

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

53protected internal virtual bool TryGetArray(out ArraySegment<T> segment)

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

184public virtual bool TryGetBuffer(out ArraySegment<byte> buffer) 410MemoryMarshal.TryGetArray(buffer, out ArraySegment<byte> destinationArray) ? 693if (MemoryMarshal.TryGetArray(buffer, out ArraySegment<byte> sourceArray))

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

160private int ReadSpan(Span<byte> destination, ArraySegment<byte> arraySegment) 479private void WriteSpan(ReadOnlySpan<byte> source, ArraySegment<byte> arraySegment)

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

311if (MemoryMarshal.TryGetArray(buffer, out ArraySegment<byte> array)) 735if (MemoryMarshal.TryGetArray(buffer, out ArraySegment<byte> array))

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

275new ValueTask<int>(MemoryMarshal.TryGetArray(buffer, out ArraySegment<char> array) ? 305new ValueTask<int>(MemoryMarshal.TryGetArray(buffer, out ArraySegment<char> array) ?

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

674MemoryMarshal.TryGetArray(buffer, out ArraySegment<char> array) ? 769MemoryMarshal.TryGetArray(buffer, out ArraySegment<char> array) ?

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

468MemoryMarshal.TryGetArray(buffer, out ArraySegment<byte> destinationArray) ? 734if (MemoryMarshal.TryGetArray(buffer, out ArraySegment<byte> sourceArray))

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

50public override bool TryGetBuffer(out ArraySegment<byte> buffer)

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

179/// Defines an implicit conversion of a <see cref="ArraySegment{T}"/> to a <see cref="Memory{T}"/> 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 (8)

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

114/// Defines an implicit conversion of a <see cref="ArraySegment{T}"/> to a <see cref="ReadOnlyMemory{T}"/> 116public static implicit operator ReadOnlyMemory<T>(ArraySegment<T> segment) => new ReadOnlyMemory<T>(segment.Array, segment.Offset, segment.Count);

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

209/// Defines an implicit conversion of a <see cref="ArraySegment{T}"/> to a <see cref="ReadOnlySpan{T}"/> 211public static implicit operator ReadOnlySpan<T>(ArraySegment<T> segment)

src\runtime\src\libraries\System.Private.CoreLib\src\System\Runtime\InteropServices\MemoryMarshal.cs (3)

311public static bool TryGetArray<T>(ReadOnlyMemory<T> memory, out ArraySegment<T> segment) 340if (Unsafe.As<MemoryManager<T>>(obj).TryGetArray(out ArraySegment<T> tempArraySegment)) 354segment = ArraySegment<T>.Empty;

src\runtime\src\libraries\System.Private.CoreLib\src\System\Runtime\Loader\AssemblyLoadContext.cs (1)

447if (stream.GetType() == typeof(MemoryStream) && ((MemoryStream)stream).TryGetBuffer(out ArraySegment<byte> memoryStreamBuffer))

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

214/// Defines an implicit conversion of a <see cref="ArraySegment{T}"/> to a <see cref="Span{T}"/> 216public static implicit operator Span<T>(ArraySegment<T> segment) =>

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

102ArraySegment<byte> pendingData = FinalFlushWriteBuffers(); 130ArraySegment<byte> pendingData = FinalFlushWriteBuffers(); 148async ValueTask DisposeAsyncCore(ArraySegment<byte> pendingData) 232private ArraySegment<byte> FinalFlushWriteBuffers() 584ArraySegment<char> decodedChars = new ArraySegment<char>(scratchChars, 0, charsWritten);

System\Runtime\Serialization\ClassDataContract.cs (1)

290return t.IsGenericType && (t.GetGenericTypeDefinition() == typeof(ArraySegment<>));

System\Runtime\Serialization\CollectionDataContract.cs (1)

1004return t.IsGenericType && (t.GetGenericTypeDefinition() == typeof(ArraySegment<>));

System\Runtime\Serialization\Json\JsonEncodingStreamWrapper.cs (1)

120public static ArraySegment<byte> ProcessBuffer(byte[] buffer, int offset, int count, Encoding? encoding)

System\Runtime\Serialization\Json\XmlJsonReader.cs (1)

791ArraySegment<byte> seg = JsonEncodingStreamWrapper.ProcessBuffer(buffer, offset, count, encoding);

System\Runtime\Serialization\MemoryStreamAdapter.cs (1)

95if (memoryStream.TryGetBuffer(out ArraySegment<byte> innerBuffer))

System\Xml\EncodingStreamWrapper.cs (2)

432internal static ArraySegment<byte> ProcessBuffer(byte[] buffer, int offset, int count, Encoding? encoding) 440ArraySegment<byte> seg;

System\Xml\XmlBinaryWriter.cs (2)

1064ArraySegment<byte> arraySegment; 1134ArraySegment<byte> arraySegment;

System\Xml\XmlUTF8TextReader.cs (1)

567ArraySegment<byte> seg = EncodingStreamWrapper.ProcessBuffer(buffer, offset, count, encoding);

System\IO\BinaryReaderExtensions.cs (1)

244else if (values is ArraySegment<T> arraySegment)

System\Value.cs (20)

System\Xml\Serialization\Types.cs (1)

1014return t.IsGenericType && (t.GetGenericTypeDefinition() == typeof(ArraySegment<>));

System\Reflection\Metadata\Blob.cs (1)

21public ArraySegment<byte> GetBytes() => new ArraySegment<byte>(Buffer, Start, Length);

src\runtime\artifacts\obj\System.Runtime\Release\net11.0\System.Runtime.Forwards.cs (1)

41[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.ArraySegment<>))]

System\Runtime\InteropServices\JavaScript\Marshaling\JSMarshalerArgument.Byte.cs (2)

123public unsafe void ToManaged(out ArraySegment<byte> value) 136public unsafe void ToJS(ArraySegment<byte> value)

System\Runtime\InteropServices\JavaScript\Marshaling\JSMarshalerArgument.Double.cs (2)

129public unsafe void ToManaged(out ArraySegment<double> value) 142public unsafe void ToJS(ArraySegment<double> value)

System\Runtime\InteropServices\JavaScript\Marshaling\JSMarshalerArgument.Int32.cs (2)

123public unsafe void ToManaged(out ArraySegment<int> value) 136public unsafe void ToJS(ArraySegment<int> value)

System\Runtime\InteropServices\JavaScript\Marshaling\JSMarshalerArgument.Object.cs (1)

328else if (type.IsGenericType && type.GetGenericTypeDefinition() == typeof(ArraySegment<>))

System\Runtime\InteropServices\JavaScript\Marshaling\JSMarshalerArgument.Single.cs (2)

129public unsafe void ToManaged(out ArraySegment<float> value) 142public unsafe void ToJS(ArraySegment<float> value)

src\runtime\src\libraries\Common\src\Interop\Windows\BCrypt\Interop.BCryptExportKey.cs (1)

26internal static ArraySegment<byte> BCryptExportKey(SafeBCryptKeyHandle key, string blobType)

src\runtime\src\libraries\Common\src\System\Security\Cryptography\CngPkcs8.cs (2)

163ArraySegment<byte> decrypted = KeyFormatHelper.DecryptPkcs8( 228ArraySegment<byte> decrypted = KeyFormatHelper.DecryptPkcs8(password, source, out int innerRead);

src\runtime\src\libraries\Common\src\System\Security\Cryptography\CompositeMLDsaCng.Windows.cs (3)

136ArraySegment<byte> pkcs8 = GetRentedPkcs8ForEncryptedOnlyExport(); 166ArraySegment<byte> pkcs8 = GetRentedPkcs8ForEncryptedOnlyExport(); 233private ArraySegment<byte> GetRentedPkcs8ForEncryptedOnlyExport()

src\runtime\src\libraries\Common\src\System\Security\Cryptography\CompositeMLDsaImplementation.Windows.cs (1)

159ArraySegment<byte> keyBlob = Interop.BCrypt.BCryptExportKey(_key, keyBlobType);

src\runtime\src\libraries\Common\src\System\Security\Cryptography\CryptoPool.cs (1)

15internal static void Return(ArraySegment<byte> arraySegment, int clearSize = ClearAll)

src\runtime\src\libraries\Common\src\System\Security\Cryptography\KeyFormatHelper.Encrypted.cs (7)

284internal static ArraySegment<byte> DecryptPkcs8( 296internal static ArraySegment<byte> DecryptPkcs8( 314ArraySegment<byte> decrypted = DecryptPkcs8(password, source, out bytesRead); 339ArraySegment<byte> decrypted = KeyFormatHelper.DecryptPkcs8(passwordBytes, source, out bytesRead); 358private static ArraySegment<byte> DecryptPkcs8( 408ArraySegment<byte> decrypted = DecryptPkcs8( 444ArraySegment<byte> decrypted = DecryptPkcs8(

src\runtime\src\libraries\Common\src\System\Security\Cryptography\MLDsaCng.Windows.cs (3)

220ArraySegment<byte> pkcs8 = GetRentedPkcs8ForEncryptedOnlyExport(); 481ArraySegment<byte> pkcs8 = GetRentedPkcs8ForEncryptedOnlyExport(); 507private ArraySegment<byte> GetRentedPkcs8ForEncryptedOnlyExport()

src\runtime\src\libraries\Common\src\System\Security\Cryptography\MLDsaImplementation.Windows.cs (1)

230ArraySegment<byte> keyBlob = Interop.BCrypt.BCryptExportKey(_key, keyBlobType);

src\runtime\src\libraries\Common\src\System\Security\Cryptography\MLKemImplementation.Windows.cs (1)

166ArraySegment<byte> key = Interop.BCrypt.BCryptExportKey(_key, blobKind);

src\runtime\src\libraries\Common\src\System\Security\Cryptography\Pkcs\Pkcs8PrivateKeyInfo.cs (2)

178ArraySegment<byte> decrypted = KeyFormatHelper.DecryptPkcs8( 209ArraySegment<byte> decrypted = KeyFormatHelper.DecryptPkcs8(

src\runtime\src\libraries\Common\src\System\Security\Cryptography\RSACng.ImportExport.cs (1)

27ArraySegment<byte> keyBlob = parameters.ToBCryptBlob();

src\runtime\src\libraries\Common\src\System\Security\Cryptography\X25519DiffieHellmanImplementation.Windows.cs (1)

200ArraySegment<byte> key = Interop.BCrypt.BCryptExportKey(_key, blobType);

src\runtime\src\libraries\Common\src\System\Security\Cryptography\X509Certificates\X509CertificateLoader.Pkcs12.cs (2)

1106ArraySegment<byte> decrypted = default; 1195internal unsafe ArraySegment<byte> ToPfx(ReadOnlySpan<char> password)

System\Security\Cryptography\CngHelpers.cs (1)

112internal static unsafe ArraySegment<byte> ToBCryptBlob(this in RSAParameters parameters)

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

378if (MemoryMarshal.TryGetArray(buffer, out ArraySegment<byte> bufferArray)) 651if (MemoryMarshal.TryGetArray(inputBuffer, out ArraySegment<byte> segment))

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

77ArraySegment<byte> keyBlob = Interop.BCrypt.BCryptExportKey( 98ArraySegment<byte> keyBlob = parameters.ToBCryptBlob();

System\Security\Cryptography\X509Certificates\CertificateRequest.cs (2)

1037ArraySegment<byte> normalizedSerial = NormalizeSerialNumber(serialNumber); 1107private static ArraySegment<byte> NormalizeSerialNumber(ReadOnlySpan<byte> serialNumber)

System\Security\Cryptography\X509Certificates\X509Certificate2.cs (1)

2012ArraySegment<byte>? decryptedPkcs8 = null;

System\Security\Cryptography\X509Certificates\X509CertificateLoader.Windows.cs (1)

226ArraySegment<byte> reassembled = bagState.ToPfx(password);

System\Security\Cryptography\X509Certificates\X509Pal.Windows.PublicKey.cs (3)

98ArraySegment<byte> keyBlob = ExportKeyBlob(bCryptKeyHandle, blobFormat); 112ArraySegment<byte> keyBlob = ExportKeyBlob(bCryptKeyHandle, blobFormat); 161private static ArraySegment<byte> ExportKeyBlob(SafeBCryptKeyHandle bCryptKeyHandle, CngKeyBlobFormat blobFormat)

src\runtime\src\libraries\Common\src\System\Security\Cryptography\CryptoPool.cs (1)

15internal static void Return(ArraySegment<byte> arraySegment, int clearSize = ClearAll)

src\runtime\src\libraries\Common\src\System\Security\Cryptography\KeyFormatHelper.Encrypted.cs (7)

284internal static ArraySegment<byte> DecryptPkcs8( 296internal static ArraySegment<byte> DecryptPkcs8( 314ArraySegment<byte> decrypted = DecryptPkcs8(password, source, out bytesRead); 339ArraySegment<byte> decrypted = KeyFormatHelper.DecryptPkcs8(passwordBytes, source, out bytesRead); 358private static ArraySegment<byte> DecryptPkcs8( 408ArraySegment<byte> decrypted = DecryptPkcs8( 444ArraySegment<byte> decrypted = DecryptPkcs8(

src\runtime\src\libraries\Common\src\System\Security\Cryptography\Pkcs\Pkcs8PrivateKeyInfo.cs (2)

178ArraySegment<byte> decrypted = KeyFormatHelper.DecryptPkcs8( 209ArraySegment<byte> decrypted = KeyFormatHelper.DecryptPkcs8(

System\ServiceModel\Channels\ConnectionUtilities.cs (1)

8internal static void ValidateBufferBounds(ArraySegment<byte> buffer)

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

210var messageBuffer = new ArraySegment<byte>(_factory.BufferManager.TakeBuffer(bufferSize), 0, bufferSize); 272private async Task<Message> DecodeBufferedMessageAsync(ArraySegment<byte> buffer, Stream inputStream, TimeoutHelper timeoutHelper)

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

226private ArraySegment<byte> _buffer; 289_buffer = default(ArraySegment<byte>);

System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (3)

431protected abstract AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, Action<object> callback, object state); 439protected abstract ArraySegment<byte> EncodeMessage(Message message); 485ArraySegment<byte> messageData;

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

165protected override AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, Action<object> callback, object state) 261ArraySegment<byte> messageData = EncodeMessage(message); 302protected override ArraySegment<byte> EncodeMessage(Message message) 821ArraySegment<byte> bytes = new ArraySegment<byte>(buffer, 0, count); 863private ArraySegment<byte> _initialReadBuffer; 878ArraySegment<byte> initialBuffer,

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

55ArraySegment<byte> messageData; 70protected override ValueTask StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout) 81protected override ArraySegment<byte> EncodeMessage(Message message) 83ArraySegment<byte> messageData = MessageEncoder.WriteMessage(message,

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

223public static ArraySegment<byte> EncodeMessageFrame(ArraySegment<byte> messageFrame) 308public static ArraySegment<byte> EncodeMessageFrame(ArraySegment<byte> messageFrame)

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

533if (MemoryMarshal.TryGetArray(buffer, out ArraySegment<byte> array)) 590ArraySegment<byte> messageData = await messageEncoder.WriteMessageAsync(message,

System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (3)

382protected abstract ValueTask StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout); 386protected abstract ArraySegment<byte> EncodeMessage(Message message); 431ArraySegment<byte> messageData;

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

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

24public ArraySegment<byte> Buffer { get; private set; } 172public void Open(ArraySegment<byte> buffer, BufferManager bufferManager)

System\ServiceModel\Channels\BufferedMessageWriter.cs (1)

28public ArraySegment<byte> WriteMessage(Message message, BufferManager bufferManager, int initialOffset, int maxSizeQuota)

System\ServiceModel\Channels\Message.cs (1)

1530ArraySegment<byte> Buffer { get; }

System\ServiceModel\Channels\MessageBuffer.cs (1)

209ArraySegment<byte> buffer = _messageData.Buffer;

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

45public virtual ValueTask<Message> ReadMessageAsync(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 52public Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager) 58public abstract Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType); 61internal async Task<ArraySegment<byte>> BufferMessageStreamAsync(Stream stream, BufferManager bufferManager, int maxBufferSize, CancellationToken cancellationToken) 118public ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager) 123public abstract ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, 132public virtual ValueTask<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize, 135return new ValueTask<ArraySegment<byte>>(WriteMessage(message, maxMessageSize, bufferManager, messageOffset));

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

17internal static void DecompressBuffer(ref ArraySegment<byte> buffer, BufferManager bufferManager, CompressionFormat compressionFormat, long maxReceivedMessageSize) 59internal static void CompressBuffer(ref ArraySegment<byte> buffer, BufferManager bufferManager, CompressionFormat compressionFormat)

System\ServiceModel\Channels\MtomMessageEncoder.cs (7)

362public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 424public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 429public override ValueTask<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 431return new ValueTask<ArraySegment<byte>>(WriteMessageInternal(message, maxMessageSize, bufferManager, messageOffset, GenerateStartInfoString(), _boundary, MtomStartUri)); 449private ArraySegment<byte> WriteMessageInternal(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset, string startInfo, string boundary, string startUri) 484ArraySegment<byte> messageData = messageWriter.WriteMessage(message, bufferManager, messageOffset, maxMessageSize); 612ArraySegment<byte> buffer = Buffer;

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

401public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType) 473public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 491public override ValueTask<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset) 527ArraySegment<byte> messageData = messageWriter.WriteMessage(message, bufferManager, messageOffset, maxMessageSize); 544return new ValueTask<ArraySegment<byte>>(messageData); 754ArraySegment<byte> buffer = Buffer;

System\ServiceModel\Diagnostics\MessageLogger.cs (1)

62internal static void LogMessage(ArraySegment<byte> arraySegment, MessageLoggingSource messageLoggingSource)

System\ServiceModel\Dispatcher\XmlSerializerOperationFormatter.cs (1)

236ArraySegment<byte> memoryBuffer;

System\ServiceModel\Security\RequestSecurityToken.cs (1)

28private ArraySegment<byte> _cachedWriteBuffer;

System\ServiceModel\Security\RequestSecurityTokenResponse.cs (1)

41private ArraySegment<byte> _cachedWriteBuffer;

System\Text\Json\Document\JsonDocument.cs (4)

814private ReadOnlySpan<byte> UnescapeString(in DbRow row, out ArraySegment<byte> rented) 833private static void ClearAndReturn(ArraySegment<byte> rented) 853ArraySegment<byte> rented = default; 867ArraySegment<byte> rented = default;

System\Text\Json\Document\JsonDocument.Parse.cs (6)

126ArraySegment<byte> drained = ReadToEnd(utf8Json); 159ArraySegment<byte> drained = ReadToEnd(utf8Json); 223ArraySegment<byte> drained = await ReadToEndAsync(utf8Json, cancellationToken).ConfigureAwait(false); 247ArraySegment<byte> drained = await ReadToEndAsync(utf8Json, cancellationToken).ConfigureAwait(false); 797private static ArraySegment<byte> ReadToEnd(Stream stream) 873ValueTask<ArraySegment<byte>>

System\Windows\Forms\BinaryFormat\WinFormsBinaryFormatWriter.cs (1)

22bool success = memoryStream.TryGetBuffer(out ArraySegment<byte> data);