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

AXE tweak

Browse Source
This commit is contained in:
Mark Nadal 2020-09-19 03:58:14 -07:00
parent 8a18a54d85
commit c1c80ff10f
2 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
axe.js
View File

@ -219,13 +219,16 @@
var routes = axe.routes || (axe.routes = {}); // USE RAD INSTEAD! TMP TESTING!
var peers = {};
Object.keys(msg.put).forEach(function(soul, node){ node = msg.put[soul];
setTimeout.each(Object.keys(msg.put), function(soul, node){ node = msg.put[soul];
var hash = soul; //Gun.obj.hash({'#': soul});
var to = routes[hash];
if(!to){ return }
Object.keys(to).forEach(function(k){ peers[k] = to[k] });
setTimeout.each(Object.keys(to), function(k){
mesh.say(msg, to[k]); //peers[k] = to[k]
});
});
console.STAT && (ST = +new Date - S) > 9 && console.STAT(S, ST, 'axe put');
mesh.say(msg, peers);
//mesh.say(msg, peers);
return;
}
mesh.say(msg, opt.peers); return; // TODO: DISABLE THIS!!! USE DHT!
@ -250,15 +253,17 @@
};
}
axe.up = {};
at.on('hi', function(peer){
var C = 0;
at.on('hi', function(peer){ C++;
this.to.next(peer);
if(!peer.url){ return }
axe.up[peer.id] = peer;
});
at.on('bye', function(peer){ this.to.next(peer);
at.on('bye', function(peer){ C--; this.to.next(peer);
if(peer.url){ delete axe.up[peer.id] }
var S = +new Date;
obj_map(peer.routes, function(route, hash){
setTimeout.each(Object.keys(peer.routes), function(hash, route){
route = peer.routes[hash];
delete route[peer.id];
if(Object.empty(route)){
delete axe.routes[hash];
@ -271,7 +276,7 @@
at.on('hi', function(peer){
this.to.next(peer);
if(peer.url){ return } // I am assuming that if we are wanting to make an outbound connection to them, that we don't ever want to drop them unless our actual config settings change.
var count = Object.keys(opt.peers).length;
var count = C;
if(opt.mob >= count){ return } // TODO: Make dynamic based on RAM/CPU also. Or possibly even weird stuff like opt.mob / axe.up length?
var peers = Object.keys(axe.up);
if(!peers.length){ return }

2
test/panic/user-paste.js
View File

@ -77,7 +77,7 @@ describe("Test vanishing property "+ config.browsers +" browser(s) across "+ con
var Gun = require(env.config.dir+'/../../');
// Attach the server to gun.
//var gun = Gun({file: env.i+'data', web: server});
console.log("UNDO THIS!!!!!!!!");var gun = Gun({file: env.i+'data', web: server, rad: false, axe: false, localStorage: false});
console.log("UNDO THIS!!!!!!!!");var gun = Gun({file: env.i+'data', web: server, rad: false, localStorage: false});
server.listen(env.config.port + env.i, function(){
// This server peer is now done with the test!
// It has successfully launched.