kakserpom / phpdaemon

                $this->pctLength = Binary::b2i($this->read(8));

            }

            if ($this->pool->maxAllowedPacket < $this->pctLength) {

                Daemon::$process->log('max-allowed-packet (' . $this->pool->config->maxallowedpacket->getHumanValue() . ') exceed, aborting connection');

                $this->finish();

                return;

            }

            $this->setWatermark($this->pctLength + ($this->isMasked ? 4 : 0));

            $this->state = static::STATE_DATA;

        }

    public function sendFrame($payload, $type = Pool::TYPE_TEXT, $isMasked = true)

    {

        $payloadLength = mb_orig_strlen($payload);

        if ($payloadLength > $this->pool->maxAllowedPacket) {

            Daemon::$process->log('max-allowed-packet (' . $this->pool->config->maxallowedpacket->getHumanValue() . ') exceed, aborting connection');

            return;

        }

        $firstByte = '';

        switch ($type) {