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
|
/* frmDownload.cs $
This file is part of the HandBrake source code.
Homepage: <http://handbrake.fr>.
It may be used under the terms of the GNU General Public License. */
namespace Handbrake
{
using System;
using System.Diagnostics;
using System.IO;
using System.Net;
using System.Threading;
using System.Windows.Forms;
public partial class frmDownload : Form
{
private readonly Thread _downloadThread;
private Stream _responceStream;
private Stream _loacalStream;
private HttpWebRequest _webRequest;
private HttpWebResponse _webResponse;
private static int _progress;
private bool _killThread;
private delegate void UpdateProgessCallback(long bytesRead, long totalBytes);
private delegate void DownloadCompleteCallback();
private delegate void DownloadFailedCallback();
public frmDownload(string filename)
{
InitializeComponent();
_downloadThread = new Thread(Download);
_downloadThread.Start(filename);
}
private void Download(object file)
{
string tempPath = Path.Combine(Path.GetTempPath(), "handbrake-setup.exe");
string hbUpdate = (string) file;
WebClient wcDownload = new WebClient();
try
{
if (File.Exists(tempPath))
File.Delete(tempPath);
_webRequest = (HttpWebRequest) WebRequest.Create(hbUpdate);
_webRequest.Credentials = CredentialCache.DefaultCredentials;
_webResponse = (HttpWebResponse) _webRequest.GetResponse();
long fileSize = _webResponse.ContentLength;
_responceStream = wcDownload.OpenRead(hbUpdate);
_loacalStream = new FileStream(tempPath, FileMode.Create, FileAccess.Write, FileShare.None);
int bytesSize;
byte[] downBuffer = new byte[2048];
long flength = 0;
while ((bytesSize = _responceStream.Read(downBuffer, 0, downBuffer.Length)) > 0)
{
if (_killThread)
return;
_loacalStream.Write(downBuffer, 0, bytesSize);
flength = _loacalStream.Length;
Invoke(new UpdateProgessCallback(this.UpdateProgress), new object[] {_loacalStream.Length, fileSize});
}
_responceStream.Close();
_loacalStream.Close();
if (flength != fileSize)
Invoke(new DownloadFailedCallback(this.DownloadFailed));
else
Invoke(new DownloadCompleteCallback(this.DownloadComplete));
}
catch
{
// Do Nothing
}
}
private void UpdateProgress(long bytesRead, long totalBytes)
{
long p = (bytesRead * 100) / totalBytes;
int.TryParse(p.ToString(), out _progress);
progress_download.Value = _progress;
lblProgress.Text = (bytesRead / 1024) + "k of " + (totalBytes / 1024) + "k ";
}
private void DownloadComplete()
{
lblProgress.Text = "Download Complete";
btn_cancel.Text = "Close";
Process.Start(Path.Combine(Path.GetTempPath(), "handbrake-setup.exe"));
this.Close();
Application.Exit();
}
private void DownloadFailed()
{
lblProgress.Text = "Download Failed";
btn_cancel.Text = "Close";
}
private void btn_cancel_Click(object sender, EventArgs e)
{
_killThread = true;
lblProgress.Text = "Cancelling ...";
if (_webResponse != null) _webResponse.Close();
if (_responceStream != null) _responceStream.Close();
if (_loacalStream != null) _loacalStream.Close();
this.Close();
}
}
}
|
