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) {