diff --git a/gun.js b/gun.js index 0f34c49c..f5ee44f1 100644 --- a/gun.js +++ b/gun.js @@ -757,6 +757,7 @@ var set = ctx.set = {'':1}; ;(console.STAT||'').p = +new Date; all.err = obj_map(put, valid, msg); + Gun.log(S, +new Date - S, 'mix'); ;(console.STAT||'').pe = +new Date; mid = ctx.node = ctx.state = u; all(); // if synchronous diff --git a/lib/radisk.js b/lib/radisk.js index 3c3b724a..45a12576 100644 --- a/lib/radisk.js +++ b/lib/radisk.js @@ -271,7 +271,6 @@ p.read = function(err, data){ var tmp; LOG && opt.log(S, +new Date - S, 'read disk', JSON.stringify(file), ++RPC, 'total all parses.'); delete Q[file]; - LOG && opt.log(S, q.length, "read queue #"); if((p.err = err) || (p.not = !data)){ p.map(q, p.ack); return } if('string' !== typeof data){ try{ @@ -306,8 +305,8 @@ var S = +new Date; var err = p.err, data = p.not? u : p.disk; while(ack = q[i++]){ ack(err, data, info) } - LOG && opt.log(S, +new Date - S, 'rad packs', ename(s.file)); - LOG && opt.log(S, q.length, 'rad packs #', ename(s.file)); + LOG && opt.log(S, +new Date - S, 'rad packs', ename(file)); + LOG && opt.log(S, q.length, 'rad packs #', ename(file)); } p.ack = function(cb){ if(!cb){ return }