From b086f57f56bf0eb9dab9cf321a0f69aaaae84347 Mon Sep 17 00:00:00 2001
From: Andrew Branson <andrew.branson@cern.ch>
Date: Wed, 30 May 2012 08:37:45 +0200
Subject: Initial Maven Conversion

---
 .../java/com/c2kernel/entity/agent/JobList.java    | 108 +++++++++++++++++++++
 1 file changed, 108 insertions(+)
 create mode 100644 src/main/java/com/c2kernel/entity/agent/JobList.java

(limited to 'src/main/java/com/c2kernel/entity/agent/JobList.java')

diff --git a/src/main/java/com/c2kernel/entity/agent/JobList.java b/src/main/java/com/c2kernel/entity/agent/JobList.java
new file mode 100644
index 0000000..f8a88ee
--- /dev/null
+++ b/src/main/java/com/c2kernel/entity/agent/JobList.java
@@ -0,0 +1,108 @@
+package com.c2kernel.entity.agent;
+
+import java.util.Iterator;
+import java.util.Vector;
+
+import com.c2kernel.persistency.ClusterStorage;
+import com.c2kernel.persistency.RemoteMap;
+import com.c2kernel.utils.Logger;
+
+
+/**************************************************************************
+*
+* @author $Author: abranson $ $Date: 2006/03/03 13:52:21 $
+* @version $Revision: 1.15 $
+***************************************************************************/
+public class JobList extends RemoteMap<Job>
+{
+
+    /**************************************************************************
+    * Empty constructor for Castor
+    **************************************************************************/
+    public JobList(int sysKey, Object locker)
+    {
+        super(sysKey, ClusterStorage.JOB, locker);
+    }
+
+
+   /**************************************************************************
+    *
+    **************************************************************************/
+    public void addJob( Job job )
+    {
+        synchronized(this) {
+            int jobId = getLastId()+1;
+            job.setID(jobId);
+            put(String.valueOf(jobId), job);
+        }
+    }
+
+	/**
+	 * Cannot be stored
+	 */
+	@Override
+	public String getClusterType() {
+		return null;
+	}
+
+
+    public Job getJob(int id) {
+        return get(String.valueOf(id));
+    }
+
+
+   /**
+    * @param job
+    */
+    public void removeJobsWithSysKey( int sysKey )
+    {
+        Iterator<Job> currentMembers = values().iterator();
+        Job           j = null;
+
+        while( currentMembers.hasNext() )
+        {
+            j = currentMembers.next();
+
+            if( j.getItemSysKey() == sysKey )
+                remove( String.valueOf(j.getID()) );
+        }
+
+        Logger.msg(5, "JobList::removeJobsWithSysKey() - " + sysKey + " DONE." );
+    }
+
+    public void removeJobsForStep( int sysKey, String stepPath )
+    {
+        Iterator<Job> currentMembers = values().iterator();
+        while( currentMembers.hasNext() )
+        {
+            Job j = currentMembers.next();
+            if( j.getItemSysKey() == sysKey && j.getStepPath().equals(stepPath))
+                remove( String.valueOf(j.getID()) );
+        }
+
+        Logger.msg(5, "JobList::removeJobsForStep() - " + sysKey + " DONE." );
+    }
+    /**
+     * @param itemKey
+     * @param string
+     * @return
+     */
+    public Vector<Job> getJobsOfSysKey(int sysKey)
+    {
+        Iterator<Job> currentMembers = values().iterator();
+        Job           j = null;
+        Vector<Job> jobs = new Vector<Job>();
+
+        while( currentMembers.hasNext() )
+        {
+            j = currentMembers.next();
+
+            if( j.getItemSysKey() == sysKey )
+                jobs.add(j);
+        }
+
+        Logger.msg(5, "JobList::getJobsOfSysKey() - returning " + jobs.size() + " Jobs." );
+
+        return jobs;
+    }
+}
\ No newline at end of file
-- 
cgit v1.2.3