xbmc/BackgroundInfoLoader.cpp

   1 /*
   2  *  Copyright (C) 2005-2018 Team Kodi
   3  *  This file is part of Kodi - https://kodi.tv
   4  *
   5  *  SPDX-License-Identifier: GPL-2.0-or-later
   6  *  See LICENSES/README.md for more information.
   7  */
   8
   9 #include "BackgroundInfoLoader.h"
  10
  11 #include "FileItem.h"
  12 #include "URL.h"
  13 #include "threads/Thread.h"
  14 #include "utils/log.h"
  15
  16 #include <mutex>
  17
  18 CBackgroundInfoLoader::CBackgroundInfoLoader() : m_thread (NULL)
  19 {
  20   m_bStop = true;
  21   m_pObserver=NULL;
  22   m_pProgressCallback=NULL;
  23   m_pVecItems = NULL;
  24   m_bIsLoading = false;
  25 }
  26
  27 CBackgroundInfoLoader::~CBackgroundInfoLoader()
  28 {
  29   StopThread();
  30 }
  31
  32 void CBackgroundInfoLoader::Run()
  33 {
  34   try
  35   {
  36     if (!m_vecItems.empty())
  37     {
  38       OnLoaderStart();
  39
  40       // Stage 1: All "fast" stuff we have already cached
  41       for (std::vector<CFileItemPtr>::const_iterator iter = m_vecItems.begin(); iter != m_vecItems.end(); ++iter)
  42       {
  43         const CFileItemPtr& pItem = *iter;
  44
  45         // Ask the callback if we should abort
  46         if ((m_pProgressCallback && m_pProgressCallback->Abort()) || m_bStop)
  47           break;
  48
  49         try
  50         {
  51           if (LoadItemCached(pItem.get()) && m_pObserver)
  52             m_pObserver->OnItemLoaded(pItem.get());
  53         }
  54         catch (...)
  55         {
  56           CLog::Log(LOGERROR,
  57                     "CBackgroundInfoLoader::LoadItemCached - Unhandled exception for item {}",
  58                     CURL::GetRedacted(pItem->GetPath()));
  59         }
  60       }
  61
  62       // Stage 2: All "slow" stuff that we need to lookup
  63       for (std::vector<CFileItemPtr>::const_iterator iter = m_vecItems.begin(); iter != m_vecItems.end(); ++iter)
  64       {
  65         const CFileItemPtr& pItem = *iter;
  66
  67         // Ask the callback if we should abort
  68         if ((m_pProgressCallback && m_pProgressCallback->Abort()) || m_bStop)
  69           break;
  70
  71         try
  72         {
  73           if (LoadItemLookup(pItem.get()) && m_pObserver)
  74             m_pObserver->OnItemLoaded(pItem.get());
  75         }
  76         catch (...)
  77         {
  78           CLog::Log(LOGERROR,
  79                     "CBackgroundInfoLoader::LoadItemLookup - Unhandled exception for item {}",
  80                     CURL::GetRedacted(pItem->GetPath()));
  81         }
  82       }
  83     }
  84
  85     OnLoaderFinish();
  86     m_bIsLoading = false;
  87   }
  88   catch (...)
  89   {
  90     m_bIsLoading = false;
  91     CLog::Log(LOGERROR, "{} - Unhandled exception", __FUNCTION__);
  92   }
  93 }
  94
  95 void CBackgroundInfoLoader::Load(CFileItemList& items)
  96 {
  97   StopThread();
  98
  99   if (items.IsEmpty())
 100     return;
 101
 102   std::unique_lock<CCriticalSection> lock(m_lock);
 103
 104   for (int nItem=0; nItem < items.Size(); nItem++)
 105     m_vecItems.push_back(items[nItem]);
 106
 107   m_pVecItems = &items;
 108   m_bStop = false;
 109   m_bIsLoading = true;
 110
 111   m_thread = new CThread(this, "BackgroundLoader");
 112   m_thread->Create();
 113   m_thread->SetPriority(ThreadPriority::BELOW_NORMAL);
 114 }
 115
 116 void CBackgroundInfoLoader::StopAsync()
 117 {
 118   m_bStop = true;
 119 }
 120
 121
 122 void CBackgroundInfoLoader::StopThread()
 123 {
 124   StopAsync();
 125
 126   if (m_thread)
 127   {
 128     m_thread->StopThread();
 129     delete m_thread;
 130     m_thread = NULL;
 131   }
 132   m_vecItems.clear();
 133   m_pVecItems = NULL;
 134   m_bIsLoading = false;
 135 }
 136
 137 bool CBackgroundInfoLoader::IsLoading()
 138 {
 139   return m_bIsLoading;
 140 }
 141
 142 void CBackgroundInfoLoader::SetObserver(IBackgroundLoaderObserver* pObserver)
 143 {
 144   m_pObserver = pObserver;
 145 }
 146
 147 void CBackgroundInfoLoader::SetProgressCallback(IProgressCallback* pCallback)
 148 {
 149   m_pProgressCallback = pCallback;
 150 }
 151