4 writes to PayloadLength
System.Net.WebSockets (4)
System\Net\WebSockets\ManagedWebSocket.cs (4)
960
header.
PayloadLength
-= totalBytesReceived;
1326
header.
PayloadLength
= receiveBufferSpan[_receiveBufferOffset + 1] & 0x7F;
1334
header.
PayloadLength
= BinaryPrimitives.ReadUInt16BigEndian(receiveBufferSpan.Slice(_receiveBufferOffset));
1340
header.
PayloadLength
= BinaryPrimitives.ReadInt64BigEndian(receiveBufferSpan.Slice(_receiveBufferOffset));
31 references to PayloadLength
System.Net.WebSockets (31)
System\Net\WebSockets\ManagedWebSocket.cs (31)
856
NetEventSource.Trace(this, $"Next frame opcode={header.Opcode}, fin={header.Fin}, compressed={header.Compressed}, payloadLength={header.
PayloadLength
}");
859
if (header.
PayloadLength
== 0 && header.Compressed)
911
if (header.
PayloadLength
> 0)
916
_inflater.Prepare(header.
PayloadLength
, payloadBuffer.Length);
920
int limit = (int)Math.Min(header.Compressed ? _inflater!.Span.Length : payloadBuffer.Length, header.
PayloadLength
);
964
_inflater!.AddBytes(totalBytesReceived, endOfMessage: header.Fin && header.
PayloadLength
== 0);
972
header.Processed = _inflater!.Inflate(payloadBuffer.Span, out totalBytesReceived) && header.
PayloadLength
== 0;
977
header.Processed = header.
PayloadLength
== 0;
1086
if (header.
PayloadLength
== 1)
1091
else if (header.
PayloadLength
>= 2)
1093
if (_receiveBufferCount < header.
PayloadLength
)
1095
await EnsureBufferContainsAsync((int)header.
PayloadLength
, cancellationToken).ConfigureAwait(false);
1100
ApplyMask(_receiveBuffer.Span.Slice(_receiveBufferOffset, (int)header.
PayloadLength
), header.Mask, 0);
1109
if (header.
PayloadLength
> 2)
1113
closeStatusDescription = s_textEncoding.GetString(_receiveBuffer.Span.Slice(_receiveBufferOffset + 2, (int)header.
PayloadLength
- 2));
1120
ConsumeFromBuffer((int)header.
PayloadLength
);
1192
if (header.
PayloadLength
> 0 && _receiveBufferCount < header.
PayloadLength
)
1194
await EnsureBufferContainsAsync((int)header.
PayloadLength
, cancellationToken).ConfigureAwait(false);
1200
&& header.
PayloadLength
== KeepAlivePingState.PingPayloadSize;
1204
ApplyMask(_receiveBuffer.Span.Slice(_receiveBufferOffset, (int)header.
PayloadLength
), header.Mask, 0);
1216
_receiveBuffer.Slice(_receiveBufferOffset, (int)header.
PayloadLength
),
1223
long pongPayload = BinaryPrimitives.ReadInt64BigEndian(_receiveBuffer.Span.Slice(_receiveBufferOffset, (int)header.
PayloadLength
));
1235
if (header.
PayloadLength
> 0)
1237
ConsumeFromBuffer((int)header.
PayloadLength
);
1331
if (header.
PayloadLength
== 126)
1337
else if (header.
PayloadLength
== 127)
1350
if (header.
PayloadLength
< 0)
1417
if (header.
PayloadLength
> MaxControlPayloadLength || !header.Fin)
1432
header.Processed = header.
PayloadLength
== 0 && !header.Compressed;
1968
internal bool EndOfMessage => Fin && Processed &&
PayloadLength
== 0;