Author: mattmann
Date: Thu Sep 13 02:57:42 2012
New Revision: 1384194
URL: http://svn.apache.org/viewvc?rev=1384194&view=rev
Log:
- fix for OODT-497: Make WorkflowProcessor PrioritySorters thread-safe
Modified:
oodt/trunk/CHANGES.txt
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/FILOPrioritySorter.java
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/HighestFIFOPrioritySorter.java
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/HighestPrioritySorter.java
Modified: oodt/trunk/CHANGES.txt
URL:
http://svn.apache.org/viewvc/oodt/trunk/CHANGES.txt?rev=1384194&r1=1384193&r2=1384194&view=diff
==============================================================================
--- oodt/trunk/CHANGES.txt (original)
+++ oodt/trunk/CHANGES.txt Thu Sep 13 02:57:42 2012
@@ -4,6 +4,8 @@ Apache OODT Change Log
Release 0.5
--------------------------------------------
+* OODT-497: Make WorkflowProcessor PrioritySorters thread-safe (mattmann)
+
* OODT-492: Refactor Workflow Instance repo to store/retrieve that state
information (mattmann)
Modified:
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/FILOPrioritySorter.java
URL:
http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/FILOPrioritySorter.java?rev=1384194&r1=1384193&r2=1384194&view=diff
==============================================================================
---
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/FILOPrioritySorter.java
(original)
+++
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/FILOPrioritySorter.java
Thu Sep 13 02:57:42 2012
@@ -50,7 +50,7 @@ public class FILOPrioritySorter implemen
* org.apache.oodt.cas.workflow.structs.PrioritySorter#sort(java.util.List)
*/
@Override
- public void sort(List<WorkflowProcessor> candidates) {
+ public synchronized void sort(List<WorkflowProcessor> candidates) {
Collections.sort(candidates, new Comparator<WorkflowProcessor>() {
/*
* (non-Javadoc)
Modified:
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/HighestFIFOPrioritySorter.java
URL:
http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/HighestFIFOPrioritySorter.java?rev=1384194&r1=1384193&r2=1384194&view=diff
==============================================================================
---
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/HighestFIFOPrioritySorter.java
(original)
+++
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/HighestFIFOPrioritySorter.java
Thu Sep 13 02:57:42 2012
@@ -62,7 +62,7 @@ public class HighestFIFOPrioritySorter i
* org.apache.oodt.cas.workflow.structs.PrioritySorter#sort(java.util.List)
*/
@Override
- public void sort(List<WorkflowProcessor> candidates) {
+ public synchronized void sort(List<WorkflowProcessor> candidates) {
Collections.sort(candidates, new Comparator<WorkflowProcessor>() {
public int compare(WorkflowProcessor o1, WorkflowProcessor o2) {
Modified:
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/HighestPrioritySorter.java
URL:
http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/HighestPrioritySorter.java?rev=1384194&r1=1384193&r2=1384194&view=diff
==============================================================================
---
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/HighestPrioritySorter.java
(original)
+++
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/HighestPrioritySorter.java
Thu Sep 13 02:57:42 2012
@@ -44,7 +44,7 @@ public class HighestPrioritySorter imple
* org.apache.oodt.cas.workflow.structs.PrioritySorter#sort(java.util.List)
*/
@Override
- public void sort(List<WorkflowProcessor> candidates) {
+ public synchronized void sort(List<WorkflowProcessor> candidates) {
Collections.sort(candidates, new Comparator<WorkflowProcessor>() {
@Override
