Feature: FCC node directory is queried on every plan execution (eclipse-edc#1243)

paullatzelsperger · algattik · algattik · commit e6d6970622c4 · 2022-05-03T16:01:50.000+02:00
* node directory is queried on every plan execution

* checkstyle

* Update extensions/catalog/federated-catalog-cache/src/main/java/org/eclipse/dataspaceconnector/catalog/cache/management/PartitionManagerImpl.java

Co-authored-by: Alexandre Gattiker &lt;algattik@users.noreply.github.com&gt;

Co-authored-by: Alexandre Gattiker &lt;algattik@users.noreply.github.com&gt;
diff --git a/extensions/catalog/federated-catalog-cache/src/main/java/org/eclipse/dataspaceconnector/catalog/cache/management/PartitionManagerImpl.java b/extensions/catalog/federated-catalog-cache/src/main/java/org/eclipse/dataspaceconnector/catalog/cache/management/PartitionManagerImpl.java
@@ -71,7 +71,7 @@ public void schedule(ExecutionPlan executionPlan) {
             monitor.debug("Partition manager: execute plan - adding workload " + currentList.size());
             workQueue.addAll(currentList);
             workQueue.unlock();
-            monitor.debug("Partition manager: execute release queue lock");
+            monitor.debug("Partition manager: unlocked queue");
         });
     }
 

Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,7 @@ public void schedule(ExecutionPlan executionPlan) {`
`71`	`71`	`monitor.debug("Partition manager: execute plan - adding workload " + currentList.size());`
`72`	`72`	`workQueue.addAll(currentList);`
`73`	`73`	`workQueue.unlock();`
`74`		`- monitor.debug("Partition manager: execute release queue lock");`
	`74`	`+ monitor.debug("Partition manager: unlocked queue");`
`75`	`75`	`});`
`76`	`76`	`}`
`77`	`77`