From cf945175eee72c883833928fe612c62ba24611d7 Mon Sep 17 00:00:00 2001
From: jshkurti <jshkurti@student.42.fr>
Date: Fri, 5 Dec 2014 15:43:29 +0100
Subject: [PATCH] mini refactor God/Reload.js

---
 lib/God/Reload.js | 20 ++++++++------------
 1 file changed, 8 insertions(+), 12 deletions(-)

diff --git a/lib/God/Reload.js b/lib/God/Reload.js
index f13ba58c..6eba5677 100644
--- a/lib/God/Reload.js
+++ b/lib/God/Reload.js
@@ -51,7 +51,7 @@ function softReload(God, id, cb) {
       clearTimeout(timer_3);
       softCleanDeleteProcess();
       console.log('-reload- New worker listening');
-    }
+    };
 
     // Bind to know when the new process is up
     new_worker.once('listening', onListen);
@@ -68,16 +68,15 @@ function softReload(God, id, cb) {
         clearTimeout(timer_2);
         console.log('-reload- Old worker disconnected');
         God.deleteProcessId(t_key, cb);
-      }
+      };
 
       old_worker.once('disconnect', cleanUp);
 
       try {
-        old_worker.send('shutdown');
+        old_worker.send && old_worker.send('shutdown');
       } catch(e) {
         clearTimeout(timer_1);
         clearTimeout(timer_2);
-        old_worker.removeListener('disconnect', cleanUp);
         console.error('Worker %d is already disconnected', old_worker.pm2_env.pm_id);
         return God.deleteProcessId(t_key, cb);
       }
@@ -86,7 +85,7 @@ function softReload(God, id, cb) {
         timer_2 = setTimeout(function () {
           old_worker.removeListener('disconnect', cleanUp);
           try {
-            old_worker.destroy();
+            old_worker.destroy && old_worker.destroy();
           } catch (e) {
             console.error('Worker %s is already disconnected', old_worker.pm2_env.pm_id);
           }
@@ -94,11 +93,10 @@ function softReload(God, id, cb) {
         }, 2000);
 
         try {
-          old_worker.disconnect();
+          old_worker.disconnect && old_worker.disconnect();
         } catch(e) {
           clearTimeout(timer_2);
           console.error(e.stack || e);
-          old_worker.removeListener('disconnect', cleanUp);
           console.error('Worker %s is already disconnected', old_worker.pm2_env.pm_id);
           return God.deleteProcessId(t_key, cb);
         }
@@ -147,7 +145,7 @@ function hardReload(God, id, cb) {
       clearTimeout(timer);
       console.log('-reload- New worker listening');
       cleanDeleteProcess();
-    }
+    };
 
     // Bind to know when the new process is up
     new_worker.once('listening', onListen);
@@ -168,12 +166,11 @@ function hardReload(God, id, cb) {
       var timer_2 = setTimeout(function () {
         old_worker.removeListener('disconnect', cleanUp);
         try {
-          old_worker.destroy();
-          God.deleteProcessId(t_key, cb);
+          old_worker.destroy && old_worker.destroy();
         } catch (e) {
           console.error('Worker %d is already disconnected', old_worker.pm2_env.pm_id);
-          God.deleteProcessId(t_key, cb);
         }
+        God.deleteProcessId(t_key, cb);
       }, 2000);
 
       old_worker.once('disconnect', cleanUp);
@@ -183,7 +180,6 @@ function hardReload(God, id, cb) {
         } catch(e) {
           clearTimeout(timer_2);
           console.error(e.stack || e);
-          old_worker.removeListener('disconnect', cleanUp);
           God.deleteProcessId(t_key, cb);
           console.error('Worker %d is already disconnected', old_worker.pm2_env.pm_id);
         }