-
Eric Cano authored
This promotion is controlled so that only a limited number a requests are in the state ToExpand or Starting at any point in time. This ensures both the availabality of repack file requests to system while preventing an explosion of file level requests. Created a one-round popping from the container (algorithms) with status switching. - Used for repack requests switching from pendig to to expand Added ElementStatus to algorithms. Implemented promotion interface in Scheduler and OstoreDb. The actual decision is taken at the Scheduler level. The function itself is called by the RepackRequestManager. Promotion is tested in a unit test. Various code maintenance: Switched to "using"-based constructor inheritance. Fixed privacy of function in cta::range.
Eric Cano authoredThis promotion is controlled so that only a limited number a requests are in the state ToExpand or Starting at any point in time. This ensures both the availabality of repack file requests to system while preventing an explosion of file level requests. Created a one-round popping from the container (algorithms) with status switching. - Used for repack requests switching from pendig to to expand Added ElementStatus to algorithms. Implemented promotion interface in Scheduler and OstoreDb. The actual decision is taken at the Scheduler level. The function itself is called by the RepackRequestManager. Promotion is tested in a unit test. Various code maintenance: Switched to "using"-based constructor inheritance. Fixed privacy of function in cta::range.
SchedulerDatabase.cpp 1.33 KiB
/*
* 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/SchedulerDatabase.hpp"
namespace cta {
//------------------------------------------------------------------------------
// destructor
//------------------------------------------------------------------------------
cta::SchedulerDatabase::~SchedulerDatabase() throw() { }
SchedulerDatabase::RepackRequestStatistics::RepackRequestStatistics() {
typedef common::dataStructures::RepackInfo::Status Status;
for (auto & s: {Status::Aborted, Status::Aborting, Status::Complete, Status::Failed, Status::Pending,
Status::Running, Status::Starting, Status::ToExpand})
operator [](s) = 0;
}
} //namespace cta