Module
/
OpenSim.Modules.DataValue
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

make write and delete in new thread

master
Christopher 2020-07-08 02:12:41 +02:00
parent 5721864302
commit bc143cb52d
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/DataValue.cs
View File

@ -12,6 +12,7 @@ using System.Linq;
using System.Reflection; using System.Reflection;
using System.Security.Cryptography; using System.Security.Cryptography;
using System.Text; using System.Text;
using System.Threading;
using System.Timers; using System.Timers;
[assembly: Addin("DataValueModule", "0.1")] [assembly: Addin("DataValueModule", "0.1")]
@ -169,7 +170,8 @@ namespace OpenSim.Modules.DataValue
checkRateLimit(); checkRateLimit();
m_cache.Add(new StorageElement(_host.GroupID.ToString(), key, value, m_storage)); m_cache.Add(new StorageElement(_host.GroupID.ToString(), key, value, m_storage));
m_storage.save(_host.GroupID.ToString(), key, value);
(new Thread(delegate () { try { m_storage.save(_host.GroupID.ToString(), key, value); } catch (Exception _innterError) { m_log.Error(_innterError.Message); } })).Start();
return; return;
} }
catch (Exception _error) catch (Exception _error)
@ -195,7 +197,7 @@ namespace OpenSim.Modules.DataValue
if (_element != null) if (_element != null)
m_cache.Remove(_element); m_cache.Remove(_element);
m_storage.remove(_host.GroupID.ToString(), key); (new Thread(delegate () { try { m_storage.remove(_host.GroupID.ToString(), key); } catch(Exception _innterError) { m_log.Error(_innterError.Message); } })).Start();
} }
catch (Exception _error) catch (Exception _error)
{ {