From 47db002aaf5526d61fefae6f40d4699bb8cd4cd0 Mon Sep 17 00:00:00 2001 From: Ylian Saint-Hilaire Date: Wed, 7 Oct 2020 23:18:15 -0700 Subject: [PATCH] APF/MPS fix. --- apfserver.js | 6 ++++++ mpsserver.js | 2 +- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/apfserver.js b/apfserver.js index e6770922..f25268ab 100644 --- a/apfserver.js +++ b/apfserver.js @@ -641,6 +641,12 @@ module.exports.CreateApfServer = function (parent, db, args) { } } + obj.SetupCiraChannelToHost = function (host, targetport) { + var apfconn = obj.apfConnections[host]; + if (apfconn == null) return null; + return obj.SetupCiraChannel(apfconn, targetport); + } + obj.SetupCiraChannel = function (socket, targetport) { var sourceport = (socket.tag.nextsourceport++ % 30000) + 1024; var cirachannel = { targetport: targetport, channelid: socket.tag.nextchannelid++, socket: socket, state: 1, sendcredits: 0, amtpendingcredits: 0, amtCiraWindow: 0, ciraWindow: 32768 }; diff --git a/mpsserver.js b/mpsserver.js index 3fd399d5..3b81cbf5 100644 --- a/mpsserver.js +++ b/mpsserver.js @@ -867,7 +867,7 @@ module.exports.CreateMpsServer = function (parent, db, args, certificates) { } obj.SetupCiraChannelToHost = function (host, targetport) { - var ciraconn = obj.parent.mpsserver.ciraConnections[host]; + var ciraconn = obj.ciraConnections[host]; if (ciraconn == null) return null; return obj.SetupCiraChannel(ciraconn, targetport); }