/* * @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 "ObjectOps.hpp" #include #include #include "common/dataStructures/DriveState.hpp" #include "common/dataStructures/DriveNextState.hpp" namespace cta::objectstore { class Backend; class Agent; class GenericObject; class EntryLogSerDeser; class DriveRegister: public ObjectOps { public: CTA_GENERATE_EXCEPTION_CLASS(NoSuchDrive); DriveRegister(const std::string & address, Backend & os); explicit DriveRegister(GenericObject& go); void initialize() override; CTA_GENERATE_EXCEPTION_CLASS(NotEmpty); void garbageCollect(const std::string &presumedOwner, AgentReference & agentReference, log::LogContext & lc, cta::catalogue::Catalogue & catalogue) override; bool isEmpty(); /** * A drive register entry (drive name + object address) */ struct DriveAddress { std::string driveName; std::string driveStateAddress; }; // Drives management ========================================================= /** * Returns all the drive states addresses stored in the drive registry. * @return a list of all the drive states */ std::list getDriveAddresses(); /** * Returns all the drive states addresses stored in the drive registry. * @return a list of all the drive states */ std::string getDriveAddress(const std::string & driveName); /** * Adds a drive status reference to the register. * @param driveName * @param driveAddress */ void setDriveAddress(const std::string & driveName, const std::string &driveAddress); /** * Removes entry from drive addresses. * @param driveName */ void removeDrive(const std::string & driveName); /** * JSON dump of the drive register * @return */ std::string dump(); }; } // namespace cta::objectstore