|
@@ 794-799 (lines=6) @@
|
| 791 |
|
} |
| 792 |
|
|
| 793 |
|
// if timeout then error |
| 794 |
|
if (($difftime = round(microtime(true) - $this->_read_time)) > $waittimeout) { |
| 795 |
|
$this->_bad("Request timeout, in _open ({$difftime} > {$waittimeout}s) state=".$this->_spool[0]['State'] |
| 796 |
|
); |
| 797 |
|
|
| 798 |
|
return false; |
| 799 |
|
} |
| 800 |
|
} |
| 801 |
|
if ($this->_socket) { |
| 802 |
|
@stream_set_timeout($this->_socket, 0, 2000); |
|
@@ 909-915 (lines=7) @@
|
| 906 |
|
|
| 907 |
|
$this->_spool[0]['State'] = 'RECEIVE'; |
| 908 |
|
$this->_spool[0]['Times']['receive'][0] = $time; |
| 909 |
|
} elseif (($difftime = round(microtime(true) - $this->_read_time)) > $waittimeout) { |
| 910 |
|
// if timeout then error |
| 911 |
|
$this->_bad( |
| 912 |
|
"Request timeout, in _send ({$difftime} > {$waittimeout}s) state=".$this->_spool[0]['State'] |
| 913 |
|
); |
| 914 |
|
break; |
| 915 |
|
} |
| 916 |
|
} |
| 917 |
|
|
| 918 |
|
// if not async-callback then continue until all is sent |