michael/scrypted
1
0
Fork 0
mirror of https://github.com/koush/scrypted.git synced 2026-06-20 16:40:30 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

server: fix consoles in clustered environment

Browse Source
This commit is contained in:
Koushik Dutta
2024-11-12 20:35:51 -08:00
parent 12be06adad
commit f69b93c9fa
12 changed files with 51 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/python/plugin_remote.py
View File

@@ -593,8 +593,8 @@ class PluginRemote:
consoleFuture = Future()
self.consoles[nativeId] = consoleFuture
plugins = await self.api.getComponent("plugins")
port = await plugins.getRemoteServicePort(self.pluginId, "console-writer")
connection = await asyncio.open_connection(port=port)
port, hostname = await plugins.getRemoteServicePort(self.pluginId, "console-writer")
connection = await asyncio.open_connection(host=hostname, port=port)
_, writer = connection
if not nativeId:
nid = "undefined"
@@ -1119,7 +1119,7 @@ class PluginRemote:
raise Exception("REPL unavailable: Plugin not loaded.")
if self.replPort == 0:
raise Exception("REPL unavailable: Python REPL not available.")
return self.replPort
return [self.replPort, os.getenv("SCRYPTED_CLUSTER_ADDRESS", None)]
raise Exception(f"unknown service {name}")
async def start_stats_runner(self):