Home
last modified time | relevance | path

Searched refs:session (Results 1 – 25 of 29) sorted by path

12

/unit/
H A DCHANGES92 *) Feature: TLS session tickets.
/unit/src/java/javax/websocket/
H A DEndpoint.java28 public abstract void onOpen(Session session, EndpointConfig config); in onOpen() argument
36 public void onClose(Session session, CloseReason closeReason) { in onClose() argument
46 public void onError(Session session, Throwable throwable) { in onError() argument
H A DSessionException.java23 private final Session session; field in SessionException
26 public SessionException(String message, Throwable cause, Session session) { in SessionException() argument
28 this.session = session; in SessionException()
33 return session; in getSession()
/unit/src/java/nginx/unit/
H A DContext.java3303 Session session = new Session(this, generateSessionId(),
3308 HttpSessionEvent event = new HttpSessionEvent(session);
3317 sessions_.put(session.getId(), session);
3319 return session;
3323 public void invalidateSession(Session session)
3326 sessions_.remove(session.getId());
3331 HttpSessionEvent event = new HttpSessionEvent(session);
3340 public void changeSessionId(Session session)
3345 old_id = session.getId();
3348 session.setId(generateSessionId());
[all …]
H A DRequest.java119 private Session session = null; field in Request
522 if (session != null) { in getSession()
526 return session; in getSession()
529 session = null; in getSession()
538 if (session != null || !create) { in getSession()
539 trace("getSession(" + create + "): " + (session != null ? session.getId() : "null")); in getSession()
541 return session; in getSession()
544 session = context.createSession(); in getSession()
554 return session; in getSession()
1244 if (session == null) { in changeSessionId()
[all …]
/unit/src/java/nginx/unit/websocket/
H A DLocalStrings.properties73 wsFrame.sessionClosed=The client data cannot be processed because the session has already been clos…
84 wsRemoteEndpoint.closed=Message will not be sent because the WebSocket session has been closed
85 …Message=The remainder of the message will not be sent because the WebSocket session has been closed
90 wsRemoteEndpoint.flushOnCloseFailed=Batched messages still enabled after session has been closed. U…
103 wsSession.timeout=The WebSocket session [{0}] timeout expired
105 …ssion.closed=The WebSocket session [{0}] has been closed and no method (apart from close()) may be…
106 wsSession.created=Created WebSocket session [{0}]
107 wsSession.doClose=Closing WebSocket session [{1}]
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
[all …]
H A DUtil.java363 Session session) { in getMessageHandlers() argument
391 getOnMessageMethod(listener), session, in getMessageHandlers()
395 getOnMessagePartialMethod(listener), session, in getMessageHandlers()
402 getOnMessageMethod(listener), session, in getMessageHandlers()
410 getOnMessageMethod(listener), session, in getMessageHandlers()
422 new PojoMessageHandlerWholeBinary(listener, m, session, in getMessageHandlers()
431 new PojoMessageHandlerWholeText(listener, m, session, in getMessageHandlers()
H A DWsWebSocketContainer.java1031 for (WsSession session : sessions.keySet()) { in destroy()
1033 session.close(cr); in destroy()
1036 "wsWebSocketContainer.sessionCloseFail", session.getId()), ioe); in destroy()
/unit/src/java/nginx/unit/websocket/pojo/
H A DLocalStrings.properties16 pojoEndpointBase.closeSessionFail=Failed to close WebSocket session during error handling
27 pojoMethodMapping.duplicateSessionParam=Multiple session parameters present on the method [{0}] of …
H A DPojoEndpointBase.java59 pathParameters, session, config)) { in doOnOpen()
60 session.addMessageHandler(mh); in doOnOpen()
67 pathParameters, session, config)); in doOnOpen()
74 handleOnOpenOrCloseError(session, e); in doOnOpen()
77 handleOnOpenOrCloseError(session, cause); in doOnOpen()
79 handleOnOpenOrCloseError(session, t); in doOnOpen()
85 private void handleOnOpenOrCloseError(Session session, Throwable t) { in handleOnOpenOrCloseError() argument
90 onError(session, t); in handleOnOpenOrCloseError()
92 session.close(); in handleOnOpenOrCloseError()
108 handleOnOpenOrCloseError(session, t); in onClose()
[all …]
H A DPojoEndpointClient.java44 public void onOpen(Session session, EndpointConfig config) { in onOpen() argument
45 doOnOpen(session, config); in onOpen()
H A DPojoEndpointServer.java38 public void onOpen(Session session, EndpointConfig endpointConfig) { in onOpen() argument
64 doOnOpen(session, endpointConfig); in onOpen()
H A DPojoMessageHandlerBase.java41 protected final Session session; field in PojoMessageHandlerBase
49 Session session, Object[] params, int indexPayload, boolean convert, in PojoMessageHandlerBase() argument
61 this.session = session; in PojoMessageHandlerBase()
75 RemoteEndpoint.Basic remoteEndpoint = session.getBasicRemote(); in processResult()
H A DPojoMessageHandlerPartialBase.java41 Session session, Object[] params, int indexPayload, in PojoMessageHandlerPartialBase() argument
44 super(pojo, method, session, params, indexPayload, convert, in PojoMessageHandlerPartialBase()
53 ((WsSession) session).getLocal().onError(session, in onMessage()
62 parameters[indexSession] = session; in onMessage()
H A DPojoMessageHandlerPartialBinary.java31 Session session, Object[] params, int indexPayload, boolean convert, in PojoMessageHandlerPartialBinary() argument
33 super(pojo, method, session, params, indexPayload, convert, indexBoolean, in PojoMessageHandlerPartialBinary()
H A DPojoMessageHandlerPartialText.java30 Session session, Object[] params, int indexPayload, boolean convert, in PojoMessageHandlerPartialText() argument
32 super(pojo, method, session, params, indexPayload, convert, indexBoolean, in PojoMessageHandlerPartialText()
H A DPojoMessageHandlerWholeBase.java38 Session session, Object[] params, int indexPayload, in PojoMessageHandlerWholeBase() argument
40 super(pojo, method, session, params, indexPayload, convert, in PojoMessageHandlerWholeBase()
49 ((WsSession) session).getLocal().onError(session, in onMessage()
59 ((WsSession) session).getLocal().onError(session, de); in onMessage()
74 parameters[indexSession] = session; in onMessage()
H A DPojoMessageHandlerWholeBinary.java49 Session session, EndpointConfig config, in PojoMessageHandlerWholeBinary() argument
53 super(pojo, method, session, params, indexPayload, convert, in PojoMessageHandlerWholeBinary()
57 if (maxMessageSize > -1 && maxMessageSize > session.getMaxBinaryMessageBufferSize()) { in PojoMessageHandlerWholeBinary()
62 session.setMaxBinaryMessageBufferSize((int) maxMessageSize); in PojoMessageHandlerWholeBinary()
H A DPojoMessageHandlerWholePong.java31 Session session, Object[] params, int indexPayload, boolean convert, in PojoMessageHandlerWholePong() argument
33 super(pojo, method, session, params, indexPayload, convert, in PojoMessageHandlerWholePong()
H A DPojoMessageHandlerWholeText.java49 Session session, EndpointConfig config, in PojoMessageHandlerWholeText() argument
53 super(pojo, method, session, params, indexPayload, convert, in PojoMessageHandlerWholeText()
57 if (maxMessageSize > -1 && maxMessageSize > session.getMaxTextMessageBufferSize()) { in PojoMessageHandlerWholeText()
62 session.setMaxTextMessageBufferSize((int) maxMessageSize); in PojoMessageHandlerWholeText()
H A DPojoMethodMapping.java229 Session session, EndpointConfig config) throws DecodeException { in getOnOpenArgs() argument
253 Session session, Throwable throwable) throws DecodeException { in getOnErrorArgs() argument
254 return buildArgs(onErrorParams, pathParameters, session, null, in getOnErrorArgs()
265 Map<String,String> pathParameters, Session session, in getMessageHandlers() argument
270 session, config)); in getMessageHandlers()
336 Map<String,String> pathParameters, Session session, in buildArgs() argument
343 result[i] = session; in buildArgs()
631 Map<String,String> pathParameters, Session session, in getMessageHandlers() argument
684 pojo, m, session, config, in getMessageHandlers()
692 pojo, m, session, config, in getMessageHandlers()
[all …]
/unit/src/java/nginx/unit/websocket/server/
H A DWsHttpUpgradeHandler.java96 Object session = handshakeRequest.getHttpSession(); in init() local
97 if (session != null ) { in init()
98 httpSessionId = ((HttpSession) session).getId(); in init()
/unit/src/
H A Dnxt_cyassl.c13 CYASSL *session; member
207 ssltls->session = s; in nxt_cyassl_conn_init()
238 CyaSSL_free(ssltls->session); in nxt_cyassl_session_cleanup()
310 ret = CyaSSL_negotiate(ssltls->session); in nxt_cyassl_conn_handshake()
361 ret = CyaSSL_read(ssltls->session, b->mem.free, in nxt_cyassl_conn_io_read()
420 ret = CyaSSL_write(ssltls->session, buf, size); in nxt_cyassl_conn_io_send()
462 ret = CyaSSL_shutdown(ssltls->session); in nxt_cyassl_conn_io_shutdown()
483 ssltls->ssl_error = CyaSSL_get_error(ssltls->session, ret); in nxt_cyassl_conn_test_error()
H A Dnxt_gnutls.c12 gnutls_session_t session; member
278 ret = gnutls_init(&ssltls->session, GNUTLS_SERVER); in nxt_gnutls_conn_init()
285 sess = ssltls->session; in nxt_gnutls_conn_init()
347 gnutls_deinit(ssltls->session); in nxt_gnutls_session_cleanup()
440 err = gnutls_handshake(ssltls->session); in nxt_gnutls_conn_handshake()
461 && gnutls_record_get_direction(ssltls->session) == 0) in nxt_gnutls_conn_handshake()
490 n = gnutls_record_recv(ssltls->session, b->mem.free, in nxt_gnutls_conn_io_read()
548 n = gnutls_record_send(ssltls->session, buf, size); in nxt_gnutls_conn_io_send()
583 if (ssltls->session == NULL || ssltls->no_shutdown) { in nxt_gnutls_conn_io_shutdown()
600 err = gnutls_bye(ssltls->session, how); in nxt_gnutls_conn_io_shutdown()
[all …]
H A Dnxt_openssl.c22 SSL *session; member
1186 tls->session = s;
1232 SSL_free(tls->session);
1267 ret = SSL_do_handshake(tls->session);
1343 ret = SSL_read(tls->session, b->mem.free, size);
1394 ret = SSL_write(tls->session, buf, size);
1445 s = tls->session;
1552 tls->ssl_error = SSL_get_error(tls->session, ret);

12