sascha
/
nextcloud-server
mirror of https://github.com/nextcloud/server.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Custom chunking support

remotes/origin/stable45
Bart Visscher 2012-07-08 22:11:13 +07:00
parent dc8193fccb
commit e8010209bb
1 changed files with 25 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
lib/connector/sabre/directory.php
Unescape Escape View File

@ -33,10 +33,31 @@ class OC_Connector_Sabre_Directory extends OC_Connector_Sabre_Node implements Sa
* @return void
*/
public function createFile($name, $data = null) {
$newPath = $this->path . '/' . $name;
OC_Filesystem::file_put_contents($newPath,$data);
if (isset($_SERVER['HTTP_OC_CHUNKED'])) {
$cache = new OC_Cache_File();
$cache->set($name, $data);
preg_match('/(?P<name>.*)-chunking-(?P<transferid>\d+)-(?P<chunkcount>\d+)-(?P<index>\d+)/', $name, $matches);
$prefix = $matches['name'].'-chunking-'.$matches['transferid'].'-'.$matches['chunkcount'].'-';
$parts = 0;
for($i=0; $i < $matches['chunkcount']; $i++) {
if ($cache->hasKey($prefix.$i)) {
$parts ++;
}
}
if ($parts == $matches['chunkcount']) {
$newPath = $this->path . '/' . $matches['name'];
$f = OC_Filesystem::fopen($newPath, 'w');
for($i=0; $i < $matches['chunkcount']; $i++) {
$chunk = $cache->get($prefix.$i);
$cache->remove($prefix.$i);
fwrite($f,$chunk);
}
fclose($f);
}
} else {
$newPath = $this->path . '/' . $name;
OC_Filesystem::file_put_contents($newPath,$data);
}
}
/**