diff --git a/app/Classes/Sock/SocketClient.php b/app/Classes/Sock/SocketClient.php index e87cf2d..5071708 100644 --- a/app/Classes/Sock/SocketClient.php +++ b/app/Classes/Sock/SocketClient.php @@ -494,6 +494,12 @@ final class SocketClient { $this->rx_buf .= $buf; + if ($flags === MSG_PEEK) { + Log::debug(sprintf('%s:- Returning [%d] chars as a result of a PEEK operation, buffer would have [%d], but still has [%d]',self::LOGKEY,$len,strlen($this->rx_buf.$buf),strlen($this->rx_buf)),['rx_buf'=>hex_dump($this->rx_buf),'buf'=>$buf]); + + return substr($this->rx_buf.$buf,0,$len); + } + if (self::DEBUG) Log::debug(sprintf('%s:- Added [%d] chars to the RX buffer',self::LOGKEY,strlen($buf)),['rx_buf'=>hex_dump($this->rx_buf)]);