Mirroristas/gun
2
0
Fork 0
mirror of https://github.com/amark/gun.git synced 2025-03-30 15:08:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

if emitting chain perf fault, then redo _rad

Browse Source
This commit is contained in:
Mark Nadal 2020-02-13 00:53:42 -08:00
parent c785a184c1
commit 699823d578
3 changed files with 40 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
gun.js
View File

@ -752,11 +752,17 @@
if(mid){ return }
if(!obj_empty(all.s)){ return } // keep waiting
Gun.log(S, +new Date - S, 'put');
Gun.log(S, ctx.SFT, 'total fire');
root.on('in', {'@': id, ok: ok || 1});
id = u;
};
var set = ctx.set = {'':1};
SC = 0;(console.STAT||'').p = +new Date;
SC = ctx.SFT = 0;(console.STAT||'').p = +new Date;
// TODO: PERF!!!! Oh yeesh, this is badly slow. Because it also calls rad? Or loops? How speed up?
// TODO: PERF!!!! Oh yeesh, this is badly slow. Because it also calls rad? Or loops? How speed up?
// TODO: PERF!!!! Oh yeesh, this is badly slow. Because it also calls rad? Or loops? How speed up?
// TODO: PERF!!!! Oh yeesh, this is badly slow. Because it also calls rad? Or loops? How speed up?
// TODO: PERF!!!! Oh yeesh, this is badly slow. Because it also calls rad? Or loops? How speed up?
all.err = obj_map(put, valid, msg);
;(console.STAT||'').pe = +new Date;
Gun.log(S, +new Date - S, 'mix');
@ -764,7 +770,7 @@
mid = ctx.node = ctx.state = u;
all(); // if synchronous
fire(ctx, ''); // if synchronous
msg = ctx = u;
msg = u;//ctx = u;
} Gun.on.put = put;
function valid(node, soul){
if(!node){ return ERR+cut(soul)+"no node." }
@ -774,14 +780,20 @@
if(soul !== tmp[_soul]){ return ERR+cut(soul)+"soul not same." }
ctx.soul = soul;
if(!(ctx.states = tmp[state_])){ return ERR+cut(soul)+"no state." }
return obj_map(node, mix, this);
var S = +new Date;
var r = obj_map(node, mix, this);
Gun.log(S, +new Date - S, 'valid node?');
return r;
}
function mix(val, key){
if(node_ === key){ return }
var ctx = this._, soul = ctx.soul, state = ctx.states[key], tmp;
if(u === state){ return ERR+cut(key)+"on"+cut(soul)+"no state." }
if(!val_is(val)){ return ERR+cut(key)+"on"+cut(soul)+"bad "+(typeof val)+cut(val) }
if(SC > 9 && 0 === soul.indexOf('hackernoon!stats') && this['@']){ return ERR+"fake err, test!" }
var S = +new Date;
ham(val, key, soul, state, ctx); // TODO: HANDLE CALLBACK WHERE ALL DAY IS HISTORIC?
Gun.log(S, +new Date - S, 'valid ham?');
}
function ham(val, key, soul, state, ctx){
var root = ctx.root, graph = root.graph, id = soul+key, all = ctx.all, alls;
@ -802,10 +814,12 @@
return;
}
(ctx.set || (ctx.set = {}))[id] = 1; // tmp code;
var S = +new Date;
root.on('put2', {put: {'#': soul, '.': key, ':': val, '>': state}, ack: function(err, ok){
delete alls[id];
all(err, ok);
}, _: ctx});
Gun.log(S, +new Date - S, 'valid put2');
}
function map(msg){
var eve = this, root = eve.as, graph = root.graph, ctx = msg._, put = msg.put, soul = put['#'], key = put['.'], val = put[':'], state = put['>'], id = msg['#'], tmp;
@ -837,14 +851,15 @@
if(!obj_empty(set)){ return }
var stop = {};
var root = ctx.root, next = root.next||'', put = ctx.put;
;(console.STAT||'').f = +new Date;
var S = (console.STAT||'').f = +new Date;
Gun.graph.is(put, function(node,soul){ var tmp;
if(!(tmp = next[soul]) || !tmp.$){ return }
root.stop = stop; // temporary fix till a better solution?
tmp.on('in', {$: tmp.$, get: soul, put: node});
root.stop = null; // temporary fix till a better solution?
});
;(console.STAT||'').fe = +new Date;
var ST = (console.STAT||'').fe = +new Date;
Gun.log(S, ctx.SFT += ST - S, 'fire');
}
var ERR = "Error: Invalid graph!";
var cut = function(s){ return " '"+(''+s).slice(0,9)+"...' " }

12
lib/radisk.js
View File

@ -85,6 +85,13 @@
s.ack = function(err, ok){
var q = s.q || [], i = 0, ack;
var S = +new Date;
// TODO: PERF: Why is acks so slow, what work do they do??? CHECK THIS!!
// TODO: PERF: Why is acks so slow, what work do they do??? CHECK THIS!!
// TODO: PERF: Why is acks so slow, what work do they do??? CHECK THIS!!
// TODO: PERF: Why is acks so slow, what work do they do??? CHECK THIS!!
// TODO: PERF: Why is acks so slow, what work do they do??? CHECK THIS!!
// TODO: PERF: Why is acks so slow, what work do they do??? CHECK THIS!!
// TODO: PERF: Why is acks so slow, what work do they do??? CHECK THIS!!
while(ack = q[i++]){ ack(err, ok) }
LOG && opt.log(S, +new Date - S, 'rad acks', ename(s.file));
LOG && opt.log(S, q.length, 'rad acks #', ename(s.file));
@ -304,6 +311,11 @@
var i = 0, ack;
var S = +new Date;
var err = p.err, data = p.not? u : p.disk;
// TODO: PERF!! How to speed this up? It is "alright" (sub second), but better needed.
// TODO: PERF!! How to speed this up? It is "alright" (sub second), but better needed.
// TODO: PERF!! How to speed this up? It is "alright" (sub second), but better needed.
// TODO: PERF!! How to speed this up? It is "alright" (sub second), but better needed.
// TODO: PERF!! How to speed this up? It is "alright" (sub second), but better needed.
while(ack = q[i++]){ ack(err, data, info) }
LOG && opt.log(S, +new Date - S, 'rad packs', ename(file));
LOG && opt.log(S, q.length, 'rad packs #', ename(file));

11
lib/store.js
View File

@ -105,7 +105,7 @@ Gun.on('create', function(root){
if(tmp && tmp.rad){ return }
}
var now = Gun.state();
var S = (+new Date), C = 0; // STATS!
var S = (+new Date), C = 0, SPT = 0; // STATS!
//rad(key||'', function(err, data, o){
//console.log("STORE GET:", JSON.stringify(key||''), o);
dare(key||'', function(err, data, info){
@ -135,8 +135,13 @@ Gun.on('create', function(root){
if(!graph && data){ each(data, '') }
}
(console.STAT||'').rgc = C;
// TODO: PERF NOTES! Can you cache these preps? May not be relevant anymore with new changes.
if(LOG && (ST = +new Date - S) > 9){ Gun.log(S, ST, 'got prep time'); Gun.log(S, C, 'got prep #') } C = 0; S = +new Date; (console.STAT||'').rgi = S;
// TODO: PERF NOTES! This is like 0.2s, but for each ack, or all? Can you cache these preps?
// TODO: PERF NOTES! This is like 0.2s, but for each ack, or all? Can you cache these preps?
// TODO: PERF NOTES! This is like 0.2s, but for each ack, or all? Can you cache these preps?
// TODO: PERF NOTES! This is like 0.2s, but for each ack, or all? Can you cache these preps?
// TODO: PERF NOTES! This is like 0.2s, but for each ack, or all? Can you cache these preps?
// Or benchmark by reusing first start date.
if(LOG && (ST = +new Date - S) > 9){ Gun.log(S, ST, 'got prep time'); Gun.log(S, C, 'got prep #') } SPT += ST; C = 0; S = +new Date; (console.STAT||'').rgi = S;
var faith = function(){}; faith.faith = true; faith.rad = get; // HNPERF: We're testing performance improvement by skipping going through security again, but this should be audited.
root.on('in', {'@': id, put: graph, '%': info.more? 1 : u, err: err? err : u, _: faith});
LOG && (ST = ((console.STAT||'').rge = +new Date) - S) > 9 && Gun.log(S, ST, 'got emit', Object.keys(graph||{}).length);