FilterCachingAlgorithm.cpp

Go to the documentation of this file.

#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;
  }
}