37 references to MessageOpcode
System.Net.WebSockets (37)
System\Net\WebSockets\ManagedWebSocket.cs (32)
98private MessageHeader _lastReceiveHeader = new MessageHeader { Opcode = MessageOpcode.Text, Fin = true, Processed = true }; 329MessageOpcode opcode; 337opcode = MessageOpcode.Continuation; 341opcode = messageType == WebSocketMessageType.Binary ? MessageOpcode.Binary : MessageOpcode.Text; 478private ValueTask SendFrameAsync(MessageOpcode opcode, bool endOfMessage, bool disableCompression, ReadOnlyMemory<byte> payloadBuffer, CancellationToken cancellationToken) 497private ValueTask SendFrameLockAcquiredNonCancelableAsync(MessageOpcode opcode, bool endOfMessage, bool disableCompression, ReadOnlyMemory<byte> payloadBuffer) 600private async ValueTask SendFrameFallbackAsync(MessageOpcode opcode, bool endOfMessage, bool disableCompression, ReadOnlyMemory<byte> payloadBuffer, Task lockTask, CancellationToken cancellationToken) 654private int WriteFrameToSendBuffer(MessageOpcode opcode, bool endOfMessage, bool disableCompression, ReadOnlySpan<byte> payloadBuffer) 705private static int WriteHeader(MessageOpcode opcode, byte[] sendBuffer, ReadOnlySpan<byte> payload, bool endOfMessage, bool useMask, bool compressed) 735if (compressed && opcode != MessageOpcode.Continuation) 884if (header.Opcode == MessageOpcode.Ping || header.Opcode == MessageOpcode.Pong) 889else if (header.Opcode == MessageOpcode.Close) 896if (header.Opcode == MessageOpcode.Continuation) 903Debug.Assert(header.Opcode == MessageOpcode.Binary || header.Opcode == MessageOpcode.Text, $"Unexpected opcode {header.Opcode}"); 911messageType: header.Opcode == MessageOpcode.Text ? WebSocketMessageType.Text : WebSocketMessageType.Binary, 993if (header.Opcode == MessageOpcode.Text && 1007header.Opcode == MessageOpcode.Text ? WebSocketMessageType.Text : WebSocketMessageType.Binary, 1209bool processPing = header.Opcode == MessageOpcode.Ping; 1211bool processPong = header.Opcode == MessageOpcode.Pong && _keepAlivePingState is not null 1225MessageOpcode.Pong, 1334header.Opcode = (MessageOpcode)(receiveBufferSpan[_receiveBufferOffset] & 0xF); 1397case MessageOpcode.Continuation: 1416case MessageOpcode.Binary: 1417case MessageOpcode.Text: 1426case MessageOpcode.Close: 1427case MessageOpcode.Ping: 1428case MessageOpcode.Pong: 1579await SendFrameAsync(MessageOpcode.Close, endOfMessage: true, disableCompression: true, new Memory<byte>(buffer, 0, count), cancellationToken).ConfigureAwait(false); 1959internal MessageOpcode Opcode;
System\Net\WebSockets\ManagedWebSocket.KeepAlive.cs (5)
33TrySendKeepAliveFrameAsync(MessageOpcode.Pong)); 36private ValueTask TrySendKeepAliveFrameAsync(MessageOpcode opcode, ReadOnlyMemory<byte> payload = default) 38Debug.Assert((opcode is MessageOpcode.Pong) || (!IsUnsolicitedPongKeepAlive && opcode is MessageOpcode.Ping)); 120await TrySendKeepAliveFrameAsync(MessageOpcode.Ping, pingPayloadBuffer).ConfigureAwait(false);