From cf0f27cc92f009f2491677529bc4ec6a910b3b8a Mon Sep 17 00:00:00 2001
From: peterino2 <peterlimail47@gmail.com>
Date: Sun, 26 Oct 2025 15:50:42 -0700
Subject: [PATCH] trying out the depot project

---
 CLAUDE.md                  |  17 +++++-
 depot/build.zig            |  35 +++++++++++
 depot/build.zig.zon        |  37 ++++++++++++
 depot/readme.md            |   3 +
 depot/shooterGame/main.zig |  34 +++++++++++
 engine/core/src/core.zig   |   3 +-
 engine/core/src/jobs.zig   |  37 ++++++++++--
 engine/core/src/scene.zig  |  55 ++++++++++-------
 lib/tracy/build.zig        |   2 +-
 projects/headless/main.zig | 118 ++++++++++++++++++++++++++++---------
 10 files changed, 284 insertions(+), 57 deletions(-)
 create mode 100644 depot/build.zig
 create mode 100644 depot/build.zig.zon
 create mode 100644 depot/readme.md
 create mode 100644 depot/shooterGame/main.zig

diff --git a/CLAUDE.md b/CLAUDE.md
index 2de434f..22811a3 100644
--- a/CLAUDE.md
+++ b/CLAUDE.md
@@ -114,7 +114,9 @@ This project uses git-bug for distributed bug tracking. Bug data is stored direc
 - `git bug bug show <id>` - Display bug details
 - `git bug bug comment <id>` - Add a comment to a bug
 - `git bug bug status <id>` - Display bug status
-- `git bug bug label <id> <label>` - Add a label to a bug
+- `git bug bug label new <id> <label>` - Add a label to a bug
+- `git bug bug label rm <id> <label>` - Remove a label from a bug
+- `git bug bug label <id>` - Display labels for a bug
 - `git bug bug status:open` - List only open bugs
 - `git bug pull` - Pull bug updates from remote
 - `git bug push` - Push bug updates to remote
@@ -125,4 +127,15 @@ This project uses git-bug for distributed bug tracking. Bug data is stored direc
 - Bug IDs can be abbreviated to the first few characters
 - Use labels to categorize bugs by component (e.g., `core`, `rendering`, `physics`, `build-system`)
 - Use `--non-interactive` flag for scripting
-- Keep bug descriptions factual - describe what happens, not speculation about why
\ No newline at end of file
+- Keep bug descriptions factual - describe what happens, not speculation about why
+
+### Standard Labels
+
+Use these standard labels to categorize bugs:
+
+- **Component labels**: `core`, `rendering`, `physics`, `build-system`, `platform`, `assets`, `audio`, `ui`
+- **Type labels**:
+  - `memory` - Memory allocation, leaks, or performance issues
+  - `threading` - Job system, parallelization, race conditions, or deadlocks
+  - `crash` - Application crashes or critical failures
+  - `build` - Build system or compilation issues
\ No newline at end of file
diff --git a/depot/build.zig b/depot/build.zig
new file mode 100644
index 0000000..6f53928
--- /dev/null
+++ b/depot/build.zig
@@ -0,0 +1,35 @@
+const std = @import("std");
+const Backlog = @import("Backlog");
+
+pub fn build(b: *std.Build) void {
+    const target = b.standardTargetOptions(.{});
+    const optimize = b.standardOptimizeOption(.{});
+
+    var blbuild = Backlog.init(b, .{
+        .target = target,
+        .optimize = optimize,
+        .backlogRoot = "../",
+    });
+
+    // blbuild.addDependencyInstalls(b, .ReleaseFast); //.ReleaseFast);
+    const exileMain = blbuild.program(.{
+        .name = "exileMain",
+        .desc = "A tiny shooter made with this engine.",
+        .root_source_file = b.path("src/main.zig"),
+    });
+
+    exileMain.setModuleEnabled("imgui", true);
+    exileMain.setModuleEnabled("audio", true);
+    exileMain.setModuleEnabled("physics", true);
+    exileMain.setModuleEnabled("ui", true);
+    exileMain.setModuleEnabled("sys", true);
+    exileMain.setModuleEnabled("net", true);
+
+    {
+        const exileGame = exileMain.addDynamicModule("exileGame", b.path("src/exileGame.zig"));
+
+        _ = exileGame.compileInstall();
+    }
+
+    _ = exileMain.compileInstall();
+}
diff --git a/depot/build.zig.zon b/depot/build.zig.zon
new file mode 100644
index 0000000..76e286b
--- /dev/null
+++ b/depot/build.zig.zon
@@ -0,0 +1,37 @@
+.{
+    .name = .MyProjects,
+    .version = "0.0.0",
+    .dependencies = .{
+        // Neonwood's /lib folder contains
+        // third party libraries.
+        //
+        // They can be directly accessed
+        //
+        // as well as any of the engine/ libraries
+        //
+        // in the general case though,
+
+        // engine libraries
+        .Backlog = .{ .path = "../" },
+
+
+        .SpirvReflect = .{ .path = "../lib/spirv-reflect-zig" },
+
+        .gameExtras = .{.path = "../extras/gameExtras"},
+        .videoplayer = .{.path = "../extras/videoplayer"},
+        .doomplayer = .{.path = "../extras/doomplayer"},
+        .bsp = .{.path = "../extras/bsp"},
+
+        .zphysics = .{.path = "../lib/zphysics"},
+        .spng = .{ .path = "../lib/spng" },
+        .ozz = .{ .path = "../lib/ozz" },
+        .sdl3 = .{ .path = "../lib/sdl3" },
+        .miniaudio = .{ .path = "../lib/miniaudio" },
+        .lua = .{ .path = "../lib/lua" },
+
+        .enet = .{ .path = "../lib/enet" },
+    },
+    .paths = .{
+        "",
+    },
+}
diff --git a/depot/readme.md b/depot/readme.md
new file mode 100644
index 0000000..abfbaf4
--- /dev/null
+++ b/depot/readme.md
@@ -0,0 +1,3 @@
+# studio games depot
+
+!! not for open source.
diff --git a/depot/shooterGame/main.zig b/depot/shooterGame/main.zig
new file mode 100644
index 0000000..e1e47f4
--- /dev/null
+++ b/depot/shooterGame/main.zig
@@ -0,0 +1,34 @@
+pub var NeonObjectTable = core.EngineObjectVTable.from(@This(), "main");
+
+allocator: std.mem.Allocator,
+
+pub fn init(allocator: std.mem.Allocator) !*@This() {
+    const self = try allocator.create(@This());
+    self.* = .{
+        .allocator = allocator,
+    };
+    return self;
+}
+
+pub fn prepare(self: *@This()) !void {
+    _ = self;
+    try api.loadDynamicModules();
+}
+
+pub fn tick(self: *@This(), dt: f64) void {
+    _ = self;
+    _ = dt;
+}
+
+pub fn deinit(self: *@This()) void {
+    self.allocator.destroy(self);
+}
+
+pub fn main() anyerror!void {
+    var spec = try api.getSpec("minimal");
+    _ = api.startEngine(&NeonObjectTable, &spec);
+}
+
+const std = @import("std");
+const api = @import("backlog");
+const core = api.core;
diff --git a/engine/core/src/core.zig b/engine/core/src/core.zig
index 51e5c4c..6cf4830 100644
--- a/engine/core/src/core.zig
+++ b/engine/core/src/core.zig
@@ -367,13 +367,14 @@ pub fn shutdown_module(_: std.mem.Allocator) void {
 
     ecs.shutdown();
     algorithm.destroyNameRegistry();
-    gEngine.deinit();
     gPackerFS.destroy();
     // LUA BEGIN
     // script.shutdown_lua();
     // LUA END
     console.shutdown();
     algorithm.string_pool.shutdown();
+
+    gEngine.deinit();
     return;
 }
 
diff --git a/engine/core/src/jobs.zig b/engine/core/src/jobs.zig
index d221bd8..74a6406 100644
--- a/engine/core/src/jobs.zig
+++ b/engine/core/src/jobs.zig
@@ -239,7 +239,7 @@ pub const JobWorker = struct {
 };
 
 const Src = std.builtin.SourceLocation;
-pub fn Barrier(src: Src) type {
+pub fn BarrierCV(src: Src) type {
     return struct {
         pub const Src = src;
 
@@ -248,7 +248,7 @@ pub fn Barrier(src: Src) type {
         pub var mutex: std.Thread.Mutex = .{};
         pub var cv: std.Thread.Condition = .{};
 
-        pub fn sync(threadId: u32, threadCount: u32) !void {
+        pub fn sync(threadId: u32, barrierCount: u32) !void {
             _ = threadId;
 
             mutex.lock();
@@ -256,18 +256,47 @@ pub fn Barrier(src: Src) type {
 
             count += 1;
 
-            if (count == threadCount) {
+            if (count == barrierCount) {
+                // 2 second timeout
                 count = 0;
                 generation += 1;
                 cv.broadcast();
             } else {
-                // 2 second timeout
                 try cv.timedWait(&mutex, 1000 * 1000 * 1000 * 2);
             }
         }
     };
 }
 
+pub fn BarrierSpin(src: Src) type {
+    return struct {
+        pub const Src = src;
+
+        pub var count: std.atomic.Value(u32) = std.atomic.Value(u32).init(0);
+        pub var park: std.atomic.Value(bool) = std.atomic.Value(bool).init(false);
+
+        pub fn sync(threadId: u32, barrierCount: u32) !void {
+            _ = threadId;
+
+            const c = count.fetchAdd(1, .release);
+            if(c + 1 == barrierCount)
+            {
+                park.store(true, .release);
+                while(count.load(.acquire) > 1) {}
+                _ = count.fetchSub(1, .release);
+                park.store(false, .release);
+            }
+            else 
+            {
+                while(park.load(.acquire) == false) {}
+                _ = count.fetchSub(1, .seq_cst);
+            }
+        }
+    };
+}
+
+pub const Barrier = BarrierSpin;
+
 pub const ThreadContext = struct {
     const Self = @This();
 
diff --git a/engine/core/src/scene.zig b/engine/core/src/scene.zig
index 6116d4b..810b2e8 100644
--- a/engine/core/src/scene.zig
+++ b/engine/core/src/scene.zig
@@ -56,6 +56,8 @@ pub const SceneObjectRepr = struct {
     attachmentMode: SceneAttachMode = .relative, // doesn't do anything yet, only support relative right now
     transformOverride: ?*core.Transform = null,
     lastUpdate: u32 = 0,
+
+    merge: std.atomic.Value(bool) = std.atomic.Value(bool).init(false), // set to true if we've merged already, false if we havent
 };
 
 pub const SceneObject = struct {
@@ -300,6 +302,9 @@ pub const SceneSystem = struct {
     tickCount: u32 = 0,
     sceneObjectContainer: *SceneObjectSet = undefined,
 
+    cachedOutputs: std.ArrayList(std.ArrayList(core.Transform)) = .{},
+    writeOutList: std.ArrayList(std.ArrayList(usize)) = .{},
+
     pub const Field = SceneObjectSet.Field;
     pub const FieldType = SceneObjectSet.FieldType;
 
@@ -326,16 +331,6 @@ pub const SceneSystem = struct {
             } else {}
         }
 
-        // core.engine_log("final\n{d} {d} {d} {d}\n{d} {d} {d} {d}", .{
-        //     final[0][0],
-        //     final[0][1],
-        //     final[0][2],
-        //     final[0][3],
-        //     final[1][0],
-        //     final[1][1],
-        //     final[1][2],
-        //     final[1][3],
-        // });
         repr.transform = core.zm.mul(
             core.zm.mul(
                 core.zm.mul(
@@ -347,17 +342,6 @@ pub const SceneSystem = struct {
             final,
         );
 
-        // core.engine_log("final\n{d} {d} {d} {d}\n{d} {d} {d} {d}", .{
-        //     repr.transform[0][0],
-        //     repr.transform[0][1],
-        //     repr.transform[0][2],
-        //     repr.transform[0][3],
-        //     repr.transform[1][0],
-        //     repr.transform[1][1],
-        //     repr.transform[1][2],
-        //     repr.transform[1][3],
-        // });
-
         repr.lastUpdate = self.tickCount;
     }
 
@@ -375,6 +359,8 @@ pub const SceneSystem = struct {
         }
     }
 
+    pub const MaxWorkerCount = 24;
+
     // ----- NeonObject interace ----
     pub fn init(allocator: std.mem.Allocator) !*@This() {
         const self = try allocator.create(@This());
@@ -387,9 +373,28 @@ pub const SceneSystem = struct {
         Scene.SceneObjectContainer = try SceneObjectSet.create(allocator);
         self.sceneObjectContainer = Scene.SceneObjectContainer;
 
+        for (0..MaxWorkerCount) |i| {
+            _ = i;
+            try self.cachedOutputs.append(self.allocator, .{});
+            try self.writeOutList.append(self.allocator, .{});
+        }
+
         return self;
     }
 
+    pub fn getOutputList(self: *@This(), threadId: u32) !*std.ArrayList(usize) {
+        const outputLen = self.sceneObjectContainer.denseItems(._repr).len;
+        try self.writeOutList.items[threadId].ensureTotalCapacity(self.allocator, outputLen);
+        self.writeOutList.items[threadId].shrinkRetainingCapacity(0);
+        return &self.writeOutList.items[threadId];
+    }
+
+    pub fn getOutputForWorker(self: *@This(), threadId: u32) ![]core.Transform {
+        const outputLen = self.sceneObjectContainer.denseItems(._repr).len;
+        try self.cachedOutputs.items[threadId].resize(self.allocator, outputLen);
+        return self.cachedOutputs.items[threadId].items;
+    }
+
     pub fn preTick(self: *@This(), dt: f64) !void {
         _ = dt;
         self.tickCount +%= 1;
@@ -407,9 +412,17 @@ pub const SceneSystem = struct {
     }
 
     pub fn deinit(self: *@This()) void {
+        for (self.cachedOutputs.items) |*i| {
+            i.deinit(self.allocator);
+        }
+        for (self.writeOutList.items) |*i| {
+            i.deinit(self.allocator);
+        }
         self.dynamicObjects.deinit(self.allocator);
         self.childrenArena.deinit();
         Scene.SceneObjectContainer.destroy();
+        self.cachedOutputs.deinit(self.allocator);
+        self.writeOutList.deinit(self.allocator);
         self.allocator.destroy(self);
     }
 };
diff --git a/lib/tracy/build.zig b/lib/tracy/build.zig
index 874859d..48a4734 100644
--- a/lib/tracy/build.zig
+++ b/lib/tracy/build.zig
@@ -11,7 +11,7 @@ pub fn build(b: *std.Build) void {
 
     //const tracy_enabled = b.option(bool, "tracy", "Enables tracy integration") orelse false;
 
-    const tracy_enabled: bool = true; //if (b.graph.env_map.hash_map.get("WITH_TRACY") != null) true else false;
+    const tracy_enabled: bool = false; //if (b.graph.env_map.hash_map.get("WITH_TRACY") != null) true else false;
     // if (b.graph.env_map.hash_map.get("WITH_TRACY")) |with_tracy| {
     //     tracy_enabled = with_tracy;
     // }
diff --git a/projects/headless/main.zig b/projects/headless/main.zig
index d105293..b8559e2 100644
--- a/projects/headless/main.zig
+++ b/projects/headless/main.zig
@@ -14,8 +14,7 @@ pub fn create(allocator: std.mem.Allocator) !*@This() {
 pub fn prepare(self: *@This()) !void {
     _ = self;
 
-    for(0..120_000) |i|
-    {
+    for (0..120_000) |i| {
         _ = i;
         const e = try core.createEntity();
         const x = e.addComponent(core.Scene).?;
@@ -31,7 +30,7 @@ pub fn tick(self: *@This(), dt: f64) void {
 
     const start = core.getEngineTime();
 
-    core.parallelJob(UpdateWorldTransformsJob{}, false, 10) catch unreachable;
+    core.parallelJob(UpdateWorldTransformsJob{}, false, 1) catch unreachable;
 
     // wait 10 ms
     while (core.getEngineTime() - start < 0.010) {
@@ -47,7 +46,7 @@ pub fn deinit(self: *@This()) void {
 }
 
 const Src = std.builtin.SourceLocation;
-pub fn Barrier(src: Src) type {
+pub fn BarrierCV(src: Src) type {
     return struct {
         pub const Src = src;
 
@@ -76,6 +75,32 @@ pub fn Barrier(src: Src) type {
     };
 }
 
+pub fn BarrierSpin(src: Src) type {
+    return struct {
+        pub const Src = src;
+
+        pub var count: std.atomic.Value(u32) = std.atomic.Value(u32).init(0);
+        pub var park: std.atomic.Value(bool) = std.atomic.Value(bool).init(false);
+
+        pub fn sync(threadId: u32, barrierCount: u32) !void {
+            _ = threadId;
+
+            const c = count.fetchAdd(1, .release);
+            if (c + 1 == barrierCount) {
+                park.store(true, .release);
+                while (count.load(.acquire) > 1) {}
+                _ = count.fetchSub(1, .release);
+                park.store(false, .release);
+            } else {
+                while (park.load(.acquire) == false) {}
+                _ = count.fetchSub(1, .seq_cst);
+            }
+        }
+    };
+}
+
+pub const Barrier = BarrierSpin;
+
 const MultiJob = struct {
     threadId: u32 = 0,
     threadCount: u32 = 1,
@@ -120,10 +145,10 @@ const UpdateWorldTransformsJob = struct {
         defer z.End();
         thread.barrier(@src()) catch unreachable;
 
-        var outputs: std.ArrayList(core.math.Transform) = .{};
-        var outputList: std.ArrayList(usize) = .{};
+        const outputs = core.get(core.SceneSystem).getOutputForWorker(thread.threadId) catch return;
+        const outputList = core.get(core.SceneSystem).getOutputList(thread.threadId) catch return;
 
-        self.updateTransformsHierarchy(thread, &outputs, &outputList) catch |err| switch (err) {
+        self.updateTransformsHierarchy(thread, outputs, outputList) catch |err| switch (err) {
             error.OutOfMemory => {
                 unreachable;
             },
@@ -133,43 +158,80 @@ const UpdateWorldTransformsJob = struct {
             // },
         };
 
-        // sync results of output List
-        thread.barrier(@src()) catch unreachable;
+        const denseRepr = core.Scene.SceneObjectContainer.denseItems(._repr);
 
-        // write out all results, there likely is no issue with false sharing as transforms are exactly 64 bytes
-        // const dense = self.world.denseScenes();
-        // for (outputList.items) |i| {
-        //     // dense[i].transform = outputs.items[i];
-        // }
+        const z3 = core.tracy.ZoneN(@src(), "Merge Outputs");
+        // merge outputs
+        // current a noop just iterate over the outputlist
+        for (outputList.items) |outIndex| {
+            if (denseRepr[outIndex].merge.cmpxchgStrong(false, true, .seq_cst, .acquire) != null) {
+                denseRepr[outIndex].transform = outputs[outIndex];
+            }
+        }
+        z3.End();
+        thread.barrier(@src()) catch unreachable;
     }
 
-    pub fn updateTransformsHierarchy(self: @This(), thread: *core.ThreadContext, outputs: *std.ArrayList(core.math.Transform), outputList: *std.ArrayList(usize)) !void {
-        _ = outputList;
-        _ = self;
+    fn updateTransform(
+        self: @This(),
+        thread: *core.ThreadContext,
+        index: usize,
+        densePosRot: []core.scene.ScenePosRot,
+        denseRepr: []core.scene.SceneObjectRepr,
+        outputs: []core.math.Transform,
+        outputList: *std.ArrayList(usize),
+    ) void {
+        var final: core.Transform = core.zm.identity();
+
+        const repr = denseRepr[index];
+
+        if (repr.parent) |parent| {
+            if (core.Scene.SceneObjectContainer.sparseToDense(parent)) |parentIndex| {
+                self.updateTransform(thread, parentIndex, densePosRot, denseRepr, outputs, outputList);
+                const parentTransform = outputs[parentIndex];
+                final = core.zm.mul(parentTransform, final);
+            } else {}
+        }
+
+        const posRot = densePosRot[index];
+
+        outputs[index] = core.zm.mul(
+            core.zm.mul(
+                core.zm.mul(
+                    core.zm.scalingV(posRot.scale.toZm()),
+                    core.zm.matFromQuat(posRot.rotation.quat),
+                ),
+                core.zm.translationV(posRot.position.toZm()),
+            ),
+            final,
+        );
+
+        outputList.appendAssumeCapacity(index);
+    }
+
+    pub fn updateTransformsHierarchy(self: @This(), thread: *core.ThreadContext, outputs: []core.math.Transform, outputList: *std.ArrayList(usize)) !void {
         const z = core.tracy.ZoneN(@src(), "updateTransformsHierarchy");
         defer z.End();
         //const dense = self.world.denseScenes();
         const densePosRot = core.Scene.SceneObjectContainer.denseItems(.posRot);
+        const denseRepr = core.Scene.SceneObjectContainer.denseItems(._repr);
 
         // everything allocated with thread.scratch is blown away when the thread is complete
-        try outputs.resize(thread.scratch(), densePosRot.len);
+        // try outputs.resize(thread.scratch(), densePosRot.len);
 
         // scan and mark all root nodes for update
-        const split = thread.splitSlice(core.scene.ScenePosRot, densePosRot);
+        const split = thread.splitSlice(core.scene.SceneObjectRepr, denseRepr);
 
-        const locals:[]core.math.Transform = try thread.scratch().alloc(core.math.Transform, split.slice.len);
+        // const locals:[]core.math.Transform = try thread.scratch().alloc(core.math.Transform, split.slice.len);
 
         const z2 = core.tracy.ZoneN(@src(), "WalkAndResolve");
-        defer z2.End();
-        for (split.slice, 0..) |posRot, i| {
+        for (split.slice, 0..) |*repr, i| {
             const index = split.startIndex + i;
-            _ = index;
-
-            locals[i] = posRot.toTransform();
+            self.updateTransform(thread, index, densePosRot, denseRepr, outputs, outputList);
+            //repr.cmpxchgStrong(false, true, .seq_cst, .acquire)
+            repr.merge.store(false, .seq_cst); // reset the merge big
         }
-
-        //for (split.slice, 0..) |repr, i| {
-        //}
+        z2.End();
     }
 };