Merge pull request #9395 from nextcloud/scanner-error-lock-cleanup

cleanup locks in scanner on error
This commit is contained in:
Morris Jobke 2018-05-23 20:05:01 +02:00 committed by GitHub
commit 6b6d522969
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 9 deletions

View File

@ -332,15 +332,18 @@ class Scanner extends BasicEmitter implements IScanner {
$this->storage->acquireLock($path, ILockingProvider::LOCK_SHARED, $this->lockingProvider); $this->storage->acquireLock($path, ILockingProvider::LOCK_SHARED, $this->lockingProvider);
} }
} }
$data = $this->scanFile($path, $reuse, -1, null, $lock); try {
if ($data and $data['mimetype'] === 'httpd/unix-directory') { $data = $this->scanFile($path, $reuse, -1, null, $lock);
$size = $this->scanChildren($path, $recursive, $reuse, $data['fileid'], $lock); if ($data and $data['mimetype'] === 'httpd/unix-directory') {
$data['size'] = $size; $size = $this->scanChildren($path, $recursive, $reuse, $data['fileid'], $lock);
} $data['size'] = $size;
if ($lock) { }
if ($this->storage->instanceOfStorage('\OCP\Files\Storage\ILockingStorage')) { } finally {
$this->storage->releaseLock($path, ILockingProvider::LOCK_SHARED, $this->lockingProvider); if ($lock) {
$this->storage->releaseLock('scanner::' . $path, ILockingProvider::LOCK_EXCLUSIVE, $this->lockingProvider); if ($this->storage->instanceOfStorage('\OCP\Files\Storage\ILockingStorage')) {
$this->storage->releaseLock($path, ILockingProvider::LOCK_SHARED, $this->lockingProvider);
$this->storage->releaseLock('scanner::' . $path, ILockingProvider::LOCK_EXCLUSIVE, $this->lockingProvider);
}
} }
} }
return $data; return $data;