geckon01/predis
1
0
Fork 0
mirror of https://github.com/predis/predis.git synced 2026-08-30 12:15:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Minor tweaks to code.

Browse Source 
Also removed a useless method, most likely a leftover from the past.
This commit is contained in:
Daniele Alessandri
2013-11-09 18:52:18 +01:00
parent b38f640ac9
commit a4d0abc734
3 changed files with 5 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/Predis/Protocol/Text/ComposableProtocolProcessor.php
-8
View File
@@ -41,14 +41,6 @@ class ComposableProtocolProcessor implements ProtocolProcessorInterface
$this->setResponseReader($reader ?: new ResponseReader());
}
/**
* {@inheritdoc}
*/
public function serialize(CommandInterface $command)
{
return $this->serializer->serialize($command);
}
/**
* {@inheritdoc}
*/
lib/Predis/Protocol/Text/ProtocolProcessor.php
+2 -1
View File
@@ -45,7 +45,8 @@ class ProtocolProcessor implements ProtocolProcessorInterface
*/
public function write(ComposableConnectionInterface $connection, CommandInterface $command)
{
$connection->writeBytes($this->serializer->serialize($command));
$request = $this->serializer->serialize($command);
$connection->writeBytes($request);
}
/**
lib/Predis/Protocol/Text/RequestSerializer.php
+3 -3
View File
@@ -27,13 +27,13 @@ class RequestSerializer implements RequestSerializerInterface
*/
public function serialize(CommandInterface $command)
{
$commandId = $command->getId();
$commandID = $command->getId();
$arguments = $command->getArguments();
$cmdlen = strlen($commandId);
$cmdlen = strlen($commandID);
$reqlen = count($arguments) + 1;
$buffer = "*{$reqlen}\r\n\${$cmdlen}\r\n{$commandId}\r\n";
$buffer = "*{$reqlen}\r\n\${$cmdlen}\r\n{$commandID}\r\n";
for ($i = 0; $i < $reqlen - 1; $i++) {
$argument = $arguments[$i];