Home
last modified time | relevance | path

Searched refs:session (Results 1 – 25 of 29) sorted by last modified time

12

/unit/
H A DCHANGES92 *) Feature: TLS session tickets.
/unit/src/
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);
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_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()
/unit/test/
H A Dtest_tls_tickets.py54 def connect(self, ctx=None, session=None, port=7080): argument
63 if session is not None:
64 client.set_session(session)
H A Dconftest.py173 def pytest_sessionstart(session): argument
742 def pytest_sessionfinish(session): argument
H A Dtest_tls_session.py39 session = {}
42 session['cache_size'] = cache_size
44 session['timeout'] = timeout
46 return self.conf(session, 'listeners/*:7080/tls/session')
48 def connect(self, ctx=None, session=None): argument
59 if session is not None:
60 client.set_session(session)
/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 …]
/unit/test/java/websockets_mirror/
H A Dapp.java14 public void onOpen(Session session) { in onOpen() argument
15 session.setMaxTextMessageBufferSize(8388608); in onOpen()
19 public void echoTextMessage(Session session, String msg) { in echoTextMessage() argument
21 if (session.isOpen()) { in echoTextMessage()
22 session.getBasicRemote().sendText(msg, true); in echoTextMessage()
26 session.close(); in echoTextMessage()
34 public void echoBinaryMessage(Session session, ByteBuffer bb) { in echoBinaryMessage() argument
36 if (session.isOpen()) { in echoBinaryMessage()
37 session.getBasicRemote().sendBinary(bb, true); in echoBinaryMessage()
41 session.close(); in echoBinaryMessage()
/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/java/nginx/unit/websocket/pojo/
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 …]
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 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()
/unit/src/java/nginx/unit/websocket/
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()
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 …]

12