allow availability recheck for external storages
This commit is contained in:
parent
4f25f34178
commit
6990100e6e
|
@ -23,6 +23,7 @@
|
||||||
|
|
||||||
namespace OCA\Files_External\Config;
|
namespace OCA\Files_External\Config;
|
||||||
|
|
||||||
|
use OC\Files\Storage\Wrapper\Availability;
|
||||||
use OCA\Files_external\Migration\StorageMigrator;
|
use OCA\Files_external\Migration\StorageMigrator;
|
||||||
use OCP\Files\Storage;
|
use OCP\Files\Storage;
|
||||||
use OC\Files\Mount\MountPoint;
|
use OC\Files\Mount\MountPoint;
|
||||||
|
@ -132,7 +133,7 @@ class ConfigAdapter implements IMountProvider {
|
||||||
|
|
||||||
try {
|
try {
|
||||||
$availability = $impl->getAvailability();
|
$availability = $impl->getAvailability();
|
||||||
if (!$availability['available']) {
|
if (!$availability['available'] && !Availability::shouldRecheck($availability)) {
|
||||||
$impl = new FailedStorage(['exception' => null]);
|
$impl = new FailedStorage(['exception' => null]);
|
||||||
}
|
}
|
||||||
} catch (\Exception $e) {
|
} catch (\Exception $e) {
|
||||||
|
|
|
@ -29,6 +29,16 @@ namespace OC\Files\Storage\Wrapper;
|
||||||
class Availability extends Wrapper {
|
class Availability extends Wrapper {
|
||||||
const RECHECK_TTL_SEC = 600; // 10 minutes
|
const RECHECK_TTL_SEC = 600; // 10 minutes
|
||||||
|
|
||||||
|
public static function shouldRecheck($availability) {
|
||||||
|
if (!$availability['available']) {
|
||||||
|
// trigger a recheck if TTL reached
|
||||||
|
if ((time() - $availability['last_checked']) > self::RECHECK_TTL_SEC) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return bool
|
* @return bool
|
||||||
*/
|
*/
|
||||||
|
@ -47,11 +57,8 @@ class Availability extends Wrapper {
|
||||||
*/
|
*/
|
||||||
private function isAvailable() {
|
private function isAvailable() {
|
||||||
$availability = $this->getAvailability();
|
$availability = $this->getAvailability();
|
||||||
if (!$availability['available']) {
|
if (self::shouldRecheck($availability)) {
|
||||||
// trigger a recheck if TTL reached
|
return $this->updateAvailability();
|
||||||
if ((time() - $availability['last_checked']) > self::RECHECK_TTL_SEC) {
|
|
||||||
return $this->updateAvailability();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
return $availability['available'];
|
return $availability['available'];
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue