| Server IP : 78.140.185.180 / Your IP : 216.73.216.168 Web Server : LiteSpeed System : Linux cpanel13.v.fozzy.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64 User : builderbox ( 1072) PHP Version : 7.3.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /home/builderbox/www/vendor/pda/pheanstalk/src/Socket/ |
Upload File : |
<?php
namespace Pheanstalk\Socket;
use Pheanstalk\Contract\SocketInterface;
use Pheanstalk\Exception\SocketException;
/**
* A Socket implementation using the standard file functions.
*/
abstract class FileSocket implements SocketInterface
{
/** @var ?resource */
protected $socket;
/**
* Writes data to the socket.
*
* @param string $data
*
* @return void
*/
public function write(string $data): void
{
$this->checkClosed();
$retries = 0;
error_clear_last();
while (!empty($data) && $retries < 10) {
$written = fwrite($this->socket, $data);
if ($written === false) {
$this->throwException();
} elseif ($written === 0) {
$retries++;
continue;
}
$data = substr($data, $written);
}
if (!empty($data)) {
throw new SocketException('Write failed');
}
}
private function throwException()
{
if (null === $error = error_get_last()) {
throw new SocketException('Unknown error');
}
throw new SocketException($error['message'], $error['type']);
}
private function checkClosed()
{
if (!isset($this->socket)) {
throw new SocketException('The connection was closed');
}
}
/**
* Reads up to $length bytes from the socket.
*
* @return string
*/
public function read(int $length): string
{
$this->checkClosed();
$buffer = '';
while (mb_strlen($buffer, '8BIT') < $length) {
$result = fread($this->socket, $length - mb_strlen($buffer, '8BIT'));
if ($result === false) {
$this->throwException();
}
$buffer .= $result;
}
return $buffer;
}
/**
* Reads up to the next new-line.
* Trailing whitespace is trimmed.
*
* @param int
*/
public function getLine(): string
{
$this->checkClosed();
$result = fgets($this->socket, 8192);
if ($result === false) {
$this->throwException();
}
return rtrim($result);
}
/**
* Disconnect the socket; subsequent usage of the socket will fail.
*/
public function disconnect(): void
{
$this->checkClosed();
fclose($this->socket);
$this->socket = null;
}
}