mirror of
https://github.com/9001/copyparty.git
synced 2025-08-17 09:02:15 -06:00
up2k: 128 MiB runahead
This commit is contained in:
parent
63c0623a5e
commit
d8ed006b9b
|
@ -219,6 +219,10 @@ function up2k_init(have_crypto) {
|
||||||
"hash": [],
|
"hash": [],
|
||||||
"handshake": [],
|
"handshake": [],
|
||||||
"upload": []
|
"upload": []
|
||||||
|
},
|
||||||
|
"bytes": {
|
||||||
|
"hashed": 0,
|
||||||
|
"uploaded": 0
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
@ -357,8 +361,11 @@ function up2k_init(have_crypto) {
|
||||||
}
|
}
|
||||||
|
|
||||||
function hashing_permitted() {
|
function hashing_permitted() {
|
||||||
var lim = multitask ? 1 : 0;
|
if (multitask) {
|
||||||
return handshakes_permitted() && lim >=
|
var ahead = st.bytes.hashed - st.bytes.uploaded;
|
||||||
|
return ahead < 1024 * 1024 * 128;
|
||||||
|
}
|
||||||
|
return handshakes_permitted() && 0 ==
|
||||||
st.todo.handshake.length +
|
st.todo.handshake.length +
|
||||||
st.busy.handshake.length;
|
st.busy.handshake.length;
|
||||||
}
|
}
|
||||||
|
@ -512,6 +519,7 @@ function up2k_init(have_crypto) {
|
||||||
|
|
||||||
var t = st.todo.hash.shift();
|
var t = st.todo.hash.shift();
|
||||||
st.busy.hash.push(t);
|
st.busy.hash.push(t);
|
||||||
|
st.bytes.hashed += t.size;
|
||||||
t.t1 = new Date().getTime();
|
t.t1 = new Date().getTime();
|
||||||
|
|
||||||
var nchunk = 0;
|
var nchunk = 0;
|
||||||
|
@ -752,6 +760,7 @@ function up2k_init(have_crypto) {
|
||||||
xhr.onload = function (xev) {
|
xhr.onload = function (xev) {
|
||||||
if (xhr.status == 200) {
|
if (xhr.status == 200) {
|
||||||
prog(t.n, npart, col_uploaded);
|
prog(t.n, npart, col_uploaded);
|
||||||
|
st.bytes.uploaded += cdr - car;
|
||||||
st.busy.upload.splice(st.busy.upload.indexOf(upt), 1);
|
st.busy.upload.splice(st.busy.upload.indexOf(upt), 1);
|
||||||
t.postlist.splice(t.postlist.indexOf(npart), 1);
|
t.postlist.splice(t.postlist.indexOf(npart), 1);
|
||||||
if (t.postlist.length == 0) {
|
if (t.postlist.length == 0) {
|
||||||
|
|
Loading…
Reference in a new issue