ogb912/opensim
1
0
Fork 0
mirror of https://github.com/opensim/opensim.git synced 2026-08-07 01:35:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

missing file

Browse Source
This commit is contained in:
UbitUmarov
2020-08-10 14:47:31 +01:00
parent ddf6d26b11
commit 3288b13977
1 changed files with 317 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

317
OpenSim/Framework/ExpiringCacheOS.cs Normal file
View File

@@ -0,0 +1,317 @@
/*
* Copyright (c) 2008, openmetaverse.org, http://opensimulator.org/
* All rights reserved.
*
* - Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
*
* - Redistributions of source code must retain the above copyright notice, this
* list of conditions and the following disclaimer.
* - Neither the name of the openmetaverse.org nor the names
* of its contributors may be used to endorse or promote products derived from
* this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
*/
// this is a lighter alternative to libomv, no sliding option
using System;
using System.Threading;
using System.Collections.Generic;
using Timer = System.Threading.Timer ;
namespace OpenSim.Framework
{
public sealed class ExpiringCacheOS<TKey1, TValue1> : IDisposable
{
private const int MINEXPIRE = 500;
private Timer m_purgeTimer;
private ReaderWriterLockSlim m_rwLock;
private readonly Dictionary<TKey1, int> m_expireControl;
private readonly Dictionary<TKey1, TValue1> m_values;
private readonly double m_startTS;
private readonly int m_expire;
public ExpiringCacheOS()
{
m_expireControl = new Dictionary<TKey1, int>();
m_values = new Dictionary<TKey1, TValue1>();
m_rwLock = new ReaderWriterLockSlim();
m_expire = MINEXPIRE;
m_startTS = Util.GetTimeStampMS();
}
public ExpiringCacheOS(int expireTimeinMS)
{
m_expireControl = new Dictionary<TKey1, int>();
m_values = new Dictionary<TKey1, TValue1>();
m_rwLock = new ReaderWriterLockSlim();
m_startTS = Util.GetTimeStampMS();
m_expire = (expireTimeinMS > MINEXPIRE) ? m_expire = expireTimeinMS : MINEXPIRE;
}
[System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.AggressiveInlining)]
private void CheckTimer()
{
if (m_purgeTimer == null)
{
m_purgeTimer = new Timer(Purge, null, m_expire, Timeout.Infinite);
}
}
[System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.AggressiveInlining)]
private void DisposeTimer()
{
if (m_purgeTimer != null)
{
m_purgeTimer.Dispose();
m_purgeTimer = null;
}
}
~ExpiringCacheOS()
{
Dispose(false);
}
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
private void Dispose(bool disposing)
{
if (m_rwLock != null)
{
DisposeTimer();
m_rwLock.Dispose();
m_rwLock = null;
}
}
private void Purge(object ignored)
{
bool gotLock = false;
int now = (int)(Util.GetTimeStampMS() - m_startTS);
try
{
try { }
finally
{
m_rwLock.EnterWriteLock();
gotLock = true;
}
if (m_expireControl.Count == 0)
{
DisposeTimer();
return;
}
List<TKey1> expired = new List<TKey1>(m_expireControl.Count);
foreach(KeyValuePair<TKey1, int> kvp in m_expireControl)
{
if(kvp.Value < now)
expired.Add(kvp.Key);
}
foreach(TKey1 key in expired)
{
m_expireControl.Remove(key);
m_values.Remove(key);
}
if(m_expireControl.Count == 0)
DisposeTimer();
else
m_purgeTimer.Change(m_expire, Timeout.Infinite);
}
finally
{
if (gotLock)
m_rwLock.ExitWriteLock();
}
}
[System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.AggressiveInlining)]
public void AddOrUpdate(TKey1 key, TValue1 val)
{
Add(key, val);
}
public void Add(TKey1 key, TValue1 val)
{
bool gotLock = false;
int now = (int)(Util.GetTimeStampMS() - m_startTS) + m_expire;
try
{
try { }
finally
{
m_rwLock.EnterWriteLock();
gotLock = true;
}
m_expireControl[key] = now;
m_values[key] = val;
CheckTimer();
}
finally
{
if (gotLock)
m_rwLock.ExitWriteLock();
}
}
[System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.AggressiveInlining)]
public void AddOrUpdate(TKey1 key, TValue1 val, int expireMS)
{
Add(key, val, expireMS);
}
[System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.AggressiveInlining)]
public void AddOrUpdate(TKey1 key, TValue1 val, double expireSeconds)
{
Add(key, val, (int)(expireSeconds * 1000));
}
public void Add(TKey1 key, TValue1 val, int expireMS)
{
bool gotLock = false;
expireMS = (expireMS > m_expire) ? expireMS : m_expire;
int now = (int)(Util.GetTimeStampMS() - m_startTS) + expireMS;
try
{
try { }
finally
{
m_rwLock.EnterWriteLock();
gotLock = true;
}
m_expireControl[key] = now;
m_values[key] = val;
CheckTimer();
}
finally
{
if (gotLock)
m_rwLock.ExitWriteLock();
}
}
public bool Remove(TKey1 key)
{
bool success;
bool gotLock = false;
try
{
try {}
finally
{
m_rwLock.EnterWriteLock();
gotLock = true;
}
success = m_expireControl.Remove(key);
success |= m_values.Remove(key);
if(m_expireControl.Count == 0)
DisposeTimer();
}
finally
{
if (gotLock)
m_rwLock.ExitWriteLock();
}
return success;
}
public void Clear()
{
bool gotLock = false;
try
{
try {}
finally
{
m_rwLock.EnterWriteLock();
gotLock = true;
}
DisposeTimer();
m_expireControl.Clear();
m_values.Clear();
}
finally
{
if (gotLock)
m_rwLock.ExitWriteLock();
}
}
public int Count
{
get { return m_expireControl.Count; }
}
public bool ContainsKey(TKey1 key)
{
bool gotLock = false;
try
{
try { }
finally
{
m_rwLock.EnterReadLock();
gotLock = true;
}
return m_expireControl.ContainsKey(key);
}
finally
{
if (gotLock)
m_rwLock.ExitReadLock();
}
}
public bool TryGetValue(TKey1 key, out TValue1 value)
{
bool success;
bool gotLock = false;
try
{
try {}
finally
{
m_rwLock.EnterReadLock();
gotLock = true;
}
success = m_values.TryGetValue(key, out value);
}
finally
{
if (gotLock)
m_rwLock.ExitReadLock();
}
return success;
}
}
}