test completely blocked thread

Author: timfish

test/e2e.test.mjs

@@ -151,6 +151,42 @@ describe('e2e Tests', { timeout }, () => {
     }));
   });
 
+  test('detect completely blocked thread', async () => {
+    const result = await runTest(__dirname, 'stalled-forever.js');
+
+    expect(result.status).toEqual(0);
+
+    expect(result.trace).toEqual(expect.objectContaining({
+      '0': {
+        frames: expect.any(Array),
+        pollState: { some_property: 'main_thread' }
+      },
+      '2': {
+        frames: expect.arrayContaining([
+          {
+            function: 'pbkdf2Sync',
+            filename: expect.any(String),
+            lineno: expect.any(Number),
+            colno: expect.any(Number),
+          },
+          {
+            function: 'longWork',
+            filename: expect.stringMatching(/long-work.js$/),
+            lineno: expect.any(Number),
+            colno: expect.any(Number),
+          },
+          {
+            function: '?',
+            filename: expect.stringMatching(/worker-forever.js$/),
+            lineno: expect.any(Number),
+            colno: expect.any(Number),
+          },
+        ]),
+        pollState: { some_property: 'worker_thread' },
+      },
+    }));
+  });
+
   test('async storage state', async (ctx) => {
     if (NODE_MAJOR_VERSION < 22) {
       ctx.skip();

test/long-work.js

@@ -8,4 +8,11 @@ function longWork() {
   }
 }
 
-module.exports = { longWork };
+function foreverWork() {
+  // eslint-disable-next-line no-constant-condition
+  while (true) {
+    longWork();
+  }
+}
+
+module.exports = { longWork, foreverWork };

test/stalled-forever.js

@@ -0,0 +1,14 @@
+const { Worker } = require('node:worker_threads');
+const { registerThread, threadPoll } = require('@sentry-internal/node-native-stacktrace');
+
+registerThread();
+
+setInterval(() => {
+  threadPoll(true, { some_property: 'main_thread' });
+}, 200).unref();
+
+const watchdog = new Worker('./test/stalled-watchdog.js');
+watchdog.on('exit', () => process.exit(0));
+
+const worker = new Worker('./test/worker-forever.js');
+

test/worker-forever.js

@@ -0,0 +1,13 @@
+const { foreverWork } = require('./long-work');
+const { registerThread, threadPoll } = require('@sentry-internal/node-native-stacktrace');
+
+registerThread();
+
+setInterval(() => {
+  threadPoll(true, { some_property: 'worker_thread' });
+}, 200).unref();
+
+setTimeout(() => {
+  console.log('Starting forever work');
+  foreverWork();
+}, 1000);