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