DTRList.h

#ifndef DTRLIST_H_
#define DTRLIST_H_

#include <arc/Thread.h>

#include "DTR.h"

namespace DataStaging {
  

  class DTRList {

    private:

      std::list<DTR_ptr> DTRs;
  
      Arc::SimpleCondition Lock;

      std::set<std::string> CachingSources;

      Arc::SimpleCondition CachingLock;

    public:

      bool add_dtr(DTR_ptr DTRToAdd);

      bool delete_dtr(DTR_ptr DTRToDelete);


      bool filter_dtrs_by_owner(StagingProcesses OwnerToFilter, std::list<DTR_ptr>& FilteredList);

      int number_of_dtrs_by_owner(StagingProcesses OwnerToFilter);


      bool filter_dtrs_by_status(DTRStatus::DTRStatusType StatusToFilter, std::list<DTR_ptr>& FilteredList);
      

      bool filter_dtrs_by_statuses(const std::vector<DTRStatus::DTRStatusType>& StatusesToFilter,
                                   std::list<DTR_ptr>& FilteredList);


      bool filter_dtrs_by_statuses(const std::vector<DTRStatus::DTRStatusType>& StatusesToFilter,
                                   std::map<DTRStatus::DTRStatusType, std::list<DTR_ptr> >& FilteredList);


      bool filter_dtrs_by_next_receiver(StagingProcesses NextReceiver, std::list<DTR_ptr>& FilteredList);
      

      bool filter_pending_dtrs(std::list<DTR_ptr>& FilteredList);


      bool filter_dtrs_by_job(const std::string& jobid, std::list<DTR_ptr>& FilteredList);
      
      void caching_started(DTR_ptr request);

      void caching_finished(DTR_ptr request);

      bool is_being_cached(DTR_ptr DTRToCheck);

      bool empty();

      std::list<std::string> all_jobs();


      void dumpState(const std::string& path);

  };

} // namespace DataStaging

#endif /*DTRLIST_H_*/