whatap - npm Package Compare versions

Comparing version 0.4.45 to 0.4.46

lib/core/agent.js

@@ -234,3 +234,7 @@ /**
 };
-
+const sleep = async(ms) => {
+    return new Promise(resolve=>{
+        setTimeout(resolve,ms)
+    })
+}
 NodeAgent.prototype.loadObserves = function() {
@@ -241,5 +245,2 @@ var agent = this;
     observes.push(HttpObserver);
-    if(agent._conf['trace_node_schedule_enabled']) {
-        observes.push(ScheduleObserver);
-    }
     observes.push(NetObserver);
@@ -258,3 +259,4 @@ observes.push(ClusterObserver);
     observes.push(PgSqlObserver);
-    
+    observes.push(ScheduleObserver);
+     
     var packageToObserve = {};
@@ -261,0 +263,0 @@ observes.forEach(function(observeObj) {

lib/observers/schedule-observer.js

@@ -37,3 +37,6 @@ /**
         ret.job = async () => {
-            var ctx = TraceContextManager.startTrace('ScheduleJob');
+            var ctx = null;
+            if(conf['trace_node_schedule_enabled']) {
+                ctx = TraceContextManager.startTrace('ScheduleJob');
+            }
             var result = null;
@@ -45,13 +48,15 @@ try {
             }
-            try {
-                var step = new MessageStep();
-                step.msg = 'Node ScheduleJob finished!!!!!'
-                step.hash =  HashUtil.hashFromString(step.msg);;
-                step.start_time = ctx.getElapsedTime();
-                step.desc = '';
-                DataTextAgent.MESSAGE.add(step.hash, step.msg);
-                ctx.profile.add(step);
-                TraceContextManager.endTrace(ctx);
-                if(ctx != null) ctx = null;
-            } catch(err) {}
+            if(conf['trace_node_schedule_enabled'] && ctx != null) {
+                try {
+                    var step = new MessageStep();
+                    step.msg = 'Node ScheduleJob finished!!!!!'
+                    step.hash =  HashUtil.hashFromString(step.msg);;
+                    step.start_time = ctx.getElapsedTime();
+                    step.desc = '';
+                    DataTextAgent.MESSAGE.add(step.hash, step.msg);
+                    ctx.profile.add(step);
+                    TraceContextManager.endTrace(ctx);
+                    if(ctx != null) ctx = null;
+                } catch(err) {}
+             }
             return result;
@@ -58,0 +63,0 @@ };

package.json

 {
   "name": "whatap",
   "homepage": "http://www.whatap.io",
-  "version": "0.4.45",
-  "releaseDate": "20220517",
+  "version": "0.4.46",
+  "releaseDate": "20220523",
   "description": "Monitoring and Profiling Service",
@@ -7,0 +7,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

910448

increased by0.03%

Lines of code

19160

increased by0.04%

No dependency changes