Add logging

Koenkk · Nov 29, 2024 · 643a52e · 643a52e
1 parent 3f0b2c4
commit 643a52e
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/src/adapter/z-stack/adapter/zStackAdapter.ts b/src/adapter/z-stack/adapter/zStackAdapter.ts
@@ -417,6 +417,7 @@ class ZStackAdapter extends Adapter {
         disableRecovery: boolean,
         sourceEndpoint?: number,
     ): Promise<Events.ZclPayload | void> {
+        logger.debug(`== sendZclFrameToEndpoint add to queue - ${ieeeAddr}/${networkAddress}`, NS);
         return await this.queue.execute<Events.ZclPayload | void>(async () => {
             this.checkInterpanLock();
             return await this.sendZclFrameToEndpointInternal(

diff --git a/src/utils/queue.ts b/src/utils/queue.ts
@@ -1,9 +1,13 @@
+import {logger} from './logger';
+
 interface Job {
     key?: string | number;
     running: boolean;
     start?: () => void;
 }
 
+const NS = 'zh:queue';
+
 class Queue {
     private jobs: Job[];
     private readonly concurrent: number;
@@ -14,6 +18,7 @@ class Queue {
     }
 
     public async execute<T>(func: () => Promise<T>, key?: string | number): Promise<T> {
+        logger.debug(`== queue add - ${key} (keys=${this.jobs.map((j) => j.key)})`, NS);
         const job: Job = {key, running: false};
         this.jobs.push(job);
 
@@ -33,9 +38,11 @@ class Queue {
         }
 
         try {
+            logger.debug(`== queue execute func - ${key} (keys=${this.jobs.map((j) => j.key)})`, NS);
             return await func();
         } finally {
             this.jobs.splice(this.jobs.indexOf(job), 1);
+            logger.debug(`== queue remove - ${key}  (keys=${this.jobs.map((j) => j.key)})`, NS);
             this.executeNext();
         }
     }