71 references to WebSocketHelper
System.ServiceModel.Http (71)
System\ServiceModel\Channels\HttpChannelFactory.cs (5)
131WebSocketSettings = WebSocketHelper.GetRuntimeWebSocketSettings(bindingElement.WebSocketSettings); 497remoteAddress = remoteAddress != null && !WebSocketHelper.IsWebSocketUri(remoteAddress.Uri) ? 498new EndpointAddress(WebSocketHelper.NormalizeHttpSchemeWithWsScheme(remoteAddress.Uri), remoteAddress) : 500via = !WebSocketHelper.IsWebSocketUri(via) ? WebSocketHelper.NormalizeHttpSchemeWithWsScheme(via) : via;
System\ServiceModel\Channels\WebSocketHelper.cs (5)
51(WebSocketHelper.SchemeWs.Equals(uri.Scheme, StringComparison.OrdinalIgnoreCase) || 52WebSocketHelper.SchemeWss.Equals(uri.Scheme, StringComparison.OrdinalIgnoreCase)); 221case WebSocketHelper.CloseOperation: 224case WebSocketHelper.SendOperation: 227case WebSocketHelper.ReceiveOperation:
System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (59)
23private int _cleanupStatus = WebSocketHelper.OperationNotStarted; 83closeTask.Wait(timeout, WebSocketHelper.ThrowCorrectException, WebSocketHelper.CloseOperation); 102task.Wait(timeout, WebSocketHelper.ThrowCorrectException, WebSocketHelper.CloseOperation); 133throw WebSocketHelper.ConvertAndTraceException(ex, timeout, WebSocketHelper.ReceiveOperation); 191_pendingWritingMessageException = WebSocketHelper.CreateExceptionOnTaskFailure(task, timeout, WebSocketHelper.SendOperation); 237_pendingWritingMessageException = WebSocketHelper.CreateExceptionOnTaskFailure(task, timeout, WebSocketHelper.CloseOperation); 274task.Wait(helper.RemainingTime(), WebSocketHelper.ThrowCorrectException, WebSocketHelper.SendOperation); 309if (Interlocked.CompareExchange(ref _cleanupStatus, WebSocketHelper.OperationFinished, WebSocketHelper.OperationNotStarted) == WebSocketHelper.OperationNotStarted) 317Fx.Assert(_cleanupStatus == WebSocketHelper.OperationFinished, 354throw WebSocketHelper.ConvertAndTraceException(e); 371throw WebSocketHelper.ConvertAndTraceException(e); 388_pendingWritingMessageException = WebSocketHelper.CreateExceptionOnTaskFailure(task, timeout, WebSocketHelper.CloseOperation); 404_pendingWritingMessageException = WebSocketHelper.CreateExceptionOnTaskFailure(task, timeout, 405WebSocketHelper.SendOperation); 478_receiveBufferSize = Math.Min(WebSocketHelper.GetReceiveBufferSize(_maxReceivedMessageSize), _maxBufferSize); 586WebSocketHelper.ThrowCorrectException(ex, TimeSpan.MaxValue, WebSocketHelper.ReceiveOperation); 616_pendingException = WebSocketHelper.ConvertAndTraceException(ex, TimeSpan.MaxValue, WebSocketHelper.ReceiveOperation); 753WebSocketHelper.ThrowCorrectException(ex, _asyncReceiveTimeout, WebSocketHelper.ReceiveOperation); 764_pendingException = WebSocketHelper.ConvertAndTraceException(ex, _asyncReceiveTimeout, WebSocketHelper.ReceiveOperation); 891_messageSourceCleanState = WebSocketHelper.OperationNotStarted; 892_endOfMessageWritten = WebSocketHelper.OperationNotStarted; 904_messageSourceCleanState = WebSocketHelper.OperationFinished; 996throw FxTrace.Exception.AsError(WebSocketHelper.GetTimeoutException(null, 997_readTimeoutHelper.OriginalTimeout, WebSocketHelper.ReceiveOperation)); 1046throw WebSocketHelper.ConvertAndTraceException(ex, new TimeSpan(ReadTimeout), WebSocketHelper.ReceiveOperation); 1097if (_endOfMessageWritten == WebSocketHelper.OperationFinished) 1126throw WebSocketHelper.ConvertAndTraceException(ex, new TimeSpan(WriteTimeout), WebSocketHelper.SendOperation); 1153if (Interlocked.CompareExchange(ref _endOfMessageWritten, WebSocketHelper.OperationFinished, WebSocketHelper.OperationNotStarted) == WebSocketHelper.OperationNotStarted) 1156task.Wait(timeoutHelper.RemainingTime(), WebSocketHelper.ThrowCorrectException, WebSocketHelper.SendOperation); 1201throw WebSocketHelper.ConvertAndTraceException(ex, timeoutHelper.OriginalTimeout, 1202WebSocketHelper.SendOperation); 1231if (Interlocked.CompareExchange(ref _messageSourceCleanState, WebSocketHelper.OperationFinished, WebSocketHelper.OperationNotStarted) == WebSocketHelper.OperationNotStarted) 1246WebSocketHelper.ThrowCorrectException, WebSocketHelper.ReceiveOperation); 1263pendingException = WebSocketHelper.ConvertAndTraceException(ex, _closeTimeout, WebSocketHelper.CloseOperation); 1273if (Interlocked.CompareExchange(ref _endOfMessageWritten, WebSocketHelper.OperationFinished, WebSocketHelper.OperationNotStarted) == WebSocketHelper.OperationNotStarted)
System\ServiceModel\Channels\WebSocketTransportSettings.cs (2)
104if (value.Split(WebSocketHelper.ProtocolSeparators).Length > 1) 110if (WebSocketHelper.IsSubProtocolInvalid(value, out invalidChar))