admin/opensim-addon-modules-exp
1
0
Fork 0
mirror of https://github.com/jamenai/opensim-addon-modules-exp.git synced 2026-07-27 21:10:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

added file writer concurrency config (INI) option FileWriterConcurrencyWorker

Browse Source
This commit is contained in:
Lordfox
2025-10-04 17:09:18 +02:00
parent 2ca5800a24
commit 0addf97b2f
2 changed files with 19 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
modules/OpenSimConcurrentFlotsamAssetCache/addon-modules/OpenSimConcurrentFlotsamAssetCache/Modules/ConcurrentFlotsamAssetCache.cs
+14 -2
View File
@@ -266,7 +266,10 @@ namespace OpenSim.Region.CoreModules.Asset
// .bak cleanup options
private bool m_EnableBakCleanup = true;
private TimeSpan m_BakMaxAge = TimeSpan.FromHours(24);
private TimeSpan m_BakMaxAge = TimeSpan.FromHours(24);
// fileWriter concurrency options
private int m_FileWriterConcurrencyWorker = 1; // number of workers to use for concurrent writes (default: 1, max: 4)
public ConcurrentFlotsamAssetCache()
{
@@ -375,6 +378,12 @@ namespace OpenSim.Region.CoreModules.Asset
if (bakMaxAgeHours < 1.0) bakMaxAgeHours = 1.0; // floor
if (bakMaxAgeHours > 168.0) bakMaxAgeHours = 168.0; // cap at 7 days
m_BakMaxAge = TimeSpan.FromHours(bakMaxAgeHours);
// fileWriter concurrency config (optional)
// WARNING: this is a very experimental option and can damage the disk if used incorrectly
m_FileWriterConcurrencyWorker = assetConfig.GetInt("FileWriterConcurrencyWorker", m_FileWriterConcurrencyWorker);
if (m_FileWriterConcurrencyWorker > 4) m_FileWriterConcurrencyWorker = 4; // keep it limited to max: 4
}
if (m_updateFileTimeOnCacheHit)
@@ -503,7 +512,7 @@ namespace OpenSim.Region.CoreModules.Asset
if (m_FileCacheEnabled && m_assetFileWriteWorker == null)
{
m_assetFileWriteWorker = new ObjectJobEngine(ProcessWrites, "ConcurrentFloatsamCacheWriter", 1000, 1);
m_assetFileWriteWorker = new ObjectJobEngine(ProcessWrites, "ConcurrentFlotsamCacheWriter", 1000, m_FileWriterConcurrencyWorker);
}
if (!string.IsNullOrWhiteSpace(m_assetLoader) && scene.RegionInfo.RegionID == m_Scenes[0].RegionInfo.RegionID)
@@ -770,6 +779,7 @@ namespace OpenSim.Region.CoreModules.Asset
public AssetBase Get(string id, string ForeignAssetService, bool dummy) => null;
// @todo: in-flight de-duplication (sync or async?? keep mono comp. = sync??
public bool Get(string id, out AssetBase asset)
{
asset = null;
@@ -835,6 +845,8 @@ namespace OpenSim.Region.CoreModules.Asset
delay = Math.Min(delay == 0 ? 1 : delay * 2, m_BackoffMaxMs);
}
}
// @todo: should we also check the asset service (upstream)? (AssetProxy support too? or AssetCache only ??)
// without upstream we produce may be silent misses...
return false;
}
modules/OpenSimConcurrentFlotsamAssetCache/bin/config-include/ConcurrentFlotsamAssetCache.ini.example
+5 -1
View File
@@ -112,4 +112,8 @@
; Maximum backoff delay per attempt in milliseconds (cap).
; Default: 40 [>= BackoffInitialMs, <= 2000]
BackoffMaxMs = 40
BackoffMaxMs = 40
; File writer concurrency (number of threads).
; Default: 1 (recommended) Max: 4 (can be dangerous for the disk)
FileWriterConcurrencyWorker = 1