WIP

2024-03-26 18:32:56 +01:00
parent b8151b1ddf
commit 5d53eddb32
62 changed files with 1267 additions and 362 deletions
@@ -0,0 +1,34 @@
+#nullable enable
+using System;
+using Duplicati.Library.IO;
+using Duplicati.Library.RestAPI.Abstractions;
+using Duplicati.Library.Utility;
+using Duplicati.Server;
+using Duplicati.WebserverCore.Abstractions;
+
+namespace Duplicati.Library.RestAPI;
+
+public class WorkerThreadsManager(ILiveControls liveControls, IScheduler scheduler) : IWorkerThreadsManager
+{
+    public WorkerThread<Runner.IRunnerData>? WorkerThread { get; private set; }
+
+    public void Spawn(Action<Runner.IRunnerData> item)
+    {
+        WorkerThread = new WorkerThread<Runner.IRunnerData>(item, liveControls.IsPaused);
+        scheduler.Init(WorkerThread);
+    }
+
+    public Tuple<long, string>? CurrentTask
+    {
+        get
+        {
+            var t = WorkerThread?.CurrentTask;
+            return t == null ? null : new Tuple<long, string>(t.TaskID, t.Backup.ID);
+        }
+    }
+
+    public void UpdateThrottleSpeeds()
+    {
+        WorkerThread?.CurrentTask?.UpdateThrottleSpeed();
+    }
+}