Method interactiveLoaderFinished

YUViewLib/src/video/VideoCache.cpp:425–489

}

void VideoCache::interactiveLoaderFinished()
{
  // Get the thread that caused this call
  QObject *      sender   = QObject::sender();
  loadingWorker *worker   = dynamic_cast<loadingWorker *>(sender);
  int            threadID = (interactiveThread[0]->worker() == worker) ? 0 : 1;
  assert(worker == interactiveThread[0]->worker() || worker == interactiveThread[1]->worker());

  // Check the list of items that are scheduled for deletion. Because a loading thread finished,
  // maybe now we can delete the item(s).
  for (auto it = itemsToDelete.begin(); it != itemsToDelete.end();)
  {
    // Is the item still being cached?
    bool itemCaching = false;
    for (loadingThread *t : cachingThreadList)
      if (t->worker()->getCacheItem() == *it)
      {
        itemCaching = true;
        break;
      }
    // Is the item still being loaded?
    bool loadingItem = (interactiveThread[0]->worker()->getCacheItem() == *it ||
                        interactiveThread[1]->worker()->getCacheItem() == *it);

    if (!itemCaching && !loadingItem)
    {
      // Remove the item from the loading queue (if in there)
      if (interactiveItemQueued[threadID] == (*it))
      {
        interactiveItemQueued[threadID]     = nullptr;
        interactiveItemQueued_Idx[threadID] = -1;
      }
      // Delete the item and remove it from the itemsToDelete list
      DEBUG_CACHING("VideoCache::interactiveLoaderFinished delete item now %s",
                    (*it)->getName().toLatin1().data());
      (*it)->deleteLater();
      it = itemsToDelete.erase(it);
    }
    else
      ++it;
  }

  // The worker finished. Is there another loading request in the queue?
  if (interactiveItemQueued[threadID] != nullptr && interactiveItemQueued_Idx[threadID] >= 0)
  {
    // Let the interactive worker work on the queued request.
    bool loadRawData = splitView->showRawData() && !playback->playing();
    interactiveThread[threadID]->worker()->setJob(interactiveItemQueued[threadID],
                                                  interactiveItemQueued_Idx[threadID]);
    interactiveThread[threadID]->worker()->setWorking(true);
    interactiveThread[threadID]->worker()->processLoadingJob(playback->playing(), loadRawData);
    DEBUG_CACHING_DETAIL("VideoCache::interactiveLoaderFinished %d started - slot %d",
                         interactiveItemQueued_Idx[threadID],
                         threadID);

    // Clear the queue slot
    interactiveItemQueued[threadID]     = nullptr;
    interactiveItemQueued_Idx[threadID] = -1;