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

Use path to differentiate persistent TCP streams.

Browse Source 
Closes #139.
This commit is contained in:
Daniele Alessandri
2013-12-11 12:28:38 +01:00
parent 3fbc012c03
commit e7f2d28f23
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/Predis/Connection/StreamConnection.php
+3 -1
View File
@@ -65,14 +65,16 @@ class StreamConnection extends AbstractConnection
*/ */
private function tcpStreamInitializer(ConnectionParametersInterface $parameters) private function tcpStreamInitializer(ConnectionParametersInterface $parameters)
{ {
$uri = "tcp://{$parameters->host}:{$parameters->port}/"; $uri = "tcp://{$parameters->host}:{$parameters->port}";
$flags = STREAM_CLIENT_CONNECT; $flags = STREAM_CLIENT_CONNECT;
if (isset($parameters->async_connect) && $parameters->async_connect) { if (isset($parameters->async_connect) && $parameters->async_connect) {
$flags |= STREAM_CLIENT_ASYNC_CONNECT; $flags |= STREAM_CLIENT_ASYNC_CONNECT;
} }
if (isset($parameters->persistent) && $parameters->persistent) { if (isset($parameters->persistent) && $parameters->persistent) {
$flags |= STREAM_CLIENT_PERSISTENT; $flags |= STREAM_CLIENT_PERSISTENT;
$uri .= strpos($path = $parameters->path, '/') === 0 ? $path : "/$path";
} }
$resource = @stream_socket_client($uri, $errno, $errstr, $parameters->timeout, $flags); $resource = @stream_socket_client($uri, $errno, $errstr, $parameters->timeout, $flags);