projects
/
youtube-dl
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
[rtve] Detect videos that are no longer available
[youtube-dl]
/
youtube_dl
/
downloader
/
http.py
diff --git
a/youtube_dl/downloader/http.py
b/youtube_dl/downloader/http.py
index 6dec528f268c9da4eb8ac534b2da8f247ec7cf4b..d136bebd1fe45761312bd90c31a95ddaf1754271 100644
(file)
--- a/
youtube_dl/downloader/http.py
+++ b/
youtube_dl/downloader/http.py
@@
-1,11
+1,10
@@
from __future__ import unicode_literals
from __future__ import unicode_literals
+import errno
import os
import os
+import socket
import time
import time
-from socket import error as SocketError
-import errno
-
from .common import FileDownloader
from ..compat import (
compat_urllib_request,
from .common import FileDownloader
from ..compat import (
compat_urllib_request,
@@
-50,7
+49,7
@@
class HttpFD(FileDownloader):
open_mode = 'wb'
if resume_len != 0:
open_mode = 'wb'
if resume_len != 0:
- if self.params.get('continuedl',
Fals
e):
+ if self.params.get('continuedl',
Tru
e):
self.report_resuming_byte(resume_len)
request.add_header('Range', 'bytes=%d-' % resume_len)
open_mode = 'ab'
self.report_resuming_byte(resume_len)
request.add_header('Range', 'bytes=%d-' % resume_len)
open_mode = 'ab'
@@
-93,6
+92,8
@@
class HttpFD(FileDownloader):
self._hook_progress({
'filename': filename,
'status': 'finished',
self._hook_progress({
'filename': filename,
'status': 'finished',
+ 'downloaded_bytes': resume_len,
+ 'total_bytes': resume_len,
})
return True
else:
})
return True
else:
@@
-101,7
+102,7
@@
class HttpFD(FileDownloader):
resume_len = 0
open_mode = 'wb'
break
resume_len = 0
open_mode = 'wb'
break
- except
SocketE
rror as e:
+ except
socket.e
rror as e:
if e.errno != errno.ECONNRESET:
# Connection reset is no problem, just retry
raise
if e.errno != errno.ECONNRESET:
# Connection reset is no problem, just retry
raise
@@
-219,12
+220,6
@@
class HttpFD(FileDownloader):
if tmpfilename != '-':
stream.close()
if tmpfilename != '-':
stream.close()
- self._hook_progress({
- 'downloaded_bytes': byte_counter,
- 'total_bytes': data_len,
- 'tmpfilename': tmpfilename,
- 'status': 'error',
- })
if data_len is not None and byte_counter != data_len:
raise ContentTooShortError(byte_counter, int(data_len))
self.try_rename(tmpfilename, filename)
if data_len is not None and byte_counter != data_len:
raise ContentTooShortError(byte_counter, int(data_len))
self.try_rename(tmpfilename, filename)