From c0e119807233def885e62617caeb37f635224d84 Mon Sep 17 00:00:00 2001 From: cviolbarbosa Date: Mon, 18 Mar 2024 10:30:24 +0100 Subject: [PATCH] reduce max time without updates before the agent is marked offline --- helyos_server/src/initialization.js | 4 ++-- .../src/modules/communication/agent_communication.js | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/helyos_server/src/initialization.js b/helyos_server/src/initialization.js index 4d145187..64fb3b03 100644 --- a/helyos_server/src/initialization.js +++ b/helyos_server/src/initialization.js @@ -7,7 +7,7 @@ const microserviceWatcher = require('./event_handlers/microservice_event_watcher const fs = require('fs'); const readYML = require('./modules/read_config_yml.js'); -const MAX_TIME_WITHOUT_UPDATE = 20; +const AGENT_IDLE_TIME_OFFLINE = process.env.AGENT_IDLE_TIME_OFFLINE || 10; const CREATE_RBMQ_ACCOUNTS = process.env.CREATE_RBMQ_ACCOUNTS || "True"; const { AGENTS_UL_EXCHANGE, AGENTS_DL_EXCHANGE, ANONYMOUS_EXCHANGE, AGENT_MQTT_EXCHANGE } = require('./services/message_broker/rabbitMQ_services.js'); const { CHECK_IN_QUEUE, AGENT_MISSION_QUEUE,AGENT_VISUALIZATION_QUEUE, AGENT_UPDATE_QUEUE, @@ -25,7 +25,7 @@ HELYOS_REPLICA = HELYOS_REPLICA === 'True'; const initWatchers = () => { - agentComm.watchWhoIsOnline(MAX_TIME_WITHOUT_UPDATE); + agentComm.watchWhoIsOnline(AGENT_IDLE_TIME_OFFLINE); microserviceWatcher.initWatcher(); }; diff --git a/helyos_server/src/modules/communication/agent_communication.js b/helyos_server/src/modules/communication/agent_communication.js index d7b41128..780cc747 100644 --- a/helyos_server/src/modules/communication/agent_communication.js +++ b/helyos_server/src/modules/communication/agent_communication.js @@ -6,7 +6,7 @@ var databaseServices = require('../../services/database/database_services.js'); const { saveLogData } = require('../systemlog.js'); const MESSAGE_VERSION = rabbitMQServices.MESSAGE_VERSION const BACKWARD_COMPATIBILITY = (process.env.BACKWARD_COMPATIBILITY || 'false') === 'true'; -const REFRESH_ONLNE_TIME_PERIOD = 10; +const REFRESH_ONLNE_TIME_PERIOD = 5; let POSITION_MARGIN; if (process.env.POSITION_MARGIN)