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

begin

Browse Source
This commit is contained in:
Mark Nadal 2020-02-02 01:09:48 -08:00
parent 9dfdf608dc
commit 328ae52c2c
4 changed files with 19 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
gun.js
View File

@ -1957,7 +1957,7 @@
;USE(function(module){
var Type = USE('../type');
var puff = (typeof setImmediate !== "undefined")? setImmediate : setTimeout;
var puff = setTimeout; //(typeof setImmediate !== "undefined")? setImmediate : setTimeout;
function Mesh(root){
var mesh = function(){};
@ -1976,15 +1976,18 @@
if('{' != raw[2]){ mesh.hear.d += raw.length||0; ++mesh.hear.c; } // STATS! // ugh, stupid double JSON encoding
if('[' === tmp){
try{msg = JSON.parse(raw);}catch(e){opt.log('DAM JSON parse error', e)}
raw = '';
if(!msg){ return }
LOG && opt.log(+new Date, msg.length, '# on hear batch');
(function go(){ // stats on single msg is 99% spike of batch stats.
var m, c = 100; // hardcoded for now?
while(c-- && (m = msg.shift())){
var m, i = 0, c = 100; // hardcoded for now?
while(c-- && (m = msg[i++])){
mesh.hear(m, peer);
}
msg = msg.slice(i);
// TODO: consider triggering peer flush to response times speedier!
if(!msg.length){ return }
puff(go, 0);
puff(go, 1);
}());
return;
}
@ -1995,14 +1998,15 @@
if(!(id = msg['#'])){ id = msg['#'] = Type.text.random(9) }
if(msg.DBG_s){ opt.log(+new Date - msg.DBG_s, 'to hear', id) }
if(dup.check(id)){ return }
dup.track(id, true).it = it(msg); // GUN core also dedups, so `true` is needed. // Does GUN core need to dedup anymore?
if(!(hash = msg['##']) && u !== msg.put){ hash = msg['##'] = Type.obj.hash(msg.put) }
dup.track(id, true); //.it = it(msg); // GUN core also dedups, so `true` is needed. // Does GUN core need to dedup anymore?
/*if(!(hash = msg['##']) && u !== msg.put){ hash = msg['##'] = Type.obj.hash(msg.put) }
if(hash && (tmp = msg['@'] || (msg.get && id))){ // Reduces backward daisy in case varying hashes at different daisy depths are the same.
if(dup.check(tmp+hash)){ return }
dup.track(tmp+hash, true).it = it(msg); // GUN core also dedups, so `true` is needed. // Does GUN core need to dedup anymore?
}
(msg._ = function(){}).via = peer;
if(tmp = msg['><']){ (msg._).to = Type.obj.map(tmp.split(','), tomap) }
*/ // TOOD: COME BACK TO THIS LATER!!! IMPORTANT MESH STUFF!!
(msg._ = function(){}).via = peer;
if(msg.dam){
if(tmp = mesh.hear[msg.dam]){
tmp(msg, peer, root);
@ -2010,7 +2014,8 @@
return;
}
var S, ST; LOG && (S = +new Date); console.STAT = {};
root.on('in', msg);
//root.on('in', msg);
root.on('in2', msg);
if(LOG && !msg.nts && (ST = +new Date - S) > 9){ opt.log(S, ST, 'msg', msg['#'], JSON.stringify(console.STAT)); if(ST > 500){ try{ require('./lib/email').send({text: ""+ST+"ms "+JSON.stringify(msg)+" | "+JSON.stringify(console.STAT), from: "mark@gun.eco", to: "mark@gun.eco", subject: "GUN MSG"}, noop); }catch(e){} } } // this is ONLY turned on if ENV CONFIGS have email/password to send out from.
return;
}

2
lib/evict.js
View File

@ -10,7 +10,7 @@
try{ heap = require('v8').getHeapStatistics }catch(e){}
if(!heap){ return }
ev.max = parseFloat(root.opt.memory || (heap().heap_size_limit / 1024 / 1024) || process.env.WEB_MEMORY || 1399) * 0.8; // max_old_space_size defaults to 1400 MB. Note: old space !== memory space though.
ev.max = parseFloat(root.opt.memory || (heap().heap_size_limit / 1024 / 1024) || process.env.WEB_MEMORY || 1399) * 0.8; // max_old_space_size defaults to 1400 MB. Note: old space !== memory space though. // KEEPING USED_HEA_SIZE < HEAP_SIZE_LIMIT ONLY THING TO BE BELOW TO PREVENT CRASH!
setInterval(check, 1000);
function check(){

6
lib/radisk.js
View File

@ -174,12 +174,14 @@
return;
}
disk = disk || Radix();
var S; LOG && (S = +new Date);
var S, C = 0; LOG && (S = +new Date);
Radix.map(mem, function(val, key){
C++;
// PLUGIN: consider adding HAM as an extra layer of protection
disk(key, val); // merge batch[key] -> disk[key]
});
LOG && opt.log(S, +new Date - S, "rad merge mem & disk");
LOG && opt.log(S, +new Date - S, "rad merge");
LOG && opt.log(S, C, "rad merge #");
r.write(file, disk, s.pop);
})
}

2
lib/store.js
View File

@ -96,7 +96,7 @@ Gun.on('create', function(root){
if(err){ opt.store.stats.get.err = err }
}catch(e){} // STATS!
//if(u === data && o.chunks > 1){ return } // if we already sent a chunk, ignore ending empty responses. // this causes tests to fail.
LOG && Gun.log(S, +new Date - S, 'got'); S = +new Date;
LOG && Gun.log(S, +new Date - S, 'got', JSON.stringify(key)); S = +new Date;
if(data){
if(typeof data !== 'string'){
if(o.atom){