about summary refs log tree commit diff
path: root/LibMatrix/Helpers/SyncStateResolver.cs
diff options
context:
space:
mode:
authorRory& <root@rory.gay>2024-09-07 00:40:12 +0200
committerRory& <root@rory.gay>2024-12-15 02:17:28 +0100
commit27f85712de2363b805b0e015c893b5865426eaa5 (patch)
tree4808d2dc1666e9a7d1ae386d5d03d2dea81995b2 /LibMatrix/Helpers/SyncStateResolver.cs
parentSync optimisation changes (diff)
downloadLibMatrix-27f85712de2363b805b0e015c893b5865426eaa5.tar.xz
Clean up dev stuff a little bit
Diffstat (limited to '')
-rw-r--r--LibMatrix/Helpers/SyncStateResolver.cs42
1 files changed, 0 insertions, 42 deletions
diff --git a/LibMatrix/Helpers/SyncStateResolver.cs b/LibMatrix/Helpers/SyncStateResolver.cs

index 5e34628..3be4492 100644 --- a/LibMatrix/Helpers/SyncStateResolver.cs +++ b/LibMatrix/Helpers/SyncStateResolver.cs
@@ -129,46 +129,6 @@ public class SyncStateResolver(AuthenticatedHomeserverGeneric homeserver, ILogge } public async Task dev() { - // var keys = (await storageProvider?.GetAllKeysAsync()).ToFrozenSet(); - // var times = new Dictionary<long, List<string>>(); - // var values = keys.Select(async x => Task.Run(async () => (x, await storageProvider?.LoadObjectAsync<SyncResponse>(x)))).ToAsyncEnumerable(); - // await foreach (var task in values) { - // var (key, data) = await task; - // if (data is null) continue; - // var derivTime = data.GetDerivedSyncTime(); - // if (!times.ContainsKey(derivTime)) times[derivTime] = new(); - // times[derivTime].Add(key); - // } - // - // foreach (var (time, ckeys) in times.OrderBy(x => x.Key)) { - // Console.WriteLine($"{time}: {ckeys.Count} keys"); - // } - - // var map = await GetCheckpointMap(); - // if (map is null) return; - // - // var times = new Dictionary<long, List<string>>(); - // foreach (var (time, keys) in map) { - // Console.WriteLine($"{time}: {keys.Count} keys - calculating times"); - // Dictionary<string, Task<SyncResponse?>?> tasks = keys.ToDictionary(x => x, x => storageProvider?.LoadObjectAsync<SyncResponse>(x)); - // var nextKey = "init"; - // long lastTime = 0; - // while (tasks.ContainsKey(nextKey)) { - // var data = await tasks[nextKey]; - // if (data is null) break; - // var derivTime = data.GetDerivedSyncTime(); - // if (derivTime == 0) derivTime = lastTime + 1; - // if (!times.ContainsKey(derivTime)) times[derivTime] = new(); - // times[derivTime].Add(nextKey); - // lastTime = derivTime; - // nextKey = data.NextBatch; - // } - // } - // - // foreach (var (time, ckeys) in times.OrderBy(x => x.Key)) { - // Console.WriteLine($"{time}: {ckeys.Count} keys"); - // } - int i = 0; var sw = Stopwatch.StartNew(); var hist = GetSerialisedHistory(); @@ -240,8 +200,6 @@ public class SyncStateResolver(AuthenticatedHomeserverGeneric homeserver, ILogge if (!key.StartsWith("old/")) continue; var parts = key.Split('/'); if (parts.Length < 3) continue; - // if (!map.ContainsKey(parts[1])) map[parts[1]] = new(); - // map[parts[1]].Add(parts[2]); if (!ulong.TryParse(parts[1], out var checkpoint)) continue; if (!map.ContainsKey(checkpoint)) map[checkpoint] = new(); map[checkpoint].Add(parts[2]);