Exit the process only when there are no other listeners

Author: seratch

packages/agents-core/src/tracing/provider.ts

@@ -188,16 +188,28 @@ export class TraceProvider {
       // Handle CTRL+C (SIGINT)
       process.on('SIGINT', async () => {
         await cleanup();
+        if (!hasOtherListenersForSignals('SIGINT')) {
+          // Only when there are no other listeners, exit the process on this SDK side
+          process.exit(130);
+        }
       });
 
       // Handle termination (SIGTERM)
       process.on('SIGTERM', async () => {
         await cleanup();
+        if (!hasOtherListenersForSignals('SIGTERM')) {
+          // Only when there are no other listeners, exit the process on this SDK side
+          process.exit(0);
+        }
       });
 
       process.on('unhandledRejection', async (reason, promise) => {
         logger.error('Unhandled rejection', reason, promise);
         await cleanup();
+        if (!hasOtherListenersForEvents('unhandledRejection')) {
+          // Only when there are no other listeners, exit the process on this SDK side
+          process.exit(1);
+        }
       });
     }
   }
@@ -207,6 +219,14 @@ export class TraceProvider {
   }
 }
 
+function hasOtherListenersForSignals(event: 'SIGINT' | 'SIGTERM'): boolean {
+  return process.listeners(event).length > 1;
+}
+
+function hasOtherListenersForEvents(event: 'unhandledRejection'): boolean {
+  return process.listeners(event).length > 1;
+}
+
 let GLOBAL_TRACE_PROVIDER: TraceProvider | undefined = undefined;
 export function getGlobalTraceProvider(): TraceProvider {
   if (!GLOBAL_TRACE_PROVIDER) {