Added workerPidfile() to bin/connect

TooTallNate · Jun 16, 2010 · 26662c6 · 26662c6
1 parent 7a32df5
commit 26662c6
Showing 1 changed file with 14 additions and 6 deletions.
diff --git a/bin/connect b/bin/connect
@@ -191,8 +191,7 @@ function status(pid) {
     } else {
         status(getpid(env.pidfile));
         for (var i = 0; i < workers; ++i) {
-            var pidfile = env.pidfile.replace('.pid', '.worker.' + i + '.pid');
-            status(getpid(pidfile));
+            status(getpid(workerPidfile(i)));
         }
     }
 }
@@ -216,8 +215,7 @@ function stop(pid){
     } else {
         stop(getpid(env.pidfile));
         for (var i = 0; i < workers; ++i) {
-            var pidfile = env.pidfile.replace('.pid', '.worker.' + i + '.pid');
-            stop(getpid(pidfile));
+            stop(getpid(workerPidfile(i)));
         }
     }
 }
@@ -237,6 +235,17 @@ function exists(path) {
     }
 }
 
+/**
+ * Return worker pidfile for the given index.
+ *
+ * @param {Number} i
+ * @return {String}
+ */
+
+function workerPidfile(i){
+    return env.pidfile.replace('.pid', '.worker.' + i + '.pid');    
+}
+
 /**
  * Require application module at the given path,
  * which must be an instanceof net.Server, otherwise
@@ -358,8 +367,7 @@ function start() {
             }
 
             // Write out worker pids
-            var pidfile = env.pidfile.replace('.pid', '.worker.' + i + '.pid');
-            fs.writeFileSync(pidfile, child.pid.toString(), 'ascii');
+            fs.writeFileSync(workerPidfile(i), child.pid.toString(), 'ascii');
 
             child.stdin.write(JSON.stringify(env), 'ascii', fd);