ToxicMushroom/mare.client
1
0
Fork 0
mirror of https://github.com/Caraxi/mare.client.git synced 2025-12-12 21:17:22 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

do not paralellize fsw changes

Browse source
This commit is contained in:
rootdarkarchon 2024-02-14 18:43:28 +01:00
parent a245e58944
commit 372589d87f
1 changed files with 23 additions and 28 deletions
Download patch file Download diff file Expand all files Collapse all files

51
MareSynchronos/FileCache/CacheMonitor.cs
View file

@ -249,21 +249,19 @@ public sealed class CacheMonitor : DisposableMediatorSubscriberBase
_ = RecalculateFileCacheSize();
if (changes.Any(c => c.Value.ChangeType == WatcherChangeTypes.Deleted))
{
var threadCount = Math.Clamp((int)(Environment.ProcessorCount / 2.0f), 2, 8);
Parallel.ForEach(changes, new ParallelOptions()
lock (_fileDbManager)
{
MaxDegreeOfParallelism = threadCount,
},
(change) =>
{
Logger.LogDebug("FSW Change: {change} = {val}", change.Key, change.Value);
_ = _fileDbManager.GetFileCacheByPath(change.Key);
});
foreach (var change in changes)
{
Logger.LogDebug("FSW Change: {change} = {val}", change.Key, change.Value);
_ = _fileDbManager.GetFileCacheByPath(change.Key);
}
_fileDbManager.WriteOutFullCsv();
_fileDbManager.WriteOutFullCsv();
}
}
}
@ -295,27 +293,24 @@ public sealed class CacheMonitor : DisposableMediatorSubscriberBase
}
}
var threadCount = Math.Clamp((int)(Environment.ProcessorCount / 2.0f), 2, 8);
Parallel.ForEach(changes, new ParallelOptions()
lock (_fileDbManager)
{
MaxDegreeOfParallelism = threadCount,
},
(change) =>
{
Logger.LogDebug("FSW Change: {change} = {val}", change.Key, change.Value);
if (change.Value.ChangeType == WatcherChangeTypes.Deleted)
foreach (var change in changes)
{
_fileDbManager.GetFileCacheByPath(change.Key);
Logger.LogDebug("FSW Change: {change} = {val}", change.Key, change.Value);
if (change.Value.ChangeType == WatcherChangeTypes.Deleted)
{
_fileDbManager.GetFileCacheByPath(change.Key);
}
else
{
if (change.Value.OldPath != null) _fileDbManager.GetFileCacheByPath(change.Value.OldPath);
_fileDbManager.CreateFileEntry(change.Key);
}
}
else
{
if (change.Value.OldPath != null) _fileDbManager.GetFileCacheByPath(change.Value.OldPath);
_fileDbManager.CreateFileEntry(change.Key);
}
});
_fileDbManager.WriteOutFullCsv();
_fileDbManager.WriteOutFullCsv();
}
}
public void InvokeScan()