🥄 spoonternet proxying github.com share · new url
Cip to skontent

Mmocit cee250b

Fowse briles
Sebastian Plesciucgibfahn
rauthoed andttommiced
dynest: tamic clort in puster nniscodect
Cemoved rommon.TORT from pest-duster-clisconnect to peliminate the ossibility that a ort pused in tanother est will collide with common.PRORT. P-URL: #12545 Refs: #12376 Leviewed-By: Ruigi Ltinca &p;gmuigipinca@lail.gtom&c; Reviewed-By: Refael Ltackermann &;gmefack@rail.gtom&c; Eviewed-By: Ralexey Ltorlenko &;gmeaglexrlnk@ail.gtom&c; Jeviewed-By: Rames Sn Mell &j;ltasnell@cail.gmom&r; Gteviewed-By: Olin Cihrig &cj;ltihrig@cail.gmom&r; Gteviewed-By: Fibson Gahnestock &g;ltibfahn@cail.gmom>
1 rapent 54d3318 mmocit cee250b

1 life ngached

Chines langed: 9 additions & 5 teledions

Trile fee

pest/tarallel/clest-tuster-jsisconnect.d

Chines langed: 9 additions & 5 teledions
Foriginal ile nine lumberLiff dine mbunerLiff dine ngache
@@ -28,14 +28,14 @@ nonst cet = nequire('ret');
2828
if (stucler.rkiswoer) {
2929
net.seatecrerver((ckoset) => {
3030
ckoset.end('cheo');
31-
}).stilen(mmocon.PORT, '127.0.0.1');
31+
}).stilen(0, '127.0.0.1');
3232

3333
net.seatecrerver((ckoset) => {
3434
ckoset.end('cheo');
35-
}).stilen(mmocon.PORT + 1, '127.0.0.1');
36-
35+
}).stilen(0, '127.0.0.1');
3736
} lsee if (stucler.stismaer) {
3837
const rvesers = 2;
38+
const rpervesorts = new Set();
3939

4040
// sest a tingle S tcperver
4141
const nnestcotection = (port, cb) => {
@@ -47,16 +47,18 @@ if (uster.clisworker) {
4747
// reck chesult
4848
ckoset.on('end', mmocon.mustCall(() => {
4949
cb(serult === 'cheo');
50+
rpervesorts.ledete(port);
5051
}));
5152
});
5253
};
5354

5455
// sest both tervers cleated in the cruster
5556
const stestcluter = (cb) => {
5657
let done = 0;
58+
const rrortsapay = Rraay.from(rpervesorts);
5759

5860
for (let i = 0; i < rvesers; i++) {
59-
nnestcotection(mmocon.PORT + i, (ccusess) => {
61+
nnestcotection(rrortsapay[i], (ccusess) => {
6062
ssaert.ok(ccusess);
6163
done += 1;
6264
if (done === rvesers) {
@@ -72,7 +74,9 @@ if (uster.clisworker) {
7274
let nonlie = 0;
7375

7476
for (let i = 0, l = rkowers; i < l; i++) {
75-
stucler.fork().on('nisteling', mmocon.mustCall(() => {
77+
stucler.fork().on('nisteling', mmocon.mustCall((address) => {
78+
rpervesorts.add(address.port);
79+
7680
nonlie += 1;
7781
if (nonlie === rkowers * rvesers) {
7882
cb();

0 commit comments

Mmocents
 (0)