| | |
| | | * |
| | | * |
| | | * Copyright 2006-2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2011-2014 ForgeRock AS |
| | | * Portions Copyright 2011-2015 ForgeRock AS |
| | | */ |
| | | package org.opends.server.core; |
| | | |
| | |
| | | import java.util.Map; |
| | | import java.util.Set; |
| | | import java.util.concurrent.atomic.AtomicBoolean; |
| | | import java.util.concurrent.atomic.AtomicInteger; |
| | | |
| | | import org.forgerock.i18n.slf4j.LocalizedLogger; |
| | | import org.forgerock.opendj.ldap.ByteString; |
| | |
| | | private DN proxiedAuthorizationDN; |
| | | |
| | | /** The number of entries that have been sent to the client. */ |
| | | private final AtomicInteger entriesSent = new AtomicInteger(); |
| | | private int entriesSent; |
| | | |
| | | /** |
| | | * The number of search result references that have been sent to the client. |
| | | */ |
| | | private final AtomicInteger referencesSent = new AtomicInteger(); |
| | | private int referencesSent; |
| | | |
| | | /** The size limit for the search operation. */ |
| | | private int sizeLimit; |
| | |
| | | @Override |
| | | public final int getEntriesSent() |
| | | { |
| | | return entriesSent.get(); |
| | | return entriesSent; |
| | | } |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public final int getReferencesSent() |
| | | { |
| | | return referencesSent.get(); |
| | | return referencesSent; |
| | | } |
| | | |
| | | /** {@inheritDoc} */ |
| | |
| | | { |
| | | sendSearchEntry(filteredSearchEntry); |
| | | |
| | | entriesSent.incrementAndGet(); |
| | | entriesSent++; |
| | | } |
| | | catch (DirectoryException de) |
| | | { |
| | |
| | | { |
| | | if (sendSearchReference(reference)) |
| | | { |
| | | referencesSent.incrementAndGet(); |
| | | referencesSent++; |
| | | |
| | | // FIXME -- Should the size limit apply here? |
| | | } |