You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
64 lines
1.7 KiB
64 lines
1.7 KiB
//========= Copyright Valve Corporation, All rights reserved. ============// |
|
// |
|
//---------------------------------------------------------------------------------------- |
|
|
|
#ifndef CL_SESSIONBLOCKDOWNLOADER_H |
|
#define CL_SESSIONBLOCKDOWNLOADER_H |
|
#ifdef _WIN32 |
|
#pragma once |
|
#endif |
|
|
|
//---------------------------------------------------------------------------------------- |
|
|
|
#include "utllinkedlist.h" |
|
#include "cl_downloader.h" |
|
#include "basethinker.h" |
|
#include "replay/replayhandle.h" |
|
|
|
//---------------------------------------------------------------------------------------- |
|
|
|
class CClientRecordingSession; |
|
|
|
//---------------------------------------------------------------------------------------- |
|
|
|
// |
|
// Downloads multiple session blocks concurrently and updates their status. |
|
// |
|
class CSessionBlockDownloader : public CBaseThinker, |
|
public IDownloadHandler |
|
{ |
|
public: |
|
CSessionBlockDownloader(); |
|
|
|
void Shutdown(); |
|
void Think(); |
|
|
|
// If pSession is NULL, all remaining downloads will affected. |
|
void AbortDownloadsAndCleanup( CClientRecordingSession *pSession ); |
|
|
|
private: |
|
bool AtMaxConcurrentDownloads() const; |
|
|
|
// |
|
// CBaseThinker |
|
// |
|
virtual float GetNextThinkTime() const; |
|
|
|
// |
|
// IDownloadHandler |
|
// |
|
virtual void OnConnecting( CHttpDownloader *pDownloader ); |
|
virtual void OnFetch( CHttpDownloader *pDownloader ); |
|
virtual void OnDownloadComplete( CHttpDownloader *pDownloader, const unsigned char *pData ); |
|
|
|
static int sm_nNumCurrentDownloads; |
|
|
|
CUtlLinkedList< CHttpDownloader *, int > m_lstDownloaders; |
|
int m_nMaxBlock; |
|
|
|
friend class CErrorSystem; |
|
}; |
|
|
|
//---------------------------------------------------------------------------------------- |
|
|
|
#endif // CL_SESSIONBLOCKDOWNLOADER_H
|
|
|