ZmqBuffer::handleWriteEvent() - Code Metrics - dazzle-php/zmq - Measure and Improve Code Quality continuously with Scrutinizer

ZmqBuffer::handleWriteEvent() B
last analyzed 2017-07-23 19:14 UTC

↳ Parent: ZmqBuffer

Complexity

Conditions	4
Paths	7

Size

Total Lines	22
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	20

Importance

Changes

Metric	Value
dl	0
loc	22
ccs	0
cts	22
cp	0
rs	8.9197
c	0
b	0
f	0
cc	4
eloc	12
nc	7
nop	0
crap	20

<?php

namespace Dazzle\Zmq;

use Dazzle\Event\BaseEventEmitter;
use Dazzle\Loop\LoopInterface;
use ZMQ;
use ZMQSocket as RawZMQSocket;
use ZMQSocketException;

class ZmqBuffer extends BaseEventEmitter
{
    /**
     * @var RawZMQSocket
     */
    public $socket;

    /**
     * @var bool
     */
    public $closed = false;

    /**
     * @var bool
     */
    public $listening = false;

    /**
     * @var LoopInterface
     */
    private $loop;

    /**
     * @var resource
     */
    private $fd;

    /**
     * @var callable
     */
    private $writeListener;

    /**
     * @var string[]
     */
    private $messages = [];

    /**
     * @param RawZMQSocket $socket
     * @param resource $fd
     * @param LoopInterface $loop
     * @param $writeListener
     */
    public function __construct(RawZMQSocket $socket, $fd, LoopInterface $loop, $writeListener)
    {
        $this->socket = $socket;
        $this->fd = $fd;
        $this->loop = $loop;
        $this->writeListener = $writeListener;
    }

    /**
     * Send message.
     *
     * @param string $message
     * @return bool
     */
    public function send($message)
    {
        if ($this->closed)
        {
            return false;
        }

        $this->messages[] = $message;

        if (!$this->listening)
        {
            $this->listening = true;
            $this->loop->addWriteStream($this->fd, $this->writeListener);
        }

        return true;
    }

    /**
     * Close buffer.
     */
    public function end()
    {
        $this->closed = true;

        if (!$this->listening)
        {
            $this->emit('end');
        }
    }

    /**
     * Handle ZMQ Write Event.
     */
    public function handleWriteEvent()
    {
        foreach ($this->messages as $i=>$message)
        {
            try
            {
                $message = (array) $message;
                $sent = (bool) $this->socket->sendmulti($message, ZMQ::MODE_DONTWAIT);
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
                unset($this->messages[$i]);
                if (0 === count($this->messages))
                {
                    $this->loop->removeWriteStream($this->fd);
                    $this->listening = false;
                    $this->emit('end');
                }
            }
            catch (ZMQSocketException $ex)

            {
                $this->emit('error', [ $ex ]);
            }
        }
    }
}


1			<?php
2
3			namespace Dazzle\Zmq;
4
5			use Dazzle\Event\BaseEventEmitter;
6			use Dazzle\Loop\LoopInterface;
7			use ZMQ;
8			use ZMQSocket as RawZMQSocket;
9			use ZMQSocketException;
10
11			class ZmqBuffer extends BaseEventEmitter
12			{
13			/**
14			* @var RawZMQSocket
15			*/
16			public $socket;
17
18			/**
19			* @var bool
20			*/
21			public $closed = false;
22
23			/**
24			* @var bool
25			*/
26			public $listening = false;
27
28			/**
29			* @var LoopInterface
30			*/
31			private $loop;
32
33			/**
34			* @var resource
35			*/
36			private $fd;
37
38			/**
39			* @var callable
40			*/
41			private $writeListener;
42
43			/**
44			* @var string[]
45			*/
46			private $messages = [];
47
48			/**
49			* @param RawZMQSocket $socket
50			* @param resource $fd
51			* @param LoopInterface $loop
52			* @param $writeListener
53			*/
54			public function __construct(RawZMQSocket $socket, $fd, LoopInterface $loop, $writeListener)
55			{
56			$this->socket = $socket;
57			$this->fd = $fd;
58			$this->loop = $loop;
59			$this->writeListener = $writeListener;
60			}
61
62			/**
63			* Send message.
64			*
65			* @param string $message
66			* @return bool
67			*/
68			public function send($message)
69			{
70			if ($this->closed)
71			{
72			return false;
73			}
74
75			$this->messages[] = $message;
76
77			if (!$this->listening)
78			{
79			$this->listening = true;
80			$this->loop->addWriteStream($this->fd, $this->writeListener);
81			}
82
83			return true;
84			}
85
86			/**
87			* Close buffer.
88			*/
89			public function end()
90			{
91			$this->closed = true;
92
93			if (!$this->listening)
94			{
95			$this->emit('end');
96			}
97			}
98
99			/**
100			* Handle ZMQ Write Event.
101			*/
102			public function handleWriteEvent()
103			{
104			foreach ($this->messages as $i=>$message)
105			{
106			try
107			{
108			$message = (array) $message;
109			$sent = (bool) $this->socket->sendmulti($message, ZMQ::MODE_DONTWAIT);
			0 ignored issues – show Unused Code introduced 2017-06-24 23:51 UTC by Report Bug Copy Issue Report `$sent` is not used, you could remove the assignment. This check looks for variable assignements that are either overwritten by other assignments or where the variable is not used subsequently. $myVar = 'Value'; $higher = false; if (rand(1, 6) > 3) { $higher = true; } else { $higher = false; } Both the `$myVar` assignment in line 1 and the `$higher` assignment in line 2 are dead. The first because `$myVar` is never used and the second because `$higher` is always overwritten for every possible time line. Loading history...
110			unset($this->messages[$i]);
111			if (0 === count($this->messages))
112			{
113			$this->loop->removeWriteStream($this->fd);
114			$this->listening = false;
115			$this->emit('end');
116			}
117			}
118			catch (ZMQSocketException $ex)
			0 ignored issues – show Bug introduced 2017-06-24 23:51 UTC by Report Bug Copy Issue Report The class `ZMQSocketException` does not exist. Is this class maybe located in a folder that is not analyzed, or in a newer version of your dependencies than listed in your composer.lock/composer.json? Loading history...
119			{
120			$this->emit('error', [ $ex ]);
121			}
122			}
123			}
124			}
125

dazzle-php / zmq

ZmqBuffer::handleWriteEvent() B last analyzed 2017-07-23 19:14 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

ZmqBuffer::handleWriteEvent() B
last analyzed 2017-07-23 19:14 UTC