Home
last modified time | relevance | path

Searched refs:WebSocketState (Results 1 – 25 of 81) sorted by relevance

1234

/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.WebSockets/tests/
H A DWebSocketTests.cs106 [InlineData(WebSocketState.None)]
108 [InlineData(WebSocketState.Open)]
111 [InlineData((WebSocketState)(-1))]
112 [InlineData((WebSocketState)(7))]
127 [InlineData(WebSocketState.Closed, new WebSocketState[] { })]
128 [InlineData(WebSocketState.Closed, new WebSocketState[] { WebSocketState.Open })]
129 …[InlineData(WebSocketState.Open, new WebSocketState[] { WebSocketState.Aborted, WebSocketState.Clo…
136 [InlineData(WebSocketState.Open, new WebSocketState[] { WebSocketState.Open })]
137 …[InlineData(WebSocketState.Open, new WebSocketState[] { WebSocketState.Open, WebSocketState.Aborte…
138 …[InlineData(WebSocketState.Open, new WebSocketState[] { WebSocketState.Aborted, WebSocketState.Ope…
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.WebSockets.Client/src/System/Net/WebSockets/
H A DWinRTWebSocket.cs53 private WebSocketState _state = WebSocketState.None;
97 private static readonly WebSocketState[] s_validConnectStates = {WebSocketState.None};
98 … private static readonly WebSocketState[] s_validConnectingStates = {WebSocketState.Connecting};
184 if ((_state != WebSocketState.None) && (_state != WebSocketState.Connecting)) in AbortInternal()
248 …c readonly WebSocketState[] s_validCloseStates = { WebSocketState.Open, WebSocketState.CloseReceiv…
256 … callClose = (_state != WebSocketState.CloseSent) && (_state != WebSocketState.Closed); in CloseAsync()
275 …vate static readonly WebSocketState[] s_validCloseOutputStates = { WebSocketState.Open, WebSocketS…
315 …private static readonly WebSocketState[] s_validReceiveStates = { WebSocketState.Open, WebSocketSt…
420 …private static readonly WebSocketState[] s_validSendStates = { WebSocketState.Open, WebSocketState…
494 WebSocketState newState, in InterlockedCheckAndUpdateState()
[all …]
H A DWinHttpWebSocket.cs55 public override WebSocketState State
72 static readonly WebSocketState[] s_validConnectStates = { WebSocketState.None };
73 static readonly WebSocketState[] s_validConnectingStates = { WebSocketState.Connecting };
283 if (_operation.State != WebSocketState.Connecting) in ThrowOnInvalidConnectState()
289 …private static readonly WebSocketState[] s_validSendStates = { WebSocketState.Open, WebSocketState…
351 …private static readonly WebSocketState[] s_validReceiveStates = { WebSocketState.Open, WebSocketSt…
352 …ivate static readonly WebSocketState[] s_validAfterReceiveStates = { WebSocketState.Open, WebSocke…
473 …private static readonly WebSocketState[] s_validCloseStates = { WebSocketState.Open, WebSocketStat…
551 …private static readonly WebSocketState[] s_validCloseOutputStates = { WebSocketState.Open, WebSock…
552 …private static readonly WebSocketState[] s_validCloseOutputStatesAfterUpdate = { WebSocketState.Cl…
[all …]
H A DWinHttpWebSocketState.cs34 private volatile WebSocketState _state = WebSocketState.None;
119 public WebSocketState State
231 public void InterlockedCheckValidStates(WebSocketState[] validStates) in InterlockedCheckValidStates()
240 WebSocketState newState, in InterlockedCheckAndUpdateState()
241 params WebSocketState[] validStates) in InterlockedCheckAndUpdateState()
251 public void CheckValidState(WebSocketState[] validStates) in CheckValidState()
256 public void UpdateState(WebSocketState value) in UpdateState()
258 if ((_state != WebSocketState.Closed) && (_state != WebSocketState.Aborted)) in UpdateState()
H A DWinHttpWebSocketCallback.cs160 state.UpdateState(WebSocketState.Closed); in OnRequestError()
187 state.UpdateState(WebSocketState.Closed); in OnRequestSecureFailure()
266 state.UpdateState(WebSocketState.CloseReceived); in OnWebSocketReadComplete()
280 state.UpdateState(WebSocketState.Closed); in OnWebSocketCloseComplete()
288 state.UpdateState(WebSocketState.CloseSent); in OnWebSocketShutdownComplete()
318 state.UpdateState(WebSocketState.Aborted); in OnWebSocketError()
369 state.UpdateState(WebSocketState.Aborted); in OnWebSocketSecureFailure()
H A DWebSocketHandle.Managed.cs33 private WebSocketState _state = WebSocketState.Connecting;
44 public WebSocketState State => _webSocket?.State ?? _state;
52 _state = WebSocketState.Closed; in Dispose()
122 if (_state == WebSocketState.Aborted) in ConnectAsyncCore()
126 else if (_state == WebSocketState.Closed) in ConnectAsyncCore()
133 if (_state < WebSocketState.Closed) in ConnectAsyncCore()
135 _state = WebSocketState.Closed; in ConnectAsyncCore()
/dports/www/py-starlette/starlette-0.17.1/starlette/
H A Dwebsockets.py9 class WebSocketState(enum.Enum): class
26 self.client_state = WebSocketState.CONNECTING
27 self.application_state = WebSocketState.CONNECTING
33 if self.client_state == WebSocketState.CONNECTING:
37 self.client_state = WebSocketState.CONNECTED
39 elif self.client_state == WebSocketState.CONNECTED:
44 self.client_state = WebSocketState.DISCONNECTED
55 if self.application_state == WebSocketState.CONNECTING:
61 self.application_state = WebSocketState.CONNECTED
63 elif self.application_state == WebSocketState.CONNECTED:
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.WebSockets.Client/tests/
H A DWebSocketHelper.cs35 Assert.Equal(WebSocketState.Open, cws.State); in TestEcho()
40 Assert.Equal(WebSocketState.Open, cws.State); in TestEcho()
53 (cws.State == WebSocketState.Open) || (cws.State == WebSocketState.CloseSent) || in TestEcho()
54 … (cws.State == WebSocketState.CloseReceived) || (cws.State == WebSocketState.Closed), in TestEcho()
58 Assert.Equal(WebSocketState.Closed, cws.State); in TestEcho()
88 (cws.State == WebSocketState.None) || in GetConnectedWebSocket()
89 (cws.State == WebSocketState.Connecting) || in GetConnectedWebSocket()
90 (cws.State == WebSocketState.Open) || in GetConnectedWebSocket()
91 (cws.State == WebSocketState.Aborted), in GetConnectedWebSocket()
95 Assert.Equal(WebSocketState.Open, cws.State); in GetConnectedWebSocket()
H A DClientWebSocketUnitTest.cs43 Assert.Equal(WebSocketState.Closed, cws.State); in Abort_CreateAndAbort_StateIsClosed()
56 Assert.Equal(WebSocketState.None, cws.State); in CloseAsync_CreateAndClose_ThrowsInvalidOperationException()
76 Assert.Equal(WebSocketState.None, cws.State); in CloseAsync_CreateAndCloseOutput_ThrowsInvalidOperationExceptionWithMessage()
93 Assert.Equal(WebSocketState.None, cws.State); in CloseAsync_CreateAndReceive_ThrowsInvalidOperationException()
117 Assert.Equal(WebSocketState.None, cws.State); in CloseAsync_CreateAndReceive_ThrowsInvalidOperationExceptionWithMessage()
185 Assert.Equal(WebSocketState.Closed, cws.State); in Abort_CreateAndDisposeAndAbort_StateIsClosedSuccess()
198 Assert.Equal(WebSocketState.Closed, cws.State); in CloseAsync_DisposeAndClose_ThrowsObjectDisposedException()
215 Assert.Equal(WebSocketState.Closed, cws.State); in CloseAsync_DisposeAndCloseOutput_ThrowsObjectDisposedExceptionWithMessage()
235 Assert.Equal(WebSocketState.Closed, cws.State); in ReceiveAsync_CreateAndDisposeAndReceive_ThrowsObjectDisposedExceptionWithMessage()
255 Assert.Equal(WebSocketState.Closed, cws.State); in SendAsync_CreateAndDisposeAndSend_ThrowsObjectDisposedExceptionWithMessage()
[all …]
H A DConnectTest.cs31 Assert.Equal(WebSocketState.Closed, cws.State); in ConnectAsync_NotWebSocketServer_ThrowsWebSocketExceptionWithMessage()
62 (cws.State == WebSocketState.None) || in ConnectAsync_AddCustomHeaders_Success()
64 (cws.State == WebSocketState.Open), in ConnectAsync_AddCustomHeaders_Success()
69 Assert.Equal(WebSocketState.Open, cws.State); in ConnectAsync_AddCustomHeaders_Success()
109 (cws.State == WebSocketState.None) || in ConnectAsync_AddHostHeader_Success()
111 (cws.State == WebSocketState.Open), in ConnectAsync_AddHostHeader_Success()
116 Assert.Equal(WebSocketState.Open, cws.State); in ConnectAsync_AddHostHeader_Success()
156 cws.State == WebSocketState.None || in ConnectAsync_CookieHeaders_Success()
158 cws.State == WebSocketState.Open, in ConnectAsync_CookieHeaders_Success()
163 Assert.Equal(WebSocketState.Open, cws.State); in ConnectAsync_CookieHeaders_Success()
[all …]
H A DCloseTest.cs48 Assert.Equal(WebSocketState.CloseReceived, cws.State); in CloseAsync_ServerInitiatedClose_Success()
56 Assert.Equal(WebSocketState.Closed, cws.State); in CloseAsync_ServerInitiatedClose_Success()
72 Assert.Equal(WebSocketState.Open, cws.State); in CloseAsync_ClientInitiatedClose_Success()
79 Assert.Equal(WebSocketState.Closed, cws.State); in CloseAsync_ClientInitiatedClose_Success()
120 Assert.Equal(WebSocketState.Open, cws.State); in CloseAsync_CloseDescriptionIsMaxLengthPlusOne_ThrowsArgumentException()
240 Assert.Equal(WebSocketState.Closed, cws.State); in CloseOutputAsync_ServerInitiated_CanSend()
270 Assert.Equal(WebSocketState.Open, cws.State); in CloseOutputAsync_DuringConcurrentReceiveAsync_ExpectedStates()
276 cws.State == WebSocketState.CloseSent || cws.State == WebSocketState.Closed, in CloseOutputAsync_DuringConcurrentReceiveAsync_ExpectedStates()
283 Assert.Equal(WebSocketState.Closed, cws.State); in CloseOutputAsync_DuringConcurrentReceiveAsync_ExpectedStates()
289 Assert.Equal(WebSocketState.Closed, cws.State); in CloseOutputAsync_DuringConcurrentReceiveAsync_ExpectedStates()
[all …]
H A DSendReceiveTest.cs139 Assert.Equal(WebSocketState.Open, cws.State); in SendAsync_SendCloseMessageType_ThrowsArgumentExceptionWithMessage()
167 Assert.Equal(WebSocketState.Open, cws.State); in SendAsync_MultipleOutstandingSendOperations_Throws()
181 Assert.Equal(WebSocketState.Aborted, cws.State); in SendAsync_MultipleOutstandingSendOperations_Throws()
186 Assert.Equal(WebSocketState.Aborted, cws.State); in SendAsync_MultipleOutstandingSendOperations_Throws()
230 Assert.Equal(WebSocketState.Open, cws.State); in ReceiveAsync_MultipleOutstandingReceiveOperations_Throws()
244 Assert.Equal(WebSocketState.Aborted, cws.State); in ReceiveAsync_MultipleOutstandingReceiveOperations_Throws()
283 Assert.Equal(WebSocketState.Open, cws.State); in SendAsync_SendZeroLengthPayloadAsEndOfMessage_Success()
290 Assert.Equal(WebSocketState.Open, cws.State); in SendAsync_SendZeroLengthPayloadAsEndOfMessage_Success()
296 Assert.Equal(WebSocketState.Open, cws.State); in SendAsync_SendZeroLengthPayloadAsEndOfMessage_Success()
429 Assert.Equal(WebSocketState.Open, clientSocket.State); in SendReceive_ConnectionClosedPrematurely_ReceiveAsyncFailsAndWebSocketStateUpdated()
[all …]
H A DClientWebSocketTestBase.cs66 Assert.Equal(WebSocketState.Aborted, cws.State); in TestCancellation()
71 Assert.Equal(WebSocketState.Aborted, cws.State); in TestCancellation()
82 Assert.Equal(WebSocketState.Aborted, cws.State); in TestCancellation()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/Common/src/System/Net/WebSockets/
H A DManagedWebSocket.cs49 …private static readonly WebSocketState[] s_validSendStates = { WebSocketState.Open, WebSocketState…
51 …private static readonly WebSocketState[] s_validReceiveStates = { WebSocketState.Open, WebSocketSt…
53 …private static readonly WebSocketState[] s_validCloseOutputStates = { WebSocketState.Open, WebSock…
55 …private static readonly WebSocketState[] s_validCloseStates = { WebSocketState.Open, WebSocketStat…
104 private WebSocketState _state = WebSocketState.Open;
206 if (state != WebSocketState.Closed && state != WebSocketState.Aborted) in ManagedWebSocket()
208 … thisRef._state = state != WebSocketState.None && state != WebSocketState.Connecting ? in ManagedWebSocket()
209 WebSocketState.Aborted : in ManagedWebSocket()
210 WebSocketState.Closed; in ManagedWebSocket()
240 _state = WebSocketState.Closed; in DisposeCore()
[all …]
/dports/net/oha/oha-0.4.7/cargo-crates/tungstenite-0.12.0/src/protocol/
H A Dmod.rs235 state: WebSocketState,
252 state: WebSocketState::Active, in new()
397 self.state = WebSocketState::Terminated; in write_pending()
548 WebSocketState::ClosedByPeer | WebSocketState::CloseAcknowledged => { in read_message_frame()
561 WebSocketState::Active => { in do_close()
584 WebSocketState::ClosedByPeer | WebSocketState::CloseAcknowledged => { in do_close()
588 WebSocketState::ClosedByUs => { in do_close()
618 enum WebSocketState { enum
631 impl WebSocketState { impl
634 matches!(self, WebSocketState::Active) in is_active()
[all …]
/dports/textproc/mdbook/mdBook-0.4.13/cargo-crates/tungstenite-0.12.0/src/protocol/
H A Dmod.rs235 state: WebSocketState,
252 state: WebSocketState::Active, in new()
397 self.state = WebSocketState::Terminated; in write_pending()
548 WebSocketState::ClosedByPeer | WebSocketState::CloseAcknowledged => { in read_message_frame()
561 WebSocketState::Active => { in do_close()
584 WebSocketState::ClosedByPeer | WebSocketState::CloseAcknowledged => { in do_close()
588 WebSocketState::ClosedByUs => { in do_close()
618 enum WebSocketState { enum
631 impl WebSocketState { implementation
634 matches!(self, WebSocketState::Active) in is_active()
[all …]
/dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/cargo-crates/tungstenite-0.13.0/src/protocol/
H A Dmod.rs235 state: WebSocketState,
252 state: WebSocketState::Active, in new()
397 self.state = WebSocketState::Terminated; in write_pending()
544 WebSocketState::ClosedByPeer | WebSocketState::CloseAcknowledged => { in read_message_frame()
557 WebSocketState::Active => { in do_close()
580 WebSocketState::ClosedByPeer | WebSocketState::CloseAcknowledged => { in do_close()
584 WebSocketState::ClosedByUs => { in do_close()
614 enum WebSocketState { enum
627 impl WebSocketState { implementation
630 matches!(self, WebSocketState::Active) in is_active()
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Web/WebSockets/
H A DAspNetWebSocket.cs97 internal WebSocketState _state = WebSocketState.Open;
136 public override WebSocketState State {
182 _state = WebSocketState.Aborted; in Abort()
345 case WebSocketState.Open: in CloseOutputAsyncImpl()
346 _state = WebSocketState.CloseSent; in CloseOutputAsyncImpl()
349 case WebSocketState.CloseReceived: in CloseOutputAsyncImpl()
350 _state = WebSocketState.Closed; in CloseOutputAsyncImpl()
411 case WebSocketState.Open: in ReceiveAsyncImpl()
415 case WebSocketState.CloseSent: in ReceiveAsyncImpl()
416 _state = WebSocketState.Closed; in ReceiveAsyncImpl()
[all …]
/dports/www/uwebsockets/uWebSockets-20.8.0/fuzzing/
H A DWebSocket.cpp11 static bool refusePayloadLength(uint64_t length, uWS::WebSocketState<true> *wState, void *s) { in refusePayloadLength()
22 static bool setCompressed(uWS::WebSocketState<true> *wState, void *s) { in setCompressed()
27 … static void forceClose(uWS::WebSocketState<true> *wState, void *s, std::string_view reason = {}) { in forceClose()
31 …ze_t length, unsigned int remainingBytes, int opCode, bool fin, uWS::WebSocketState<true> *webSock… in handleFragment()
50 uWS::WebSocketState<true> state; in LLVMFuzzerTestOneInput()
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System/net/System/Net/WebSockets/
H A DWebSocket.cs23 public abstract WebSocketState State { get; }
142 …protected static void ThrowOnInvalidState(WebSocketState state, params WebSocketState[] validState… in ThrowOnInvalidState()
148 foreach (WebSocketState currentState in validStates) in ThrowOnInvalidState()
162 protected static bool IsStateTerminal(WebSocketState state) in IsStateTerminal()
164 return state == WebSocketState.Closed || in IsStateTerminal()
165 state == WebSocketState.Aborted; in IsStateTerminal()
H A DWebSocketBase.cs59 private volatile WebSocketState m_State;
113 m_State = WebSocketState.Open; in WebSocketBase()
142 public override WebSocketState State
219 ThrowOnInvalidState(State, WebSocketState.Open, WebSocketState.CloseSent); in ReceiveAsyncCore()
324 ThrowOnInvalidState(State, WebSocketState.Open, WebSocketState.CloseReceived); in SendAsyncCore()
557 ThrowOnInvalidState(State, WebSocketState.Open, WebSocketState.CloseReceived); in CloseOutputAsyncCore()
669 case WebSocketState.Open: in OnCloseOutputCompleted()
698 m_State = WebSocketState.Closed; in StartOnCloseCompleted()
798 … WebSocketState.Open, WebSocketState.CloseReceived, WebSocketState.CloseSent); in CloseAsyncCore()
1261 if (State == WebSocketState.Closed || State == WebSocketState.Aborted) in ThrowIfClosedOrAborted()
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.WebSockets/src/System/Net/WebSockets/
H A DWebSocket.cs19 public abstract WebSocketState State { get; }
88 …protected static void ThrowOnInvalidState(WebSocketState state, params WebSocketState[] validState… in ThrowOnInvalidState()
94 foreach (WebSocketState currentState in validStates) in ThrowOnInvalidState()
108 protected static bool IsStateTerminal(WebSocketState state) =>
109 state == WebSocketState.Closed || state == WebSocketState.Aborted;
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.HttpListener/src/System/Net/Windows/WebSockets/
H A DWebSocketBase.cs47 private volatile WebSocketState _state;
100 _state = WebSocketState.Open; in WebSocketBase()
129 public override WebSocketState State
204 ThrowOnInvalidState(State, WebSocketState.Open, WebSocketState.CloseSent); in ReceiveAsyncCore()
304 ThrowOnInvalidState(State, WebSocketState.Open, WebSocketState.CloseReceived); in SendAsyncCore()
518 ThrowOnInvalidState(State, WebSocketState.Open, WebSocketState.CloseReceived); in CloseOutputAsyncCore()
630 case WebSocketState.Open: in OnCloseOutputCompleted()
659 _state = WebSocketState.Closed; in StartOnCloseCompleted()
752 … WebSocketState.Open, WebSocketState.CloseReceived, WebSocketState.CloseSent); in CloseAsyncCore()
1206 if (State == WebSocketState.Closed || State == WebSocketState.Aborted) in ThrowIfClosedOrAborted()
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/System/Test/System.Net.WebSockets/
H A DClientWebSocketTest.cs53 if (socket.State == WebSocketState.Open) in Teardown()
122 Assert.AreEqual (WebSocketState.None, socket.State); in EchoTest()
124 Assert.AreEqual (WebSocketState.Open, socket.State); in EchoTest()
138 Assert.AreEqual (WebSocketState.Closed, socket.State); in EchoTest()
146 Assert.AreEqual (WebSocketState.Open, socket.State); in CloseOutputAsyncTest()
149 Assert.AreEqual (WebSocketState.CloseSent, socket.State); in CloseOutputAsyncTest()
152 Assert.AreEqual (WebSocketState.CloseReceived, socket.State); in CloseOutputAsyncTest()
167 Assert.AreEqual (WebSocketState.Open, socket.State); in CloseAsyncTest()
170 Assert.AreEqual (WebSocketState.Closed, socket.State); in CloseAsyncTest()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.HttpListener/tests/
H A DHttpListenerWebSocketTests.cs173 Assert.Equal(WebSocketState.CloseSent, context.WebSocket.State); in CloseOutputAsync_HandshakeStartedFromClient_Success()
194 Assert.Equal(WebSocketState.Closed, context.WebSocket.State); in CloseOutputAsync_HandshakeStartedFromClient_Success()
235 Assert.Equal(WebSocketState.CloseReceived, context.WebSocket.State); in CloseAsync_HandshakeStartedFromClient_Success()
257 Assert.Equal(WebSocketState.Closed, context.WebSocket.State); in CloseAsync_HandshakeStartedFromClient_Success()
313 Assert.Equal(WebSocketState.Aborted, context.WebSocket.State); in Dispose_CallAfterDisposed_Nop()
316 Assert.Equal(WebSocketState.Aborted, context.WebSocket.State); in Dispose_CallAfterDisposed_Nop()
319 Assert.Equal(WebSocketState.Aborted, context.WebSocket.State); in Dispose_CallAfterDisposed_Nop()
327 Assert.Equal(WebSocketState.Aborted, context.WebSocket.State); in Abort_CallAfterAborted_Nop()
330 Assert.Equal(WebSocketState.Aborted, context.WebSocket.State); in Abort_CallAfterAborted_Nop()
333 Assert.Equal(WebSocketState.Aborted, context.WebSocket.State); in Abort_CallAfterAborted_Nop()

1234