Only kill the workers running on the current machine (branch 1.1.8)

Command/StopWorkerCommand.php

@@ -26,7 +26,10 @@ protected function execute(InputInterface $input, OutputInterface $output)
         $resque = $this->getContainer()->get('bcc_resque.resque');
 
         if ($input->getOption('all')) {
-            $workers = $resque->getWorkers();
+            $workers = $resque->getWorkers(true);
+            if (empty($workers)) {
+                $output->writeln('<comment>You don\'t have any workers on this machine.</comment>');
+            }
         } else {
             $worker = $resque->getWorker($input->getArgument('id'));
 

Resque.php

@@ -127,11 +127,25 @@ public function getQueue($queue)
         return new Queue($queue);
     }
 
-    public function getWorkers()
+    public function getWorkers($local = false)
     {
+        $workers = \Resque_Worker::all();
+
+        if ($local) {
+            $hostname = php_uname('n');
+
+            if(function_exists('gethostname')) {
+                $hostname = gethostname();
+            }
+
+            $workers = \array_filter($workers, function ($worker) use ($hostname) {
+                return strpos((string) $worker, $hostname . ':') === 0;
+            });
+        }
+
         return \array_map(function ($worker) {
             return new Worker($worker);
-        }, \Resque_Worker::all());
+        }, $workers);
     }
 
     public function getWorker($id)