taywon/Salmon
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Secured statemachine

Browse Source
This commit is contained in:
taywon 2024-05-19 17:19:32 +02:00
parent 4ab6ffd890
commit 188d8f48e3
1 changed files with 35 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
Salmon.Core/Depth/StateMachine.cs
View File

@ -81,20 +81,24 @@ public class StateMachine
public IEnumerable<string> GetIds() public IEnumerable<string> GetIds()
{ {
if (!Populated)
PopulateWithHistory().Wait();
lock (Mutex) lock (Mutex)
{
if (!Populated)
PopulateWithHistory().Wait();
foreach (var kv in Implementation) foreach (var kv in Implementation)
yield return kv.Key; yield return kv.Key;
}
} }
public IEnumerable<Triplet> Get() public IEnumerable<Triplet> Get()
{ {
if (!Populated)
PopulateWithHistory().Wait();
lock (Mutex) lock (Mutex)
{
if (!Populated)
PopulateWithHistory().Wait();
foreach (var kv in Implementation) foreach (var kv in Implementation)
foreach (var kvv in kv.Value) foreach (var kvv in kv.Value)
yield return new Triplet yield return new Triplet
@ -104,17 +108,24 @@ public class StateMachine
value = kvv.Value.Value, value = kvv.Value.Value,
LastFlush = kvv.Value.When LastFlush = kvv.Value.When
}; };
}
} }
public IEnumerable<Triplet> Get(string key) public IEnumerable<Triplet> Get(string key)
{ {
if (!Populated)
PopulateWithHistory().Wait();
Dictionary<string, ImplValue> dic; Dictionary<string, ImplValue> dic;
lock (Mutex) lock (Mutex)
{
if (!Populated)
PopulateWithHistory().Wait();
if (!Implementation.TryGetValue(key, out dic)) if (!Implementation.TryGetValue(key, out dic))
yield break; yield break;
}
foreach(var kv in dic) foreach(var kv in dic)
yield return new Triplet yield return new Triplet
@ -128,13 +139,19 @@ public class StateMachine
public DateTime? GetLastUpdate(string key) public DateTime? GetLastUpdate(string key)
{ {
if (!Populated)
PopulateWithHistory().Wait();
Dictionary<string, ImplValue> dic; Dictionary<string, ImplValue> dic;
lock (Mutex) lock (Mutex)
{
if (!Populated)
PopulateWithHistory().Wait();
if (!Implementation.TryGetValue(key, out dic)) if (!Implementation.TryGetValue(key, out dic))
return null; return null;
}
DateTime mostrecent = DateTime.MinValue; DateTime mostrecent = DateTime.MinValue;
foreach (var kv in dic) foreach (var kv in dic)
@ -149,13 +166,16 @@ public class StateMachine
public object? Get(string key, string predicate) public object? Get(string key, string predicate)
{ {
if (!Populated)
PopulateWithHistory().Wait();
lock (Mutex) lock (Mutex)
{
if (!Populated)
PopulateWithHistory().Wait();
if (Implementation.TryGetValue(key, out var value)) if (Implementation.TryGetValue(key, out var value))
if (value.TryGetValue(predicate, out var ret)) if (value.TryGetValue(predicate, out var ret))
return ret; return ret;
}
return null; return null;
} }