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() = default;
  19
  20 CBackgroundInfoLoader::~CBackgroundInfoLoader()
  21 {
  22   StopThread();
  23 }
  24
  25 void CBackgroundInfoLoader::Reset()
  26 {
  27   m_pVecItems = nullptr;
  28   m_vecItems.clear();
  29   m_bIsLoading = false;
  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   }
  87   catch (...)
  88   {
  89     CLog::Log(LOGERROR, "{} - Unhandled exception", __FUNCTION__);
  90   }
  91
  92   Reset();
  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   Reset();
 133 }
 134
 135 bool CBackgroundInfoLoader::IsLoading()
 136 {
 137   return m_bIsLoading;
 138 }
 139
 140 void CBackgroundInfoLoader::SetObserver(IBackgroundLoaderObserver* pObserver)
 141 {
 142   m_pObserver = pObserver;
 143 }
 144
 145 void CBackgroundInfoLoader::SetProgressCallback(IProgressCallback* pCallback)
 146 {
 147   m_pProgressCallback = pCallback;
 148 }
 149