Adapt log in Dispatcher.

Fixing installer to manually update the time.
This commit is contained in:
Martin Karkowski 2021-07-29 13:22:33 +02:00
parent cc688561fa
commit 28291e3b8e
3 changed files with 21 additions and 6 deletions

View File

@ -3,6 +3,10 @@ cd "%DIR%"
if not "%1"=="am_admin" (powershell start -verb runas '%0' am_admin & exit /b) if not "%1"=="am_admin" (powershell start -verb runas '%0' am_admin & exit /b)
@REM Update the Time
w32tm /config /manualpeerlist:DC_HostName.DomainName.com /syncfromflags:manual /reliable:yes /update
gpupdate /force
@echo off @echo off
git stash git stash
git checkout dev git checkout dev

View File

@ -235,7 +235,7 @@ export class nopeDispatcher implements INopeDispatcher {
this.externalDispatchers.setContent([]); this.externalDispatchers.setContent([]);
if (this._logger) { if (this._logger) {
this._logger.info("Dispatcher online. -> Reseting and Initializing"); this._logger.info("Dispatcher online. -> Reseting and Initializing: ", this.id);
} }
this.reset(); this.reset();
@ -1053,7 +1053,8 @@ export class nopeDispatcher implements INopeDispatcher {
this._mappingOfRemoteDispatchersAndServices.delete(dispatcher); this._mappingOfRemoteDispatchersAndServices.delete(dispatcher);
this._mappingOfRemoteDispatchersAndPropsOrEvents.delete(dispatcher); this._mappingOfRemoteDispatchersAndPropsOrEvents.delete(dispatcher);
this._mappingOfRemoteDispatchersAndInstances.delete(dispatcher); this._mappingOfRemoteDispatchersAndInstances.delete(dispatcher);
this._externalDispatchers.delete(dispatcher); const dispatcherInfo = this._externalDispatchers.get(dispatcher);
const deleted = this._externalDispatchers.delete(dispatcher);
// Iterate over the available instances and remove the providers: // Iterate over the available instances and remove the providers:
for (const instance of this._instances.values()) { for (const instance of this._instances.values()) {
@ -1095,9 +1096,9 @@ export class nopeDispatcher implements INopeDispatcher {
); );
} }
if (this._logger?.enabledFor(Logger.DEBUG)) { if (deleted && this._logger?.enabledFor(Logger.WARN)) {
// If there is a Logger: // If there is a Logger:
this._logger.debug("a dispatcher went offline"); this._logger.warn("a dispatcher on", dispatcherInfo?.host.name || "unkown", "went offline. ID of the Dispatcher: ", dispatcher);
} }
} }

View File

@ -13,6 +13,7 @@ import { getLayer } from "../../../lib/communication/getLayer";
import { getDispatcher } from "../../../lib/dispatcher/getDispatcher"; import { getDispatcher } from "../../../lib/dispatcher/getDispatcher";
import { nopeDispatcherManager } from "../../../lib/dispatcher/nopeDispatcherManager"; import { nopeDispatcherManager } from "../../../lib/dispatcher/nopeDispatcherManager";
import { getNopeLogger } from "../../../lib/logger/getLogger"; import { getNopeLogger } from "../../../lib/logger/getLogger";
import { LoggerLevels } from "../../../lib/logger/nopeLogger";
import { ICommunicationBridge } from "../../../lib/types/nope/nopeCommunication.interface"; import { ICommunicationBridge } from "../../../lib/types/nope/nopeCommunication.interface";
import { INopeObserver } from "../../../lib/types/nope/nopeObservable.interface"; import { INopeObserver } from "../../../lib/types/nope/nopeObservable.interface";
@ -78,6 +79,15 @@ export async function interact(
dest: "port" dest: "port"
}); });
parser.addArgument(["-l", "--log"], {
help:
"Specify the Logger Level. Defaults to \"info\". Valid values are: " +
LoggerLevels.join(", "),
defaultValue: "info",
type: "string",
dest: "log"
});
const args = parser.parseArgs(); const args = parser.parseArgs();
// Define a Logger // Define a Logger
@ -93,9 +103,9 @@ export async function interact(
communicator: getLayer( communicator: getLayer(
"io-client", "io-client",
"http://" + args.uri + ":" + args.port.toString(), "http://" + args.uri + ":" + args.port.toString(),
"info" args.log
) as ICommunicationBridge, ) as ICommunicationBridge,
logger: getNopeLogger("dispatcher", "info") logger: getNopeLogger("dispatcher", args.log)
}, },
nopeDispatcherManager nopeDispatcherManager
) as nopeDispatcherManager; ) as nopeDispatcherManager;