summaryrefslogtreecommitdiffstats
path: root/apps/dav/lib/Upload/AssemblyStream.php
diff options
context:
space:
mode:
Diffstat (limited to 'apps/dav/lib/Upload/AssemblyStream.php')
-rw-r--r--apps/dav/lib/Upload/AssemblyStream.php40
1 files changed, 37 insertions, 3 deletions
diff --git a/apps/dav/lib/Upload/AssemblyStream.php b/apps/dav/lib/Upload/AssemblyStream.php
index eaf24f8741a..c8a1be82f6b 100644
--- a/apps/dav/lib/Upload/AssemblyStream.php
+++ b/apps/dav/lib/Upload/AssemblyStream.php
@@ -83,12 +83,46 @@ class AssemblyStream implements \Icewind\Streams\File {
}
/**
- * @param string $offset
+ * @param int $offset
* @param int $whence
* @return bool
*/
public function stream_seek($offset, $whence = SEEK_SET) {
- return false;
+ if ($whence === SEEK_CUR) {
+ $offset = $this->stream_tell() + $offset;
+ } else if ($whence === SEEK_END) {
+ $offset = $this->size + $offset;
+ }
+
+ if ($offset > $this->size) {
+ return false;
+ }
+
+ $nodeIndex = 0;
+ $nodeStart = 0;
+ while (true) {
+ if (!isset($this->nodes[$nodeIndex + 1])) {
+ break;
+ }
+ $node = $this->nodes[$nodeIndex];
+ if ($nodeStart + $node->getSize() > $offset) {
+ break;
+ }
+ $nodeIndex++;
+ $nodeStart += $node->getSize();
+ }
+
+ $stream = $this->getStream($this->nodes[$nodeIndex]);
+ $nodeOffset = $offset - $nodeStart;
+ if(fseek($stream, $nodeOffset) === -1) {
+ return false;
+ }
+ $this->currentNode = $nodeIndex;
+ $this->currentNodeRead = $nodeOffset;
+ $this->currentStream = $stream;
+ $this->pos = $offset;
+
+ return true;
}
/**
@@ -210,7 +244,7 @@ class AssemblyStream implements \Icewind\Streams\File {
*
* @param string $name
* @return array
- * @throws \Exception
+ * @throws \BadMethodCallException
*/
protected function loadContext($name) {
$context = stream_context_get_options($this->context);