[pinpoint-apm#223] commonStreamResponse's sequenceid per requestid of…

… Active Thread Count
feelform · Sep 13, 2024 · c9594a7 · c9594a7
1 parent 0faf843
commit c9594a7
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/lib/client/grpc-data-sender.js b/lib/client/grpc-data-sender.js
@@ -149,6 +149,7 @@ class GrpcDataSender {
     this.commandStream = new GrpcReadableStream(() => {
       const writable = this.profilerClient.handleCommandV2()
 
+      let activeThreadCountSequenceId = 0
       writable.on('data', (cmdRequest) => {
         const requestId = cmdRequest.getRequestid()
         const command = cmdRequest.getCommandCase()
@@ -171,7 +172,8 @@ class GrpcDataSender {
           'ACTIVE_THREAD_COUNT': () => {
             const commonStreamResponse = new cmdMessages.PCmdStreamResponse()
             commonStreamResponse.setResponseid(requestId)
-            commonStreamResponse.setSequenceid(1)
+            activeThreadCountSequenceId++
+            commonStreamResponse.setSequenceid(activeThreadCountSequenceId)
             const stringValue = new wrappers.StringValue()
             stringValue.setValue('')
             commonStreamResponse.setMessage(stringValue)

diff --git a/lib/metric/active-thread-count.js b/lib/metric/active-thread-count.js
@@ -8,7 +8,6 @@
 
 const Scheduler = require('../utils/scheduler')
 const activeTrace = require('./active-trace')
-const log = require('../utils/logger')
 
 class ActiveThreadCount {
   constructor(dataSender, streamChannelManager, enabled) {