nsinnovations/fusionpbx
2
0
Fork 0
mirror of https://github.com/fusionpbx/fusionpbx.git synced 2026-02-12 06:04:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add timeout parameter to read_event method

Browse Source 
Updated read_event method to accept a timeout parameter for stream_select.
This commit is contained in:
FusionPBX
2026-02-07 14:13:56 -07:00
committed by GitHub
parent 6f9cb85859
commit 0279dd90e6
1 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
resources/classes/event_socket.php
View File

@@ -126,11 +126,13 @@ class event_socket {
/**
* Read the event body from the socket
*
*
* @param int|null $timeout the timeout in microseconds for stream_select, Default 10000
*
* @return mixed Content body or false if not connected or empty message
* @depends buffer::class
*/
public function read_event() {
public function read_event($timeout = 10000) {
if (!$this->connected()) {
return false;
}
@@ -152,8 +154,16 @@ class event_socket {
break;
}
$buffer = fgets($this->fp, 1024);
$b->append($buffer);
// Check if we have data available
$read = [$this->fp];
$write = [];
$except = [];
if (stream_select($read, $write, $except, 0, $timeout) > 0) {
$buffer = fgets($this->fp, 1024);
if ($buffer !== false) {
$b->append($buffer);
}
}
}
if (array_key_exists('Content-Length', $content)) {