| | |
| | | |
| | | import static org.opends.messages.JebMessages.*; |
| | | import static org.opends.server.backends.pluggable.JebFormat.*; |
| | | import static org.opends.server.backends.pluggable.EntryIDSet.newSetFromBytes; |
| | | |
| | | import java.util.AbstractSet; |
| | | import java.util.ArrayList; |
| | |
| | | continue; |
| | | } |
| | | |
| | | EntryIDSet entryIDList; |
| | | EntryIDSet entryIDSet; |
| | | |
| | | try |
| | | { |
| | | entryIDList = new EntryIDSet(key, value); |
| | | entryIDSet = newSetFromBytes(key, value); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | |
| | | continue; |
| | | } |
| | | |
| | | updateIndexStats(entryIDList); |
| | | updateIndexStats(entryIDSet); |
| | | |
| | | if (entryIDList.isDefined()) |
| | | if (entryIDSet.isDefined()) |
| | | { |
| | | Entry entry; |
| | | try |
| | |
| | | continue; |
| | | } |
| | | |
| | | for (EntryID id : entryIDList) |
| | | for (EntryID id : entryIDSet) |
| | | { |
| | | Entry childEntry; |
| | | try |
| | |
| | | continue; |
| | | } |
| | | |
| | | EntryIDSet entryIDList; |
| | | EntryIDSet entryIDSet; |
| | | try |
| | | { |
| | | entryIDList = new EntryIDSet(key, value); |
| | | entryIDSet = newSetFromBytes(key, value); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | |
| | | continue; |
| | | } |
| | | |
| | | updateIndexStats(entryIDList); |
| | | updateIndexStats(entryIDSet); |
| | | |
| | | if (entryIDList.isDefined()) |
| | | if (entryIDSet.isDefined()) |
| | | { |
| | | Entry entry; |
| | | try |
| | |
| | | continue; |
| | | } |
| | | |
| | | for (EntryID id : entryIDList) |
| | | for (EntryID id : entryIDSet) |
| | | { |
| | | Entry subordEntry; |
| | | try |
| | |
| | | final ByteString key = cursor.getKey(); |
| | | ByteString value = cursor.getValue(); |
| | | |
| | | EntryIDSet entryIDList; |
| | | EntryIDSet entryIDSet; |
| | | try |
| | | { |
| | | entryIDList = new EntryIDSet(key, value); |
| | | entryIDSet = newSetFromBytes(key, value); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | |
| | | continue; |
| | | } |
| | | |
| | | updateIndexStats(entryIDList); |
| | | updateIndexStats(entryIDSet); |
| | | |
| | | if (entryIDList.isDefined()) |
| | | if (entryIDSet.isDefined()) |
| | | { |
| | | EntryID prevID = null; |
| | | |
| | | for (EntryID id : entryIDList) |
| | | for (EntryID id : entryIDSet) |
| | | { |
| | | if (prevID != null && id.equals(prevID) && logger.isTraceEnabled()) |
| | | { |