aboutsummaryrefslogtreecommitdiff
path: root/youtube_dl/downloader/dash.py
diff options
context:
space:
mode:
authorYen Chi Hsuan <yan12125@gmail.com>2015-06-10 14:45:54 +0800
committerYen Chi Hsuan <yan12125@gmail.com>2015-06-10 14:45:54 +0800
commit5bf3276e8d6ee7d017c8be04414398752cd9cdf3 (patch)
tree2d6f7d92a6b8a8ce0eb898d50fbf91b759964f72 /youtube_dl/downloader/dash.py
parent93dfcb9357b400b4d7e353d0a9db0e0194135b19 (diff)
downloadyoutube-dl-5bf3276e8d6ee7d017c8be04414398752cd9cdf3.tar.xz
[downloader/dash] Add testing facility
Diffstat (limited to 'youtube_dl/downloader/dash.py')
-rw-r--r--youtube_dl/downloader/dash.py18
1 files changed, 16 insertions, 2 deletions
diff --git a/youtube_dl/downloader/dash.py b/youtube_dl/downloader/dash.py
index cd84e0b07..a4685d307 100644
--- a/youtube_dl/downloader/dash.py
+++ b/youtube_dl/downloader/dash.py
@@ -16,12 +16,21 @@ class DashSegmentsFD(FileDownloader):
base_url = info_dict['url']
segment_urls = info_dict['segment_urls']
+ is_test = self.params.get('test', False)
+ remaining_bytes = self._TEST_FILE_SIZE if is_test else None
byte_counter = 0
- def append_url_to_file(outf, target_url, target_name):
+ def append_url_to_file(outf, target_url, target_name, remaining_bytes=None):
self.to_screen('[DashSegments] %s: Downloading %s' % (info_dict['id'], target_name))
req = compat_urllib_request.Request(target_url)
+ if remaining_bytes is not None:
+ req.add_header('Range', 'bytes=0-%d' % (remaining_bytes - 1))
+
data = self.ydl.urlopen(req).read()
+
+ if remaining_bytes is not None:
+ data = data[:remaining_bytes]
+
outf.write(data)
return len(data)
@@ -37,8 +46,13 @@ class DashSegmentsFD(FileDownloader):
for i, segment_url in enumerate(segment_urls):
segment_len = append_url_to_file(
outf, combine_url(base_url, segment_url),
- 'segment %d / %d' % (i + 1, len(segment_urls)))
+ 'segment %d / %d' % (i + 1, len(segment_urls)),
+ remaining_bytes)
byte_counter += segment_len
+ if remaining_bytes is not None:
+ remaining_bytes -= segment_len
+ if remaining_bytes <= 0:
+ break
self.try_rename(tmpfilename, filename)