FilterCachingAlgorithm.cpp

 
/* SPDX-License-Identifier: CC0-1.0 */
 
#include "FilterCachingAlgorithm.h"
 
#include <algorithm>
#include <iostream>
 
#include <QList>
 
#include "Buffer.h"
#include "Distance.h"
#include "RawCubeChunk.h"
#include "Statistics.h"
 
using std::max;
 
namespace Isis {
  FilterCachingAlgorithm::FilterCachingAlgorithm(int numParallelIOs) {
    m_chunksToKeep = NULL;
    m_chunksToKeep = new QList< QList< RawCubeChunk * > >;
 
    while(m_chunksToKeep->size() < numParallelIOs)
      m_chunksToKeep->append( QList<RawCubeChunk *>() );
 
    m_currentIo = 0;
  }
 
 
  FilterCachingAlgorithm::~FilterCachingAlgorithm() {
    if(m_chunksToKeep) {
      delete m_chunksToKeep;
      m_chunksToKeep = NULL;
    }
  }
 
 
  CubeCachingAlgorithm::CacheResult
      FilterCachingAlgorithm::recommendChunksToFree(
      QList<RawCubeChunk *> allocated, QList<RawCubeChunk *> justUsed,
          const Buffer &justRequested) {
    QList<RawCubeChunk *> chunksToToss;
    CacheResult result(chunksToToss);
 
    // This read has different chunks than before...
    if(!justUsed.size() ||
       !(*m_chunksToKeep)[m_currentIo].size() ||
         ((*m_chunksToKeep)[m_currentIo][0] != justUsed[0] &&
          (*m_chunksToKeep)[m_currentIo] != justUsed)) {
      (*m_chunksToKeep)[m_currentIo] = justUsed;
 
      // We don't know if Cube tossed any of the chunks, so we really need to
      //   look in the allocated list for things to toss. Let's work this by
      //   getting a list of things to keep and then freeing everything
      //   that is not in that list.
      QListIterator<RawCubeChunk *> allocatedIterator(allocated);
 
      while(allocatedIterator.hasNext()) {
        RawCubeChunk *chunk = allocatedIterator.next();
 
        bool found = false;
 
        foreach(QList<RawCubeChunk *> chunksForIo, *m_chunksToKeep) {
          if(!found)
            found = chunksForIo.indexOf(chunk) != -1;
        }
 
        if(!found) {
          chunksToToss.append(chunk);
        }
      }
 
      result = CacheResult(chunksToToss);
    }
 
    m_currentIo ++;
 
    if(m_currentIo >= m_chunksToKeep->size())
      m_currentIo = 0;
 
    return result;
  }
}