(ctx context.Context)
| 657 | } |
| 658 | |
| 659 | func (d *dependency) IoIntenseQueue(ctx context.Context) queue.Queue { |
| 660 | d.mu.Lock() |
| 661 | defer d.mu.Unlock() |
| 662 | |
| 663 | _, reload := ctx.Value(ReloadCtx{}).(bool) |
| 664 | if d.ioIntenseQueue != nil && !reload { |
| 665 | return d.ioIntenseQueue |
| 666 | } |
| 667 | |
| 668 | if d.ioIntenseQueue != nil { |
| 669 | d.ioIntenseQueue.Shutdown() |
| 670 | } |
| 671 | |
| 672 | settings := d.SettingProvider() |
| 673 | queueSetting := settings.Queue(context.Background(), setting.QueueTypeIOIntense) |
| 674 | |
| 675 | d.ioIntenseQueue = queue.New(d.Logger(), d.TaskClient(), d.TaskRegistry(), d, |
| 676 | queue.WithBackoffFactor(queueSetting.BackoffFactor), |
| 677 | queue.WithMaxRetry(queueSetting.MaxRetry), |
| 678 | queue.WithBackoffMaxDuration(queueSetting.BackoffMaxDuration), |
| 679 | queue.WithRetryDelay(queueSetting.RetryDelay), |
| 680 | queue.WithWorkerCount(queueSetting.WorkerNum), |
| 681 | queue.WithName("IoIntenseQueue"), |
| 682 | queue.WithMaxTaskExecution(queueSetting.MaxExecution), |
| 683 | queue.WithResumeTaskType(queue.CreateArchiveTaskType, queue.ExtractArchiveTaskType, queue.RelocateTaskType, queue.ImportTaskType), |
| 684 | queue.WithTaskPullInterval(10*time.Second), |
| 685 | ) |
| 686 | return d.ioIntenseQueue |
| 687 | } |
| 688 | |
| 689 | func (d *dependency) RemoteDownloadQueue(ctx context.Context) queue.Queue { |
| 690 | d.mu.Lock() |
nothing calls this directly
no test coverage detected