LumeWeb
/
libhyperproxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: LumeWeb:35bf05c25ec48099017a35b9c7953a8e38f6c24a
Branches Tags
LumeWeb:master
LumeWeb:develop
LumeWeb:v0.0.2-develop.4
LumeWeb:v0.0.2-develop.3
LumeWeb:v0.0.2-develop.2
LumeWeb:v0.0.2-develop.1
LumeWeb:v0.0.1
...
compare: LumeWeb:b3d6fd46683b01c1a7f10b60e48079e475c4257d
Branches Tags
LumeWeb:develop
LumeWeb:master
LumeWeb:v0.0.2-develop.4
LumeWeb:v0.0.2-develop.3
LumeWeb:v0.0.2-develop.2
LumeWeb:v0.0.2-develop.1
LumeWeb:v0.0.1

2 Commits
35bf05c25e ... b3d6fd4668

Author SHA1 Message Date
Derrick Hammer b3d6fd4668
*Update dist 2023-04-16 05:48:53 -04:00
Derrick Hammer b04db8668b
*Put _nextPeer into the constructor 2023-04-16 05:48:32 -04:00
2 changed files with 5 additions and 2 deletions
Show Stats Expand all files Collapse all files

3
dist/proxies/multiSocket.js vendored
View File

@ -68,7 +68,7 @@ class MultiSocketProxy extends proxy_js_1.default {
} }
socketClass; socketClass;
_peers = new Map(); _peers = new Map();
_nextPeer = (0, util_js_1.roundRobinFactory)(this._peers); _nextPeer;
_server = false; _server = false;
_allowedPorts = []; _allowedPorts = [];
constructor(options) { constructor(options) {
@ -87,6 +87,7 @@ class MultiSocketProxy extends proxy_js_1.default {
if (options.server) { if (options.server) {
this._server = true; this._server = true;
} }
this._nextPeer = (0, util_js_1.roundRobinFactory)(this._peers);
} }
_socketMap = new Map(); _socketMap = new Map();
get socketMap() { get socketMap() {

4
src/proxies/multiSocket.ts
View File

@ -89,9 +89,10 @@ export default class MultiSocketProxy extends Proxy {
await conn.init(); await conn.init();
this.emit("peer", conn); this.emit("peer", conn);
} }
private socketClass: any; private socketClass: any;
private _peers: Map<string, PeerEntity> = new Map<string, PeerEntity>(); private _peers: Map<string, PeerEntity> = new Map<string, PeerEntity>();
private _nextPeer = roundRobinFactory(this._peers); private _nextPeer;
private _server = false; private _server = false;
private _allowedPorts = []; private _allowedPorts = [];
@ -109,6 +110,7 @@ export default class MultiSocketProxy extends Proxy {
if (options.server) { if (options.server) {
this._server = true; this._server = true;
} }
this._nextPeer = roundRobinFactory(this._peers);
} }
private _socketMap = new Map<number, number>(); private _socketMap = new Map<number, number>();