| | |
| | | * CDDL HEADER END |
| | | * |
| | | * |
| | | * Portions Copyright 2006 Sun Microsystems, Inc. |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.core; |
| | | |
| | |
| | | import org.opends.server.types.SearchFilter; |
| | | import org.opends.server.types.SearchScope; |
| | | |
| | | import static org.opends.server.loggers.Debug.*; |
| | | import static org.opends.server.loggers.debug.DebugLogger.debugCought; |
| | | import static org.opends.server.loggers.debug.DebugLogger.debugEnabled; |
| | | import org.opends.server.types.DebugLogLevel; |
| | | |
| | | |
| | | |
| | |
| | | */ |
| | | public class PersistentSearch |
| | | { |
| | | /** |
| | | * The fully-qualified name of this class for debugging purposes. |
| | | */ |
| | | private static final String CLASS_NAME = |
| | | "org.opends.server.core.PersistentSearch"; |
| | | |
| | | |
| | | |
| | |
| | | Set<PersistentSearchChangeType> changeTypes, |
| | | boolean returnECs) |
| | | { |
| | | assert debugConstructor(CLASS_NAME, String.valueOf(searchOperation), |
| | | String.valueOf(changeTypes), |
| | | String.valueOf(returnECs)); |
| | | |
| | | this.searchOperation = searchOperation; |
| | | this.changeTypes = changeTypes; |
| | |
| | | */ |
| | | public SearchOperation getSearchOperation() |
| | | { |
| | | assert debugEnter(CLASS_NAME, "getSearchOperation"); |
| | | |
| | | return searchOperation; |
| | | } |
| | |
| | | */ |
| | | public Set<PersistentSearchChangeType> getChangeTypes() |
| | | { |
| | | assert debugEnter(CLASS_NAME, "getChangeTypes"); |
| | | |
| | | return changeTypes; |
| | | } |
| | |
| | | */ |
| | | public boolean getReturnECs() |
| | | { |
| | | assert debugEnter(CLASS_NAME, "getReturnECs"); |
| | | |
| | | return returnECs; |
| | | } |
| | |
| | | */ |
| | | public DN getBaseDN() |
| | | { |
| | | assert debugEnter(CLASS_NAME, "getBaseDN"); |
| | | |
| | | return baseDN; |
| | | } |
| | |
| | | */ |
| | | public SearchScope getScope() |
| | | { |
| | | assert debugEnter(CLASS_NAME, "getScope"); |
| | | |
| | | return scope; |
| | | } |
| | |
| | | */ |
| | | public SearchFilter getFilter() |
| | | { |
| | | assert debugEnter(CLASS_NAME, "getFilter"); |
| | | |
| | | return filter; |
| | | } |
| | |
| | | */ |
| | | public void processAdd(AddOperation addOperation, Entry entry) |
| | | { |
| | | assert debugEnter(CLASS_NAME, "processAdd", String.valueOf(addOperation), |
| | | String.valueOf(entry)); |
| | | |
| | | |
| | | // See if we care about add operations. |
| | |
| | | } |
| | | catch (DirectoryException de) |
| | | { |
| | | assert debugException(CLASS_NAME, "processAdd", de); |
| | | if (debugEnabled()) |
| | | { |
| | | debugCought(DebugLogLevel.ERROR, de); |
| | | } |
| | | |
| | | // FIXME -- Do we need to do anything here? |
| | | |
| | |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | assert debugException(CLASS_NAME, "processAdd", e); |
| | | if (debugEnabled()) |
| | | { |
| | | debugCought(DebugLogLevel.ERROR, e); |
| | | } |
| | | |
| | | DirectoryServer.deregisterPersistentSearch(this); |
| | | |
| | |
| | | } |
| | | catch (Exception e2) |
| | | { |
| | | assert debugException(CLASS_NAME, "processAdd", e2); |
| | | if (debugEnabled()) |
| | | { |
| | | debugCought(DebugLogLevel.ERROR, e2); |
| | | } |
| | | } |
| | | } |
| | | } |
| | |
| | | */ |
| | | public void processDelete(DeleteOperation deleteOperation, Entry entry) |
| | | { |
| | | assert debugEnter(CLASS_NAME, "processDelete", |
| | | String.valueOf(deleteOperation), String.valueOf(entry)); |
| | | |
| | | |
| | | // See if we care about delete operations. |
| | |
| | | } |
| | | catch (DirectoryException de) |
| | | { |
| | | assert debugException(CLASS_NAME, "processDelete", de); |
| | | if (debugEnabled()) |
| | | { |
| | | debugCought(DebugLogLevel.ERROR, de); |
| | | } |
| | | |
| | | // FIXME -- Do we need to do anything here? |
| | | |
| | |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | assert debugException(CLASS_NAME, "processDelete", e); |
| | | if (debugEnabled()) |
| | | { |
| | | debugCought(DebugLogLevel.ERROR, e); |
| | | } |
| | | |
| | | DirectoryServer.deregisterPersistentSearch(this); |
| | | |
| | |
| | | } |
| | | catch (Exception e2) |
| | | { |
| | | assert debugException(CLASS_NAME, "processDelete", e2); |
| | | if (debugEnabled()) |
| | | { |
| | | debugCought(DebugLogLevel.ERROR, e2); |
| | | } |
| | | } |
| | | } |
| | | } |
| | |
| | | public void processModify(ModifyOperation modifyOperation, Entry oldEntry, |
| | | Entry newEntry) |
| | | { |
| | | assert debugEnter(CLASS_NAME, "processModify", |
| | | String.valueOf(modifyOperation), String.valueOf(oldEntry), |
| | | String.valueOf(newEntry)); |
| | | |
| | | |
| | | // See if we care about modify operations. |
| | |
| | | } |
| | | catch (DirectoryException de) |
| | | { |
| | | assert debugException(CLASS_NAME, "processModify", de); |
| | | if (debugEnabled()) |
| | | { |
| | | debugCought(DebugLogLevel.ERROR, de); |
| | | } |
| | | |
| | | // FIXME -- Do we need to do anything here? |
| | | |
| | |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | assert debugException(CLASS_NAME, "processModify", e); |
| | | if (debugEnabled()) |
| | | { |
| | | debugCought(DebugLogLevel.ERROR, e); |
| | | } |
| | | |
| | | DirectoryServer.deregisterPersistentSearch(this); |
| | | |
| | |
| | | } |
| | | catch (Exception e2) |
| | | { |
| | | assert debugException(CLASS_NAME, "processModify", e2); |
| | | if (debugEnabled()) |
| | | { |
| | | debugCought(DebugLogLevel.ERROR, e2); |
| | | } |
| | | } |
| | | } |
| | | } |
| | |
| | | public void processModifyDN(ModifyDNOperation modifyDNOperation, |
| | | Entry oldEntry, Entry newEntry) |
| | | { |
| | | assert debugEnter(CLASS_NAME, "processModifyDN", |
| | | String.valueOf(modifyDNOperation), |
| | | String.valueOf(oldEntry), String.valueOf(newEntry)); |
| | | |
| | | |
| | | // See if we care about modify DN operations. |
| | |
| | | } |
| | | catch (DirectoryException de) |
| | | { |
| | | assert debugException(CLASS_NAME, "processModifyDN", de); |
| | | if (debugEnabled()) |
| | | { |
| | | debugCought(DebugLogLevel.ERROR, de); |
| | | } |
| | | |
| | | // FIXME -- Do we need to do anything here? |
| | | |
| | |
| | | } |
| | | catch (Exception e) |
| | | { |
| | | assert debugException(CLASS_NAME, "processModifyDN", e); |
| | | if (debugEnabled()) |
| | | { |
| | | debugCought(DebugLogLevel.ERROR, e); |
| | | } |
| | | |
| | | DirectoryServer.deregisterPersistentSearch(this); |
| | | |
| | |
| | | } |
| | | catch (Exception e2) |
| | | { |
| | | assert debugException(CLASS_NAME, "processModifyDN", e2); |
| | | if (debugEnabled()) |
| | | { |
| | | debugCought(DebugLogLevel.ERROR, e2); |
| | | } |
| | | } |
| | | } |
| | | } |
| | |
| | | */ |
| | | public String toString() |
| | | { |
| | | assert debugEnter(CLASS_NAME, "toString"); |
| | | |
| | | StringBuilder buffer = new StringBuilder(); |
| | | toString(buffer); |
| | |
| | | */ |
| | | public void toString(StringBuilder buffer) |
| | | { |
| | | assert debugEnter(CLASS_NAME, "toString", "java.lang.StringBuilder"); |
| | | |
| | | buffer.append("PersistentSearch(connID="); |
| | | buffer.append(searchOperation.getConnectionID()); |