LumeWeb
/
kernel-protomux
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

*_mux doesnt exist in Protomux

This commit is contained in:
Derrick Hammer 2023-04-06 17:22:18 -04:00
parent 2b645af1e9
commit ab4632b644
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
index.js
View File

@ -605,14 +605,14 @@ module.exports = class Protomux {
const info = this._get(protocol, id); const info = this._get(protocol, id);
if (this._slave) { if (this._slave) {
await this._mux.pullRemote(); await this.pullRemote();
} }
// allow the remote to grow the ids by one // allow the remote to grow the ids by one
if (this._remote.length === rid) { if (this._remote.length === rid) {
this._remote.push(null); this._remote.push(null);
if (this._slave) { if (this._slave) {
await this._mux.pushRemote(this._remote.length - 1); await this.pushRemote(this._remote.length - 1);
} }
} }
@ -626,12 +626,12 @@ module.exports = class Protomux {
if (session === null) { if (session === null) {
if (this._slave) { if (this._slave) {
await this._mux.pullFree(); await this.pullFree();
} }
// we already closed the channel - ignore // we already closed the channel - ignore
this._free.push(localId - 1); this._free.push(localId - 1);
if (this._slave) { if (this._slave) {
await this._mux.pushFree(localId - 1); await this.pushFree(localId - 1);
} }
return; return;
} }
@ -658,7 +658,7 @@ module.exports = class Protomux {
info.incoming.push(remoteId); info.incoming.push(remoteId);
if (this._slave) { if (this._slave) {
await this._mux.pushRemotes(); await this.pushRemotes();
} }
this._requestSession(protocol, id, info).catch(this._safeDestroyBound); this._requestSession(protocol, id, info).catch(this._safeDestroyBound);
@ -677,12 +677,12 @@ module.exports = class Protomux {
const session = this._local[localId - 1]; const session = this._local[localId - 1];
if (this._slave) { if (this._slave) {
await this._mux.pullFree(localId - 1); await this.pullFree(localId - 1);
} }
this._free.push(localId - 1); this._free.push(localId - 1);
if (this._slave) { if (this._slave) {
await this._mux.pushFree(localId - 1); await this.pushFree(localId - 1);
} }
if (session !== null) session._close(true); if (session !== null) session._close(true);