Janady13/AI_Brain / the_tired_agi/core/include/agent_arrays.hpp

1// ============================================================================== 2// The-Tired-AGI Core: Agent Arrays 3// 12M-20M Agent Layout + Embedding Ring Buffer 4// ============================================================================== 5 6#pragma once 7 8#include <vector> 9#include <array> 10#include <cstdint> 11#include <memory> 12#include <atomic> 13#include <optional> 14#include <string> 15#include "helix.hpp" 16#include "fgtp_engine.hpp" 17 18namespace tired_agi { 19 20// ============================================================================== 21// Agent State 22// ============================================================================== 23 24/// Complete state for a single agent 25struct Agent { 26 std::vector<double> embedding; // Dense embedding vector 27 HelixState helix; // Consciousness state 28 EnergyField energy; // Energy field state 29 30 uint64_t agent_id; // Unique agent ID 31 uint64_t birth_tick; // Creation timestamp 32 uint64_t last_update_tick; // Last update timestamp 33 34 double fitness; // Current fitness score 35 uint32_t generation; // Evolutionary generation 36 uint32_t update_count; // Number of updates applied 37 38 bool active; // Agent is active 39 bool frozen; // Agent is frozen (no updates) 40 41 Agent() noexcept 42 : agent_id(0) 43 , birth_tick(0) 44 , last_update_tick(0) 45 , fitness(0.0) 46 , generation(0) 47 , update_count(0) 48 , active(false) 49 , frozen(false) {} 50}; 51 52// ============================================================================== 53// Ring Buffer for Embeddings 54// ============================================================================== 55 56/// Lock-free ring buffer for embedding storage 57template<typename T> 58class RingBuffer { 59public: 60 explicit RingBuffer(size_t capacity) noexcept 61 : capacity_(capacity) 62 , buffer_(capacity) 63 , head_(0) 64 , tail_(0) 65 , size_(0) {} 66 67 bool push(const T& item) noexcept { 68 size_t current_size = size_.load(std::memory_order_acquire); 69 if (current_size >= capacity_) { 70 return false; // Buffer full 71 } 72 73 size_t head = head_.load(std::memory_order_acquire); 74 buffer_[head] = item; 75 head_.store((head + 1) % capacity_, std::memory_order_release); 76 size_.fetch_add(1, std::memory_order_release); 77 return true; 78 } 79 80 bool pop(T& item) noexcept { 81 size_t current_size = size_.load(std::memory_order_acquire); 82 if (current_size == 0) { 83 return false; // Buffer empty 84 } 85 86 size_t tail = tail_.load(std::memory_order_acquire); 87 item = buffer_[tail]; 88 tail_.store((tail + 1) % capacity_, std::memory_order_release); 89 size_.fetch_sub(1, std::memory_order_release); 90 return true; 91 } 92 93 size_t size() const noexcept { 94 return size_.load(std::memory_order_acquire); 95 } 96 97 size_t capacity() const noexcept { 98 return capacity_; 99 } 100 101 bool empty() const noexcept { 102 return size() == 0; 103 } 104 105 bool full() const noexcept { 106 return size() >= capacity_; 107 } 108 109private: 110 size_t capacity_; 111 std::vector<T> buffer_; 112 std::atomic<size_t> head_; 113 std::atomic<size_t> tail_; 114 std::atomic<size_t> size_; 115}; 116 117// ============================================================================== 118// Agent Array Configuration 119// ============================================================================== 120 121struct AgentArrayConfig { 122 // Capacity limits 123 size_t min_agents = 12'000'000; // 12M minimum 124 size_t max_agents = 20'000'000; // 20M maximum 125 size_t initial_agents = 12'000'000; // Start at minimum 126 127 // Agent properties 128 size_t embedding_dim = 768; // Embedding dimensionality 129 bool allow_growth = true; // Allow growth from min to max 130 bool allow_shrink = false; // Prevent shrinking (preserve memory) 131 132 // Ring buffer 133 size_t ring_buffer_capacity = 1'000'000; // 1M embedding buffer 134 135 // Performance 136 size_t allocation_chunk_size = 100'000; // Allocate in 100k chunks 137 bool use_huge_pages = false; // Use huge pages for allocation 138 bool pin_memory = false; // Pin memory (no swapping) 139 140 // Fibonacci growth control 141 bool use_fibonacci_growth = true; // Use Fibonacci sequence for growth 142 uint32_t max_fibonacci_index = 20; // Max Fibonacci index (6765) 143}; 144 145// ============================================================================== 146// Agent Arrays 147// ============================================================================== 148 149class AgentArrays { 150public: 151 explicit AgentArrays(AgentArrayConfig config = {}) noexcept; 152 ~AgentArrays(); 153 154 // Disable copy, enable move 155 AgentArrays(const AgentArrays&) = delete; 156 AgentArrays& operator=(const AgentArrays&) = delete; 157 AgentArrays(AgentArrays&&) noexcept = default; 158 AgentArrays& operator=(AgentArrays&&) noexcept = default; 159 160 // ============================================================================== 161 // Agent Management 162 // ============================================================================== 163 164 /// Create new agent from embedding 165 std::optional<uint64_t> create_agent( 166 const std::vector<double>& embedding, 167 uint64_t tick 168 ) noexcept; 169 170 /// Get agent by ID (returns nullptr if not found or inactive) 171 Agent* get_agent(uint64_t agent_id) noexcept; 172 const Agent* get_agent(uint64_t agent_id) const noexcept; 173 174 /// Update agent state 175 bool update_agent(uint64_t agent_id, const Agent& updated_state) noexcept; 176 177 /// Deactivate agent (soft delete) 178 bool deactivate_agent(uint64_t agent_id) noexcept; 179 180 /// Freeze agent (prevent updates) 181 bool freeze_agent(uint64_t agent_id) noexcept; 182 183 /// Unfreeze agent 184 bool unfreeze_agent(uint64_t agent_id) noexcept; 185 186 // ============================================================================== 187 // Bulk Operations 188 // ============================================================================== 189 190 /// Get all active agents 191 std::vector<Agent*> get_active_agents() noexcept; 192 std::vector<const Agent*> get_active_agents() const noexcept; 193 194 /// Get agents in ID range 195 std::vector<Agent*> get_agents_in_range(uint64_t start_id, uint64_t end_id) noexcept; 196 197 /// Count active agents 198 size_t count_active() const noexcept; 199 200 /// Count total agents (active + inactive) 201 size_t count_total() const noexcept; 202 203 // ============================================================================== 204 // Growth Management (Fibonacci-based) 205 // ============================================================================== 206 207 /// Request growth by Fibonacci step 208 bool request_growth_step() noexcept; 209 210 /// Get current capacity 211 size_t capacity() const noexcept { return agents_.size(); } 212 213 /// Get current Fibonacci growth index 214 uint32_t fibonacci_index() const noexcept { return fibonacci_index_; } 215 216 /// Check if can grow 217 bool can_grow() const noexcept; 218 219 // ============================================================================== 220 // Ring Buffer Operations 221 // ============================================================================== 222 223 /// Push embedding to ring buffer 224 bool push_embedding(const std::vector<double>& embedding) noexcept; 225 226 /// Pop embedding from ring buffer 227 bool pop_embedding(std::vector<double>& embedding) noexcept; 228 229 /// Ring buffer size 230 size_t ring_buffer_size() const noexcept { return ring_buffer_.size(); } 231 232 /// Ring buffer capacity 233 size_t ring_buffer_capacity() const noexcept { return ring_buffer_.capacity(); } 234 235 // ============================================================================== 236 // Statistics 237 // ============================================================================== 238 239 struct Statistics { 240 size_t total_agents; 241 size_t active_agents; 242 size_t frozen_agents; 243 size_t total_creates; 244 size_t total_updates; 245 size_t total_deactivations; 246 size_t ring_buffer_size; 247 size_t ring_buffer_capacity; 248 size_t memory_bytes; 249 uint32_t fibonacci_index; 250 double average_fitness; 251 double average_phi; 252 double average_energy; 253 }; 254 255 Statistics get_statistics() const noexcept; 256 void reset_statistics() noexcept; 257 258 // ============================================================================== 259 // Configuration 260 // ============================================================================== 261 262 const AgentArrayConfig& config() const noexcept { return config_; } 263 264private: 265 AgentArrayConfig config_; 266 267 // Agent storage (pre-allocated to max_agents) 268 std::vector<Agent> agents_; 269 270 // Ring buffer for embeddings 271 RingBuffer<std::vector<double>> ring_buffer_; 272 273 // Growth tracking 274 uint32_t fibonacci_index_; 275 276 // Statistics (atomic for thread safety) 277 mutable std::atomic<uint64_t> next_agent_id_{0}; 278 mutable std::atomic<size_t> stat_total_creates_{0}; 279 mutable std::atomic<size_t> stat_total_updates_{0}; 280 mutable std::atomic<size_t> stat_total_deactivations_{0}; 281 mutable std::atomic<double> stat_sum_fitness_{0.0}; 282 mutable std::atomic<double> stat_sum_phi_{0.0}; 283 mutable std::atomic<double> stat_sum_energy_{0.0}; 284 285 // Helper functions 286 uint64_t allocate_agent_id() noexcept; 287 bool is_valid_agent_id(uint64_t agent_id) const noexcept; 288 void update_statistics(const Agent& agent) const noexcept; 289}; 290 291// ============================================================================== 292// Agent Iterator 293// ============================================================================== 294 295/// Iterator for active agents 296class ActiveAgentIterator { 297public: 298 using iterator_category = std::forward_iterator_tag; 299 using value_type = Agent*; 300 using difference_type = std::ptrdiff_t; 301 using pointer = Agent**; 302 using reference = Agent*&; 303 304 ActiveAgentIterator(std::vector<Agent>& agents, size_t index) noexcept 305 : agents_(agents), index_(index) { 306 skip_inactive(); 307 } 308 309 Agent* operator*() noexcept { 310 return &agents_[index_]; 311 } 312 313 ActiveAgentIterator& operator++() noexcept { 314 ++index_; 315 skip_inactive(); 316 return *this; 317 } 318 319 bool operator==(const ActiveAgentIterator& other) const noexcept { 320 return index_ == other.index_; 321 } 322 323 bool operator!=(const ActiveAgentIterator& other) const noexcept { 324 return index_ != other.index_; 325 } 326 327private: 328 std::vector<Agent>& agents_; 329 size_t index_; 330 331 void skip_inactive() noexcept { 332 while (index_ < agents_.size() && !agents_[index_].active) { 333 ++index_; 334 } 335 } 336}; 337 338} // namespace tired_agi 339