115116117118119120121122123124125
} else { this.handler.timeout(conn); synchronized (ssliosession) { if (ssliosession.isOutboundDone() && !ssliosession.isInboundDone()) { // The session failed to terminate cleanly ssliosession.shutdown(); } } } } }
128129130131132133134135136137138
try { sslSession.bind(SSLMode.CLIENT, this.params); } catch (SSLException ex) { this.handler.exception(conn, ex); sslSession.shutdown(); } } public void disconnected(final IOSession session) { NHttpClientIOTarget conn =
152153154155156157158159160161162
conn.consumeInput(this.handler); } sslSession.inboundTransport(); } catch (IOException ex) { this.handler.exception(conn, ex); sslSession.shutdown(); } } public void outputReady(final IOSession session) { NHttpClientIOTarget conn =
169170171172173174175176177178179
conn.produceOutput(this.handler); } sslSession.outboundTransport(); } catch (IOException ex) { this.handler.exception(conn, ex); sslSession.shutdown(); } } public void timeout(final IOSession session) { NHttpClientIOTarget conn =
183184185186187188189190191192193
this.handler.timeout(conn); synchronized (sslSession) { if (sslSession.isOutboundDone() && !sslSession.isInboundDone()) { // The session failed to terminate cleanly sslSession.shutdown(); } } } }
127128129130131132133134135136137
try { sslSession.bind(SSLMode.SERVER, this.params); } catch (SSLException ex) { this.handler.exception(conn, ex); sslSession.shutdown(); } } public void disconnected(final IOSession session) { NHttpServerIOTarget conn =
151152153154155156157158159160161
conn.consumeInput(this.handler); } sslSession.inboundTransport(); } catch (IOException ex) { this.handler.exception(conn, ex); sslSession.shutdown(); } } public void outputReady(final IOSession session) { NHttpServerIOTarget conn =
168169170171172173174175176177178
conn.produceOutput(this.handler); } sslSession.outboundTransport(); } catch (IOException ex) { this.handler.exception(conn, ex); sslSession.shutdown(); } } public void timeout(final IOSession session) { NHttpServerIOTarget conn =
182183184185186187188189190191192
this.handler.timeout(conn); synchronized (sslSession) { if (sslSession.isOutboundDone() && !sslSession.isInboundDone()) { // The session failed to cleanly terminate sslSession.shutdown(); } } } }
200201202203204205206207208209210