| File was renamed from opendj-sdk/sdk/src/org/opends/sdk/ldap/AbstractLDAPTransport.java |
| | |
| | | * Copyright 2009 Sun Microsystems, Inc. |
| | | */ |
| | | |
| | | package org.opends.sdk.ldap; |
| | | package com.sun.opends.sdk.ldap; |
| | | |
| | | |
| | | |
| | |
| | | import com.sun.grizzly.streams.StreamReader; |
| | | import com.sun.grizzly.streams.StreamWriter; |
| | | import com.sun.grizzly.utils.ConcurrentQueuePool; |
| | | |
| | | import org.opends.sdk.ldap.LDAPDecoder; |
| | | |
| | | |
| | | /** |
| | | * Abstract LDAP transport. |
| | | */ |
| | | abstract class AbstractLDAPTransport |
| | | public abstract class AbstractLDAPTransport |
| | | { |
| | | private class ASN1ReaderPool extends |
| | | ConcurrentQueuePool<ASN1StreamReader> |
| | |
| | | |
| | | |
| | | |
| | | AbstractLDAPTransport() |
| | | protected AbstractLDAPTransport() |
| | | { |
| | | this.defaultFilterChainFactory = new DefaultFilterChainFactory(); |
| | | |
| | |
| | | |
| | | |
| | | |
| | | ASN1StreamWriter getASN1Writer(StreamWriter streamWriter) |
| | | public ASN1StreamWriter getASN1Writer(StreamWriter streamWriter) |
| | | { |
| | | ASN1StreamWriter asn1Writer = asn1WriterPool.poll(); |
| | | asn1Writer.setStreamWriter(streamWriter); |
| | |
| | | |
| | | |
| | | |
| | | PatternFilterChainFactory getDefaultFilterChainFactory() |
| | | public PatternFilterChainFactory getDefaultFilterChainFactory() |
| | | { |
| | | return defaultFilterChainFactory; |
| | | } |
| | | |
| | | |
| | | |
| | | void releaseASN1Writer(ASN1StreamWriter asn1Writer) |
| | | public void releaseASN1Writer(ASN1StreamWriter asn1Writer) |
| | | { |
| | | asn1WriterPool.offer(asn1Writer); |
| | | } |
| | | |
| | | |
| | | |
| | | abstract LDAPMessageHandler getMessageHandler(Connection<?> connection); |
| | | protected abstract LDAPMessageHandler getMessageHandler( |
| | | Connection<?> connection); |
| | | |
| | | |
| | | |
| | | abstract void removeMessageHandler(Connection<?> connection); |
| | | protected abstract void removeMessageHandler(Connection<?> connection); |
| | | |
| | | |
| | | |