package com.c2kernel.entity.agent;

import java.util.ArrayList;
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 )
    {
    	ArrayList<String> staleJobs = new ArrayList<String>();
        Iterator<String> jobIter = keySet().iterator();
        while( jobIter.hasNext() )
        {
        	String jid = jobIter.next();
            Job j = get(jid);
            if( j.getItemSysKey() == sysKey && j.getStepPath().equals(stepPath))
                staleJobs.add(jid);
        }
        
        Logger.msg(3, "JobList.removeJobsForStep() - removing "+staleJobs.size());

        for (String jid : staleJobs) {
			remove(jid);
		}
        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;
    }
}