commit d15c0ce8ac10a903efc1379bf19cbe48641f331b
author renzheng.wang <wangrzneu@gmail.com> Wed Jul 06 08:22:11 2022 +0800
committer GitHub <noreply@github.com> Wed Jul 06 08:22:11 2022 +0800
tree 1163cf14315ecb2caa44cd3030288c281b609f62
parent 406d4420fa1c21cad2ba8e713488a1a00b99de0b

stop reporting traces after the worker process begins to exit (#105)

lib/skywalking/client.lua

diff --git a/lib/skywalking/client.lua b/lib/skywalking/client.lua
index 2dfd70a..881160d 100644
--- a/lib/skywalking/client.lua
+++ b/lib/skywalking/client.lua
@@ -204,9 +204,14 @@
         end
 
         segmentTransform = segmentTransform .. segment
-        segment = queue:rpop(Const.segment_queue)
         count = count + 1
 
+        if ngx.worker.exiting() then
+            break
+        end
+
+        segment = queue:rpop(Const.segment_queue)
+
         if count >= SEGMENT_BATCH_COUNT then
             if sendSegments('[' .. segmentTransform .. ']', backend_http_uri) then
                 totalCount = totalCount + count