t0w0bi/ClubPenguinClient
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

do not paralellize fsw changes

Browse Source
This commit is contained in:
rootdarkarchon
2024-02-14 18:43:28 +01:00
committed by Loporrit
parent 79dbe377d1
commit 08eb1d194a
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()