From c9594a7190b7830463ab9d60d9f4d479bcf8143a Mon Sep 17 00:00:00 2001
From: Yongseok <feelform@gmail.com>
Date: Fri, 13 Sep 2024 15:32:30 +0900
Subject: [PATCH] [#223] commonStreamResponse's sequenceid per requestid of
 Active Thread Count

---
 lib/client/grpc-data-sender.js    | 4 +++-
 lib/metric/active-thread-count.js | 1 -
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/lib/client/grpc-data-sender.js b/lib/client/grpc-data-sender.js
index abaab1a6..6c0e9c35 100644
--- 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
index 61f5e157..6b3c2883 100644
--- 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) {