up2k: limit runahead in client

This commit is contained in:
ed 2021-01-23 19:05:45 +01:00
parent 3b1839c2ce
commit 69b83dfdc4
2 changed files with 10 additions and 8 deletions

View file

@ -293,7 +293,8 @@ class Up2k(object):
job = job or reg[wark]
if job["prel"] == cj["prel"] and job["name"] == cj["name"]:
# ensure the files haven't been deleted manually
for fn in job["name"], job["tnam"]:
names = [job[x] for x in ["name", "tnam"] if x in job]
for fn in names:
path = os.path.join(job["ptop"], job["prel"], fn)
if not os.path.exists(path):
job = None

View file

@ -349,16 +349,17 @@ function up2k_init(have_crypto) {
//
function handshakes_permitted() {
return multitask || (
st.todo.upload.length == 0 &&
st.busy.upload.length == 0);
var lim = multitask ? 1 : 0;
return lim >=
st.todo.upload.length +
st.busy.upload.length;
}
function hashing_permitted() {
return multitask || (
handshakes_permitted() &&
st.todo.handshake.length == 0 &&
st.busy.handshake.length == 0);
var lim = multitask ? 1 : 0;
return handshakes_permitted() && lim >=
st.todo.handshake.length +
st.busy.handshake.length;
}
var tasker = (function () {