mirrors/copyparty
1
0
Fork 0
mirror of https://github.com/9001/copyparty.git synced 2025-08-18 01:22:13 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

ok ok

Browse source
This commit is contained in:
ed 2021-04-21 21:26:55 +02:00
parent e4654ee7f1
commit e5c4f49901
1 changed files with 16 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
copyparty/web/up2k.js
View file

@ -747,9 +747,21 @@ function up2k_init(have_crypto) {
var tasker = (function () { var tasker = (function () {
var tto = null, var tto = null,
running = false,
was_busy = false; was_busy = false;
function defer() {
running = false;
clearTimeout(tto);
tto = setTimeout(taskerd, 100);
}
function taskerd() { function taskerd() {
if (running)
return;
clearTimeout(tto);
running = true;
while (true) { while (true) {
var is_busy = 0 != var is_busy = 0 !=
st.todo.hash.length + st.todo.hash.length +
@ -770,11 +782,8 @@ function up2k_init(have_crypto) {
if (is_busy) { if (is_busy) {
var now = new Date().getTime(); var now = new Date().getTime();
flag.take(now); flag.take(now);
if (!flag.ours) { if (!flag.ours)
clearTimeout(tto); return defer();
tto = setTimeout(taskerd, 100);
return;
}
} }
else if (flag.ours) { else if (flag.ours) {
flag.give(); flag.give();
@ -816,11 +825,8 @@ function up2k_init(have_crypto) {
mou_ikkai = true; mou_ikkai = true;
} }
if (!mou_ikkai) { if (!mou_ikkai)
clearTimeout(tto); return defer();
tto = setTimeout(taskerd, 100);
return;
}
} }
} }
taskerd(); taskerd();