taskProcessingManager->getProviders(); foreach ($providers as $provider) { if (!$provider instanceof ISynchronousProvider) { continue; } $taskTypeId = $provider->getTaskTypeId(); // only use this provider if it is the preferred one $preferredProvider = $this->taskProcessingManager->getPreferredProvider($taskTypeId); if ($provider->getId() !== $preferredProvider->getId()) { continue; } try { $task = $this->taskProcessingManager->getNextScheduledTask([$taskTypeId]); } catch (NotFoundException $e) { continue; } catch (Exception $e) { $this->logger->error('Unknown error while retrieving scheduled TaskProcessing tasks', ['exception' => $e]); continue; } if (!$this->taskProcessingManager->processTask($task, $provider)) { // Schedule again $this->jobList->add(self::class, $argument); } } // check if this job needs to be scheduled again: // if there is at least one preferred synchronous provider that has a scheduled task $synchronousProviders = array_filter($providers, fn ($provider) => $provider instanceof ISynchronousProvider); $synchronousPreferredProviders = array_filter($synchronousProviders, function ($provider) { $taskTypeId = $provider->getTaskTypeId(); $preferredProvider = $this->taskProcessingManager->getPreferredProvider($taskTypeId); return $provider->getId() === $preferredProvider->getId(); }); $taskTypes = array_values( array_map( fn ($provider) => $provider->getTaskTypeId(), $synchronousPreferredProviders ) ); $taskTypesWithTasks = array_filter($taskTypes, function ($taskType) { try { $this->taskProcessingManager->getNextScheduledTask([$taskType]); return true; } catch (NotFoundException|Exception $e) { return false; } }); if (count($taskTypesWithTasks) > 0) { // Schedule again $this->jobList->add(self::class, $argument); } } } t'>add-default-request-timeout-const Nextcloud server, a safe home for all your data: https://github.com/nextcloud/serverwww-data
aboutsummaryrefslogtreecommitdiffstats
path: root/dist/dav-settings-personal-availability.js
blob: 8b5c362cf3297818a97da4b7440c9cdc47ac65c6 (plain) 
1
2