extent-family.hpp

Go to the documentation of this file.

/*
  EXTENT-FAMILY.hpp  -  maintain a sequence of memory extents used cyclically
 
   Copyright (C)
     2023,            Hermann Vosseler <Ichthyostega@web.de>
 
 **Lumiera** 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 2 of the License, or (at your
 option) any later version. See the file COPYING for further details.
 
*/
 
 
#ifndef SRC_VAULT_MEM_EXTENT_FAMILY_H_
#define SRC_VAULT_MEM_EXTENT_FAMILY_H_
 
 
#include "vault/common.hpp"
#include "lib/uninitialised-storage.hpp"
#include "lib/iter-adapter.hpp"
#include "lib/nocopy.hpp"
#include "lib/util.hpp"
 
#include <algorithm>
#include <memory>
#include <vector>
#include <array>
 
 
namespace vault{
namespace mem {
  namespace err = lumiera::error;
  
  namespace {
    const size_t ALLOC_SAFETY_LIMIT = 8_GiB;
  }
  
  using util::unConst;
  
  template<typename T, size_t siz>
  class ExtentDiagnostic;
  
  
  
  template<typename T, size_t siz>
  class ExtentFamily
    : util::NonCopyable
    {
      static const size_t EXCESS_ALLOC{5};
      
      
    public:
      struct Extent
        : std::array<T,siz>
        {
          using Payload = T;
          using SIZ = std::integral_constant<size_t,siz>;
        };
      
      
    private:
      using _UniqueStoragePtr = std::unique_ptr<lib::UninitialisedStorage<T,siz>>;
      
      struct Storage
        : _UniqueStoragePtr
        {
          Storage()
            : _UniqueStoragePtr{new lib::UninitialisedStorage<T,siz>}
            { }
          
          Extent&
          access()
            {
              auto* rawStorage = this->get();
              ENSURE (rawStorage != nullptr);
              return static_cast<Extent&> (rawStorage->array());
            }
        };
      using Extents = std::vector<Storage>;
      
      
      struct IdxLink
        {
          ExtentFamily* exFam{nullptr};
          size_t        index{0};
          
          /* === state protocol API for IterStateWrapper === */
          bool
          checkPoint()  const
            {
              return exFam and index != exFam->after_;
            }
          
          Extent&
          yield()  const
            {
              return exFam->access (index);
            }
          
          void
          iterNext()
            {
              index = exFam->incWrap (index);
            }
          
          bool
          operator== (IdxLink const& oi)  const
            {
              return exFam == oi.exFam
                 and index == oi.index;
            }
          
          
          /* === pass-through extended functionality === */
          
          size_t getIndex() { return index;    }
          
          void
          expandAlloc (size_t cnt =1)
            {
              size_t prevStart = exFam->start_;
              exFam->openNew(cnt);
              if (index >= prevStart)
                index += (exFam->start_-prevStart);
                // was in a segment that might be moved up
              ENSURE (exFam->isValidPos (index));
            }
          
          void
          validatePos (Extent* knownTarget)
            {
              if (exFam->matchPos (index,knownTarget))
                return;
              size_t prevIdx = index;
              do{
                  iterNext();
                  if (exFam->matchPos (index,knownTarget))
                    return;
                }
              while (index != prevIdx);
              // went full circle without hitting the expected target Extent....
              throw err::Logic {"Unable to fix-up an iterator after Extent allocation. "
                                "Reference position obsolete or unknown to the memory manager."};
            }
        };
      
      
      
      /* ==== Management Data ==== */
      
      Extents extents_;
      size_t start_,after_;
      
    public:
      explicit
      ExtentFamily(size_t initialCnt =1)
        : extents_{initialCnt}
        , start_{0}        //  Extents allocated yet marked unused
        , after_{0}
        { }
      
      void
      reserve (size_t expectedMaxExtents)
        {                // pertaining management data only
          extents_.reserve (expectedMaxExtents);
        }
      
      void
      openNew (size_t cnt =1)
        {
          if (not canAccomodate (cnt))
            {//insufficient reserve => allocate
              size_t oldSiz = slotCnt();
              size_t addSiz = cnt - freeSlotCnt()
                              + EXCESS_ALLOC;
              // add a strike of new extents at the end
              ___sanityCheckAllocSize (addSiz);
              extents_.resize (oldSiz + addSiz);
              if (isWrapped())
                {// need the new elements in the middle, before the existing start_
                  auto p = extents_.begin();
                  auto first = p + start_;
                  auto mid   = p + oldSiz;
                  auto last  = p + oldSiz + addSiz;
                  // relocate [fist..mid) after [mid..last)
                  std::rotate (first, mid, last);
                  start_ += addSiz;
                }
            }
          // now sufficient reserve extents are available
          ENSURE (canAccomodate (cnt));
          after_ = incWrap (after_, cnt);
        }
      
      void
      dropOld (size_t cnt)
        {
          REQUIRE (cnt <= activeSlotCnt());
          start_ = incWrap (start_, cnt);
        }                        
      
      
      using iterator = lib::IterableDecorator<IdxLink>;
      
      iterator begin() { return iterator{IdxLink{this, start_}}; }
      iterator end()   { return iterator{IdxLink{this, after_}}; }
      
      friend iterator begin (ExtentFamily& exFam) { return exFam.begin(); }
      friend iterator end   (ExtentFamily& exFam) { return exFam.end();   }
      
      
      bool empty()    const { return start_ == after_; }
      
      iterator
      last()
        {
          REQUIRE (not empty());             // trick to safely decrement by one
          size_t penultimate = incWrap (after_, slotCnt()-1);
          return iterator{IdxLink{this, penultimate}};
        }
      
      
    private: /* ====== storage management implementation ====== */
      bool
      isWrapped()  const
        {
          return after_ < start_;
        }     // note: both are equal only when empty
      
      size_t
      slotCnt()  const
        {
          return extents_.size();
        }
      
      size_t
      activeSlotCnt()  const
        {
          REQUIRE (start_ <  slotCnt());
          REQUIRE (after_ <= slotCnt());
          
          return not isWrapped()? after_ - start_
                                : (after_ - 0)
                                 +(slotCnt() - start_);
        }
      
      size_t
      freeSlotCnt()  const
        {           // always keep one in reserve...
          REQUIRE (activeSlotCnt() < slotCnt());
          
          return slotCnt() - activeSlotCnt();
        }
      
      bool
      canAccomodate (size_t addCnt)  const
        {
          return addCnt < freeSlotCnt();
        }     // keep one in reserve to allow for
             //  unambiguous iteration end in wrapped state
      
      size_t
      incWrap (size_t idx, size_t inc =1)
        {
          return (idx+inc) % slotCnt();
        }
      
      bool
      isValidPos (size_t idx)  const
        {
          REQUIRE (idx < slotCnt());
          REQUIRE (activeSlotCnt() > 0);
          
          return isWrapped()? (start_ <= idx and idx < slotCnt())
                               or idx < after_
                            : (start_ <= idx and idx < after_);
        }
      
      bool
      matchPos (size_t idx, void* address)
        {
          REQUIRE (idx < slotCnt());
          return address == extents_[idx].get();
        }
      
      Extent&
      access (size_t idx)  const
        {
          REQUIRE (isValidPos (idx));
          return unConst(this)->extents_[idx].access();
        }     // deliberately const-ness does not cover payload
      
      void
      ___sanityCheckAllocSize (size_t addCnt)
        {
          size_t resultSiz = slotCnt()+addCnt;
          size_t requiredSpace = resultSiz * sizeof(Extent);
          if (requiredSpace > ALLOC_SAFETY_LIMIT)
            throw err::Fatal{"Raw allocation exceeds safety limit: "
                            +util::showSize(requiredSpace)    +" > "
                            +util::showSize(ALLOC_SAFETY_LIMIT)
                            ,err::LUMIERA_ERROR_CAPACITY};
        }
      
      
      friend class ExtentDiagnostic<T,siz>;
    };
  
  
  
  
  
  
  
  /* ===== Test / Diagnostic ===== */
  
  template<typename T, size_t siz>
  struct ExtentDiagnostic
    {
      using ExFam = ExtentFamily<T,siz>;
      
      ExFam& exFam_;
      
      size_t first()  { return exFam_.start_; }
      size_t last()   { return exFam_.after_; }
      size_t size()   { return exFam_.slotCnt(); }
      size_t active() { return exFam_.activeSlotCnt(); }
    };
  
  template<typename T, size_t siz>
  inline ExtentDiagnostic<T,siz>
  watch (ExtentFamily<T,siz>& extentFamily)
  {
    return ExtentDiagnostic<T,siz>{extentFamily};
  }
  
}} // namespace vault::mem
#endif /*SRC_VAULT_MEM_EXTENT_FAMILY_H_*/