idanoo/php-resque
1
0
Fork 0
mirror of https://github.com/idanoo/php-resque.git synced 2024-11-25 01:35:14 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Remove lambda and namespaces causing PHP 5.2 incompatibility

Browse Source
This commit is contained in:
chris.boulton 2011-03-27 15:02:06 +11:00
parent d2f804b82e
commit 0372a27ab7
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lib/Redisent/Redisent.php
View File

@ -51,7 +51,7 @@ class Redisent {
$this->port = $port; $this->port = $port;
$this->__sock = fsockopen($this->host, $this->port, $errno, $errstr); $this->__sock = fsockopen($this->host, $this->port, $errno, $errstr);
if (!$this->__sock) { if (!$this->__sock) {
throw new \Exception("{$errno} - {$errstr}"); throw new Exception("{$errno} - {$errstr}");
} }
} }
@ -63,15 +63,13 @@ class Redisent {
/* Build the Redis unified protocol command */ /* Build the Redis unified protocol command */
array_unshift($args, strtoupper($name)); array_unshift($args, strtoupper($name));
$command = sprintf('*%d%s%s%s', count($args), CRLF, implode(array_map(function($arg) { $command = sprintf('*%d%s%s%s', count($args), CRLF, implode(array_map(array($this, 'formatArgument'), $args), CRLF), CRLF);
return sprintf('$%d%s%s', strlen($arg), CRLF, $arg);
}, $args), CRLF), CRLF);
/* Open a Redis connection and execute the command */ /* Open a Redis connection and execute the command */
for ($written = 0; $written < strlen($command); $written += $fwrite) { for ($written = 0; $written < strlen($command); $written += $fwrite) {
$fwrite = fwrite($this->__sock, substr($command, $written)); $fwrite = fwrite($this->__sock, substr($command, $written));
if ($fwrite === FALSE) { if ($fwrite === FALSE) {
throw new \Exception('Failed to write entire command to stream'); throw new Exception('Failed to write entire command to stream');
} }
} }
@ -139,4 +137,7 @@ class Redisent {
return $response; return $response;
} }
private function formatArgument($arg) {
return sprintf('$%d%s%s', strlen($arg), CRLF, $arg);
}
} }