1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
#include "Main.h"
//#include "../Components/wac_downloads/wac_downloads_download_manager.h"
using namespace Nullsoft::Utility;
DownloadViewCallback::DownloadViewCallback()
{}
void DownloadViewCallback::OnInit( DownloadToken token )
{
// ---- Inform the download status service of our presence----
downloadStatus.AddDownloadThread( token, WAC_API_DOWNLOADMANAGER->GetSource( token ), WAC_API_DOWNLOADMANAGER->GetTitle( token ), WAC_API_DOWNLOADMANAGER->GetLocation( token ) );
}
void DownloadViewCallback::OnConnect( DownloadToken token )
{}
void DownloadViewCallback::OnData( DownloadToken token, void *data, size_t datalen )
{
if ( token == NULL )
return;
api_httpreceiver *http = WAC_API_DOWNLOADMANAGER->GetReceiver( token );
size_t totalSize = http->content_length();
size_t downloaded = (size_t)WAC_API_DOWNLOADMANAGER->GetBytesDownloaded( token );
// if killswitch is turned on, then cancel download
downloadStatus.UpdateStatus( token, downloaded, totalSize );
dirty++;
}
void DownloadViewCallback::OnCancel( DownloadToken token )
{
api_httpreceiver *http = WAC_API_DOWNLOADMANAGER->GetReceiver( token );
DownloadedFile *data = new DownloadedFile( AutoWide( http->get_url() ), WAC_API_DOWNLOADMANAGER->GetLocation( token ), WAC_API_DOWNLOADMANAGER->GetSource( token ), WAC_API_DOWNLOADMANAGER->GetTitle( token ), DownloadedFile::DOWNLOAD_CANCELED, _time64( 0 ) );
data->totalSize = http->content_length();
data->bytesDownloaded = (size_t)WAC_API_DOWNLOADMANAGER->GetBytesDownloaded( token );
{
AutoLock lock( downloadedFiles );
downloadedFiles.downloadList.push_back( *data );
DownloadsUpdated( token, &downloadedFiles.downloadList[ downloadedFiles.downloadList.size() - 1 ] );
}
downloadStatus.DownloadThreadDone( token );
delete data;
dirty++;
}
void DownloadViewCallback::OnError( DownloadToken token, int error )
{
api_httpreceiver *http = WAC_API_DOWNLOADMANAGER->GetReceiver( token );
DownloadedFile *data = new DownloadedFile( AutoWide( http->get_url() ), WAC_API_DOWNLOADMANAGER->GetLocation( token ), WAC_API_DOWNLOADMANAGER->GetSource( token ), WAC_API_DOWNLOADMANAGER->GetTitle( token ), DownloadedFile::DOWNLOAD_FAILURE, _time64( 0 ) );
data->totalSize = http->content_length();
data->bytesDownloaded = (size_t)WAC_API_DOWNLOADMANAGER->GetBytesDownloaded( token );
{
AutoLock lock( downloadedFiles );
downloadedFiles.downloadList.push_back( *data );
DownloadsUpdated( token, &downloadedFiles.downloadList[ downloadedFiles.downloadList.size() - 1 ] );
}
downloadStatus.DownloadThreadDone( token );
delete data;
dirty++;
}
void DownloadViewCallback::OnFinish( DownloadToken token )
{
api_httpreceiver *http = WAC_API_DOWNLOADMANAGER->GetReceiver( token );
DownloadedFile *data = new DownloadedFile( AutoWide( http->get_url() ), WAC_API_DOWNLOADMANAGER->GetLocation( token ), WAC_API_DOWNLOADMANAGER->GetSource( token ), WAC_API_DOWNLOADMANAGER->GetTitle( token ), DownloadedFile::DOWNLOAD_SUCCESS, _time64( 0 ) );
data->totalSize = http->content_length();
data->bytesDownloaded = (size_t)WAC_API_DOWNLOADMANAGER->GetBytesDownloaded( token );
{
AutoLock lock( downloadedFiles );
downloadedFiles.downloadList.push_back( *data );
//AddDownloadData(*data);
DownloadsUpdated( token, &downloadedFiles.downloadList[ downloadedFiles.downloadList.size() - 1 ] );
}
downloadStatus.DownloadThreadDone( token );
delete data;
dirty++;
}
size_t DownloadViewCallback::AddRef()
{
return this->_ref_count.fetch_add( 1 );
}
size_t DownloadViewCallback::Release()
{
std::size_t l_ref_countr = this->_ref_count.fetch_sub( 1 );
if ( l_ref_countr == 0 )
delete( this );
return l_ref_countr;
}
DownloadViewCallback::~DownloadViewCallback()
{}
#define CBCLASS DownloadViewCallback
START_DISPATCH;
VCB( IFC_DOWNLOADMANAGERCALLBACK_ONFINISH, OnFinish )
VCB( IFC_DOWNLOADMANAGERCALLBACK_ONCANCEL, OnCancel )
VCB( IFC_DOWNLOADMANAGERCALLBACK_ONERROR, OnError )
VCB( IFC_DOWNLOADMANAGERCALLBACK_ONDATA, OnData )
VCB( IFC_DOWNLOADMANAGERCALLBACK_ONCONNECT, OnConnect )
VCB( IFC_DOWNLOADMANAGERCALLBACK_ONINIT, OnInit )
CB( ADDREF, AddRef )
CB( RELEASE, Release )
END_DISPATCH;
#undef CBCLASS
|
