From 218b40d6e175f5b58b89ff7e0b3050577d3aff2f Mon Sep 17 00:00:00 2001
From: matthew_swift <matthew_swift@localhost>
Date: Mon, 10 Nov 2008 13:41:49 +0000
Subject: [PATCH] This change fixes issue 3567:
---
opends/src/server/org/opends/server/workflowelement/localbackend/LocalBackendDeleteOperation.java | 63 +++++++++++++++++++------------
1 files changed, 39 insertions(+), 24 deletions(-)
diff --git a/opends/src/server/org/opends/server/workflowelement/localbackend/LocalBackendDeleteOperation.java b/opends/src/server/org/opends/server/workflowelement/localbackend/LocalBackendDeleteOperation.java
index 3e8571a..ccd4c22 100644
--- a/opends/src/server/org/opends/server/workflowelement/localbackend/LocalBackendDeleteOperation.java
+++ b/opends/src/server/org/opends/server/workflowelement/localbackend/LocalBackendDeleteOperation.java
@@ -47,6 +47,7 @@
import org.opends.server.core.DeleteOperationWrapper;
import org.opends.server.core.DeleteOperation;
import org.opends.server.core.DirectoryServer;
+import org.opends.server.core.PersistentSearch;
import org.opends.server.core.PluginConfigManager;
import org.opends.server.loggers.debug.DebugTracer;
import org.opends.server.types.AttributeType;
@@ -143,16 +144,16 @@
/**
* Process this delete operation in a local backend.
*
- * @param backend The backend in which the delete operation should be
- * processed.
- *
- * @throws CanceledOperationException if this operation should be
- * cancelled
+ * @param wfe
+ * The local backend work-flow element.
+ * @throws CanceledOperationException
+ * if this operation should be cancelled
*/
- void processLocalDelete(Backend backend) throws CanceledOperationException {
+ void processLocalDelete(final LocalBackendWorkflowElement wfe)
+ throws CanceledOperationException
+ {
boolean executePostOpPlugins = false;
-
- this.backend = backend;
+ this.backend = wfe.getBackend();
clientConnection = getClientConnection();
@@ -444,29 +445,43 @@
}
- // Notify any change notification listeners that might be registered with
- // the server.
+ // Register a post-response call-back which will notify persistent
+ // searches and change listeners.
if (getResultCode() == ResultCode.SUCCESS)
{
- for (ChangeNotificationListener changeListener :
- DirectoryServer.getChangeNotificationListeners())
+ registerPostResponseCallback(new Runnable()
{
- try
+
+ public void run()
{
- changeListener.handleDeleteOperation(this, entry);
- }
- catch (Exception e)
- {
- if (debugEnabled())
- {
- TRACER.debugCaught(DebugLogLevel.ERROR, e);
+ // Notify persistent searches.
+ for (PersistentSearch psearch : wfe.getPersistentSearches()) {
+ psearch.processDelete(entry, getChangeNumber());
}
- Message message = ERR_DELETE_ERROR_NOTIFYING_CHANGE_LISTENER.get(
- getExceptionMessage(e));
- logError(message);
+ // Notify change listeners.
+ for (ChangeNotificationListener changeListener : DirectoryServer
+ .getChangeNotificationListeners())
+ {
+ try
+ {
+ changeListener.handleDeleteOperation(
+ LocalBackendDeleteOperation.this, entry);
+ }
+ catch (Exception e)
+ {
+ if (debugEnabled())
+ {
+ TRACER.debugCaught(DebugLogLevel.ERROR, e);
+ }
+
+ Message message = ERR_DELETE_ERROR_NOTIFYING_CHANGE_LISTENER
+ .get(getExceptionMessage(e));
+ logError(message);
+ }
+ }
}
- }
+ });
}
}
--
Gitblit v1.10.0