AppserverIo\Server\Handlers\RequestHandlerThread

Complexity

Total Complexity

4

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	0

Test Coverage

Coverage

0%

Importance

Changes	3
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	1
B	run()	0	24	3

<?php

/**
 * \AppserverIo\Server\Handlers\RequestHandlerThread
 *
 * NOTICE OF LICENSE
 *
 * This source file is subject to the Open Software License (OSL 3.0)
 * that is available through the world-wide-web at this URL:
 * http://opensource.org/licenses/osl-3.0.php
 *
 * PHP version 5
 *
 * @author    Johann Zelger <jz@appserver.io>
 * @copyright 2015 TechDivision GmbH <info@appserver.io>
 * @license   http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
 * @link      https://github.com/appserver-io/server
 * @link      http://www.appserver.io
 */

namespace AppserverIo\Server\Handlers;

use AppserverIo\Server\Interfaces\ServerContextInterface;
use AppserverIo\Server\Interfaces\WorkerInterface;

/**
 * This class is just for testing purpose, so please don't use it for this moment.
 *
 * @author    Johann Zelger <jz@appserver.io>
 * @copyright 2015 TechDivision GmbH <info@appserver.io>
 * @license   http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
 * @link      https://github.com/appserver-io/server
 * @link      http://www.appserver.io
 */
class RequestHandlerThread extends \Thread
{
    /**
     * Constructs the request handler thread and start's it
     *
     * @param resource                                              $connectionResource The connection resource
     * @param array                                                 $connectionHandlers An array of connection handlers
     * @param \AppserverIo\Server\Interfaces\ServerContextInterface $serverContext      The server's context
     * @param \AppserverIo\Server\Interfaces\WorkerInterface        $worker             The worker instance
     */
    public function __construct(
        $connectionResource,
        array $connectionHandlers,
        ServerContextInterface $serverContext,
        WorkerInterface $worker
    ) {
        $this->connectionResource = $connectionResource;
        $this->connectionHandlers = $connectionHandlers;
        $this->serverContext = $serverContext;
        $this->worker = $worker;
        $this->start();
    }

    /**
     * Runs workload
     *
     * @return void
     */
    public function run()
    {
        // setup environment for handler
        require SERVER_AUTOLOADER;

        // set local var refs
        $serverContext = $this->serverContext;
        $connectionHandlers = $this->connectionHandlers;
        $worker = $this->worker;

        // get socket type
        $socketType = $serverContext->getServerConfig()->getSocketType();

        // get connection instance by resource
        $connection = $socketType::getInstance($this->connectionResource);

        // iterate all connection handlers to handle connection right
        foreach ($connectionHandlers as $connectionHandler) {
            // if connectionHandler handled connection than break out of foreach
            if ($connectionHandler->handle($connection, $worker)) {
                break;
            }
        }
    }
}