nextcloud / server

						$result = $storage->$operation($internalPath);

					}

				} catch (\Exception $e) {

					if (in_array('write', $hooks) || in_array('delete', $hooks)) {

						$this->unlockFile($path, ILockingProvider::LOCK_EXCLUSIVE);

					} else if (in_array('read', $hooks)) {

						$this->unlockFile($path, ILockingProvider::LOCK_SHARED);

					}

					throw $e;

				}

					// make sure our unlocking callback will still be called if connection is aborted

					ignore_user_abort(true);

					$result = CallbackWrapper::wrap($result, null, null, function () use ($hooks, $path) {

						if (in_array('write', $hooks)) {

							$this->unlockFile($path, ILockingProvider::LOCK_EXCLUSIVE);

						} else if (in_array('read', $hooks)) {

							$this->unlockFile($path, ILockingProvider::LOCK_SHARED);

						}

					});

				}

					}

				}

				if (!$unlockLater

					&& (in_array('write', $hooks) || in_array('delete', $hooks) || in_array('read', $hooks))

				) {

					$this->unlockFile($path, ILockingProvider::LOCK_SHARED);

				}

				return $result;

			} else {

				$this->unlockFile($path, ILockingProvider::LOCK_SHARED);