nodejs
diff --git a/Collapse file
‎src/node_util.cc‎
Copy file name to clipboardExpand all lines: src/node_util.cc
+8Lines changed: 8 additions & 0 deletions b/Collapse file
‎src/node_util.cc‎
Copy file name to clipboardExpand all lines: src/node_util.cc
+8Lines changed: 8 additions & 0 deletions
diff --git a/Collapse file
‎src/node_watchdog.cc‎
Copy file name to clipboardExpand all lines: src/node_watchdog.cc
+7Lines changed: 7 additions & 0 deletions b/Collapse file
‎src/node_watchdog.cc‎
Copy file name to clipboardExpand all lines: src/node_watchdog.cc
+7Lines changed: 7 additions & 0 deletions
diff --git a/Collapse file
‎src/node_watchdog.h‎
Copy file name to clipboardExpand all lines: src/node_watchdog.h
+1Lines changed: 1 addition & 0 deletions b/Collapse file
‎src/node_watchdog.h‎
Copy file name to clipboardExpand all lines: src/node_watchdog.h
+1Lines changed: 1 addition & 0 deletions
diff --git a/Collapse file
‎test/parallel/test-util-sigint-watchdog.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-util-sigint-watchdog.js
+13-6Lines changed: 13 additions & 6 deletions b/Collapse file
‎test/parallel/test-util-sigint-watchdog.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-util-sigint-watchdog.js
+13-6Lines changed: 13 additions & 6 deletions
@@ -103,6 +103,13 @@ void StopSigintWatchdog(const FunctionCallbackInfo<Value>& args) {
   args.GetReturnValue().Set(had_pending_signals);
 }
 
+
+void WatchdogHasPendingSigint(const FunctionCallbackInfo<Value>& args) {
+  bool ret = SigintWatchdogHelper::GetInstance()->HasPendingSignal();
+  args.GetReturnValue().Set(ret);
+}
+
+
 void Initialize(Local<Object> target,
                 Local<Value> unused,
                 Local<Context> context) {
@@ -118,6 +125,7 @@ void Initialize(Local<Object> target,
 
   env->SetMethod(target, "startSigintWatchdog", StartSigintWatchdog);
   env->SetMethod(target, "stopSigintWatchdog", StopSigintWatchdog);
+  env->SetMethod(target, "watchdogHasPendingSigint", WatchdogHasPendingSigint);
 }
 
 }  // namespace util
 
@@ -258,6 +258,13 @@ bool SigintWatchdogHelper::Stop() {
 }
 
 
+bool SigintWatchdogHelper::HasPendingSignal() {
+  Mutex::ScopedLock lock(list_mutex_);
+
+  return has_pending_signal_;
+}
+
+
 void SigintWatchdogHelper::Register(SigintWatchdog* wd) {
   Mutex::ScopedLock lock(list_mutex_);
 
 
@@ -63,6 +63,7 @@ class SigintWatchdogHelper {
   static SigintWatchdogHelper* GetInstance() { return &instance; }
   void Register(SigintWatchdog* watchdog);
   void Unregister(SigintWatchdog* watchdog);
+  bool HasPendingSignal();
 
   int Start();
   bool Stop();
 
@@ -20,34 +20,41 @@ if (common.isWindows) {
   // Test with one call to the watchdog, one signal.
   binding.startSigintWatchdog();
   process.kill(process.pid, 'SIGINT');
-  setTimeout(common.mustCall(() => {
+  waitForPendingSignal(common.mustCall(() => {
     const hadPendingSignals = binding.stopSigintWatchdog();
     assert.strictEqual(hadPendingSignals, true);
     next();
-  }), common.platformTimeout(100));
+  }));
 },
 (next) => {
   // Nested calls are okay.
   binding.startSigintWatchdog();
   binding.startSigintWatchdog();
   process.kill(process.pid, 'SIGINT');
-  setTimeout(common.mustCall(() => {
+  waitForPendingSignal(common.mustCall(() => {
     const hadPendingSignals1 = binding.stopSigintWatchdog();
     const hadPendingSignals2 = binding.stopSigintWatchdog();
     assert.strictEqual(hadPendingSignals1, true);
     assert.strictEqual(hadPendingSignals2, false);
     next();
-  }), common.platformTimeout(100));
+  }));
 },
 () => {
   // Signal comes in after first call to stop.
   binding.startSigintWatchdog();
   binding.startSigintWatchdog();
   const hadPendingSignals1 = binding.stopSigintWatchdog();
   process.kill(process.pid, 'SIGINT');
-  setTimeout(common.mustCall(() => {
+  waitForPendingSignal(common.mustCall(() => {
     const hadPendingSignals2 = binding.stopSigintWatchdog();
     assert.strictEqual(hadPendingSignals1, false);
     assert.strictEqual(hadPendingSignals2, true);
-  }), common.platformTimeout(100));
+  }));
 }].reduceRight((a, b) => common.mustCall(b).bind(null, a))();
+
+function waitForPendingSignal(cb) {
+  if (binding.watchdogHasPendingSigint())
+    cb();
+  else
+    setTimeout(waitForPendingSignal, 10, cb);
+}