Explorar o código

Add support for microsecond read/write timeouts.

Daniele Alessandri %!s(int64=15) %!d(string=hai) anos
pai
achega
435fdeab75
Modificáronse 1 ficheiros con 3 adicións e 1 borrados
  1. 3 1
      lib/Predis.php

+ 3 - 1
lib/Predis.php

@@ -779,7 +779,9 @@ class Connection implements IConnection {
         }
 
         if (isset($this->_params->read_write_timeout)) {
-            stream_set_timeout($this->_socket, $this->_params->read_write_timeout);
+            $timeoutSeconds  = floor($this->_params->read_write_timeout);
+            $timeoutUSeconds = ($this->_params->read_write_timeout - $timeoutSeconds) * 1000000;
+            stream_set_timeout($this->_socket, $timeoutSeconds, $timeoutUSeconds);
         }
 
         if (count($this->_initCmds) > 0){