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

up2k-cli: cond. readahead

Browse source
This commit is contained in:
ed 2021-04-21 18:39:55 +02:00
parent 505a8fc6f6
commit 2c4b4ab928
1 changed files with 12 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
copyparty/web/up2k.js
View file

@ -491,6 +491,7 @@ function up2k_init(have_crypto) {
var ask_up = bcfg_get('ask_up', true); var ask_up = bcfg_get('ask_up', true);
var flag_en = bcfg_get('flag_en', false); var flag_en = bcfg_get('flag_en', false);
var fsearch = bcfg_get('fsearch', false); var fsearch = bcfg_get('fsearch', false);
var min_filebuf = 0;
var fdom_ctr = 0; var fdom_ctr = 0;
var st = { var st = {
@ -936,13 +937,14 @@ function up2k_init(have_crypto) {
pvis.move(t.n, 'bz'); pvis.move(t.n, 'bz');
var segm_next = function () { var segm_next = function () {
if (nchunk >= nchunks || (bpend > chunksize && bpend >= 32 * 1024 * 1024)) if (nchunk >= nchunks || (bpend > chunksize && bpend >= min_filebuf))
return false; return false;
var reader = new FileReader(), var reader = new FileReader(),
nch = nchunk++, nch = nchunk++,
car = nch * chunksize, car = nch * chunksize,
cdr = car + chunksize; cdr = car + chunksize,
t0 = new Date().getTime();
if (cdr >= t.size) if (cdr >= t.size)
cdr = t.size; cdr = t.size;
@ -950,6 +952,14 @@ function up2k_init(have_crypto) {
bpend += cdr - car; bpend += cdr - car;
reader.onload = function (e) { reader.onload = function (e) {
if (!min_filebuf && nch == 1) {
min_filebuf = 1;
var td = (new Date().getTime()) - t0;
if (td > 50) {
ebi('u2foot').innerHTML += "<p>excessive filereader latency (" + td + " ms), increasing readahead</p>";
min_filebuf = 32 * 1024 * 1024;
}
}
hash_calc(nch, e.target.result); hash_calc(nch, e.target.result);
}; };
reader.onerror = segm_err; reader.onerror = segm_err;