/* * @project The CERN Tape Archive (CTA) * @copyright Copyright © 2021-2022 CERN * @license This program is free software, distributed under the terms of the GNU General Public * Licence version 3 (GPL Version 3), copied verbatim in the file "COPYING". You can * redistribute it and/or modify it under the terms of the GPL Version 3, 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. * * In applying this licence, CERN does not waive the privileges and immunities * granted to it by virtue of its status as an Intergovernmental Organization or * submit itself to any jurisdiction. */ #pragma once #include "scheduler/RetrieveMount.hpp" #include "scheduler/RetrieveJob.hpp" #include namespace cta { class MockRetrieveJob: public cta::RetrieveJob { public: int completes; int failures; MockRetrieveJob(RetrieveMount & rm): cta::RetrieveJob(&rm, cta::common::dataStructures::RetrieveRequest(), cta::common::dataStructures::ArchiveFile(), 1, cta::PositioningMethod::ByBlock), completes(0), failures(0) { common::dataStructures::TapeFile tf; tf.copyNb = 1; archiveFile.tapeFiles.push_back(tf); } virtual void asyncSetSuccessful() override { completes++; } void transferFailed(const std::string &failureReason, cta::log::LogContext&) override { failures++; }; std::optional diskSystemName() override { return m_diskSystemName; } void setDiskSystemName(std::string diskSystemName) { //allow tests to optionally set a disk system name m_diskSystemName = diskSystemName; } ~MockRetrieveJob() noexcept {} private: std::optional m_diskSystemName; }; }