Home
last modified time | relevance | path

Searched refs:wsSession (Results 1 – 9 of 9) sorted by relevance

/unit/src/java/nginx/unit/websocket/
H A DFutureToSendHandler.java40 private final WsSession wsSession; field in FutureToSendHandler
43 public FutureToSendHandler(WsSession wsSession) { in FutureToSendHandler() argument
44 this.wsSession = wsSession; in FutureToSendHandler()
80 wsSession.registerFuture(this); in get()
83 wsSession.unregisterFuture(this); in get()
97 wsSession.registerFuture(this); in get()
100 wsSession.unregisterFuture(this); in get()
H A DWsFrameBase.java49 protected final WsSession wsSession; field in WsFrameBase
92 public WsFrameBase(WsSession wsSession, Transformation transformation) { in WsFrameBase() argument
97 this.wsSession = wsSession; in WsFrameBase()
115 wsSession.updateLastActive(); in processInputBuffer()
184 int size = wsSession.getMaxBinaryMessageBufferSize(); in processInitialHeader()
188 binaryMsgHandler = wsSession.getBinaryMessageHandler(); in processInitialHeader()
193 int size = wsSession.getMaxTextMessageBufferSize(); in processInitialHeader()
198 textMsgHandler = wsSession.getTextMessageHandler(); in processInitialHeader()
348 if (wsSession.isOpen()) { in processDataControl()
349 wsSession.getBasicRemote().sendPong(controlBufferBinary); in processDataControl()
[all …]
H A DLocalStrings.properties103 wsSession.timeout=The WebSocket session [{0}] timeout expired
106 wsSession.created=Created WebSocket session [{0}]
107 wsSession.doClose=Closing WebSocket session [{1}]
108 wsSession.duplicateHandlerBinary=A binary message handler has already been configured
109 wsSession.duplicateHandlerPong=A pong message handler has already been configured
110 wsSession.duplicateHandlerText=A text message handler has already been configured
111 wsSession.invalidHandlerTypePong=A pong message handler must implement MessageHandler.Whole
112 wsSession.flushFailOnClose=Failed to flush batched messages on session close
114 wsSession.sendCloseFail=Failed to send close message for session [{0}] to remote endpoint
118 wsSession.instanceNew=Endpoint instance registration failed
[all …]
H A DWsFrameClient.java41 public WsFrameClient(ByteBuffer response, AsyncChannelWrapper channel, WsSession wsSession, in WsFrameClient() argument
43 super(wsSession, transformation); in WsFrameClient()
129 wsSession.close(cr); in close()
H A DWsWebSocketContainer.java502 wsSession, transformation); in connectToServerRecursive()
507 endpoint.onOpen(wsSession, clientEndpointConfiguration); in connectToServerRecursive()
508 registerSession(endpoint, wsSession); in connectToServerRecursive()
522 return wsSession; in connectToServerRecursive()
583 if (!wsSession.isOpen()) { in registerSession()
596 wsSessions.add(wsSession); in registerSession()
598 sessions.put(wsSession, wsSession); in registerSession()
607 wsSessions.remove(wsSession); in unregisterSession()
616 sessions.remove(wsSession); in unregisterSession()
1078 for (WsSession wsSession : sessions.keySet()) { in backgroundProcess()
[all …]
H A DWsRemoteEndpointImplBase.java86 private WsSession wsSession; field in WsRemoteEndpointImplBase
140 FutureToSendHandler f2sh = new FutureToSendHandler(wsSession); in sendBytesByFuture()
200 FutureToSendHandler f2sh = new FutureToSendHandler(wsSession); in sendStringByFuture()
282 wsSession.updateLastActive(); in sendMessageBlock()
303 wsSession.updateLastActive(); in startMessage()
381 wsSession.updateLastActive(); in endMessage()
470 Object obj = wsSession.getUserProperties().get(Constants.BLOCKING_SEND_TIMEOUT_PROPERTY); in getBlockingSendTimeout()
575 FutureToSendHandler f2sh = new FutureToSendHandler(wsSession); in sendObjectByFuture()
636 protected void setSession(WsSession wsSession) { in setSession() argument
637 this.wsSession = wsSession; in setSession()
/unit/src/java/nginx/unit/websocket/server/
H A DWsServerContainer.java341 super.registerSession(endpoint, wsSession); in registerSession()
342 if (wsSession.isOpen() && in registerSession()
345 registerAuthenticatedSession(wsSession, in registerSession()
346 wsSession.getHttpSessionId()); in registerSession()
358 if (wsSession.getUserPrincipal() != null && in unregisterSession()
360 unregisterAuthenticatedSession(wsSession, in unregisterSession()
361 wsSession.getHttpSessionId()); in unregisterSession()
363 super.unregisterSession(endpoint, wsSession); in unregisterSession()
376 wsSessions.add(wsSession); in registerAuthenticatedSession()
385 wsSessions.remove(wsSession); in unregisterAuthenticatedSession()
[all …]
H A DWsHttpUpgradeHandler.java64 private WsSession wsSession; field in WsHttpUpgradeHandler
115 wsSession = new WsSession(ep, wsRemoteEndpointServer, in init()
123 ep.onOpen(wsSession, endpointConfig); in init()
124 webSocketContainer.registerSession(ep, wsSession); in init()
154 ep.onError(wsSession, throwable); in onError()
170 wsSession.onClose(cr); in close()
/unit/src/java/nginx/unit/
H A DRequest.java121 private WsSession wsSession = null; field in Request
1281 wsSession = s; in setWsSession()
1289 wsSession.processFrame(buf, opCode, last); in processWsFrame()
1291 wsSession.onClose(e.getCloseReason()); in processWsFrame()
1300 wsSession.onClose(); in closeWsSession()