123 references to WebSocketHelper
System.ServiceModel (123)
System\ServiceModel\Channels\ClientWebSocketTransportDuplexSessionChannel.cs (10)
226string serverVersion = webResponse.Headers[WebSocketHelper.SecWebSocketVersion]; 232string serverSubProtocol = webResponse.Headers[WebSocketHelper.SecWebSocketProtocol]; 245request.Headers[WebSocketHelper.SecWebSocketProtocol] = this.WebSocketSettings.SubProtocol; 335this.webSocketKey = request.Headers[WebSocketHelper.SecWebSocketKey]; 377WebSocketHelper.GetReceiveBufferSize(this.channelFactory.MaxReceivedMessageSize), 442string expectedAcceptHeader = WebSocketHelper.ComputeAcceptHeader(this.webSocketKey); 443CheckResponseHeader(response, WebSocketHelper.SecWebSocketAccept, expectedAcceptHeader, false); 447CheckResponseHeader(response, WebSocketHelper.SecWebSocketProtocol, this.WebSocketSettings.SubProtocol, true); 451string headerValue = response.Headers[WebSocketHelper.SecWebSocketProtocol]; 495request.Headers[WebSocketHelper.SecWebSocketVersion] = webSocketVersion;
System\ServiceModel\Channels\DefaultWebSocketConnectionHandler.cs (8)
52if (!CheckHttpHeader(request, WebSocketHelper.SecWebSocketVersion, this.checkVersionFunc)) 101response.Headers.Remove(WebSocketHelper.SecWebSocketProtocol); 104response.Headers.Add(WebSocketHelper.SecWebSocketProtocol, negotiatedProtocol); 112SR.GetString(SR.WebSocketInvalidProtocolNoHeader, this.subProtocol, WebSocketHelper.SecWebSocketProtocol))); 126if (request.Headers.TryGetValues(WebSocketHelper.SecWebSocketProtocol, out clientProtocols)) 135if (WebSocketHelper.TryParseSubProtocol(headerValue, out protocolList)) 162response.Headers.Add(WebSocketHelper.SecWebSocketProtocol, subprotocol); 171response.Headers.Add(WebSocketHelper.SecWebSocketVersion, version);
System\ServiceModel\Channels\HttpChannelFactory.cs (8)
170this.webSocketSettings = WebSocketHelper.GetRuntimeWebSocketSettings(bindingElement.WebSocketSettings); 172int webSocketBufferSize = WebSocketHelper.ComputeClientBufferSize(this.MaxReceivedMessageSize); 440EndpointAddress httpRemoteAddress = remoteAddress != null && WebSocketHelper.IsWebSocketUri(remoteAddress.Uri) ? 441new EndpointAddress(WebSocketHelper.NormalizeWsSchemeWithHttpScheme(remoteAddress.Uri), remoteAddress) : 444Uri httpVia = WebSocketHelper.IsWebSocketUri(via) ? WebSocketHelper.NormalizeWsSchemeWithHttpScheme(via) : via; 487else if (!WebSocketHelper.OSSupportsWebSockets() && this.ClientWebSocketFactory == null) 735Uri httpWebRequestUri = isWebSocketRequest ? WebSocketHelper.GetWebSocketUri(via) : via;
System\ServiceModel\Channels\HttpChannelListener.cs (9)
114this.webSocketSettings = WebSocketHelper.GetRuntimeWebSocketSettings(bindingElement.WebSocketSettings); 848else if (!WebSocketHelper.OSSupportsWebSockets()) 853this.currentWebSocketVersion = WebSocketHelper.GetCurrentVersion(); 855int webSocketBufferSize = WebSocketHelper.ComputeServerBufferSize(bindingElement.MaxReceivedMessageSize); 927TD.MaxPendingConnectionsExceeded(SR.GetString(SR.WebSocketMaxPendingConnectionsReached, this.WebSocketSettings.MaxPendingConnections, WebSocketHelper.MaxPendingConnectionsString, WebSocketHelper.WebSocketTransportSettingsString)); 933TraceCode.MaxPendingConnectionsReached, SR.GetString(SR.WebSocketMaxPendingConnectionsReached, this.WebSocketSettings.MaxPendingConnections, WebSocketHelper.MaxPendingConnectionsString, WebSocketHelper.WebSocketTransportSettingsString), 934new StringTraceRecord(WebSocketHelper.MaxPendingConnectionsString, this.WebSocketSettings.MaxPendingConnections.ToString(System.Globalization.CultureInfo.InvariantCulture)),
System\ServiceModel\Channels\HttpPipeline.cs (3)
801if (response.Headers.Contains(WebSocketHelper.SecWebSocketProtocol)) 803foreach (string headerValue in response.Headers.GetValues(WebSocketHelper.SecWebSocketProtocol)) 809response.Headers.Remove(WebSocketHelper.SecWebSocketProtocol);
System\ServiceModel\Channels\HttpRequestContext.cs (2)
504WebSocketHelper.ThrowCorrectException(ex); 805WebSocketHelper.GetReceiveBufferSize(this.listener.MaxReceivedMessageSize),
System\ServiceModel\Channels\HttpTransportBindingElement.cs (3)
787bool useWebSocketTransport = WebSocketHelper.UseWebSocketTransport(this.WebSocketSettings.TransportUsage, policyContext.Contract.IsDuplex()); 882bool useWebSocketTransport = WebSocketHelper.UseWebSocketTransport(this.WebSocketSettings.TransportUsage, endpointContext.ContractConversionContext.Contract.IsDuplex()); 887address = new EndpointAddress(WebSocketHelper.GetWebSocketUri(endpointContext.Endpoint.Address.Uri), endpointContext.Endpoint.Address);
System\ServiceModel\Channels\WebSocketHelper.cs (7)
54string fullString = webSocketKey + WebSocketHelper.WebSocketKeyPostString; 105(WebSocketHelper.SchemeWs.Equals(uri.Scheme, StringComparison.OrdinalIgnoreCase) || 106WebSocketHelper.SchemeWss.Equals(uri.Scheme, StringComparison.OrdinalIgnoreCase)); 198string version = request.Headers[WebSocketHelper.SecWebSocketVersion]; 344case WebSocketHelper.CloseOperation: 347case WebSocketHelper.SendOperation: 350case WebSocketHelper.ReceiveOperation:
System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (71)
34int cleanupStatus = WebSocketHelper.OperationNotStarted; 160closeTask.Wait(timeout, WebSocketHelper.ThrowCorrectException, WebSocketHelper.CloseOperation); 185task.Wait(timeout, WebSocketHelper.ThrowCorrectException, WebSocketHelper.CloseOperation); 233WebSocketHelper.ThrowExceptionOnTaskFailure(t, timeout, WebSocketHelper.SendOperation); 294WebSocketHelper.ThrowExceptionOnTaskFailure(t, timeout, WebSocketHelper.CloseOperation); 343task.Wait(helper.RemainingTime(), WebSocketHelper.ThrowCorrectException, WebSocketHelper.SendOperation); 378if (Interlocked.CompareExchange(ref this.cleanupStatus, WebSocketHelper.OperationFinished, WebSocketHelper.OperationNotStarted) == WebSocketHelper.OperationNotStarted) 386Fx.Assert(this.cleanupStatus == WebSocketHelper.OperationFinished, 425throw WebSocketHelper.ConvertAndTraceException(e); 443throw WebSocketHelper.ConvertAndTraceException(e); 542this.receiveBufferSize = Math.Min(WebSocketHelper.GetReceiveBufferSize(this.maxReceivedMessageSize), this.maxBufferSize); 594throw FxTrace.Exception.AsError(WebSocketHelper.GetTimeoutException(null, this.asyncReceiveTimeout, WebSocketHelper.ReceiveOperation)); 700WebSocketHelper.ThrowCorrectException(ex, TimeSpan.MaxValue, WebSocketHelper.ReceiveOperation); 731this.pendingException = WebSocketHelper.ConvertAndTraceException(ex, TimeSpan.MaxValue, WebSocketHelper.ReceiveOperation); 896WebSocketHelper.ThrowCorrectException(ex, this.asyncReceiveTimeout, WebSocketHelper.ReceiveOperation); 907this.pendingException = WebSocketHelper.ConvertAndTraceException(ex, this.asyncReceiveTimeout, WebSocketHelper.ReceiveOperation); 1060this.messageSourceCleanState = WebSocketHelper.OperationNotStarted; 1061this.endOfMessageWritten = WebSocketHelper.OperationNotStarted; 1073this.messageSourceCleanState = WebSocketHelper.OperationFinished; 1163throw FxTrace.Exception.AsError(WebSocketHelper.GetTimeoutException(null, TimeoutHelper.FromMilliseconds(this.ReadTimeout), WebSocketHelper.ReceiveOperation)); 1194WebSocketHelper.ThrowExceptionOnTaskFailure(t, TimeoutHelper.FromMilliseconds(this.ReadTimeout), WebSocketHelper.ReceiveOperation); 1222WebSocketHelper.ThrowExceptionOnTaskFailure((Task)task, TimeoutHelper.FromMilliseconds(this.ReadTimeout), WebSocketHelper.ReceiveOperation); 1234throw FxTrace.Exception.AsError(WebSocketHelper.GetTimeoutException(null, TimeoutHelper.FromMilliseconds(this.ReadTimeout), WebSocketHelper.ReceiveOperation)); 1262task.Wait(helper.RemainingTime(), WebSocketHelper.ThrowCorrectException, WebSocketHelper.ReceiveOperation); 1301if (this.endOfMessageWritten == WebSocketHelper.OperationFinished) 1308throw FxTrace.Exception.AsError(WebSocketHelper.GetTimeoutException(null, TimeoutHelper.FromMilliseconds(this.WriteTimeout), WebSocketHelper.SendOperation)); 1320task.Wait(TimeoutHelper.FromMilliseconds(this.WriteTimeout), WebSocketHelper.ThrowCorrectException, WebSocketHelper.SendOperation); 1330if (this.endOfMessageWritten == WebSocketHelper.OperationFinished) 1337throw FxTrace.Exception.AsError(WebSocketHelper.GetTimeoutException(null, TimeoutHelper.FromMilliseconds(this.WriteTimeout), WebSocketHelper.SendOperation)); 1357WebSocketHelper.ThrowExceptionOnTaskFailure(t, TimeoutHelper.FromMilliseconds(this.WriteTimeout), WebSocketHelper.SendOperation); 1366WebSocketHelper.ThrowExceptionOnTaskFailure(task, TimeoutHelper.FromMilliseconds(this.WriteTimeout), WebSocketHelper.SendOperation); 1379if (Interlocked.CompareExchange(ref this.endOfMessageWritten, WebSocketHelper.OperationFinished, WebSocketHelper.OperationNotStarted) == WebSocketHelper.OperationNotStarted) 1382task.Wait(timeout, WebSocketHelper.ThrowCorrectException, WebSocketHelper.SendOperation); 1418WebSocketHelper.ThrowCorrectException(ex, TimeoutHelper.FromMilliseconds(this.WriteTimeout), WebSocketHelper.SendOperation); 1427WebSocketHelper.ThrowCorrectException(ex); 1457if (Interlocked.CompareExchange(ref this.messageSourceCleanState, WebSocketHelper.OperationFinished, WebSocketHelper.OperationNotStarted) == WebSocketHelper.OperationNotStarted) 1469receiveTask.Wait(helper.RemainingTime(), WebSocketHelper.ThrowCorrectException, WebSocketHelper.ReceiveOperation); 1485pendingException = WebSocketHelper.ConvertAndTraceException(ex, timeout, WebSocketHelper.CloseOperation); 1495if (Interlocked.CompareExchange(ref this.endOfMessageWritten, WebSocketHelper.OperationFinished, WebSocketHelper.OperationNotStarted) == WebSocketHelper.OperationNotStarted)
System\ServiceModel\Channels\WebSocketTransportSettings.cs (2)
128if (value.Split(WebSocketHelper.ProtocolSeparators).Length > 1) 134if (WebSocketHelper.IsSubProtocolInvalid(value, out invalidChar))