Compare commits
7 Commits
storage_co
...
main
Author | SHA1 | Date |
---|---|---|
cosmonaut | 3e60d2dff2 | |
cosmonaut | 3b460cf326 | |
cosmonaut | 079765d009 | |
cosmonaut | 0d567f1854 | |
cosmonaut | 9b90d47d01 | |
cosmonaut | 842398b237 | |
cosmonaut | b31120310c |
|
@ -3,7 +3,6 @@
|
||||||
<PropertyGroup>
|
<PropertyGroup>
|
||||||
<TargetFramework>net8.0</TargetFramework>
|
<TargetFramework>net8.0</TargetFramework>
|
||||||
<Nullable>enable</Nullable>
|
<Nullable>enable</Nullable>
|
||||||
<Platforms>x64</Platforms>
|
|
||||||
<AllowUnsafeBlocks>true</AllowUnsafeBlocks>
|
<AllowUnsafeBlocks>true</AllowUnsafeBlocks>
|
||||||
</PropertyGroup>
|
</PropertyGroup>
|
||||||
|
|
||||||
|
|
|
@ -7,8 +7,8 @@ namespace MoonTools.ECS.Collections;
|
||||||
public unsafe class NativeArray<T> : IDisposable where T : unmanaged
|
public unsafe class NativeArray<T> : IDisposable where T : unmanaged
|
||||||
{
|
{
|
||||||
private T* Elements;
|
private T* Elements;
|
||||||
public int Count { get; private set; }
|
public int Count { get; private set;}
|
||||||
public int Capacity { get; private set; }
|
private int Capacity;
|
||||||
private int ElementSize;
|
private int ElementSize;
|
||||||
|
|
||||||
public Span<T> ToSpan() => new Span<T>(Elements, Count);
|
public Span<T> ToSpan() => new Span<T>(Elements, Count);
|
||||||
|
@ -61,7 +61,7 @@ public unsafe class NativeArray<T> : IDisposable where T : unmanaged
|
||||||
Count = 0;
|
Count = 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void ResizeTo(int size)
|
private void ResizeTo(int size)
|
||||||
{
|
{
|
||||||
Capacity = size;
|
Capacity = size;
|
||||||
Elements = (T*) NativeMemory.Realloc((void*) Elements, (nuint) (ElementSize * Capacity));
|
Elements = (T*) NativeMemory.Realloc((void*) Elements, (nuint) (ElementSize * Capacity));
|
||||||
|
|
|
@ -7,8 +7,8 @@ namespace MoonTools.ECS.Collections;
|
||||||
internal unsafe class NativeArray : IDisposable
|
internal unsafe class NativeArray : IDisposable
|
||||||
{
|
{
|
||||||
private nint Elements;
|
private nint Elements;
|
||||||
public int Count { get; private set; }
|
public int Count { get; private set;}
|
||||||
public int Capacity { get; private set; }
|
private int Capacity;
|
||||||
public readonly int ElementSize;
|
public readonly int ElementSize;
|
||||||
|
|
||||||
private bool IsDisposed;
|
private bool IsDisposed;
|
||||||
|
@ -44,7 +44,7 @@ internal unsafe class NativeArray : IDisposable
|
||||||
Elements = (nint) NativeMemory.Realloc((void*) Elements, (nuint) (ElementSize * Capacity));
|
Elements = (nint) NativeMemory.Realloc((void*) Elements, (nuint) (ElementSize * Capacity));
|
||||||
}
|
}
|
||||||
|
|
||||||
public void ResizeTo(int capacity)
|
private void ResizeTo(int capacity)
|
||||||
{
|
{
|
||||||
Capacity = capacity;
|
Capacity = capacity;
|
||||||
Elements = (nint) NativeMemory.Realloc((void*) Elements, (nuint) (ElementSize * Capacity));
|
Elements = (nint) NativeMemory.Realloc((void*) Elements, (nuint) (ElementSize * Capacity));
|
||||||
|
@ -65,11 +65,6 @@ internal unsafe class NativeArray : IDisposable
|
||||||
Count -= 1;
|
Count -= 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void RemoveLastElement()
|
|
||||||
{
|
|
||||||
Count -= 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void Append<T>(T component) where T : unmanaged
|
public void Append<T>(T component) where T : unmanaged
|
||||||
{
|
{
|
||||||
if (Count >= Capacity)
|
if (Count >= Capacity)
|
||||||
|
|
|
@ -1,105 +1,90 @@
|
||||||
using System;
|
using System;
|
||||||
using System.Runtime.CompilerServices;
|
using System.Collections.Generic;
|
||||||
using System.Runtime.InteropServices;
|
|
||||||
using MoonTools.ECS.Collections;
|
using MoonTools.ECS.Collections;
|
||||||
|
|
||||||
namespace MoonTools.ECS;
|
namespace MoonTools.ECS;
|
||||||
|
|
||||||
public class ComponentStorage : IDisposable
|
internal class ComponentStorage : IDisposable
|
||||||
{
|
{
|
||||||
internal readonly NativeArray<Entity> DenseArray = new NativeArray<Entity>();
|
internal readonly Dictionary<Entity, int> EntityIDToStorageIndex = new Dictionary<Entity, int>(16);
|
||||||
internal readonly NativeArray<int> SparseArray = new NativeArray<int>();
|
internal readonly NativeArray Components;
|
||||||
internal nint ElementArray;
|
internal readonly NativeArray<Entity> EntityIDs;
|
||||||
internal int ElementArrayCapacity;
|
internal readonly TypeId TypeId;
|
||||||
|
internal readonly int ElementSize;
|
||||||
|
|
||||||
private bool IsDisposed;
|
private bool IsDisposed;
|
||||||
|
|
||||||
public int ElementSize { get; private set; }
|
public ComponentStorage(TypeId typeId, int elementSize)
|
||||||
public int Count => DenseArray.Count;
|
|
||||||
|
|
||||||
public unsafe ComponentStorage(int elementSize)
|
|
||||||
{
|
{
|
||||||
for (var i = 0; i < 16; i += 1)
|
|
||||||
{
|
|
||||||
SparseArray.Append(Entity.Null.ID); // sentinel value
|
|
||||||
}
|
|
||||||
|
|
||||||
ElementArrayCapacity = 16;
|
|
||||||
ElementArray = (nint) NativeMemory.Alloc((nuint) (elementSize * ElementArrayCapacity));
|
|
||||||
ElementSize = elementSize;
|
ElementSize = elementSize;
|
||||||
|
Components = new NativeArray(elementSize);
|
||||||
|
EntityIDs = new NativeArray<Entity>();
|
||||||
|
TypeId = typeId;
|
||||||
}
|
}
|
||||||
|
|
||||||
public bool Any() => DenseArray.Count > 0;
|
public bool Any()
|
||||||
|
|
||||||
public unsafe ref T Get<T>(Entity entity) where T : unmanaged
|
|
||||||
{
|
{
|
||||||
return ref ((T*) ElementArray)[SparseArray[entity.ID]];
|
return Components.Count > 0;
|
||||||
}
|
|
||||||
|
|
||||||
public unsafe ref T GetFirst<T>() where T : unmanaged
|
|
||||||
{
|
|
||||||
#if DEBUG
|
|
||||||
if (DenseArray.Count == 0)
|
|
||||||
{
|
|
||||||
throw new IndexOutOfRangeException("Component storage is empty!");
|
|
||||||
}
|
|
||||||
#endif
|
|
||||||
return ref ((T*) ElementArray)[0];
|
|
||||||
}
|
|
||||||
|
|
||||||
public unsafe bool Set<T>(Entity entity, T component) where T : unmanaged
|
|
||||||
{
|
|
||||||
var newEntity = entity.ID >= SparseArray.Count || SparseArray[entity.ID] == Entity.Null.ID;
|
|
||||||
if (newEntity)
|
|
||||||
{
|
|
||||||
// the entity is being added! let's do some record keeping
|
|
||||||
var index = DenseArray.Count;
|
|
||||||
DenseArray.Append(entity);
|
|
||||||
if (entity.ID >= SparseArray.Count)
|
|
||||||
{
|
|
||||||
var oldCount = SparseArray.Count;
|
|
||||||
SparseArray.ResizeTo(entity.ID + 1);
|
|
||||||
for (var i = oldCount; i < SparseArray.Capacity; i += 1)
|
|
||||||
{
|
|
||||||
SparseArray.Append(Entity.Null.ID); // sentinel value
|
|
||||||
}
|
|
||||||
}
|
|
||||||
SparseArray[entity.ID] = index;
|
|
||||||
|
|
||||||
if (entity.ID >= ElementArrayCapacity)
|
|
||||||
{
|
|
||||||
ElementArrayCapacity = entity.ID + 1;
|
|
||||||
ElementArray = (nint) NativeMemory.Realloc((void*) ElementArray, (nuint) (ElementArrayCapacity * ElementSize));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Unsafe.Write((void*) (ElementArray + ElementSize * SparseArray[entity.ID]), component);
|
|
||||||
return !newEntity;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public bool Has(Entity entity)
|
public bool Has(Entity entity)
|
||||||
{
|
{
|
||||||
return entity.ID < SparseArray.Count && SparseArray[entity.ID] != Entity.Null.ID;
|
return EntityIDToStorageIndex.ContainsKey(entity);
|
||||||
}
|
}
|
||||||
|
|
||||||
public unsafe bool Remove(Entity entity)
|
public ref T Get<T>(in Entity entity) where T : unmanaged
|
||||||
{
|
{
|
||||||
if (Has(entity))
|
return ref Components.Get<T>(EntityIDToStorageIndex[entity]);
|
||||||
|
}
|
||||||
|
|
||||||
|
public ref T GetFirst<T>() where T : unmanaged
|
||||||
|
{
|
||||||
|
#if DEBUG
|
||||||
|
if (Components.Count == 0)
|
||||||
{
|
{
|
||||||
var denseIndex = SparseArray[entity.ID];
|
throw new IndexOutOfRangeException("Component storage is empty!");
|
||||||
var lastItem = DenseArray[DenseArray.Count - 1];
|
}
|
||||||
DenseArray[denseIndex] = lastItem;
|
#endif
|
||||||
SparseArray[lastItem.ID] = denseIndex;
|
return ref Components.Get<T>(0);
|
||||||
SparseArray[entity.ID] = Entity.Null.ID; // sentinel value
|
}
|
||||||
|
|
||||||
if (denseIndex != DenseArray.Count - 1)
|
// Returns true if the entity had this component.
|
||||||
|
public bool Set<T>(in Entity entity, in T component) where T : unmanaged
|
||||||
|
{
|
||||||
|
if (EntityIDToStorageIndex.TryGetValue(entity, out var index))
|
||||||
|
{
|
||||||
|
Components.Set(index, component);
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
EntityIDToStorageIndex[entity] = Components.Count;
|
||||||
|
EntityIDs.Append(entity);
|
||||||
|
Components.Append(component);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Returns true if the entity had this component.
|
||||||
|
public bool Remove(in Entity entity)
|
||||||
|
{
|
||||||
|
if (EntityIDToStorageIndex.TryGetValue(entity, out int index))
|
||||||
|
{
|
||||||
|
var lastElementIndex = Components.Count - 1;
|
||||||
|
|
||||||
|
var lastEntity = EntityIDs[lastElementIndex];
|
||||||
|
|
||||||
|
// move a component into the hole to maintain contiguous memory
|
||||||
|
Components.Delete(index);
|
||||||
|
EntityIDs.Delete(index);
|
||||||
|
EntityIDToStorageIndex.Remove(entity);
|
||||||
|
|
||||||
|
// update the index if it changed
|
||||||
|
if (lastElementIndex != index)
|
||||||
{
|
{
|
||||||
NativeMemory.Copy((void*) (ElementArray + ElementSize * (DenseArray.Count - 1)), (void*) (ElementArray + ElementSize * denseIndex), (nuint) ElementSize);
|
EntityIDToStorageIndex[lastEntity] = index;
|
||||||
}
|
}
|
||||||
|
|
||||||
DenseArray.RemoveLastElement();
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -108,47 +93,46 @@ public class ComponentStorage : IDisposable
|
||||||
|
|
||||||
public void Clear()
|
public void Clear()
|
||||||
{
|
{
|
||||||
DenseArray.Clear();
|
Components.Clear();
|
||||||
for (var i = 0; i < SparseArray.Capacity; i += 1)
|
EntityIDs.Clear();
|
||||||
{
|
EntityIDToStorageIndex.Clear();
|
||||||
SparseArray[i] = Entity.Null.ID;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public Entity FirstEntity()
|
public Entity FirstEntity()
|
||||||
{
|
{
|
||||||
#if DEBUG
|
#if DEBUG
|
||||||
if (DenseArray.Count == 0)
|
if (EntityIDs.Count == 0)
|
||||||
{
|
{
|
||||||
throw new IndexOutOfRangeException("Component storage is empty!");
|
throw new IndexOutOfRangeException("Component storage is empty!");
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
return DenseArray[0];
|
return EntityIDs[0];
|
||||||
}
|
}
|
||||||
|
|
||||||
#if DEBUG
|
#if DEBUG
|
||||||
internal Span<Entity> Debug_GetEntities()
|
internal IEnumerable<Entity> Debug_GetEntities()
|
||||||
{
|
{
|
||||||
return DenseArray.ToSpan();
|
return EntityIDToStorageIndex.Keys;
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
protected unsafe virtual void Dispose(bool disposing)
|
protected virtual void Dispose(bool disposing)
|
||||||
{
|
{
|
||||||
if (!IsDisposed)
|
if (!IsDisposed)
|
||||||
{
|
{
|
||||||
if (disposing)
|
Components.Dispose();
|
||||||
{
|
EntityIDs.Dispose();
|
||||||
DenseArray.Dispose();
|
|
||||||
SparseArray.Dispose();
|
|
||||||
}
|
|
||||||
|
|
||||||
NativeMemory.Free((void*) ElementArray);
|
|
||||||
|
|
||||||
IsDisposed = true;
|
IsDisposed = true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ~ComponentStorage()
|
||||||
|
// {
|
||||||
|
// // Do not change this code. Put cleanup code in 'Dispose(bool disposing)' method
|
||||||
|
// Dispose(disposing: false);
|
||||||
|
// }
|
||||||
|
|
||||||
public void Dispose()
|
public void Dispose()
|
||||||
{
|
{
|
||||||
// Do not change this code. Put cleanup code in 'Dispose(bool disposing)' method
|
// Do not change this code. Put cleanup code in 'Dispose(bool disposing)' method
|
||||||
|
|
|
@ -11,7 +11,7 @@ public abstract class DebugSystem : System
|
||||||
protected DebugSystem(World world) : base(world) { }
|
protected DebugSystem(World world) : base(world) { }
|
||||||
|
|
||||||
protected World.ComponentTypeEnumerator Debug_GetAllComponentTypes(Entity entity) => World.Debug_GetAllComponentTypes(entity);
|
protected World.ComponentTypeEnumerator Debug_GetAllComponentTypes(Entity entity) => World.Debug_GetAllComponentTypes(entity);
|
||||||
protected Span<Entity> Debug_GetEntities(Type componentType) => World.Debug_GetEntities(componentType);
|
protected IEnumerable<Entity> Debug_GetEntities(Type componentType) => World.Debug_GetEntities(componentType);
|
||||||
protected IEnumerable<Type> Debug_SearchComponentType(string typeString) => World.Debug_SearchComponentType(typeString);
|
protected IEnumerable<Type> Debug_SearchComponentType(string typeString) => World.Debug_SearchComponentType(typeString);
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
|
|
|
@ -1,6 +1,3 @@
|
||||||
namespace MoonTools.ECS;
|
namespace MoonTools.ECS;
|
||||||
|
|
||||||
public readonly record struct Entity(int ID)
|
public readonly record struct Entity(uint ID);
|
||||||
{
|
|
||||||
public static readonly Entity Null = new Entity(int.MaxValue);
|
|
||||||
}
|
|
||||||
|
|
|
@ -5,12 +5,12 @@ namespace MoonTools.ECS;
|
||||||
|
|
||||||
internal class IdAssigner : IDisposable
|
internal class IdAssigner : IDisposable
|
||||||
{
|
{
|
||||||
int Next = 0;
|
uint Next;
|
||||||
NativeArray<int> AvailableIds = new NativeArray<int>();
|
NativeArray<uint> AvailableIds = new NativeArray<uint>();
|
||||||
|
|
||||||
private bool IsDisposed;
|
private bool IsDisposed;
|
||||||
|
|
||||||
public int Assign()
|
public uint Assign()
|
||||||
{
|
{
|
||||||
if (AvailableIds.TryPop(out var id))
|
if (AvailableIds.TryPop(out var id))
|
||||||
{
|
{
|
||||||
|
@ -22,7 +22,7 @@ internal class IdAssigner : IDisposable
|
||||||
return id;
|
return id;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void Unassign(int id)
|
public void Unassign(uint id)
|
||||||
{
|
{
|
||||||
AvailableIds.Append(id);
|
AvailableIds.Append(id);
|
||||||
}
|
}
|
||||||
|
@ -46,6 +46,13 @@ internal class IdAssigner : IDisposable
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// // TODO: override finalizer only if 'Dispose(bool disposing)' has code to free unmanaged resources
|
||||||
|
// ~IdAssigner()
|
||||||
|
// {
|
||||||
|
// // Do not change this code. Put cleanup code in 'Dispose(bool disposing)' method
|
||||||
|
// Dispose(disposing: false);
|
||||||
|
// }
|
||||||
|
|
||||||
public void Dispose()
|
public void Dispose()
|
||||||
{
|
{
|
||||||
// Do not change this code. Put cleanup code in 'Dispose(bool disposing)' method
|
// Do not change this code. Put cleanup code in 'Dispose(bool disposing)' method
|
||||||
|
|
|
@ -15,4 +15,6 @@ public abstract class Manipulator : EntityComponentReader
|
||||||
protected void Unrelate<TRelationKind>(in Entity entityA, in Entity entityB) where TRelationKind : unmanaged => World.Unrelate<TRelationKind>(entityA, entityB);
|
protected void Unrelate<TRelationKind>(in Entity entityA, in Entity entityB) where TRelationKind : unmanaged => World.Unrelate<TRelationKind>(entityA, entityB);
|
||||||
protected void UnrelateAll<TRelationKind>(in Entity entity) where TRelationKind : unmanaged => World.UnrelateAll<TRelationKind>(entity);
|
protected void UnrelateAll<TRelationKind>(in Entity entity) where TRelationKind : unmanaged => World.UnrelateAll<TRelationKind>(entity);
|
||||||
protected void Destroy(in Entity entity) => World.Destroy(entity);
|
protected void Destroy(in Entity entity) => World.Destroy(entity);
|
||||||
|
|
||||||
|
protected void Send<TMessage>(in TMessage message) where TMessage : unmanaged => World.Send(message);
|
||||||
}
|
}
|
||||||
|
|
|
@ -39,7 +39,7 @@ public static class RandomManager
|
||||||
x = Primes[Random.Next(Primes.Length - 1)];
|
x = Primes[Random.Next(Primes.Length - 1)];
|
||||||
}
|
}
|
||||||
|
|
||||||
return new LinearCongruentialEnumerator(Random.Next(n), x, n);
|
return new LinearCongruentialEnumerator(Random.Next(n + 1), x, n);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -65,7 +65,7 @@ public struct LinearCongruentialEnumerator
|
||||||
public bool MoveNext()
|
public bool MoveNext()
|
||||||
{
|
{
|
||||||
current += 1;
|
current += 1;
|
||||||
if (current < start + count)
|
if (current <= start + count)
|
||||||
{
|
{
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
123
src/Snapshot.cs
123
src/Snapshot.cs
|
@ -1,7 +1,6 @@
|
||||||
using System;
|
using System;
|
||||||
using System.Collections.Generic;
|
using System.Collections.Generic;
|
||||||
using System.Runtime.CompilerServices;
|
using System.Runtime.CompilerServices;
|
||||||
using System.Runtime.InteropServices;
|
|
||||||
using MoonTools.ECS.Collections;
|
using MoonTools.ECS.Collections;
|
||||||
|
|
||||||
namespace MoonTools.ECS;
|
namespace MoonTools.ECS;
|
||||||
|
@ -16,11 +15,11 @@ public class Snapshot : IDisposable
|
||||||
|
|
||||||
private List<RelationSnapshot> RelationSnapshots = new List<RelationSnapshot>();
|
private List<RelationSnapshot> RelationSnapshots = new List<RelationSnapshot>();
|
||||||
|
|
||||||
private Dictionary<Entity, IndexableSet<TypeId>> EntityRelationIndex =
|
private List<IndexableSet<TypeId>> EntityRelationIndex =
|
||||||
new Dictionary<Entity, IndexableSet<TypeId>>();
|
new List<IndexableSet<TypeId>>();
|
||||||
|
|
||||||
private Dictionary<Entity, IndexableSet<TypeId>> EntityComponentIndex =
|
private List<IndexableSet<TypeId>> EntityComponentIndex =
|
||||||
new Dictionary<Entity, IndexableSet<TypeId>>();
|
new List<IndexableSet<TypeId>>();
|
||||||
|
|
||||||
private List<string> EntityTags = new List<string>();
|
private List<string> EntityTags = new List<string>();
|
||||||
|
|
||||||
|
@ -61,7 +60,7 @@ public class Snapshot : IDisposable
|
||||||
relationStorage.Clear();
|
relationStorage.Clear();
|
||||||
}
|
}
|
||||||
|
|
||||||
for (var i = 0; i < world.ComponentIndex.Count; i += 1)
|
for (var i = 0; i < ComponentSnapshots.Count; i += 1)
|
||||||
{
|
{
|
||||||
var componentStorage = world.ComponentIndex[i];
|
var componentStorage = world.ComponentIndex[i];
|
||||||
ComponentSnapshots[i].Restore(componentStorage);
|
ComponentSnapshots[i].Restore(componentStorage);
|
||||||
|
@ -77,40 +76,43 @@ public class Snapshot : IDisposable
|
||||||
// restore entity relation index state
|
// restore entity relation index state
|
||||||
// FIXME: arghhhh this is so slow
|
// FIXME: arghhhh this is so slow
|
||||||
|
|
||||||
foreach (var (id, relationTypeSet) in world.EntityRelationIndex)
|
foreach (var relationTypeSet in world.EntityRelationIndex)
|
||||||
{
|
{
|
||||||
relationTypeSet.Clear();
|
relationTypeSet.Clear();
|
||||||
}
|
}
|
||||||
|
|
||||||
foreach (var (id, relationTypeSet) in EntityRelationIndex)
|
for (var i = 0; i < EntityRelationIndex.Count; i += 1)
|
||||||
{
|
{
|
||||||
|
var relationTypeSet = EntityRelationIndex[i];
|
||||||
|
|
||||||
foreach (var typeId in relationTypeSet)
|
foreach (var typeId in relationTypeSet)
|
||||||
{
|
{
|
||||||
world.EntityRelationIndex[id].Add(typeId);
|
world.EntityRelationIndex[i].Add(typeId);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// restore entity component index state
|
// restore entity component index state
|
||||||
// FIXME: arrghghhh this is so slow
|
// FIXME: arrghghhh this is so slow
|
||||||
|
|
||||||
foreach (var (id, componentTypeSet) in world.EntityComponentIndex)
|
foreach (var componentTypeSet in world.EntityComponentIndex)
|
||||||
{
|
{
|
||||||
componentTypeSet.Clear();
|
componentTypeSet.Clear();
|
||||||
}
|
}
|
||||||
|
|
||||||
foreach (var (id, componentTypeSet) in EntityComponentIndex)
|
for (var i = 0; i < EntityComponentIndex.Count; i += 1)
|
||||||
{
|
{
|
||||||
|
var componentTypeSet = EntityComponentIndex[i];
|
||||||
|
|
||||||
foreach (var typeId in componentTypeSet)
|
foreach (var typeId in componentTypeSet)
|
||||||
{
|
{
|
||||||
world.EntityComponentIndex[id].Add(typeId);
|
world.EntityComponentIndex[i].Add(typeId);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// restore entity tags
|
// restore entity tags
|
||||||
world.EntityTags.Clear();
|
for (var i = 0; i < EntityTags.Count; i += 1)
|
||||||
foreach (var s in EntityTags)
|
|
||||||
{
|
{
|
||||||
world.EntityTags.Add(s);
|
world.EntityTags[i] = EntityTags[i];
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -147,37 +149,39 @@ public class Snapshot : IDisposable
|
||||||
RelationSnapshots[i].Take(world.RelationIndex[i]);
|
RelationSnapshots[i].Take(world.RelationIndex[i]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// fill in missing index structures
|
||||||
|
|
||||||
|
for (var i = EntityComponentIndex.Count; i < world.EntityComponentIndex.Count; i += 1)
|
||||||
|
{
|
||||||
|
EntityComponentIndex.Add(new IndexableSet<TypeId>());
|
||||||
|
}
|
||||||
|
|
||||||
|
for (var i = EntityRelationIndex.Count; i < world.EntityRelationIndex.Count; i += 1)
|
||||||
|
{
|
||||||
|
EntityRelationIndex.Add(new IndexableSet<TypeId>());
|
||||||
|
}
|
||||||
|
|
||||||
// copy entity relation index
|
// copy entity relation index
|
||||||
// FIXME: arghhhh this is so slow
|
// FIXME: arghhhh this is so slow
|
||||||
foreach (var (id, relationTypeSet) in world.EntityRelationIndex)
|
for (var i = 0; i < world.EntityRelationIndex.Count; i += 1)
|
||||||
{
|
{
|
||||||
if (!EntityRelationIndex.ContainsKey(id))
|
EntityRelationIndex[i].Clear();
|
||||||
{
|
|
||||||
EntityRelationIndex.Add(id, new IndexableSet<TypeId>());
|
|
||||||
}
|
|
||||||
|
|
||||||
EntityRelationIndex[id].Clear();
|
foreach (var typeId in world.EntityRelationIndex[i])
|
||||||
|
|
||||||
foreach (var typeId in relationTypeSet)
|
|
||||||
{
|
{
|
||||||
EntityRelationIndex[id].Add(typeId);
|
EntityRelationIndex[i].Add(typeId);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// copy entity component index
|
// copy entity component index
|
||||||
// FIXME: arghhhh this is so slow
|
// FIXME: arghhhh this is so slow
|
||||||
foreach (var (id, componentTypeSet) in world.EntityComponentIndex)
|
for (var i = 0; i < world.EntityComponentIndex.Count; i += 1)
|
||||||
{
|
{
|
||||||
if (!EntityComponentIndex.ContainsKey(id))
|
EntityComponentIndex[i].Clear();
|
||||||
{
|
|
||||||
EntityComponentIndex.Add(id, new IndexableSet<TypeId>());
|
|
||||||
}
|
|
||||||
|
|
||||||
EntityComponentIndex[id].Clear();
|
foreach (var typeId in world.EntityComponentIndex[i])
|
||||||
|
|
||||||
foreach (var typeId in componentTypeSet)
|
|
||||||
{
|
{
|
||||||
EntityComponentIndex[id].Add(typeId);
|
EntityComponentIndex[i].Add(typeId);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -207,51 +211,46 @@ public class Snapshot : IDisposable
|
||||||
|
|
||||||
private class ComponentSnapshot : IDisposable
|
private class ComponentSnapshot : IDisposable
|
||||||
{
|
{
|
||||||
private readonly NativeArray<Entity> DenseArray;
|
private readonly NativeArray Components;
|
||||||
private readonly NativeArray<int> SparseArray;
|
private readonly NativeArray<Entity> EntityIDs;
|
||||||
private nint ElementArray;
|
|
||||||
private int ElementArrayCapacity;
|
|
||||||
|
|
||||||
private bool IsDisposed;
|
private bool IsDisposed;
|
||||||
|
|
||||||
public unsafe ComponentSnapshot(int elementSize)
|
public ComponentSnapshot(int elementSize)
|
||||||
{
|
{
|
||||||
ElementArray = (nint) NativeMemory.Alloc((nuint) (16 * elementSize));
|
Components = new NativeArray(elementSize);
|
||||||
DenseArray = new NativeArray<Entity>(elementSize);
|
EntityIDs = new NativeArray<Entity>();
|
||||||
SparseArray = new NativeArray<int>(elementSize);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public unsafe void Take(ComponentStorage componentStorage)
|
public void Take(ComponentStorage componentStorage)
|
||||||
{
|
{
|
||||||
componentStorage.DenseArray.CopyTo(DenseArray);
|
componentStorage.Components.CopyAllTo(Components);
|
||||||
componentStorage.SparseArray.CopyTo(SparseArray);
|
componentStorage.EntityIDs.CopyTo(EntityIDs);
|
||||||
if (componentStorage.ElementArrayCapacity > ElementArrayCapacity)
|
}
|
||||||
|
|
||||||
|
public void Restore(ComponentStorage componentStorage)
|
||||||
|
{
|
||||||
|
Components.CopyAllTo(componentStorage.Components);
|
||||||
|
EntityIDs.CopyTo(componentStorage.EntityIDs);
|
||||||
|
|
||||||
|
componentStorage.EntityIDToStorageIndex.Clear();
|
||||||
|
for (int i = 0; i < EntityIDs.Count; i += 1)
|
||||||
{
|
{
|
||||||
ElementArrayCapacity = componentStorage.ElementArrayCapacity;
|
var entityID = EntityIDs[i];
|
||||||
NativeMemory.Realloc((void*) ElementArray, (nuint) (componentStorage.ElementSize * ElementArrayCapacity));
|
componentStorage.EntityIDToStorageIndex[entityID] = i;
|
||||||
}
|
}
|
||||||
NativeMemory.Copy((void*) componentStorage.ElementArray, (void*) ElementArray, (nuint) (ElementArrayCapacity * componentStorage.ElementSize));
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public unsafe void Restore(ComponentStorage componentStorage)
|
protected virtual void Dispose(bool disposing)
|
||||||
{
|
|
||||||
DenseArray.CopyTo(componentStorage.DenseArray);
|
|
||||||
SparseArray.CopyTo(componentStorage.SparseArray);
|
|
||||||
NativeMemory.Copy((void*) ElementArray, (void*) componentStorage.ElementArray, (nuint) (ElementArrayCapacity * componentStorage.ElementSize));
|
|
||||||
}
|
|
||||||
|
|
||||||
protected unsafe virtual void Dispose(bool disposing)
|
|
||||||
{
|
{
|
||||||
if (!IsDisposed)
|
if (!IsDisposed)
|
||||||
{
|
{
|
||||||
if (disposing)
|
if (disposing)
|
||||||
{
|
{
|
||||||
DenseArray.Dispose();
|
Components.Dispose();
|
||||||
SparseArray.Dispose();
|
EntityIDs.Dispose();
|
||||||
}
|
}
|
||||||
|
|
||||||
NativeMemory.Free((void*) ElementArray);
|
|
||||||
|
|
||||||
IsDisposed = true;
|
IsDisposed = true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -353,12 +352,12 @@ public class Snapshot : IDisposable
|
||||||
relationSnapshot.Dispose();
|
relationSnapshot.Dispose();
|
||||||
}
|
}
|
||||||
|
|
||||||
foreach (var componentSet in EntityComponentIndex.Values)
|
foreach (var componentSet in EntityComponentIndex)
|
||||||
{
|
{
|
||||||
componentSet.Dispose();
|
componentSet.Dispose();
|
||||||
}
|
}
|
||||||
|
|
||||||
foreach (var relationSet in EntityRelationIndex.Values)
|
foreach (var relationSet in EntityRelationIndex)
|
||||||
{
|
{
|
||||||
relationSet.Dispose();
|
relationSet.Dispose();
|
||||||
}
|
}
|
||||||
|
|
|
@ -16,12 +16,12 @@ public readonly record struct TypeId(uint Value) : IComparable<TypeId>
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public class ComponentTypeIdAssigner
|
internal class ComponentTypeIdAssigner
|
||||||
{
|
{
|
||||||
protected static ushort Counter;
|
protected static ushort Counter;
|
||||||
}
|
}
|
||||||
|
|
||||||
public class ComponentTypeIdAssigner<T> : ComponentTypeIdAssigner
|
internal class ComponentTypeIdAssigner<T> : ComponentTypeIdAssigner
|
||||||
{
|
{
|
||||||
public static readonly ushort Id;
|
public static readonly ushort Id;
|
||||||
public static readonly int Size;
|
public static readonly int Size;
|
||||||
|
@ -41,12 +41,12 @@ public class ComponentTypeIdAssigner<T> : ComponentTypeIdAssigner
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public class RelationTypeIdAssigner
|
internal class RelationTypeIdAssigner
|
||||||
{
|
{
|
||||||
protected static ushort Counter;
|
protected static ushort Counter;
|
||||||
}
|
}
|
||||||
|
|
||||||
public class RelationTypeIdAssigner<T> : RelationTypeIdAssigner
|
internal class RelationTypeIdAssigner<T> : RelationTypeIdAssigner
|
||||||
{
|
{
|
||||||
public static readonly ushort Id;
|
public static readonly ushort Id;
|
||||||
public static readonly int Size;
|
public static readonly int Size;
|
||||||
|
@ -61,12 +61,12 @@ public class RelationTypeIdAssigner<T> : RelationTypeIdAssigner
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public class MessageTypeIdAssigner
|
internal class MessageTypeIdAssigner
|
||||||
{
|
{
|
||||||
protected static ushort Counter;
|
protected static ushort Counter;
|
||||||
}
|
}
|
||||||
|
|
||||||
public class MessageTypeIdAssigner<T> : MessageTypeIdAssigner
|
internal class MessageTypeIdAssigner<T> : MessageTypeIdAssigner
|
||||||
{
|
{
|
||||||
public static readonly ushort Id;
|
public static readonly ushort Id;
|
||||||
public static readonly int Size;
|
public static readonly int Size;
|
||||||
|
|
67
src/World.cs
67
src/World.cs
|
@ -3,6 +3,10 @@ using System.Collections.Generic;
|
||||||
using System.Runtime.CompilerServices;
|
using System.Runtime.CompilerServices;
|
||||||
using MoonTools.ECS.Collections;
|
using MoonTools.ECS.Collections;
|
||||||
|
|
||||||
|
#if DEBUG
|
||||||
|
using System.Reflection;
|
||||||
|
#endif
|
||||||
|
|
||||||
namespace MoonTools.ECS;
|
namespace MoonTools.ECS;
|
||||||
|
|
||||||
public class World : IDisposable
|
public class World : IDisposable
|
||||||
|
@ -26,7 +30,7 @@ public class World : IDisposable
|
||||||
|
|
||||||
// Relation Storages
|
// Relation Storages
|
||||||
internal List<RelationStorage> RelationIndex = new List<RelationStorage>();
|
internal List<RelationStorage> RelationIndex = new List<RelationStorage>();
|
||||||
internal Dictionary<Entity, IndexableSet<TypeId>> EntityRelationIndex = new Dictionary<Entity, IndexableSet<TypeId>>();
|
internal List<IndexableSet<TypeId>> EntityRelationIndex = new List<IndexableSet<TypeId>>();
|
||||||
|
|
||||||
// Message Storages
|
// Message Storages
|
||||||
private List<MessageStorage> MessageIndex = new List<MessageStorage>();
|
private List<MessageStorage> MessageIndex = new List<MessageStorage>();
|
||||||
|
@ -34,7 +38,7 @@ public class World : IDisposable
|
||||||
public FilterBuilder FilterBuilder => new FilterBuilder(this);
|
public FilterBuilder FilterBuilder => new FilterBuilder(this);
|
||||||
|
|
||||||
internal readonly List<ComponentStorage> ComponentIndex = new List<ComponentStorage>();
|
internal readonly List<ComponentStorage> ComponentIndex = new List<ComponentStorage>();
|
||||||
internal Dictionary<Entity, IndexableSet<TypeId>> EntityComponentIndex = new Dictionary<Entity, IndexableSet<TypeId>>();
|
internal List<IndexableSet<TypeId>> EntityComponentIndex = new List<IndexableSet<TypeId>>();
|
||||||
|
|
||||||
internal IdAssigner EntityIdAssigner = new IdAssigner();
|
internal IdAssigner EntityIdAssigner = new IdAssigner();
|
||||||
|
|
||||||
|
@ -51,7 +55,8 @@ public class World : IDisposable
|
||||||
// add missing storages, it's possible for there to be multiples in multi-world scenarios
|
// add missing storages, it's possible for there to be multiples in multi-world scenarios
|
||||||
for (var i = ComponentIndex.Count; i <= typeId; i += 1)
|
for (var i = ComponentIndex.Count; i <= typeId; i += 1)
|
||||||
{
|
{
|
||||||
var componentStorage = new ComponentStorage(ComponentTypeElementSizes[i]);
|
var missingTypeId = new TypeId((uint) i);
|
||||||
|
var componentStorage = new ComponentStorage(missingTypeId, ComponentTypeElementSizes[i]);
|
||||||
ComponentIndex.Add(componentStorage);
|
ComponentIndex.Add(componentStorage);
|
||||||
ComponentTypeToFilter.Add(new List<Filter>());
|
ComponentTypeToFilter.Add(new List<Filter>());
|
||||||
}
|
}
|
||||||
|
@ -96,10 +101,10 @@ public class World : IDisposable
|
||||||
{
|
{
|
||||||
var entity = new Entity(EntityIdAssigner.Assign());
|
var entity = new Entity(EntityIdAssigner.Assign());
|
||||||
|
|
||||||
if (!EntityComponentIndex.ContainsKey(entity))
|
if (entity.ID == EntityComponentIndex.Count)
|
||||||
{
|
{
|
||||||
EntityRelationIndex.Add(entity, new IndexableSet<TypeId>());
|
EntityRelationIndex.Add(new IndexableSet<TypeId>());
|
||||||
EntityComponentIndex.Add(entity, new IndexableSet<TypeId>());
|
EntityComponentIndex.Add(new IndexableSet<TypeId>());
|
||||||
EntityTags.Add(tag);
|
EntityTags.Add(tag);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -118,8 +123,11 @@ public class World : IDisposable
|
||||||
|
|
||||||
public void Destroy(in Entity entity)
|
public void Destroy(in Entity entity)
|
||||||
{
|
{
|
||||||
|
var componentSet = EntityComponentIndex[(int) entity.ID];
|
||||||
|
var relationSet = EntityRelationIndex[(int) entity.ID];
|
||||||
|
|
||||||
// remove all components from storages
|
// remove all components from storages
|
||||||
foreach (var componentTypeIndex in EntityComponentIndex[entity])
|
foreach (var componentTypeIndex in componentSet)
|
||||||
{
|
{
|
||||||
var componentStorage = ComponentIndex[componentTypeIndex];
|
var componentStorage = ComponentIndex[componentTypeIndex];
|
||||||
componentStorage.Remove(entity);
|
componentStorage.Remove(entity);
|
||||||
|
@ -131,29 +139,32 @@ public class World : IDisposable
|
||||||
}
|
}
|
||||||
|
|
||||||
// remove all relations from storage
|
// remove all relations from storage
|
||||||
foreach (var relationTypeIndex in EntityRelationIndex[entity])
|
foreach (var relationTypeIndex in relationSet)
|
||||||
{
|
{
|
||||||
var relationStorage = RelationIndex[relationTypeIndex];
|
var relationStorage = RelationIndex[relationTypeIndex];
|
||||||
relationStorage.RemoveEntity(entity);
|
relationStorage.RemoveEntity(entity);
|
||||||
}
|
}
|
||||||
|
|
||||||
EntityComponentIndex[entity].Clear();
|
componentSet.Clear();
|
||||||
EntityRelationIndex[entity].Clear();
|
relationSet.Clear();
|
||||||
|
|
||||||
// recycle ID
|
// recycle ID
|
||||||
EntityIdAssigner.Unassign(entity.ID);
|
EntityIdAssigner.Unassign(entity.ID);
|
||||||
|
|
||||||
|
EntityTags[(int) entity.ID] = "";
|
||||||
}
|
}
|
||||||
|
|
||||||
// COMPONENTS
|
// COMPONENTS
|
||||||
|
|
||||||
public bool Has<T>(in Entity entity) where T : unmanaged
|
public bool Has<T>(in Entity entity) where T : unmanaged
|
||||||
{
|
{
|
||||||
return GetComponentStorage<T>().Has(entity);
|
var storage = GetComponentStorage<T>();
|
||||||
|
return storage.Has(entity);
|
||||||
}
|
}
|
||||||
|
|
||||||
internal bool Has(in Entity entity, in TypeId typeId)
|
internal bool Has(in Entity entity, in TypeId typeId)
|
||||||
{
|
{
|
||||||
return ComponentIndex[(int) typeId.Value].Has(entity);
|
return EntityComponentIndex[(int) entity.ID].Contains(typeId);
|
||||||
}
|
}
|
||||||
|
|
||||||
public bool Some<T>() where T : unmanaged
|
public bool Some<T>() where T : unmanaged
|
||||||
|
@ -183,13 +194,12 @@ public class World : IDisposable
|
||||||
public void Set<T>(in Entity entity, in T component) where T : unmanaged
|
public void Set<T>(in Entity entity, in T component) where T : unmanaged
|
||||||
{
|
{
|
||||||
var componentStorage = GetComponentStorage<T>();
|
var componentStorage = GetComponentStorage<T>();
|
||||||
var typeId = new TypeId(ComponentTypeIdAssigner<T>.Id);
|
|
||||||
|
|
||||||
if (!componentStorage.Set(entity, component))
|
if (!componentStorage.Set(entity, component))
|
||||||
{
|
{
|
||||||
EntityComponentIndex[entity].Add(typeId);
|
EntityComponentIndex[(int) entity.ID].Add(componentStorage.TypeId);
|
||||||
|
|
||||||
foreach (var filter in ComponentTypeToFilter[typeId])
|
foreach (var filter in ComponentTypeToFilter[componentStorage.TypeId])
|
||||||
{
|
{
|
||||||
filter.Check(entity);
|
filter.Check(entity);
|
||||||
}
|
}
|
||||||
|
@ -199,13 +209,12 @@ public class World : IDisposable
|
||||||
public void Remove<T>(in Entity entity) where T : unmanaged
|
public void Remove<T>(in Entity entity) where T : unmanaged
|
||||||
{
|
{
|
||||||
var componentStorage = GetComponentStorage<T>();
|
var componentStorage = GetComponentStorage<T>();
|
||||||
var typeId = new TypeId(ComponentTypeIdAssigner<T>.Id);
|
|
||||||
|
|
||||||
if (componentStorage.Remove(entity))
|
if (componentStorage.Remove(entity))
|
||||||
{
|
{
|
||||||
EntityComponentIndex[entity].Remove(typeId);
|
EntityComponentIndex[(int) entity.ID].Remove(componentStorage.TypeId);
|
||||||
|
|
||||||
foreach (var filter in ComponentTypeToFilter[typeId])
|
foreach (var filter in ComponentTypeToFilter[componentStorage.TypeId])
|
||||||
{
|
{
|
||||||
filter.Check(entity);
|
filter.Check(entity);
|
||||||
}
|
}
|
||||||
|
@ -235,8 +244,8 @@ public class World : IDisposable
|
||||||
{
|
{
|
||||||
var relationStorage = GetRelationStorage<T>();
|
var relationStorage = GetRelationStorage<T>();
|
||||||
relationStorage.Set(entityA, entityB, relation);
|
relationStorage.Set(entityA, entityB, relation);
|
||||||
EntityRelationIndex[entityA].Add(new TypeId(RelationTypeIdAssigner<T>.Id));
|
EntityRelationIndex[(int) entityA.ID].Add(new TypeId(RelationTypeIdAssigner<T>.Id));
|
||||||
EntityRelationIndex[entityB].Add(new TypeId(RelationTypeIdAssigner<T>.Id));
|
EntityRelationIndex[(int) entityB.ID].Add(new TypeId(RelationTypeIdAssigner<T>.Id));
|
||||||
}
|
}
|
||||||
|
|
||||||
public void Unrelate<T>(in Entity entityA, in Entity entityB) where T : unmanaged
|
public void Unrelate<T>(in Entity entityA, in Entity entityB) where T : unmanaged
|
||||||
|
@ -388,13 +397,15 @@ public class World : IDisposable
|
||||||
#if DEBUG
|
#if DEBUG
|
||||||
public ComponentTypeEnumerator Debug_GetAllComponentTypes(Entity entity)
|
public ComponentTypeEnumerator Debug_GetAllComponentTypes(Entity entity)
|
||||||
{
|
{
|
||||||
return new ComponentTypeEnumerator(this, EntityComponentIndex[entity]);
|
return new ComponentTypeEnumerator(this, EntityComponentIndex[(int) entity.ID]);
|
||||||
}
|
}
|
||||||
|
|
||||||
public Span<Entity> Debug_GetEntities(Type componentType)
|
public IEnumerable<Entity> Debug_GetEntities(Type componentType)
|
||||||
{
|
{
|
||||||
var storage = ComponentIndex[ComponentTypeToId[componentType]];
|
var baseGetComponentStorageMethod = typeof(World).GetMethod(nameof(World.GetComponentStorage), BindingFlags.NonPublic | BindingFlags.Instance)!;
|
||||||
return storage.Debug_GetEntities();
|
var genericGetComponentStorageMethod = baseGetComponentStorageMethod.MakeGenericMethod(componentType);
|
||||||
|
var storage = genericGetComponentStorageMethod.Invoke(this, null) as ComponentStorage;
|
||||||
|
return storage!.Debug_GetEntities();
|
||||||
}
|
}
|
||||||
|
|
||||||
public IEnumerable<Type> Debug_SearchComponentType(string typeString)
|
public IEnumerable<Type> Debug_SearchComponentType(string typeString)
|
||||||
|
@ -457,14 +468,14 @@ public class World : IDisposable
|
||||||
messageStorage.Dispose();
|
messageStorage.Dispose();
|
||||||
}
|
}
|
||||||
|
|
||||||
foreach (var typeSet in EntityComponentIndex.Values)
|
foreach (var componentSet in EntityComponentIndex)
|
||||||
{
|
{
|
||||||
typeSet.Dispose();
|
componentSet.Dispose();
|
||||||
}
|
}
|
||||||
|
|
||||||
foreach (var typeSet in EntityRelationIndex.Values)
|
foreach (var relationSet in EntityRelationIndex)
|
||||||
{
|
{
|
||||||
typeSet.Dispose();
|
relationSet.Dispose();
|
||||||
}
|
}
|
||||||
|
|
||||||
foreach (var filter in FilterIndex.Values)
|
foreach (var filter in FilterIndex.Values)
|
||||||
|
|
Loading…
Reference in New Issue