Basic fault tolerance
This commit is contained in:
parent
7c315da6f4
commit
e052e13584
|
@ -221,13 +221,13 @@ def download_track(mode: str, track_id: str, extra_keys=None, disable_progressba
|
||||||
unit_divisor=1024,
|
unit_divisor=1024,
|
||||||
disable=disable_progressbar
|
disable=disable_progressbar
|
||||||
) as p_bar:
|
) as p_bar:
|
||||||
while True:
|
b = 0
|
||||||
|
while b < 5:
|
||||||
#for _ in range(int(total_size / Zotify.CONFIG.get_chunk_size()) + 2):
|
#for _ in range(int(total_size / Zotify.CONFIG.get_chunk_size()) + 2):
|
||||||
data = stream.input_stream.stream().read(Zotify.CONFIG.get_chunk_size())
|
data = stream.input_stream.stream().read(Zotify.CONFIG.get_chunk_size())
|
||||||
p_bar.update(file.write(data))
|
p_bar.update(file.write(data))
|
||||||
downloaded += len(data)
|
downloaded += len(data)
|
||||||
if data == b'':
|
b += 1 if data == b'' else 0
|
||||||
break
|
|
||||||
if Zotify.CONFIG.get_download_real_time():
|
if Zotify.CONFIG.get_download_real_time():
|
||||||
delta_real = time.time() - time_start
|
delta_real = time.time() - time_start
|
||||||
delta_want = (downloaded / total_size) * (duration_ms/1000)
|
delta_want = (downloaded / total_size) * (duration_ms/1000)
|
||||||
|
|
Loading…
Reference in New Issue