1 write to m_WebSocket
System (1)
net\System\Net\WebSockets\WebSocketBase.cs (1)
1617
m_WebSocket
= webSocket;
65 references to m_WebSocket
System (65)
net\System\Net\WebSockets\WebSocketBase.cs (65)
1655
Monitor.Enter(
m_WebSocket
.SessionHandle, ref sessionHandleLockTaken);
1656
m_WebSocket
.ThrowIfPendingException();
1673
m_WebSocket
.ThrowIfDisposed();
1674
WebSocketProtocolComponent.WebSocketGetAction(
m_WebSocket
,
1694
if (
m_WebSocket
.StartOnCloseReceived(ref thisLockTaken))
1699
ReleaseLock(
m_WebSocket
.SessionHandle, ref sessionHandleLockTaken);
1704
callCompleteOnCloseCompleted = await
m_WebSocket
.StartOnCloseCompleted(
1711
m_WebSocket
.ResetFlagAndTakeLock(
m_WebSocket
.m_ThisLock, ref thisLockTaken);
1717
m_WebSocket
.ResetFlagAndTakeLock(
m_WebSocket
.m_ThisLock, ref thisLockTaken);
1718
m_WebSocket
.FinishOnCloseCompleted();
1721
m_WebSocket
.FinishOnCloseReceived(ReceiveResult.CloseStatus.Value, ReceiveResult.CloseStatusDescription);
1727
ReleaseLock(
m_WebSocket
.m_ThisLock, ref thisLockTaken);
1745
ArraySegment<byte> payload =
m_WebSocket
.m_InternalBuffer.ConvertNativeBuffer(action, dataBuffers[0], bufferType);
1747
ReleaseLock(
m_WebSocket
.SessionHandle, ref sessionHandleLockTaken);
1748
WebSocketHelpers.ThrowIfConnectionAborted(
m_WebSocket
.m_InnerStream, true);
1751
Task<int> readTask =
m_WebSocket
.m_InnerStream.ReadAsync(payload.Array,
1756
m_WebSocket
.m_KeepAliveTracker.OnDataReceived();
1766
Monitor.Enter(
m_WebSocket
.SessionHandle, ref sessionHandleLockTaken);
1767
m_WebSocket
.ThrowIfPendingException();
1776
WebSocketProtocolComponent.WebSocketCompleteAction(
m_WebSocket
,
1782
WebSocketProtocolComponent.WebSocketCompleteAction(
m_WebSocket
, actionContext, 0);
1784
ReleaseLock(
m_WebSocket
.SessionHandle, ref sessionHandleLockTaken);
1785
await
m_WebSocket
.m_InnerStream.FlushAsync().SuppressContextFlow();
1786
Monitor.Enter(
m_WebSocket
.SessionHandle, ref sessionHandleLockTaken);
1792
if (
m_WebSocket
.State != WebSocketState.CloseSent ||
1803
ArraySegment<byte> framingBuffer =
m_WebSocket
.m_InternalBuffer.ConvertNativeBuffer(action, dataBuffers[0], bufferType);
1818
if (
m_WebSocket
.m_InternalBuffer.IsPinnedSendPayloadBuffer(dataBuffers[1], bufferType))
1820
payload =
m_WebSocket
.m_InternalBuffer.ConvertPinnedSendPayloadFromNative(dataBuffers[1], bufferType);
1824
payload =
m_WebSocket
.m_InternalBuffer.ConvertNativeBuffer(action, dataBuffers[1], bufferType);
1831
ReleaseLock(
m_WebSocket
.SessionHandle, ref sessionHandleLockTaken);
1832
WebSocketHelpers.ThrowIfConnectionAborted(
m_WebSocket
.m_InnerStream, false);
1833
await
m_WebSocket
.SendFrameAsync(sendBuffers, cancellationToken).SuppressContextFlow();
1834
Monitor.Enter(
m_WebSocket
.SessionHandle, ref sessionHandleLockTaken);
1835
m_WebSocket
.ThrowIfPendingException();
1837
m_WebSocket
.m_KeepAliveTracker.OnDataSent();
1842
WebSocketProtocolComponent.WebSocketCompleteAction(
m_WebSocket
,
1872
ReleaseLock(
m_WebSocket
.SessionHandle, ref sessionHandleLockTaken);
1873
Monitor.Enter(
m_WebSocket
.SessionHandle, ref sessionHandleLockTaken);
1879
ReleaseLock(
m_WebSocket
.SessionHandle, ref sessionHandleLockTaken);
1911
m_WebSocket
.ThrowIfDisposed();
1913
int originalReceiveState = Interlocked.CompareExchange(ref
m_WebSocket
.m_ReceiveState,
1926
if (!
m_WebSocket
.m_InternalBuffer.ReceiveFromBufferedPayload(buffer.Value, out receiveResult))
1928
m_WebSocket
.UpdateReceiveState(ReceiveState.Idle, ReceiveState.PayloadAvailable);
1953
m_WebSocket
.ThrowIfDisposed();
1954
m_WebSocket
.ThrowIfPendingException();
1955
WebSocketProtocolComponent.WebSocketReceive(
m_WebSocket
);
1998
WebSocketProtocolComponent.WebSocketCompleteAction(
m_WebSocket
,
2016
m_WebSocket
.m_InternalBuffer.ConvertCloseBuffer(action, dataBuffers[0], out closeStatus, out reason);
2023
payload =
m_WebSocket
.m_InternalBuffer.ConvertNativeBuffer(action, dataBuffers[0], bufferType);
2032
m_WebSocket
.m_InternalBuffer.BufferPayload(payload, buffer.Value.Count, messageType, endOfMessage);
2050
m_WebSocket
.UpdateReceiveState(newReceiveState, m_ReceiveState);
2054
WebSocketProtocolComponent.WebSocketCompleteAction(
m_WebSocket
,
2091
m_WebSocket
.m_InternalBuffer.PinSendBuffer(buffer.Value, out m_BufferHasBeenPinned);
2092
payloadBuffer.Data.BufferData =
m_WebSocket
.m_InternalBuffer.ConvertPinnedSendPayloadToNative(buffer.Value);
2107
m_WebSocket
.m_InternalBuffer.ReleasePinnedSendBuffer();
2117
m_WebSocket
.ThrowIfDisposed();
2118
m_WebSocket
.ThrowIfPendingException();
2123
WebSocketProtocolComponent.WebSocketSend(
m_WebSocket
, BufferType, payloadBuffer.Value);
2127
WebSocketProtocolComponent.WebSocketSendWithoutBody(
m_WebSocket
, BufferType);
2158
m_WebSocket
.ThrowIfDisposed();
2159
m_WebSocket
.ThrowIfPendingException();
2173
m_WebSocket
.m_InternalBuffer.PinSendBuffer(closeBuffer, out m_BufferHasBeenPinned);
2174
payloadBuffer.CloseStatus.ReasonData =
m_WebSocket
.m_InternalBuffer.ConvertPinnedSendPayloadToNative(closeBuffer);