Compare commits

...

2 Commits

Author SHA1 Message Date
UbitUmarov
2720a1db36 change the rebakes throotle code 2026-06-16 21:56:11 +01:00
UbitUmarov
60a32d28e4 add AddOrUpdate to ExpiringKey 2026-06-16 21:41:15 +01:00
2 changed files with 29 additions and 17 deletions

View File

@@ -28,6 +28,7 @@ using System;
using System.Threading;
using System.Collections.Generic;
using Timer = System.Threading.Timer ;
using System.Runtime.InteropServices;
namespace OpenSim.Framework
{
@@ -168,6 +169,28 @@ namespace OpenSim.Framework
finally { m_rwLock.ExitWriteLock(); }
}
public bool AddOrUpdate(Tkey1 key, int expireMS)
{
int now;
if (expireMS > 0)
{
expireMS = (expireMS > m_expire) ? expireMS : m_expire;
now = (int)(Util.GetTimeStampMS() - m_startTS) + expireMS;
}
else
now = int.MinValue;
m_rwLock.EnterWriteLock();
try
{
ref int entry = ref CollectionsMarshal.GetValueRefOrAddDefault(m_dictionary, key, out bool exists);
entry = now;
CheckTimer();
return exists;
}
finally { m_rwLock.ExitWriteLock(); }
}
public bool Remove(Tkey1 key)
{
m_rwLock.EnterWriteLock();

View File

@@ -68,8 +68,8 @@ namespace OpenSim.Region.CoreModules.Avatar.AvatarFactory
private object m_setAppearanceLock = new object();
// add throttle
private ConcurrentDictionary<string, long> m_rebakeThrottle = new ConcurrentDictionary<string, long>();
private const int REBAKE_THROTTLE_SECONDS = 30;
readonly ExpiringKey<string> m_rebakeThrottle = new(500 * REBAKE_THROTTLE_SECONDS);
#region Region Module interface
@@ -456,28 +456,17 @@ namespace OpenSim.Region.CoreModules.Avatar.AvatarFactory
sp.Appearance.WearableCacheItems = wearableCache;
// throttle rebake requests
if (missing.Count > 0)
{
long now = DateTime.UtcNow.Ticks;
string spuuidstr = sp.UUID.ToString();
foreach (UUID id in missing)
{
string key = sp.UUID.ToString() + ":" + id.ToString();
string key = spuuidstr + id.ToString();
long last;
if (m_rebakeThrottle.TryGetValue(key, out last))
{
TimeSpan age = new TimeSpan(now - last);
if (age.TotalSeconds < REBAKE_THROTTLE_SECONDS)
continue;
}
if(m_rebakeThrottle.AddOrUpdate(key, 1000 * REBAKE_THROTTLE_SECONDS))
continue;
m_rebakeThrottle[key] = now;
m_log.DebugFormat(
"[AVFACTORY]: Missing baked texture {0} for {1}, requesting rebake",
id, sp.Name);
m_log.Debug($"[AVFACTORY]: Missing baked texture {id} for {sp.Name}, requesting rebake");
sp.ControllingClient.SendRebakeAvatarTextures(id);
}