| | |
| | | * |
| | | * |
| | | * Copyright 2008-2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2010-2013 ForgeRock AS |
| | | * Portions Copyright 2010-2014 ForgeRock AS |
| | | */ |
| | | package org.opends.server.workflowelement.externalchangelog; |
| | | |
| | |
| | | import org.opends.server.types.operation.SearchEntrySearchOperation; |
| | | import org.opends.server.types.operation.SearchReferenceSearchOperation; |
| | | import org.opends.server.util.ServerConstants; |
| | | import org.opends.server.util.TimeThread; |
| | | |
| | | import static org.opends.messages.CoreMessages.*; |
| | | import static org.opends.messages.ReplicationMessages.*; |
| | | import static org.opends.server.config.ConfigConstants.*; |
| | | import static org.opends.server.loggers.ErrorLogger.*; |
| | | import static org.opends.server.loggers.debug.DebugLogger.*; |
| | |
| | | return; |
| | | } |
| | | |
| | | int lookthroughCount = 0; |
| | | int lookthroughLimit = getClientConnection().getLookthroughLimit(); |
| | | |
| | | // Process change log entries. |
| | | while (update != null) |
| | | { |
| | | if(lookthroughLimit > 0 && lookthroughCount > lookthroughLimit) |
| | | { |
| | | //Lookthrough limit exceeded |
| | | setResultCode(ResultCode.ADMIN_LIMIT_EXCEEDED); |
| | | appendErrorMessage( |
| | | NOTE_ECL_LOOKTHROUGH_LIMIT_EXCEEDED.get(lookthroughLimit)); |
| | | return; |
| | | } |
| | | // Check for a request to cancel this operation. |
| | | checkIfCanceled(false); |
| | | |
| | |
| | | return; |
| | | } |
| | | |
| | | lookthroughCount++; |
| | | |
| | | update = eclServerHandler.getNextECLUpdate(); |
| | | } |
| | | } |
| | |
| | | } |
| | | return returnEntry(entry, controls); |
| | | } |
| | | |
| | | // Check the timelimit here as well, in case there are no matches |
| | | if ((getTimeLimit() > 0) && (TimeThread.getTime() >= |
| | | getTimeLimitExpiration())) |
| | | { |
| | | setResultCode(ResultCode.TIME_LIMIT_EXCEEDED); |
| | | appendErrorMessage(ERR_SEARCH_TIME_LIMIT_EXCEEDED.get(getTimeLimit())); |
| | | return false; |
| | | } |
| | | |
| | | return true; |
| | | } |
| | | |