using DCFApixels.DragonECS.Internal; using System; using System.Collections.Generic; using System.Runtime.CompilerServices; using System.Runtime.InteropServices; namespace DCFApixels.DragonECS { public interface IEcsWorld : IEcsReadonlyTable { #region Properties //private float _timeScale;//TODO реализовать собсвенныйтайм склей для разных миров public int ID { get; } public EcsPipeline Pipeline { get; } public int EntitesCount { get; } public int EntitesCapacity { get; } public EcsReadonlyGroup Entities => default; #endregion #region Entities public EcsEntity NewEntity(); public void DelEntity(EcsEntity entity); public bool EntityIsAlive(int entityID, short gen); public EcsEntity GetEntity(int entityID); public void Destroy(); #endregion #region Group internal EcsGroup GetGroupFromPool(); internal void ReleaseGroup(EcsGroup group); #endregion } public abstract class EcsWorld { internal static IEcsWorld[] Worlds = new IEcsWorld[8]; private static IntDispenser _worldIdDispenser = new IntDispenser(0); public readonly short id; protected EcsWorld(bool isIndexed) { if(isIndexed == true) { id = (short)_worldIdDispenser.GetFree(); if (id >= Worlds.Length) Array.Resize(ref Worlds, Worlds.Length << 1); Worlds[id] = (IEcsWorld)this; } else { id = -1; } } protected void Realeze() { Worlds[id] = null; _worldIdDispenser.Release(id); } } public abstract class EcsWorld : EcsWorld, IEcsWorld where TWorldArchetype : EcsWorld { private IntDispenser _entityDispenser; private int[] _denseEntities; private int _entitiesCount; private short[] _gens; //старший бит указывает на то жива ли сущьность. private EcsGroup _allEntites; //private short[] _componentCounts; //TODO private EcsPool[] _pools; private EcsNullPool _nullPool; private EcsQueryBase[] _queries; private EcsPipeline _pipeline; private List _groups; public IEcsRealationTable[] _relationTables; private readonly int _worldArchetypeID = ComponentIndexer.GetWorldId(); #region RelationTables public IEcsRealationTable GetRelationTalbe(TWorldArhetype targetWorld) where TWorldArhetype : EcsWorld { int targetID = targetWorld.ID; if (targetID <= 0) throw new ArgumentException("targetWorld.ID <= 0"); if(_relationTables.Length <= targetID) Array.Resize(ref _relationTables, targetID + 8); if (_relationTables[targetID] == null) { // _relationTables[targetID]= new EcsRelationTable } throw new NotImplementedException(); } #endregion #region RunnersCache private PoolRunnres _poolRunnres; private IEcsEntityCreate _entityCreate; private IEcsEntityDestroy _entityDestry; #endregion #region GetterMethods public ReadOnlySpan GetAllPools() => new ReadOnlySpan(_pools); public int GetComponentID() => ComponentIndexer.GetComponentId(_worldArchetypeID);////ComponentType.uniqueID; #endregion #region Internal Properties int IEcsReadonlyTable.Count => _entitiesCount; int IEcsReadonlyTable.Capacity => _denseEntities.Length; #endregion #region Properties public Type ArchetypeType => typeof(TWorldArchetype); public int ID => id; public EcsPipeline Pipeline => _pipeline; public int EntitesCount => _entitiesCount; public int EntitesCapacity => _denseEntities.Length; public EcsReadonlyGroup Entities => _allEntites.Readonly; #endregion #region Constructors public EcsWorld(EcsPipeline pipline = null) : base(true) { _pipeline = pipline ?? EcsPipeline.Empty; if (!_pipeline.IsInit) pipline.Init(); _entityDispenser = new IntDispenser(0); _nullPool = EcsNullPool.instance; _pools = new EcsPool[512]; ArrayUtility.Fill(_pools, _nullPool); _gens = new short[512]; _queries = new EcsQuery[QueryType.capacity]; _groups = new List(128); _denseEntities = new int[512]; _poolRunnres = new PoolRunnres(_pipeline); _entityCreate = _pipeline.GetRunner(); _entityDestry = _pipeline.GetRunner(); _pipeline.GetRunner>().Inject((TWorldArchetype)this); _pipeline.GetRunner>().Inject(this); _pipeline.GetRunner().OnWorldCreate(this); _allEntites = new EcsGroup(this); } #endregion #region GetPool public EcsPool GetPool() where T : struct { //int uniqueID = ComponentType.uniqueID; int uniqueID = ComponentIndexer.GetComponentId(_worldArchetypeID); if (uniqueID >= _pools.Length) { int oldCapacity = _pools.Length; Array.Resize(ref _pools, _pools.Length << 1); ArrayUtility.Fill(_pools, _nullPool, oldCapacity, oldCapacity - _pools.Length); } if (_pools[uniqueID] == _nullPool) { _pools[uniqueID] = new EcsPool(this, uniqueID, 512, _poolRunnres); } return (EcsPool)_pools[uniqueID]; } //public EcsPool UncheckedGetPool() where T : struct => (EcsPool)_pools[ComponentType.uniqueID]; #endregion #region Query public TQuery Query(out TQuery query) where TQuery : EcsQueryBase { int uniqueID = QueryType.uniqueID; if (_queries.Length < QueryType.capacity) Array.Resize(ref _queries, QueryType.capacity); if (_queries[uniqueID] == null) { _queries[uniqueID] = EcsQuery.Builder.Build(this); } query = (TQuery)_queries[uniqueID]; return query; } #endregion #region IsMaskCompatible/IsMaskCompatibleWithout [MethodImpl(MethodImplOptions.AggressiveInlining)] public bool IsMaskCompatible(int entityID) where TInc : struct, IInc { return IsMaskCompatible(EcsMaskMap.GetMask(), entityID); } [MethodImpl(MethodImplOptions.AggressiveInlining)] public bool IsMaskCompatible(int entityID) where TInc : struct, IInc where TExc : struct, IExc { return IsMaskCompatible(EcsMaskMap.GetMask(), entityID); } public bool IsMaskCompatible(EcsComponentMask mask, int entityID) { #if (DEBUG && !DISABLE_DRAGONECS_DEBUG) || !DRAGONECS_NO_SANITIZE_CHECKS if (mask.WorldArchetypeType != typeof(TWorldArchetype)) throw new EcsFrameworkException("mask.WorldArchetypeType != typeof(TTableArhetype)"); #endif for (int i = 0, iMax = mask.Inc.Length; i < iMax; i++) { if (!_pools[mask.Inc[i]].Has(entityID)) return false; } for (int i = 0, iMax = mask.Exc.Length; i < iMax; i++) { if (_pools[mask.Exc[i]].Has(entityID)) return false; } return true; } public bool IsMaskCompatibleWithout(EcsComponentMask mask, int entity, int otherComponentID) { #if (DEBUG && !DISABLE_DRAGONECS_DEBUG) || !DRAGONECS_NO_SANITIZE_CHECKS if (mask.WorldArchetypeType != typeof(TWorldArchetype)) throw new EcsFrameworkException("mask.WorldArchetypeType != typeof(TTableArhetype)"); #endif for (int i = 0, iMax = mask.Inc.Length; i < iMax; i++) { int componentID = mask.Inc[i]; if (componentID == otherComponentID || !_pools[componentID].Has(entity)) return false; } for (int i = 0, iMax = mask.Exc.Length; i < iMax; i++) { int componentID = mask.Exc[i]; if (componentID != otherComponentID && _pools[componentID].Has(entity)) return false; } return true; } #endregion #region Entity public EcsEntity NewEntity() { int entityID = _entityDispenser.GetFree(); if (_entityDispenser.LastInt >= _denseEntities.Length) Array.Resize(ref _denseEntities, _denseEntities.Length << 1); _denseEntities[_entitiesCount++] = entityID; if (_gens.Length <= entityID) { Array.Resize(ref _gens, _gens.Length << 1); foreach (var item in _groups) item.OnWorldResize(_gens.Length); foreach (var item in _pools) item.OnWorldResize(_gens.Length); } _gens[entityID] |= short.MinValue; EcsEntity entity = new EcsEntity(entityID, _gens[entityID]++, id); _entityCreate.OnEntityCreate(entity); _allEntites.Add(entityID); return entity; } public void DelEntity(EcsEntity entity) { _allEntites.Remove(entity.id); _entityDispenser.Release(entity.id); _gens[entity.id] |= short.MinValue; _entitiesCount--; _entityDestry.OnEntityDestroy(entity); } [MethodImpl(MethodImplOptions.AggressiveInlining)] public EcsEntity GetEntity(int entityID) { return new EcsEntity(entityID, _gens[entityID], id); } [MethodImpl(MethodImplOptions.AggressiveInlining)] public bool EntityIsAlive(int entityID, short gen) { return _gens[entityID] == gen; } #endregion #region Destroy public void Destroy() { _entityDispenser = null; _denseEntities = null; _gens = null; _pools = null; _nullPool = null; _queries = null; Realeze(); } public void DestryWithPipeline() { Destroy(); _pipeline.Destroy(); } #endregion #region Other void IEcsReadonlyTable.RegisterGroup(EcsGroup group) { _groups.Add(group); } #endregion #region Utils internal static class QueryType { public static int increment = 0; public static int capacity = 128; } internal static class QueryType { public static int uniqueID; static QueryType() { uniqueID = QueryType.increment++; if (QueryType.increment > QueryType.capacity) QueryType.capacity <<= 1; } } /* internal static class ComponentType { internal static int increment = 1; internal static int Capacity { get => types.Length; } internal static Type[] types = new Type[64]; } internal static class ComponentType { internal static int uniqueID; static ComponentType() { uniqueID = ComponentType.increment++; #if (DEBUG && !DISABLE_DRAGONECS_DEBUG) || !DRAGONECS_NO_SANITIZE_CHECKS if (ComponentType.increment + 1 > ushort.MaxValue) { throw new EcsFrameworkException($"No more room for new component for this {typeof(TWorldArchetype).FullName} IWorldArchetype"); } #endif if (uniqueID >= ComponentType.types.Length) { Array.Resize(ref ComponentType.types, ComponentType.types.Length << 1); } ComponentType.types[uniqueID] = typeof(T); } }*/ #endregion #region GroupsPool private Stack _pool = new Stack(64); EcsGroup IEcsWorld.GetGroupFromPool() { if (_pool.Count <= 0) { return new EcsGroup(this); } return _pool.Pop(); } void IEcsWorld.ReleaseGroup(EcsGroup group) { #if (DEBUG && !DISABLE_DEBUG) || !DRAGONECS_NO_SANITIZE_CHECKS if (group.World != this) throw new ArgumentException("groupFilter.World != this"); #endif group.Clear(); _pool.Push(group); } #endregion } [StructLayout(LayoutKind.Sequential, Pack = 8, Size = 24)] internal readonly struct PoolRunnres { public readonly IEcsComponentAdd add; public readonly IEcsComponentWrite write; public readonly IEcsComponentDel del; public PoolRunnres(EcsPipeline pipeline) { add = pipeline.GetRunner(); write = pipeline.GetRunner(); del = pipeline.GetRunner(); } } public static class ComponentIndexer { private static List resizer = new List(); private static int tokenCount = 0; private static int[] componentCounts = new int[0]; private static class World { public static int id = GetToken(); } private static int GetToken() { tokenCount++; Array.Resize(ref componentCounts, tokenCount); foreach (var item in resizer) item.Resize(tokenCount); return tokenCount - 1; } [MethodImpl(MethodImplOptions.AggressiveInlining)] public static int GetWorldId() => World.id; [MethodImpl(MethodImplOptions.AggressiveInlining)] public static int GetComponentId(int worldID) => Component.Get(worldID); private abstract class Resizer { public abstract void Resize(int size); } private sealed class Resizer : Resizer { public override void Resize(int size) => Array.Resize(ref Component.ids, size); } private static class Component { public static int[] ids; static Component() { ids = new int[tokenCount]; for (int i = 0; i < ids.Length; i++) ids[i] = -1; resizer.Add(new Resizer()); } [MethodImpl(MethodImplOptions.AggressiveInlining)] public static int Get(int token) { ref int id = ref ids[token]; if (id < 0) id = componentCounts[token]++; return id; } } } }