bubel-ecs/tests/tests.d

800 lines
16 KiB
D

module tests.tests;
/*
import std.experimental.allocator;
import std.experimental.allocator.mallocator;*/
import ecs.entity;
import ecs.events;
import ecs.manager;
import ecs.system;
import ecs.attributes;
import ecs.core;
import core.time;
import std.stdio;
version(Windows)
{
import core.sys.windows.windows;
struct Time
{
static long getUSecTime()
{
LARGE_INTEGER time, freq;
QueryPerformanceFrequency(&freq);
QueryPerformanceCounter(&time);
return time.QuadPart / (freq.QuadPart / 1000_000);
}
}
}
else version(Posix)
{
import core.sys.posix.time;
struct Time
{
static long getUSecTime()
{
time_t time;
timespec spec;
clock_gettime(CLOCK_REALTIME, &spec);
//time = spec.tv_sec;
return spec.tv_sec * 1000_000 + spec.tv_nsec / 1000;//time / 1000_000;
/*LARGE_INTEGER time, freq;
QueryPerformanceFrequency(&freq);
QueryPerformanceCounter(&time);
return time.QuadPart / (freq.QuadPart / 1000_000);*/
}
}
}
struct TestEvent
{
mixin ECS.Event; //__gshared ushort event_id;
int a;
}
struct TestEvent2
{
mixin ECS.Event; //__gshared ushort event_id;
float a;
}
static struct TestComp
{
mixin ECS.Component; //__gshared ushort component_id;
int a = 1;
ulong b = 2;
static void serializeComponent(SerializeVector output)
{
}
static void deserializeComponent(ubyte[] data)
{
}
}
static struct TestComp2
{
mixin ECS.Component; //__gshared ushort component_id;
int b = 3;
int a = 4;
static void serializeComponent(ref TestComp comp, SerializeVector output)
{
}
static void deserializeComponent(ref TestComp comp, ubyte[] data)
{
}
}
static struct TestComp3
{
mixin ECS.Component; //__gshared ushort component_id;
uint gg = 5; //good game
uint bg = 6; //bad game
void serializeComponent(SerializeVector output)
{
}
void deserializeComponent(ubyte[] data)
{
}
}
static struct TestComp4
{
mixin ECS.Component; //__gshared ushort component_id;
uint gg = 7; //good game
uint bg = 8; //bad game
ulong a = 9;
ulong b = 10;
ulong c = 11;
ulong g = 12;
static void serializeComponent(ref TestComp comp, SerializeVector output)
{
}
static void deserializeComponent(ref TestComp comp, ubyte[] data)
{
}
}
static struct TestComp5
{
mixin ECS.Component; //__gshared ushort component_id;
uint gg = 7; //good game
uint bg = 8; //bad game
ulong a = 9;
ulong b = 10;
ulong c = 11;
ulong g = 12;
static void serializeComponent(ref TestComp comp, SerializeVector output)
{
}
static void deserializeComponent(ref TestComp comp, ubyte[] data)
{
}
}
struct ChangeTestSystem
{
mixin ECS.System!16; //__gshared ushort system_id;
void onCreate()
{
//writeln("On Change Test System create.");
printf("On Change Test System create.\n");
}
void onCreate(int i)
{
//writeln("On Change Test System create.");
printf("On Change Test System create.\n");
}
void onDestroy()
{
//writeln("On Change Test System destroy.");
printf("On Change Test System destroy.\n");
}
void onAddEntity(EntitiesData data)
{
//printf("Entity added! ID: ");
foreach (i; 0 .. data.length)
printf("Entity added! ID: %u\n",data.entites[i].id);
////writeln("Entity added! ID: ", data.entites[i].id);
}
void onRemoveEntity(EntitiesData data)
{
////writeln("Entity removed! ID: ", data.entites[0].id);
printf("Entity removed! ID: %u\n",data.entites[0].id);
}
void onChangeEntity(EntitiesData data)
{
////writeln("Entity changed! ID: ", data.entites[0].id);
printf("Entity changed! ID: %u\n",data.entites[0].id);
}
bool onBegin()
{
////writeln("On Test System begin.");
return true;
}
void onEnd()
{
////writeln("On Test System end.");
}
void initialize(ref Entity entity, ref TestComp comp)
{
}
static struct EntitiesData
{
size_t length;
const(Entity)[] entites;
TestComp4[] test4;
@optional TestComp5[] test5;
}
void onUpdate(EntitiesData data)
{
foreach (i; 0 .. data.length)
{
}
}
}
struct TestSystem
{
mixin ECS.System!16; //__gshared ushort system_id;
void onCreate()
{
//writeln("On Test System create.");
printf("On Change Test System create.\n");
}
void onDestroy()
{
//writeln("On Test System destroy.");
printf("On Change Test System destroy.\n");
}
void onAddEntity(EntitiesData data)
{
//foreach(i;0..data.length)
////writeln("Entity added ID: ",data.entites[i].id.id);
}
/*
void onRemoveEntity(EntitiesData data)
{
////writeln("Entity destroyed ID: ",data.entites[0].id);
}*/
bool onBegin()
{
////writeln("On Test System begin.");
return true;
}
void onEnd()
{
////writeln("On Test System end.");
}
void initialize(ref Entity entity, ref TestComp comp)
{
}
static struct EntitiesData
{
size_t length;
const(Entity)[] entites;
TestComp[] test;
TestComp2[] test2;
@readonly @optional const(TestComp3)[] test3;
//@excluded TestComp4[] test4;
}
void onUpdate(ref Entity entity, ref TestComp test, ref TestComp2 test2) //, TestComp3* test3) //ref TestComp comp)
{
assert(cast(size_t)&test % TestComp.alignof == 0);
assert(cast(size_t)&test2 % TestComp2.alignof == 0);
import std.stdio;
test.a += 1000;
test.b += 2000;
test2.b += 2;
test2.a = 8;
}
void onUpdate(EntitiesData data)
{
foreach (i; 0 .. data.length)
{
data.test[i].a += 1000;
data.test[i].b += 2000;
data.test2[i].b += 2;
data.test2[i].a = 8;
}
}
void handleEvent(TestEvent event, ref TestComp test, ref TestComp2 test2, TestComp3* test3)
{
}
}
struct TestSystemWithHighPriority
{
mixin ECS.System!16; //__gshared ushort system_id;
static struct EntitiesData
{
TestComp[] test;
}
void initialize(ref Entity entity, ref TestComp comp)
{
int o = 1;
}
void onUpdate(EntitiesData data)
{
}
/*void handleEvent(Event event, ref TestComp comp)
{
}*/
}
struct Sys1
{
mixin ECS.System;
struct EntitiesData
{
TestComp[] comp;
}
void onAddEntity(EntitiesData data)
{
}
}
struct Sys2
{
mixin ECS.System;
struct EntitiesData
{
TestComp[] comp;
}
void onAddEntity(EntitiesData data)
{
}
}
struct Sys3
{
mixin ECS.System;
struct EntitiesData
{
TestComp[] comp;
}
void onAddEntity(EntitiesData data)
{
}
void onUpdate(EntitiesData data)
{
}
}
import std.meta;
struct TestSystem2
{
mixin ECS.System!16; //__gshared ushort system_id;
/*enum ExcludedComponents
{
TestComp,
TestComp4
}*/
//alias ExcludedComponents = AliasSeq!("TestComp", "TestComp4");
/*
string ExcludedComponents2;*/
static struct EntitiesData
{
short length;
const(Entity)[] entity;
TestComp3[] test;
//@excluded TestComp[] testt;
}
static struct EventInput
{
Entity* entity;
TestComp3* test;
//TestComp* tt;
}
/*void handleEvent(EventInput input)
{
}*/
void handleEvent(/*EventInput input, */Entity* entity, ref TestEvent event)
{
TestComp3* test = entity.getComponent!TestComp3;
test.bg = event.a;
TestEvent2 event2;
event2.a = event.a + 8;
gEM.sendEvent(entity.id, event2);
}
void handleEvent(/*EventInput input, */Entity* entity, ref TestEvent2 event)
{
TestComp3* test = entity.getComponent!TestComp3;
test.gg = cast(uint) event.a;
}
void onEnable()
{
import std.stdio;
//writeln("TestSystem2 enabled");
printf("TestSystem2 enabled\n");
}
void onDisable()
{
import std.stdio;
//writeln("TestSystem2 disabled");
printf("TestSystem2 disabled\n");
}
void initialize(ref Entity entity, ref TestComp comp)
{
}
void onUpdate(EntitiesData data)
{
foreach (i; 0 .. data.test.length)
{
data.test[i].gg += 14;
TestEvent event;
event.a = data.test[i].gg + 4;
gEM.sendEvent(data.entity[i].id, event); //*/
/*TestEvent2 event2;
event2.a = data.test[i].gg + 8;
gEM.sendEvent(data.entity[i].id, event2);//*/
//gEM.sendEvent!(TestEvent)(data.entity[i].id, event);
//gEM.sendSelfEvent!(TestEvent)(data.entity[i].id, TestEvent());
}
}
void lateUpdate(ref EntitiesData data)
{
foreach (i; 0 .. data.test.length)
{
data.test[i].gg -= 1;
//gEM.sendSelfEvent!(TestEvent)(data.entity[i].id, TestEvent());
}
}
/*void handleEvent(Event event, ref TestComp comp)
{
}*/
}
extern(C) int main()
{
void dispatch(EntityManager.JobGroup jobs) nothrow @nogc
{
foreach (job; jobs.jobs)
{
////writeln(job);
job.execute();
}
}
void writeEntityComponents(Entity* entity)
{
printf("EntityID(%u, %u)",entity.id.id,entity.id.counter);
//write(entity.id);
TestComp* test_comp = entity.getComponent!TestComp;
if (test_comp)
printf("TestComp(%u, %u)",test_comp.a,test_comp.b);//write(*test_comp);
TestComp2* test_comp2 = entity.getComponent!TestComp2;
if (test_comp2)
printf("TestComp2(%u, %u)",test_comp2.a,test_comp2.b);//write(*test_comp2);
TestComp3* test_comp3 = entity.getComponent!TestComp3;
if (test_comp3)
printf("TestComp3(%u, %u)",test_comp3.gg,test_comp3.bg);//write(*test_comp3);
TestComp4* test_comp4 = entity.getComponent!TestComp4;
if (test_comp4)
printf("TestComp4(%u, %u, %u, %u, %u, %u)",test_comp4.gg,test_comp4.bg,test_comp4.a,test_comp4.b,test_comp4.c,test_comp4.g);//write(*test_comp4);
printf("\n");
//writeln();
////writeln((cast(uint*) pp)[0 .. 14], " ", pp);
}
EntityManager.initialize(1);
gEM.setJobDispachFunc(&dispatch);
assert(gEM !is null);
gEM.beginRegister();
gEM.registerPass("fixed");
//MonoTime time = MonoTime.currTime;
long time = Time.getUSecTime();
gEM.registerComponent!TestComp2;
gEM.registerComponent!TestComp4;
gEM.registerComponent!TestComp;
gEM.registerComponent!TestComp3;
gEM.registerComponent!TestComp5;
gEM.registerEvent!TestEvent;
gEM.registerEvent!TestEvent2;
/*ulong dur = (MonoTime.currTime - time).total!"usecs";
//writeln("Components register: ", dur, " usecs");
time = MonoTime.currTime;*/
printf("Components register: %f usecs\n",cast(float)(Time.getUSecTime() - time));
time = Time.getUSecTime();
gEM.registerSystem!TestSystemWithHighPriority(100, "fixed");
gEM.registerSystem!TestSystem(0);
gEM.registerSystem!ChangeTestSystem(0);
gEM.registerSystem!Sys1(10);
gEM.registerSystem!Sys2(-100);
gEM.registerSystem!Sys3(-2);
//gEM.registerSystem!TestSystemWithHighPriority(100);
//gEM.registerSystem!TestSystem2(0);*/
gEM.endRegister();
/*dur = (MonoTime.currTime - time).total!"usecs";
//writeln("Systems register: ", dur, " usecs");
time = MonoTime.currTime;*/
printf("Systems register: %f usecs\n",cast(float)(Time.getUSecTime() - time));
time = Time.getUSecTime();
//ushort[3] ids = [TestComp2.component_id, TestComp.component_id, TestComp4.component_id];
ushort[2] ids = [TestComp2.component_id, TestComp.component_id];
EntityTemplate* tmpl = gEM.allocateTemplate(ids);
//ushort[3] ids2 = [TestComp3.component_id, TestComp.component_id, TestComp4.component_id];
ushort[2] ids2 = [TestComp3.component_id, TestComp.component_id];
EntityTemplate* tmpl2 = gEM.allocateTemplate(ids2);
////writeln(tmpl.info.components[]);
//*cast(EntityID*) tmpl.entity_data.ptr = EntityID(1, 1);
//dur = (MonoTime.currTime - time).total!"usecs";
//writeln("Template allocating: ", dur, " usecs");
printf("Template allocating: %f usecs\n",cast(float)(Time.getUSecTime() - time));
time = Time.getUSecTime();
EntityID entity;
{
entity = gEM.addEntity(tmpl).id;
writeEntityComponents(gEM.getEntity(entity));
EntityManager.EntitiesBlock* block = EntityManager.instance.getMetaData(
gEM.getEntity(entity));
EntityManager.EntityInfo* info = block.type_info;
//writeln(info.add_listeners);
//if(info)assert(0);
}
//time = MonoTime.currTime;
time = Time.getUSecTime();
//foreach(i; 0..1_000_000)gEM.addEntity(tmpl);
//foreach(i; 0..1_000_000)gEM.removeEntity(gEM.addEntity(tmpl).id);
import ecs.std;
EntityID[] idss = Mallocator.makeArray!EntityID(5000);//[5000]
//scope(exit)Mallocator.dispose(idss);
foreach (i; 0 .. 200)
{
gEM.begin();
foreach (j; 0 .. 5_000)
idss[j] = gEM.addEntity(tmpl).id;
foreach (j; 0 .. 5_000)
gEM.removeEntity(idss[j]);
gEM.end();
}
gEM.commit();
//dur = (MonoTime.currTime - time).total!"usecs";
//writeln("Entities adding: ", dur, " usecs");
printf("Entities adding: %f usecs\n",cast(float)(Time.getUSecTime() - time));
time = Time.getUSecTime();
uint blocks = 0;
foreach (info; &gEM.entities_infos.byValue)
{
EntityManager.EntitiesBlock* block = info.first_block;
while (block !is null)
{
block = block.next_block;
blocks++;
}
}
//writeln("Entities blocks: ", blocks);
printf("Entities blocks: %u\n",blocks);
//foreach(j; 0..1_000)gEM.addEntity(tmpl);
gEM.beginRegister();
gEM.registerSystem!TestSystem2(0);
gEM.endRegister();
System* sys = EntityManager.instance.getSystem(TestSystem2.system_id);
//gEM.generateDependencies();
//assert(*(cast(EntityID*)(cast(void*)tmpl.info.first_block+24)) == EntityID(1,1));
//assert(*(cast(EntityID*)(cast(void*)tmpl.info.first_block+48)) == EntityID(1,1));
EntityID entity2;
//time = MonoTime.currTime;
time = Time.getUSecTime();
EntityID[] entities = Mallocator.makeArray!EntityID(1_000_000);
foreach (i; 0 .. 500_000)
{
entity2 = gEM.addEntity(tmpl).id;
entities[i*2] = entity2;
entities[i*2+1] = gEM.addEntity(tmpl2).id;
}
gEM.commit();
//dur = (MonoTime.currTime - time).total!"usecs";
//writeln("Entities adding2: ", dur, " usecs");
//time = MonoTime.currTime;
printf("Entities adding2: %f usecs\n",cast(float)(Time.getUSecTime() - time));
time = Time.getUSecTime();
foreach (i; 0 .. 1_000_000)
{
EntityManager.instance.addComponents(entities[i],TestComp5());
if((i & 0x00FFFF) == 0)gEM.commit();
}
gEM.commit();
//dur = (MonoTime.currTime - time).total!"usecs";
//writeln("Components adding: ", dur, " usecs");
//time = MonoTime.currTime;
printf("Components adding: %f usecs\n",cast(float)(Time.getUSecTime() - time));
time = Time.getUSecTime();
foreach (i; 0 .. 1_000_000)
{
EntityManager.instance.removeComponents!TestComp5(entities[i]);
//if((i & 0x00FFFF) == 0)gEM.commit();
}
gEM.commit();
//dur = (MonoTime.currTime - time).total!"usecs";
//writeln("Components removing: ", dur, " usecs");
printf("Components removing: %f usecs\n",cast(float)(Time.getUSecTime() - time));
time = Time.getUSecTime();
Mallocator.dispose(entities);
//time = MonoTime.currTime;
time = Time.getUSecTime();
gEM.begin();
//gEM.updateMT();
gEM.update();
gEM.end();
//dur = (MonoTime.currTime - time).total!"usecs";
//writeln("Update: ", dur, " usecs");
printf("Update: %f usecs\n",cast(float)(Time.getUSecTime() - time));
writeEntityComponents(gEM.getEntity(entity2));
//time = MonoTime.currTime;
time = Time.getUSecTime();
gEM.begin();
gEM.updateMT();
//gEM.update();
gEM.end();
//dur = (MonoTime.currTime - time).total!"usecs";
//writeln("Update: ", dur, " usecs");
printf("Update: %f usecs\n",cast(float)(Time.getUSecTime() - time));
writeEntityComponents(gEM.getEntity(entity2));
//time = MonoTime.currTime;
time = Time.getUSecTime();
gEM.begin();
gEM.updateMT();
//gEM.update();
gEM.end();
//dur = (MonoTime.currTime - time).total!"usecs";
//writeln("Update: ", dur, " usecs");
printf("Update: %f usecs\n",cast(float)(Time.getUSecTime() - time));
writeEntityComponents(gEM.getEntity(entity2));
entity = gEM.addEntity(tmpl).id;
gEM.begin();
gEM.update();
gEM.end();
//Entity* pp;// = gEM.getEntity(entity.id);
////writeln((cast(uint*) pp)[0 .. 14], " ", pp);
writeEntityComponents(gEM.getEntity(entity));
//writeln("Entity, its copy, and template, and default filled tempalte");
gEM.addEntity(tmpl);
writeEntityComponents(gEM.getEntity(entity));
writeEntityComponents(gEM.addEntityCopy(entity));
EntityTemplate* copy_tempalte = gEM.allocateTemplate(entity);
writeEntityComponents(gEM.addEntity(copy_tempalte));
EntityTemplate* copy_default_tempalte = gEM.allocateTemplate(entity,true);
writeEntityComponents(gEM.addEntity(copy_default_tempalte));
gEM.addComponents(entity, TestComp4());
gEM.addComponents(entity, TestComp3());
gEM.begin();
gEM.update();
gEM.end();
writeEntityComponents(gEM.getEntity(entity));
gEM.removeComponents!(TestComp)(entity);
gEM.addComponents(entity, TestComp());
gEM.addComponents(entity, TestComp5());
gEM.begin();
gEM.update();
gEM.update("fixed");
gEM.end();
gEM.removeComponents!(TestComp4)(entity);
gEM.commit();
printf("pre end\n");
writeEntityComponents(gEM.getEntity(entity));
//import std.stdio;
////writeln((cast(uint*)tmpl.info.first_block)[0..48]);
gEM.freeTemplate(tmpl);
gEM.freeTemplate(tmpl2);
gEM.freeTemplate(copy_tempalte);
gEM.freeTemplate(copy_default_tempalte);
EntityManager.destroy();
Mallocator.dispose(idss);
printf("end\n");//*/
return 0;
}