ComputingQuotaOffer.h

Go to the documentation of this file.

// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
// All rights not expressly granted are reserved.
//
// This software is distributed under the terms of the GNU General Public
// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
//
// In applying this license 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.
 
#ifndef O2_COMPUTINGQUOTAOFFER_H_
#define O2_COMPUTINGQUOTAOFFER_H_
 
#include <functional>
#include <cstdint>
#include <cstddef>
 
namespace o2::framework
{
 
struct ComputingQuotaOfferRef {
  int index;
};
 
enum struct OfferScore {
  // The offers seen so far are enough. We can proceed with the dataprocessing.
  Enough,
  // The offers seen so far are not enough, but the current one
  // is ok and we need to look for more.
  More,
  // The offer is not needed, but something else in the device
  // might use it.
  Unneeded,
  // The offer is not suitable and should be given back to the
  // driver.
  Unsuitable
};
 
struct ComputingQuotaOffer {
  int cpu = 0;
  int64_t memory = 0;
  int64_t sharedMemory = 0;
  int64_t runtime = 0;
  int user = -1;
  OfferScore score = OfferScore::Unneeded;
  bool valid = false;
};
 
struct ComputingQuotaInfo {
  // When the offer was received
  size_t received = 0;
  // First time it was used
  size_t firstUsed = 0;
  // Last time it was used
  size_t lastUsed = 0;
};
 
struct ComputingQuotaStats {
  int64_t totalConsumedBytes = 0;
  int64_t totalConsumedOffers = 0;
  int64_t totalExpiredBytes = 0;
  int64_t totalExpiredOffers = 0;
};
 
using ComputingQuotaRequest = std::function<OfferScore(ComputingQuotaOffer const& offer, ComputingQuotaOffer const& accumulated)>;
 
using ComputingQuotaConsumer = std::function<void(int id, std::array<ComputingQuotaOffer, 16>&, ComputingQuotaStats&, std::function<void(ComputingQuotaOffer const&, ComputingQuotaStats& stats)>)>;
 
} // namespace o2::framework
 
#endif // O2_COMPUTINGQUOTAOFFER_H_