[#402] Change default SSL HandshakeTimeout -1 -> 10s (see #146) (#411)
| | |
| | | * |
| | | * Copyright 2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2011-2016 ForgeRock AS. |
| | | * Portions Copyright 2019-2024 3A Systems, LLC. |
| | | */ |
| | | package org.forgerock.opendj.grizzly; |
| | | |
| | |
| | | |
| | | SSLEngineConfigurator serverSslEngineConfigurator = buildServerSSLEngineConfigurator(sslContext); |
| | | final SSLFilter sslFilter = new SSLFilter(serverSslEngineConfigurator, sslEngineConfigurator); |
| | | sslFilter.setHandshakeTimeout(getLongProperty("org.forgerock.opendj.grizzly.handshakeTimeout", sslFilter.getHandshakeTimeout(TimeUnit.MILLISECONDS)), TimeUnit.MILLISECONDS); |
| | | sslFilter.setHandshakeTimeout(getLongProperty("org.forgerock.opendj.grizzly.handshakeTimeout", 10000), TimeUnit.MILLISECONDS); |
| | | installFilter(sslFilter); |
| | | sslFilter.handshake(connection, completionHandler); |
| | | } |
| | |
| | | * |
| | | * Copyright 2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2012-2016 ForgeRock AS. |
| | | * Portions Copyright 2017-2024 3A Systems, LLC. |
| | | */ |
| | | package org.forgerock.opendj.grizzly; |
| | | |
| | |
| | | } |
| | | |
| | | SSLFilter sslFilter = new SSLFilter(); |
| | | sslFilter.setHandshakeTimeout(getLongProperty("org.forgerock.opendj.grizzly.handshakeTimeout", sslFilter.getHandshakeTimeout(TimeUnit.MILLISECONDS)), TimeUnit.MILLISECONDS); |
| | | sslFilter.setHandshakeTimeout(getLongProperty("org.forgerock.opendj.grizzly.handshakeTimeout", 10000), TimeUnit.MILLISECONDS); |
| | | installFilter(startTls ? new StartTLSFilter(sslFilter) : sslFilter); |
| | | return true; |
| | | } |
| | |
| | | * |
| | | * Copyright 2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2011-2016 ForgeRock AS. |
| | | * Portions Copyright 2019-2024 3A Systems, LLC. |
| | | */ |
| | | |
| | | package org.forgerock.opendj.grizzly; |
| | |
| | | assertThat(context.isClosed()).isFalse(); |
| | | if (config.sendDisconnectNotification) { |
| | | context.disconnect(ResultCode.BUSY, "busy"); |
| | | for(int i=1;i<10 && !context.isClosed() ;i++) { |
| | | Thread.sleep(100); |
| | | } |
| | | } else { |
| | | context.disconnect(); |
| | | } |
| | | for(int i=1;i<100 && !context.isClosed() ;i++) { |
| | | Thread.sleep(100); |
| | | } |
| | | assertThat(context.isClosed()).isTrue(); |
| | | } |
| | | // Block until remote close is signalled. |