fixup: revert to previous workaround

nodejs · Dec 8, 2015 · 253fd62 · 253fd62
1 parent 4624147
commit 253fd62
Showing 1 changed file with 16 additions and 12 deletions.
diff --git a/test/parallel/test-cluster-shared-leak.js b/test/parallel/test-cluster-shared-leak.js
@@ -15,18 +15,22 @@ if (cluster.isMaster) {
   worker1 = cluster.fork();
   worker1.on('message', common.mustCall(function() {
     worker2 = cluster.fork();
-    // make sure worker2 is listening before doing anything else
-    cluster.once('listening', function() {
-      conn = net.connect(common.PORT, common.mustCall(function() {
-        worker1.send('die');
-        worker2.send('die');
-      }));
-      conn.on('error', function(e) {
-        // ECONNRESET is OK
-        if (e.code === 'ECONNRESET')
-          return;
-        throw e;
-      });
+    worker2.on('error', function(e) {
+      console.error('worker2 error');
+      // EPIPE is OK on Windows
+      if (common.isWindows && e.code === 'EPIPE')
+        return;
+      throw e;
+    });
+    conn = net.connect(common.PORT, common.mustCall(function() {
+      worker1.send('die');
+      worker2.send('die');
+    }));
+    conn.on('error', function(e) {
+      // ECONNRESET is OK
+      if (e.code === 'ECONNRESET')
+        return;
+      throw e;
     });
   }));