Comodojo\Daemon\Listeners\WorkerWatchdog

Complexity

Total Complexity

4

Size/Duplication

Total Lines	25
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	handle()	0	23	4

<?php namespace Comodojo\Daemon\Listeners;

use \League\Event\AbstractListener;
use \League\Event\EventInterface;

/**
 * @package     Comodojo Daemon
 * @author      Marco Giovinazzi <marco.giovinazzi@comodojo.org>
 * @license     MIT
 *
 * LICENSE:
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

class WorkerWatchdog extends AbstractListener {

    public function handle(EventInterface $event) {

        $daemon = $event->getProcess();

The method getProcess() does not exist on League\Event\EventInterface. It seems like you code against a sub-type of League\Event\EventInterface such as Comodojo\Daemon\Events\PosixEvent or Comodojo\Daemon\Events\SocketEvent.

        $workers = $daemon->getWorkers();
        $logger = $daemon->getLogger();

        foreach ( $workers as $name => $worker ) {

            if ( $workers->running($worker->getPid()) ) {

                $logger->debug("Worker $name seems to be running");

            } else {

                $logger->warning("Worker $name has exited");

                if ( $worker->getForever() ) {
                    $logger->warning("Attempting to restart $name");
                    $workers->start($name, true);
                } else {
                    $logger->error("Worker $name has exited, shutting down daemon");
                    $daemon->stop();
                }

            }

        }

    }

}