| | |
| | | import java.util.Arrays; |
| | | import java.util.concurrent.CountDownLatch; |
| | | import java.util.concurrent.TimeUnit; |
| | | import java.util.concurrent.atomic.AtomicBoolean; |
| | | import java.util.logging.Level; |
| | | |
| | | import org.forgerock.opendj.ldap.requests.AbandonRequest; |
| | |
| | | final MockServerConnection serverConnection = new MockServerConnection(); |
| | | final MockServerConnectionFactory serverConnectionFactory = |
| | | new MockServerConnectionFactory(serverConnection); |
| | | final AtomicBoolean isDummyFilterInvoked = new AtomicBoolean(false); |
| | | |
| | | TCPNIOTransport transport = TCPNIOTransportBuilder.newInstance() |
| | | .setProcessor( |
| | |
| | | @Override |
| | | public NextAction handleAccept(FilterChainContext ctx) |
| | | throws IOException { |
| | | StaticUtils.DEBUG_LOG.log(Level.INFO, |
| | | "Accepting using dummy filter"); |
| | | Thread.dumpStack(); |
| | | isDummyFilterInvoked.set(true); |
| | | return super.handleAccept(ctx); |
| | | } |
| | | }).build()).build(); |
| | |
| | | connection.close(); |
| | | assertThat(serverConnection.isClosed.await(10, TimeUnit.SECONDS)).isTrue(); |
| | | } finally { |
| | | StaticUtils.DEBUG_LOG.log(Level.INFO, "isDummyFilterInvoked=" + isDummyFilterInvoked.get()); |
| | | listener.close(); |
| | | } |
| | | } |