Skip to content

Commit c43cf19

Browse files
committed
debug added
1 parent b4e65e8 commit c43cf19

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

services/servicebus/service.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -293,6 +293,7 @@ async def unregister_remote_node(self, node: Node):
293293

294294
def register_server(self, data: dict) -> bool:
295295
server_name = data['server_name']
296+
296297
# check for protocol incompatibilities
297298
if data['hook_version'] != self.version:
298299
self.log.error(f'Server "{server_name}" has wrong Hook version installed. '
@@ -303,11 +304,16 @@ def register_server(self, data: dict) -> bool:
303304
return False
304305
self.log.debug(f' => Registering DCS-Server "{server_name}"')
305306
server: ServerImpl = cast(ServerImpl, self.servers[server_name])
307+
306308
# set the PID
307309
if not server.process:
310+
self.log.debug(f' => No process of {server_name} found. Searching ...')
308311
server.process = next(utils.find_process("DCS_server.exe|DCS.exe", server.instance.name), None)
309312
if not server.process:
310313
self.log.warning("Could not find active DCS process. Please check, if you have started DCS with -w!")
314+
else:
315+
self.log.debug(f' => Process of {server_name} found.')
316+
311317
# if we are an agent, initialize the server
312318
if not self.master:
313319
if 'current_mission' in data:
@@ -339,12 +345,14 @@ def register_server(self, data: dict) -> bool:
339345
return False
340346
else:
341347
webgui_ports[webgui_port] = s.name
348+
342349
# check for DSMC
343350
if server.status == Status.RUNNING and data.get('dsmc_enabled', False) and 'DSMC' not in server.extensions:
344351
self.log.warning(" => DSMC is enabled for this server but DSMC extension is not loaded!")
345352
self.log.warning(" You need to configure DSMC on your own to prevent issues with the mission list.")
346353

347354
# update the database and check for server name changes
355+
self.log.debug(f' => Checking the database for server {server_name} ...')
348356
with self.pool.connection() as conn:
349357
with closing(conn.cursor()) as cursor:
350358
cursor.execute(
@@ -361,6 +369,7 @@ def register_server(self, data: dict) -> bool:
361369
self.log.warning(f'Registration of server "{server_name}" aborted due to conflict.')
362370
self.servers.pop(server_name, None)
363371
return False
372+
self.log.debug(f' => Database for server {server_name} checked.')
364373
return True
365374

366375
def rename_server(self, server: Server, new_name: str):

0 commit comments

Comments
 (0)