#include "tfxattributes.h"

#include "trenderer.h"

#include "tcacheresource.h"

#include "tcacheresourcepool.h"

#include "tpassivecachemanager.h"

//#define USE_SQLITE_HDPOOL

/* PRACTICAL EXPLANATION:

The TPassiveCacheManager's purpose is that of storing render results from a

specified set of fx nodes.

When an fx is passed to the manager to be cached, a structure of type FxData is

generated for the fx.

It is stored inside the manager and ASSOCIATED to the fx through an INDEX key -

this one being stored

inside the fx data.

In particular, the FxData instances contain a PERSISTANT identifier

(passiveCacheId) that is saved inside

the scene data, a flag specifying the cache status of the fx node (like, if it's

enabled or not), and

a description of the schematic dag below the associated fx.

Now, when a resource request is made to the TPassiveCacheManager, it checks the

FxData about the generating

fx - if it contains the flag specifying that it must be cached, a resource is

allocated (if not already

present), a reference to it is stored, and finally the resource is returned.

References to interesting resources are stored in a TABLE container, indexed by

"rendering context" and

fx. A rendering context is hereby intended as a SEQUENCE of render processes

where the next render of the

sequence is assumed to REPLACE the previous one.

We therefore have one context for the swatch viewer, one for File>Preview, one

for the Preview Fx of each

fx node, and one context for EACH FRAME of the sceneviewer preview (one frame is

not supposed to replace

another in that case).

The table is in practice a map of maps (a kind of 'comb' structure) - where the

primary map is associated

by render context and the secondary ones by fx. This mean that we are able to

address and iterate contexts

easier than fxs. Values of the table are set of resources.

RESOURCES MAINTENANCE POLICY:

As resources use a concrete amount of memory for storage, they should be kept in

the resources table only

for the time they are supposedly useful to the user. There are 2 ways of dealing

with this issue.

1) First, we can track scene changes and eliminate those resources that will no

longer be accessed due to the

applied change. This happens, for example, when a level is being drawn, fxs are

inserted, moved or removed.

Level changes are delivered immediately to the ::invalidateLevel(..) method,

which removes all resources

whose name contains the level's name. Unfortunately, this cannot be done at

frame precision (ie you cannot

invalidate a single frame of the level, but ALL the level).

Xsheet (schematic) changes are tracked through the schematic node description

stored inside the FxData structure.

Once one such change happens, all resources update their description - if that

changes, the associated resources

are released.

The same schematic description is used to track and release resources affected

by changes on a downstream fx's

parameters.

There are also scene changes that are inherently hard to track or intercept. For

example, pegbar affines changes,

fx nodes expressions referencing data not directly connected to the fx, and

possibly others. These are currently

NOT handled by direct tracking.

2) As there may be resources which escape the resource control by point (1), we

need some extra control

policies. Here they are:

We assume that the pool of resources accessed by render processes of a same

render context should be CONSTANT

IF NO SCENE CHANGE HAPPENS. In other words, we are guessing that only those

resources used in the last

rendering will be used in the next. Resources accessed in a render but NOT in

the next (of the same context)

are released.

However, it could be that the sequence of render processes from a context is

halted from a certain moment on.

In that case, it is a waste to keep the resources accessed by its last render if

no new render will ever take

place. We then assume further that a rendering context can be ENABLED or

DISABLED - when a render context is

enabled, it will most likely have a next render - and therefore can keep its

resources in memory.

Once a context is DISABLED, it moves the resources to a TEMPORARY context.

Resources in the temporary context are those 'on their way for release'. They

will be KEPT only if the

next rendering - INDEPENDENTLY FROM THE RENDER CONTEXT - requires them (in this

case, they will be adopted

by the new context). This is necessary since context disables typically happen

when a preview window closes.

It is not unfrequent that users close the preview window, modify the scene, and

then restore the preview.

CONSIDERATIONS:

* The File>Render generates NO CONTEXT - and therefore does NOT PASSIVELY CACHE

RESOURCES, since it cannot be

  stated whether it is in the 'enabled' or 'disabled' state. It could be

considered coherent with what tcomposer

  does, by the way...

* Our resources maintenance policy ensures that the memory usage should be

stable over time - that is, no

  useless resource is kept in memory.

  Of course, it is possibly more restrictive than what the user may desire. For

example, closing 2 preview

  windows marks their resources for deletion, but only one of the two restored

previews will keep its

  resources intact...

*/

//*****************************************************************************************

//    Preliminaries

//*****************************************************************************************

//  Local stuff - inlines

namespace {

inline QRect toQRect(const TRect &r) {

  return QRect(r.x0, r.y0, r.getLx(), r.getLy());

}

inline TRect toTRect(const QRect &r) {

  return TRect(r.left(), r.top(), r.right(), r.bottom());

}

}

//---------------------------------------------------------------------------

TFx *TPassiveCacheManager::getNotAllowingAncestor(TFx *fx) {

  // Trace all output ports

  int outputPortsCount = fx->getOutputConnectionCount();

  /*if(!outputPortsCount)   //We have no access to TApp here!!

{

//It could be a terminal fx. In that case, pass to the xsheet fx

FxDag* dag = TApp::instance()->getCurrentXsheet()->getXsheet()->getFxDag();

if(dag->getTerminalFxs()->containsFx(fx))

return getNotAllowingAncestor(dag->getXsheetFx());

}*/

  // Now, for common ports

  for (int i = 0; i < outputPortsCount; ++i) {

    // Find the output Fx and the port connected to our fx

    TFxPort *port    = fx->getOutputConnection(i);

    TRasterFx *outFx = static_cast<trasterfx *="">(port->getOwnerFx());</trasterfx>

    int portIdx, portsCount = outFx->getInputPortCount();

    for (portIdx = 0; portIdx < portsCount; ++portIdx)

      if (outFx->getInputPort(portIdx) == port) break;

    assert(portIdx < portsCount);

    if (!outFx->allowUserCacheOnPort(portIdx)) return outFx;

    TFx *naAncestor = getNotAllowingAncestor(outFx);

    if (naAncestor) return naAncestor;

  }

  return 0;

}

//*****************************************************************************************

//    Resources Container Definition

//*****************************************************************************************

template <typename colkey,="" rowkey,="" typename="" val=""></typename>

class Table {

public:

  typedef typename std::map<colkey, val=""> Row;</colkey,>

private:

  std::map<rowkey, row=""> m_table;</rowkey,>

  friend class Iterator;

  friend class ColIterator;

public:

  typedef typename std::map<rowkey, row="">::iterator RowsIterator;</rowkey,>

  class Iterator {

  protected:

    Table *m_table;

    RowsIterator m_rowIt;

    typename Row::iterator m_it;

    friend class Table;

    Iterator(Table *table) : m_table(table) {}

    virtual void makeConsistent() {

      if (m_it == m_rowIt->second.end()) {

        if (++m_rowIt == m_table->m_table.end()) return;

        m_it = m_rowIt->second.begin();

      }

    }

  public:

    const RowKey &row() { return m_rowIt->first; }

    const ColKey &col() { return m_it->first; }

    virtual void operator++() {

      ++m_it;

      makeConsistent();

    }

    virtual operator bool() { return m_rowIt != m_table->m_table.end(); }

    Val &operator*() { return m_it->second; }

    Val *operator->() { return &m_it->second; }

    bool operator==(const Iterator &it) { return m_it == it.m_it; }

    bool operator!=(const Iterator &it) { return !operator==(it); }

  };

  class ColIterator final : public Iterator {

    ColKey m_colKey;

    friend class Table;

    ColIterator(Table *table, const ColKey &c) : Iterator(table), m_colKey(c) {}

    void makeConsistent() override {

      Iterator::m_rowIt = Iterator::m_rowIt;

      while (Iterator::m_rowIt != Iterator::m_table->m_table.end()) {

        Iterator::m_it = Iterator::m_rowIt->second.find(m_colKey);

        if (Iterator::m_it != Iterator::m_rowIt->second.end()) break;

        ++Iterator::m_rowIt;

      }

    }

  public:

    void operator++() override {

      ++Iterator::m_rowIt;

      makeConsistent();

    }

  };

  class RowIterator final : public Iterator {

    friend class Table;

    RowIterator(Table *table) : Iterator(table) {}

    void makeConsistent() override {}

  public:

    RowIterator(const RowsIterator rowIt) : Iterator(0) {

      Iterator::m_rowIt = rowIt;

      Iterator::m_it    = rowIt->second.begin();

    }

    void operator++() override { ++Iterator::m_it; }

    operator bool() override {

      return Iterator::m_it != Iterator::m_rowIt->second.end();

    }

  };

public:

  Table() {}

  ~Table() {}

  std::map<rowkey, row=""> &rows() { return m_table; }</rowkey,>

  Iterator begin() {

    Iterator result(this);

    result.m_rowIt = m_table.begin();

    if (result.m_rowIt != m_table.end())

      result.m_it = result.m_rowIt->second.begin();

    return result;

  }

  RowIterator rowBegin(const RowKey &row) {

    RowIterator result(this);

    result.m_rowIt = m_table.find(row);

    if (result.m_rowIt != m_table.end())

      result.m_it = result.m_rowIt->second.begin();

    return result;

  }

  ColIterator colBegin(const ColKey &col) {

    ColIterator result(this, col);

    result.m_rowIt = m_table.begin();

    result.makeConsistent();

    return result;

  }

  Val &value(const RowKey &r, const ColKey &c) { return m_table[r][c]; }

  Iterator insert(const RowKey &r, const ColKey &c, const Val &val) {

    Iterator result(this);

    result.m_rowIt = m_table.insert(std::make_pair(r, Row())).first;

    result.m_it = result.m_rowIt->second.insert(std::make_pair(c, val)).first;

    return result;

  }

  Iterator erase(const Iterator &it) {

    Iterator result(it);

    Row &row = it.m_rowIt->second;

    ++result.m_it;

    row.erase(it.m_it);

    if (result.m_it == row.end() && row.empty()) {

      result.makeConsistent();

      m_table.erase(it.m_rowIt);

      return result;

    }

    result.makeConsistent();

    return result;

  }

  void erase(const ColKey &c) {

    ColIterator it(colBegin(c));

    while (it) {

      RowsIterator rowIt = it.m_rowIt;

      rowIt->second.erase(it.m_it);

      ++it;

      if (rowIt->second.empty()) m_table.erase(rowIt);

    }

  }

  void erase(const RowKey &r) { m_table.erase(r); }

  void clear() { m_table.clear(); }

};

//--------------------------------------------------------------------------

struct LockedResourceP {

  TCacheResourceP m_resource;

  LockedResourceP(const TCacheResourceP &resource) : m_resource(resource) {

    m_resource->addLock();

  }

  LockedResourceP(const LockedResourceP &resource)

      : m_resource(resource.m_resource) {

    m_resource->addLock();

  }

  ~LockedResourceP() { m_resource->releaseLock(); }

  LockedResourceP &operator=(const LockedResourceP &src) {

    src.m_resource->addLock();

    if (m_resource) m_resource->releaseLock();

    m_resource = src.m_resource;

    return *this;

  }

  operator bool() const { return m_resource; }

  bool operator<(const LockedResourceP &resource) const {

    return m_resource < resource.m_resource;

  }

  TCacheResource *operator->() const { return m_resource.getPointer(); }

  TCacheResource &operator*() const { return *m_resource.getPointer(); }

};

typedef Table<std::string, int,="" std::set<lockedresourcep="">> ResourcesTable;</std::string,>

//--------------------------------------------------------------------------

class TPassiveCacheManager::ResourcesContainer {

  ResourcesTable m_resources;

public:

  ResourcesContainer() {}

  ~ResourcesContainer() {}

  ResourcesTable &getTable() { return m_resources; }

};

//*****************************************************************************************

//    FxData implementation

//*****************************************************************************************

TPassiveCacheManager::FxData::FxData()

    : m_storageFlag(0), m_passiveCacheId(0) {}

//-------------------------------------------------------------------------

TPassiveCacheManager::FxData::~FxData() {}

//*****************************************************************************************

//    Manager generator

//*****************************************************************************************

//=======================================

//    TPassiveCacheManagerGenerator

//---------------------------------------

class TPassiveCacheManagerGenerator final

    : public TRenderResourceManagerGenerator {

  TRenderResourceManager *operator()(void) override {

    // return new TPassiveCacheManager;

    return TPassiveCacheManager::instance();

  }

};

MANAGER_FILESCOPE_DECLARATION_DEP(TPassiveCacheManager,

                                  TPassiveCacheManagerGenerator,

                                  TFxCacheManager::deps())

//*****************************************************************************************

//    Implementation

//*****************************************************************************************

TPassiveCacheManager::TPassiveCacheManager()

#ifdef USE_SQLITE_HDPOOL

    : m_currStorageFlag(ON_DISK)

#else

    : m_currStorageFlag(IN_MEMORY)

#endif

    , m_enabled(true)

    , m_descriptorCallback(0)

    , m_mutex(QMutex::Recursive)

    , m_resources(new ResourcesContainer) {

  reset();

}

//-------------------------------------------------------------------------

TPassiveCacheManager::~TPassiveCacheManager() { delete m_resources; }

//-------------------------------------------------------------------------

TPassiveCacheManager *TPassiveCacheManager::instance() {

  static TPassiveCacheManager theInstance;

  return &theInstance;

}

//-------------------------------------------------------------------------

void TPassiveCacheManager::setContextName(unsigned long renderId,

                                          const std::string &name) {

  QMutexLocker locker(&m_mutex);

  // Retrieve the context data if already present

  std::map<std::string, uchar="">::iterator it = m_contextNames.find(name);</std::string,>

  if (it == m_contextNames.end())

    it = m_contextNames.insert(std::make_pair(name, 0)).first;

  it->second = !it->second;

  m_contextNamesByRenderId.insert(

      std::make_pair(renderId, name + "%" + std::to_string(it->second)));

}

//-------------------------------------------------------------------------

std::string TPassiveCacheManager::getContextName() {

  QMutexLocker locker(&m_mutex);

  // First, search the context name

  std::map<unsigned long,="" std::string="">::iterator it =</unsigned>

      m_contextNamesByRenderId.find(TRenderer::renderId());

  if (it == m_contextNamesByRenderId.end()) return "";

  return it->second;

}

//-------------------------------------------------------------------------

void TPassiveCacheManager::setEnabled(bool enabled) { m_enabled = enabled; }

//-------------------------------------------------------------------------

bool TPassiveCacheManager::isEnabled() const { return m_enabled; }

//-------------------------------------------------------------------------

void TPassiveCacheManager::setStorageMode(StorageFlag mode) {

  m_currStorageFlag = mode;

}

//-------------------------------------------------------------------------

TPassiveCacheManager::StorageFlag TPassiveCacheManager::getStorageMode() const {

  return m_currStorageFlag;

}

//-----------------------------------------------------------------------------------

void TPassiveCacheManager::setTreeDescriptor(TreeDescriptor callback) {

  m_descriptorCallback = callback;

}

//-----------------------------------------------------------------------------------

int TPassiveCacheManager::getNewPassiveCacheId() {

  return ++m_currentPassiveCacheId;

}

//-----------------------------------------------------------------------------------

int TPassiveCacheManager::updatePassiveCacheId(int id) {

  if (m_updatingPassiveCacheIds)

    m_currentPassiveCacheId = std::max(m_currentPassiveCacheId, id);

  else

    id = getNewPassiveCacheId();

  return id;

}

//-----------------------------------------------------------------------------------

void TPassiveCacheManager::onSceneLoaded() {

  m_updatingPassiveCacheIds = false;

// Initialize the fxs tree description. This was not possible before, as the

// scene was yet incomplete (in loading state).

#ifndef USE_SQLITE_HDPOOL

  unsigned int count = m_fxDataVector.size();

  for (unsigned int i = 0; i < count; ++i) {

    FxData &data = m_fxDataVector[i];

    (*m_descriptorCallback)(data.m_treeDescription, data.m_fx);

  }

#endif

}

//-----------------------------------------------------------------------------------

void TPassiveCacheManager::touchFxData(int &idx) {

  if (idx >= 0) return;

  QMutexLocker locker(&m_mutex);

  m_fxDataVector.push_back(FxData());

  idx = m_fxDataVector.size() - 1;

}

//-----------------------------------------------------------------------------------

int TPassiveCacheManager::declareCached(TFx *fx, int passiveCacheId) {

  int &idx = fx->getAttributes()->passiveCacheDataIdx();

  touchFxData(idx);

  FxData &data          = m_fxDataVector[idx];

  data.m_fx             = fx;

  data.m_storageFlag    = m_currStorageFlag;

  data.m_passiveCacheId = updatePassiveCacheId(passiveCacheId);

  return idx;

}

//-------------------------------------------------------------------------

void TPassiveCacheManager::reset() {

  m_updatingPassiveCacheIds = true;

  m_currentPassiveCacheId   = 0;

  m_fxDataVector.clear();

  m_resources->getTable().clear();

}

//-------------------------------------------------------------------------

bool TPassiveCacheManager::cacheEnabled(TFx *fx) {

  int idx = fx->getAttributes()->passiveCacheDataIdx();

  if (idx < 0) return false;

  assert(idx < (int)m_fxDataVector.size());

  QMutexLocker locker(&m_mutex);

  return m_fxDataVector[idx].m_storageFlag > 0;

}

//-------------------------------------------------------------------------

int TPassiveCacheManager::getPassiveCacheId(TFx *fx) {

  int idx = fx->getAttributes()->passiveCacheDataIdx();

  if (idx < 0) return 0;

  // This needs not be mutex locked

  assert(idx < (int)m_fxDataVector.size());

  return m_fxDataVector[idx].m_passiveCacheId;

}

//-------------------------------------------------------------------------

TPassiveCacheManager::StorageFlag TPassiveCacheManager::getStorageMode(

    TFx *fx) {

  int idx = fx->getAttributes()->passiveCacheDataIdx();

  if (idx < 0) return NONE;

  QMutexLocker locker(&m_mutex);

  return (StorageFlag)m_fxDataVector[idx].m_storageFlag;

}

//-------------------------------------------------------------------------

void TPassiveCacheManager::enableCache(TFx *fx) {

  int &idx = fx->getAttributes()->passiveCacheDataIdx();

  touchFxData(idx);

  FxData &data = m_fxDataVector[idx];

  QMutexLocker locker(&m_mutex);

#ifdef DIAGNOSTICS

  DIAGNOSTICS_STR("#activity.txt | " + QTime::currentTime().toString() + " " +

                  QString("Enable Cache"));

#endif

  StorageFlag flag = getStorageMode();

  if (flag) {

    UCHAR &storedFlag = data.m_storageFlag;

    UCHAR oldFlag     = storedFlag;

    storedFlag |= flag;

    if (data.m_passiveCacheId == 0)

      data.m_passiveCacheId = getNewPassiveCacheId();

    if ((storedFlag & ON_DISK) && !(oldFlag & ON_DISK)) {

      ResourcesTable::ColIterator it =

          m_resources->getTable().colBegin(data.m_passiveCacheId);

      for (; it; ++it) {

        std::set<lockedresourcep> &resources = *it;</lockedresourcep>

        std::set<lockedresourcep>::iterator jt;</lockedresourcep>

        for (jt = resources.begin(); jt != resources.end(); ++jt)

          (*jt)->enableBackup();

      }

    }

#ifndef USE_SQLITE_HDPOOL

    if ((storedFlag & IN_MEMORY) && !(oldFlag & IN_MEMORY)) {

      data.m_fx = fx;

      (*m_descriptorCallback)(data.m_treeDescription, data.m_fx);

    }

#endif

  }

}

//-------------------------------------------------------------------------

void TPassiveCacheManager::disableCache(TFx *fx) {

  int idx = fx->getAttributes()->passiveCacheDataIdx();

  if (idx < 0) return;

  FxData &data = m_fxDataVector[idx];

  QMutexLocker locker(&m_mutex);

#ifdef DIAGNOSTICS

  DIAGNOSTICS_STR("#activity.txt | " + QTime::currentTime().toString() + " " +

                  QString("Disable Cache"));

#endif

  StorageFlag flag = getStorageMode();

  if (flag) {

    UCHAR &storedFlag = data.m_storageFlag;

    UCHAR oldFlag     = storedFlag;

    storedFlag &= ~flag;

    if ((oldFlag & IN_MEMORY) && !(storedFlag & IN_MEMORY)) {

      m_resources->getTable().erase(data.m_passiveCacheId);

      data.m_fx              = TFxP();

      data.m_treeDescription = "";

    }

#ifdef USE_SQLITE_HDPOOL

    if ((oldFlag & ON_DISK) && !(storedFlag & ON_DISK))

      TCacheResourcePool::instance()->releaseReferences(

          "P" + QString::number(data.m_passiveCacheId));

#endif

  }

}

//-------------------------------------------------------------------------

void TPassiveCacheManager::toggleCache(TFx *fx) {

  int &idx = fx->getAttributes()->passiveCacheDataIdx();

  touchFxData(idx);

  FxData &data = m_fxDataVector[idx];

  QMutexLocker locker(&m_mutex);

  StorageFlag flag = getStorageMode();

  if (flag) {

    UCHAR &storedFlag = data.m_storageFlag;

    UCHAR oldFlag     = storedFlag;

    storedFlag ^= flag;

#ifdef DIAGNOSTICS

    DIAGNOSTICS_STR("#activity.txt | " + QTime::currentTime().toString() + " " +

                    QString("Toggle Cache (now ") +

                    ((storedFlag & IN_MEMORY) ? "enabled)" : "disabled)"));

#endif

    if (data.m_passiveCacheId == 0)

      data.m_passiveCacheId = getNewPassiveCacheId();

    if ((storedFlag & ON_DISK) && !(oldFlag & ON_DISK)) {

      ResourcesTable::ColIterator it =

          m_resources->getTable().colBegin(data.m_passiveCacheId);

      for (; it; ++it) {

        std::set<lockedresourcep> &resources = *it;</lockedresourcep>

        std::set<lockedresourcep>::iterator jt;</lockedresourcep>

        for (jt = resources.begin(); jt != resources.end(); ++jt)

          (*jt)->enableBackup();

      }

    }

    // Implementa la versione contraria - eliminazione dell'fx nell'hdPool...

    // Metti anche questo in versione ritardata con flush... Il flush e' da

    // unificare...

    // e magari da spostare direttamente nell'hdPool

    if ((oldFlag & IN_MEMORY) && !(storedFlag & IN_MEMORY)) {

      m_resources->getTable().erase(data.m_passiveCacheId);

      data.m_fx              = TFxP();

      data.m_treeDescription = "";

    }

#ifndef USE_SQLITE_HDPOOL

    if ((storedFlag & IN_MEMORY) && !(oldFlag & IN_MEMORY)) {

      data.m_fx = fx;

      (*m_descriptorCallback)(data.m_treeDescription, data.m_fx);

    }

#endif

#ifdef USE_SQLITE_HDPOOL

    if ((oldFlag & ON_DISK) && !(storedFlag & ON_DISK))

      TCacheResourcePool::instance()->releaseReferences(

          "P" + QString::number(data.m_passiveCacheId));

#endif

  }

}

//-------------------------------------------------------------------------

void TPassiveCacheManager::invalidateLevel(const std::string &levelName) {

  QMutexLocker locker(&m_mutex);

  // Traverse the managed resources for passed levelName.

  ResourcesTable &table       = m_resources->getTable();

  ResourcesTable::Iterator it = table.begin();

  while (it) {

    std::set<lockedresourcep> &resources = *it;</lockedresourcep>

    std::set<lockedresourcep>::iterator jt, kt;</lockedresourcep>

    for (jt = resources.begin(); jt != resources.end();) {

      if ((*jt)->getName().find(levelName) != std::string::npos) {

        kt = jt++;

        it->erase(kt);

      } else

        ++jt;

    }

    if (resources.empty())

      it = table.erase(it);

    else

      ++it;

  }

#ifdef USE_SQLITE_HDPOOL

  // Store the level name until the invalidation is forced

  m_invalidatedLevels.insert(levelName);

#endif

}

//-------------------------------------------------------------------------

void TPassiveCacheManager::forceInvalidate() {

#ifdef USE_SQLITE_HDPOOL

  TCacheResourcePool *pool = TCacheResourcePool::instance();

  // Clear all invalidated levels from the resource pool

  std::set<std::string>::iterator it;</std::string>

  for (it = m_invalidatedLevels.begin(); it != m_invalidatedLevels.end(); ++it)

    pool->clearKeyword(*it);

  m_invalidatedLevels.clear();

#endif

}

//-------------------------------------------------------------------------

// Generate the fx's tree description. If it is contained in one of those

// stored with cached fxs, release their associated resources.

void TPassiveCacheManager::onFxChanged(const TFxP &fx) {

#ifndef USE_SQLITE_HDPOOL

  std::string fxTreeDescription;

  (*m_descriptorCallback)(fxTreeDescription, fx);

  unsigned int count = m_fxDataVector.size();

  for (unsigned int i = 0; i < count; ++i) {

    FxData &data = m_fxDataVector[i];

    if (!data.m_fx) continue;

    if (data.m_treeDescription.find(fxTreeDescription) != std::string::npos)

      m_resources->getTable().erase(data.m_passiveCacheId);

  }

#endif

}

//-------------------------------------------------------------------------

// Regenerate the tree descriptions of cached fxs. If the new description does

// not match the previous one, release the associated resources.

void TPassiveCacheManager::onXsheetChanged() {

#ifndef USE_SQLITE_HDPOOL

#ifdef DIAGNOSTICS

  DIAGNOSTICS_STR("#activity.txt | " + QTime::currentTime().toString() +

                  " XSheet changed");

#endif

  unsigned int count = m_fxDataVector.size();

  for (unsigned int i = 0; i < count; ++i) {

    FxData &data = m_fxDataVector[i];

    if (!data.m_fx) continue;

    std::string newTreeDescription;

    (*m_descriptorCallback)(newTreeDescription, data.m_fx);

    if (data.m_treeDescription != newTreeDescription) {

      m_resources->getTable().erase(data.m_passiveCacheId);

      data.m_treeDescription = newTreeDescription;

    }

  }

#endif

}

//-------------------------------------------------------------------------

void TPassiveCacheManager::getResource(TCacheResourceP &resource,

                                       const std::string &alias, const TFxP &fx,

                                       double frame, const TRenderSettings &rs,

                                       ResourceDeclaration *resData) {

  if (!(m_enabled && fx && rs.m_userCachable)) return;

  StorageFlag flag = getStorageMode(fx.getPointer());

  if (flag == NONE) return;

  std::string contextName(getContextName());

  if (contextName.empty()) return;

  // Build a resource if none was passed.

  if (!resource) resource = TCacheResourceP(alias, true);

#ifdef USE_SQLITE_HDPOOL

  if (flag & ON_DISK) {

    resource->enableBackup();