summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--apps/dav/lib/Upload/AssemblyStream.php9
1 files changed, 9 insertions, 0 deletions
diff --git a/apps/dav/lib/Upload/AssemblyStream.php b/apps/dav/lib/Upload/AssemblyStream.php
index 3ba24bf60fd..24417851f2f 100644
--- a/apps/dav/lib/Upload/AssemblyStream.php
+++ b/apps/dav/lib/Upload/AssemblyStream.php
@@ -57,6 +57,9 @@ class AssemblyStream implements \Icewind\Streams\File {
/** @var int */
private $currentNode = 0;
+ /** @var int */
+ private $currentNodeRead = 0;
+
/**
* @param string $path
* @param string $mode
@@ -110,10 +113,16 @@ class AssemblyStream implements \Icewind\Streams\File {
do {
$data = fread($this->currentStream, $count);
$read = strlen($data);
+ $this->currentNodeRead += $read;
if (feof($this->currentStream)) {
fclose($this->currentStream);
+ $currentNodeSize = $this->nodes[$this->currentNode]->getSize();
+ if ($this->currentNodeRead < $currentNodeSize) {
+ throw new \Exception('Stream from assembly node shorter than expected, got ' . $this->currentNodeRead . ' bytes, expected ' . $currentNodeSize);
+ }
$this->currentNode++;
+ $this->currentNodeRead = 0;
if ($this->currentNode < count($this->nodes)) {
$this->currentStream = $this->getStream($this->nodes[$this->currentNode]);
} else {