Skip to content
Snippets Groups Projects
Commit 4b1ce4e9 authored by Steven Murray's avatar Steven Murray
Browse files

Removed the unused RetrievalJobQueues class

parent d7ac5368
Branches
Tags
No related merge requests found
......@@ -33,7 +33,6 @@ set (CTA_SCHEDULER_SRC_FILES
RemoteStorage.cpp
RetrievalFileTransfer.cpp
RetrievalJob.cpp
RetrievalJobQueues.cpp
RetrievalJobState.cpp
RetrievalMount.cpp
RetrievalRequest.cpp
......
/*
* The CERN Tape Archive (CTA) project
* Copyright (C) 2015 CERN
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include "scheduler/RetrievalJobQueues.hpp"
//------------------------------------------------------------------------------
// destructor
//------------------------------------------------------------------------------
cta::RetrievalJobQueues::~RetrievalJobQueues() throw() {
}
/*
* The CERN Tape Archive (CTA) project
* Copyright (C) 2015 CERN
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#pragma once
#include "scheduler/RetrievalJob.hpp"
#include "scheduler/RetrievalMount.hpp"
#include "common/exception/Exception.hpp"
#include <list>
#include <stdint.h>
#include <string>
using cta::exception::Exception;
namespace cta {
/**
* Abstract class representing the retrieval job queues.
*/
class RetrievalJobQueues {
public:
/**
* Destructor.
*/
virtual ~RetrievalJobQueues() throw() = 0;
/**
* Queues the specified retrieval job with the specified priority.
*
* @param priority The priority of the job to be queued.
* @param job The job to be queued.
*/
virtual void queueJob(const uint32_t priority, const RetrievalJob &job) = 0;
/**
* Deletes the retrieval job associated with the specified destination disk
* file.
*
* @param dstUrl The URL of the destination disk file.
*/
virtual void deleteJob(const std::string &dstUrl) = 0;
/**
* Returns the current list of retrieval jobs for the specified tape.
*
* @param vid The volume-indentifier name of the tape.
*/
virtual std::list<RetrievalJob> getJobs(const std::string &vid) = 0;
/**
* Notifies this object that the specified file transfer has succeeded.
*
* @param copyNb The copy number of the source tape file.
* @param dstUrl The URL of the destination disk file.
*/
virtual void fileTransferSucceeded(const uint32_t copyNb,
const std::string &dstUrl) = 0;
/**
* Notifies this object that the specified file transfer has failed.
*
* @param copyNb The copy number of the source tape file.
* @param dstUrl The URL of the destination disk file.
* @param reason The reason the file transfer failed.
*/
virtual void fileTransferFailed(const uint32_t copyNb,
const std::string &dstUrl, const Exception &reason) = 0;
/**
* Returns the next retrieval mount for the specified tape or NULL if there
* currenly isn't one.
*
* @param vid The volume-indentifier name of the tape.
* @return The next retrieval mount or NULL if there isn't one. Please note
* that it is the responsibility of the caller to deallocate any returned
* RetrievalMount object.
*/
virtual RetrievalMount *getNextMount(const std::string &vid) = 0;
/**
* Returns the next batch of retrieval jobs for the specified on-going tape
* mount.
*
* @param mountId The identifier of the mount.
*/
virtual std::list<RetrievalJob> getNextJobsForMount(
const std::string &mountId) = 0;
/**
* Requests this object to execute any time dependent and asynchronous logic.
*/
virtual void tick() = 0;
}; // class RetrievalJobQueues
} // namespace cta
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment