Set StreamHandler stream chunk size, fixes Seldaek#1552

This ensures atomic log record writing to the output stream.
robocoder · May 24, 2022 · 2b79e01 · 2b79e01
1 parent 52ebd23
commit 2b79e01
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/Monolog/Handler/StreamHandler.php b/src/Monolog/Handler/StreamHandler.php
@@ -23,6 +23,9 @@
  */
 class StreamHandler extends AbstractProcessingHandler
 {
+    const MAX_CHUNK_SIZE = 2147483647;
+
+    /** @var resource|null */
     protected $stream;
     protected $url;
     private $errorMessage;
@@ -45,6 +48,7 @@ public function __construct($stream, $level = Logger::DEBUG, $bubble = true, $fi
         parent::__construct($level, $bubble);
         if (is_resource($stream)) {
             $this->stream = $stream;
+            stream_set_chunk_size($this->stream, self::MAX_CHUNK_SIZE);
         } elseif (is_string($stream)) {
             $this->url = Utils::canonicalizePath($stream);
         } else {
@@ -109,6 +113,7 @@ protected function write(array $record)
 
                 throw new \UnexpectedValueException(sprintf('The stream or file "%s" could not be opened in append mode: '.$this->errorMessage, $this->url));
             }
+            stream_set_chunk_size($this->stream, self::MAX_CHUNK_SIZE);
         }
 
         if ($this->useLocking) {