mirror of
https://github.com/Team-Resurgent/XBMC4Xbox.git
synced 2026-08-15 11:18:13 -07:00
Rocky5
921f9fe9f8
If ever adding the XBMC4Xbox source to GitHub use "git add -f -A" or it wont add all the files.
120 lines
3.4 KiB
C++
120 lines
3.4 KiB
C++
/*
|
|
* Copyright (C) 2005-2013 Team XBMC
|
|
* http://xbmc.org
|
|
*
|
|
* This Program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation; either version 2, or (at your option)
|
|
* any later version.
|
|
*
|
|
* This Program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with XBMC; see the file COPYING. If not, see
|
|
* <http://www.gnu.org/licenses/>.
|
|
*
|
|
*/
|
|
|
|
#include "DownloadQueueManager.h"
|
|
|
|
#include <assert.h>
|
|
|
|
// Global instance of the download manager
|
|
CDownloadQueueManager g_DownloadManager;
|
|
|
|
CDownloadQueueManager::CDownloadQueueManager()
|
|
{
|
|
InitializeCriticalSection(&m_critical);
|
|
}
|
|
|
|
CDownloadQueueManager::~CDownloadQueueManager(void)
|
|
{
|
|
DeleteCriticalSection(&m_critical);
|
|
}
|
|
|
|
VOID CDownloadQueueManager::Initialize()
|
|
{
|
|
}
|
|
|
|
|
|
TICKET CDownloadQueueManager::RequestContent(CStdString& aUrl, IDownloadQueueObserver* aObserver)
|
|
{
|
|
EnterCriticalSection(&m_critical);
|
|
TICKET ticket = GetNextDownloadQueue()->RequestContent(aUrl, aObserver);
|
|
LeaveCriticalSection(&m_critical);
|
|
return ticket;
|
|
}
|
|
|
|
TICKET CDownloadQueueManager::RequestFile(CStdString& aUrl, CStdString& aFilePath, IDownloadQueueObserver* aObserver)
|
|
{
|
|
EnterCriticalSection(&m_critical);
|
|
TICKET ticket = GetNextDownloadQueue()->RequestFile(aUrl, aFilePath, aObserver);
|
|
LeaveCriticalSection(&m_critical);
|
|
return ticket;
|
|
}
|
|
|
|
TICKET CDownloadQueueManager::RequestFile(CStdString& aUrl, IDownloadQueueObserver* aObserver)
|
|
{
|
|
EnterCriticalSection(&m_critical);
|
|
TICKET ticket = GetNextDownloadQueue()->RequestFile(aUrl, aObserver);
|
|
LeaveCriticalSection(&m_critical);
|
|
return ticket;
|
|
}
|
|
|
|
void CDownloadQueueManager::CancelRequests(IDownloadQueueObserver *aObserver)
|
|
{
|
|
EnterCriticalSection(&m_critical);
|
|
// run through all our queues and remove all requests from this observer
|
|
for (QUEUEPOOL::iterator it = m_queues.begin(); it != m_queues.end(); ++it)
|
|
{
|
|
CDownloadQueue* downloadQueue = *it;
|
|
downloadQueue->CancelRequests(aObserver);
|
|
}
|
|
LeaveCriticalSection(&m_critical);
|
|
}
|
|
|
|
CDownloadQueue* CDownloadQueueManager::GetNextDownloadQueue()
|
|
{
|
|
CDownloadQueue* pQueueAvailable = NULL;
|
|
|
|
// if we haven't added any queues to the pool, add one.
|
|
if (m_queues.size() < 1)
|
|
{
|
|
m_queues.push_back( new CDownloadQueue() );
|
|
}
|
|
|
|
// return the queue with the least number of items pending
|
|
for (QUEUEPOOL::iterator it = m_queues.begin(); it != m_queues.end(); ++it)
|
|
{
|
|
// always choose the first queue if we haven't selected one yet
|
|
if (!pQueueAvailable)
|
|
{
|
|
pQueueAvailable = *it;
|
|
}
|
|
else
|
|
{
|
|
// pick this queue if it has less items pending than our previous selection
|
|
if ( pQueueAvailable->Size() > (*it)->Size() )
|
|
{
|
|
pQueueAvailable = *it;
|
|
}
|
|
}
|
|
}
|
|
|
|
// if we picked a queue with pending items and we haven't reached out max pool limit
|
|
if (pQueueAvailable->Size() > 0 && m_queues.size() < MAX_DOWNLOAD_QUEUES)
|
|
{
|
|
// spawn a new queue
|
|
pQueueAvailable = new CDownloadQueue();
|
|
m_queues.push_back(pQueueAvailable);
|
|
}
|
|
|
|
assert(pQueueAvailable != NULL);
|
|
|
|
return pQueueAvailable;
|
|
}
|
|
|