New completion signifier taskCompletedWithNote()

dCache · Nov 26, 2024 · de724b4 · de724b4
1 parent bcfa723
commit de724b4
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 0 deletions.
diff --git a/modules/dcache/src/main/java/org/dcache/pool/migration/Job.java b/modules/dcache/src/main/java/org/dcache/pool/migration/Job.java
@@ -785,6 +785,18 @@ public void taskCompleted(Task task) {
         }
     }
 
+    @Override
+    public void taskCompletedWithNote(Task task, String msg) {
+        _lock.lock();
+        try {
+            taskCompleted(task);
+
+            addNote(new Note(task.getId(), task.getPnfsId(), msg));
+        } finally {
+            _lock.unlock();
+        }
+    }
+
     public Object messageArrived(CellMessage envelope, PoolMigrationJobCancelMessage message) {
         DelayedReply reply = new DelayedReply();
         _lock.lock();

diff --git a/modules/dcache/src/main/java/org/dcache/pool/migration/TaskCompletionHandler.java b/modules/dcache/src/main/java/org/dcache/pool/migration/TaskCompletionHandler.java
@@ -26,4 +26,5 @@ public interface TaskCompletionHandler {
      * The task completed without error.
      */
     void taskCompleted(Task task);
+    default void taskCompletedWithNote(Task task, String) { taskCompleted(task); }
 }