From d1e5fe55252799742c6dc12265130edce17ff4be Mon Sep 17 00:00:00 2001
From: neil_a_wilson <neil_a_wilson@localhost>
Date: Wed, 27 Sep 2006 20:28:10 +0000
Subject: [PATCH] Make a few general changes to operation processing:

---
 opends/src/server/org/opends/server/core/DeleteOperation.java |   68 ++--------------------------------
 1 files changed, 4 insertions(+), 64 deletions(-)

diff --git a/opends/src/server/org/opends/server/core/DeleteOperation.java b/opends/src/server/org/opends/server/core/DeleteOperation.java
index 13185af..9ee9afc 100644
--- a/opends/src/server/org/opends/server/core/DeleteOperation.java
+++ b/opends/src/server/org/opends/server/core/DeleteOperation.java
@@ -499,22 +499,7 @@
     // Check for and handle a request to cancel this operation.
     if (cancelRequest != null)
     {
-      setCancelResult(CancelResult.CANCELED);
-
-      if (cancelRequest.notifyOriginalRequestor() ||
-          DirectoryServer.notifyAbandonedOperations())
-      {
-        setResultCode(ResultCode.CANCELED);
-
-        String cancelReason = cancelRequest.getCancelReason();
-        if (cancelReason != null)
-        {
-          appendErrorMessage(cancelReason);
-        }
-
-        clientConnection.sendResponse(this);
-      }
-
+      indicateCancelled(cancelRequest);
       processingStopTime = System.currentTimeMillis();
       return;
     }
@@ -557,22 +542,7 @@
       // Check for and handle a request to cancel this operation.
       if (cancelRequest != null)
       {
-        setCancelResult(CancelResult.CANCELED);
-
-        if (cancelRequest.notifyOriginalRequestor() ||
-            DirectoryServer.notifyAbandonedOperations())
-        {
-          setResultCode(ResultCode.CANCELED);
-
-          String cancelReason = cancelRequest.getCancelReason();
-          if (cancelReason != null)
-          {
-            appendErrorMessage(cancelReason);
-          }
-
-          clientConnection.sendResponse(this);
-        }
-
+        indicateCancelled(cancelRequest);
         processingStopTime = System.currentTimeMillis();
         logDeleteResponse(this);
         return;
@@ -922,22 +892,7 @@
         // Check for and handle a request to cancel this operation.
         if (cancelRequest != null)
         {
-          setCancelResult(CancelResult.CANCELED);
-
-          if (cancelRequest.notifyOriginalRequestor() ||
-              DirectoryServer.notifyAbandonedOperations())
-          {
-            setResultCode(ResultCode.CANCELED);
-
-            String cancelReason = cancelRequest.getCancelReason();
-            if (cancelReason != null)
-            {
-              appendErrorMessage(cancelReason);
-            }
-
-            clientConnection.sendResponse(this);
-          }
-
+          indicateCancelled(cancelRequest);
           processingStopTime = System.currentTimeMillis();
           logDeleteResponse(this);
           return;
@@ -974,22 +929,7 @@
         // Check for and handle a request to cancel this operation.
         if (cancelRequest != null)
         {
-          setCancelResult(CancelResult.CANCELED);
-
-          if (cancelRequest.notifyOriginalRequestor() ||
-              DirectoryServer.notifyAbandonedOperations())
-          {
-            setResultCode(ResultCode.CANCELED);
-
-            String cancelReason = cancelRequest.getCancelReason();
-            if (cancelReason != null)
-            {
-              appendErrorMessage(cancelReason);
-            }
-
-            clientConnection.sendResponse(this);
-          }
-
+          indicateCancelled(cancelRequest);
           processingStopTime = System.currentTimeMillis();
           logDeleteResponse(this);
           return;

--
Gitblit v1.10.0