Mirroristas/gun
2
0
Fork 0
mirror of https://github.com/amark/gun.git synced 2025-06-07 06:36:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: fix log

Browse Source
This commit is contained in:
bluelovers 2020-02-05 11:00:16 +08:00
parent 60c98a5ba0
commit d2512f2842
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
lib/radisk.js
View File

@ -299,7 +299,7 @@
Q[g.file] = [{key: key, ack: cb, file: g.file, opt: o}]; Q[g.file] = [{key: key, ack: cb, file: g.file, opt: o}];
if(!g.file){ if(!g.file){
g.it(null, u, {}); g.it(null, u, {});
return true; return true;
} }
r.parse(g.file, g.check); r.parse(g.file, g.check);
return true; return true;
@ -333,14 +333,14 @@
){ ){
o.more = u; o.more = u;
as.ack(g.err, data, o); as.ack(g.err, data, o);
return return
} }
if(u !== data){ if(u !== data){
var S = +new Date; var S = +new Date;
as.ack(g.err, data, o); // more might be coming! as.ack(g.err, data, o); // more might be coming!
LOG && opt.log(S, +new Date - S, 'rad range ack.'); // 1.4s LOG && opt.log(S, +new Date - S, 'rad range ack.'); // 1.4s
if(o.parsed >= o.limit){ return } // even if more, we've hit our limit, asking peer will need to make a new ask with a new starting point. if(o.parsed >= o.limit){ return } // even if more, we've hit our limit, asking peer will need to make a new ask with a new starting point.
} }
o.next = as.file; o.next = as.file;
r.read(key, as.ack, o); r.read(key, as.ack, o);
} }
@ -360,10 +360,10 @@
r.list(go); r.list(go);
}); });
if(good){ return } if(good){ return }
var id = Gun.text.random(3); console.log("MISLOCATED DATA", id); var id = Gun.text.random(3); opt.log("MISLOCATED DATA", id);
r.save(disk, function ack(err, ok){ r.save(disk, function ack(err, ok){
if(err){ return r.save(disk, ack) } // ad infinitum??? if(err){ return r.save(disk, ack) } // ad infinitum???
console.log("MISLOCATED CORRECTED", id); opt.log("MISLOCATED CORRECTED", id);
}); });
} }
/*g.check2 = function(err, disk, info){ /*g.check2 = function(err, disk, info){
@ -478,7 +478,7 @@
l[2] = t.slice(i + o.i); l[2] = t.slice(i + o.i);
return l; return l;
} }
p.ack = function(cb){ p.ack = function(cb){
if(!cb){ return } if(!cb){ return }
if(p.err || p.not){ return cb(p.err, u, info) } if(p.err || p.not){ return cb(p.err, u, info) }
cb(u, p.disk, info); cb(u, p.disk, info);
@ -618,7 +618,7 @@
var Gun = window.Gun; var Gun = window.Gun;
var Radix = window.Radix; var Radix = window.Radix;
window.Radisk = Radisk; window.Radisk = Radisk;
} else { } else {
var Gun = require('../gun'); var Gun = require('../gun');
var Radix = require('./radix'); var Radix = require('./radix');
//var Radix = require('./radix2'); Radisk = require('./radisk2'); //var Radix = require('./radix2'); Radisk = require('./radisk2');
@ -627,4 +627,4 @@
Radisk.Radix = Radix; Radisk.Radix = Radix;
}()); }());