EntropyEngine::Networking::ConnectionManager::ConnectionSlot

EntropyEngine::Networking::ConnectionManager::ConnectionSlot

Internal storage for a connection slot.

Public Attributes

	Name
std::shared_ptr< std::function< void(ConnectionState)> >	userStateCb User state callback.
std::shared_ptr< std::function< void(const std::vector< uint8_t > &)> >	userMessageCb User message callback.
ConnectionType	type Connection type (Local or Remote).
std::atomic< ConnectionState >	state Current connection state (query source).
std::mutex	pendingMsgMutex Protects pendingMessages queue.
std::vector< std::vector< uint8_t > >	pendingMessages Messages received before callback was registered.
std::atomic< uint32_t >	nextFree Next free slot index (free list).
std::mutex	mutex Per-slot mutex for connection operations.
std::atomic< ConnectionState >	lastPublishedState Last state sent to metrics (dedup tracking).
std::atomic< uint32_t >	generation Generation counter for handle validation.
std::unique_ptr< NetworkConnection >	connection Backend implementation (Unix/WebRTC/XPC).

Public Attributes Documentation

variable userStateCb

std::shared_ptr< std::function< void(ConnectionState)> > userStateCb;

User state callback.

variable userMessageCb

std::shared_ptr< std::function< void(const std::vector< uint8_t > &)> > userMessageCb;

User message callback.

variable type

ConnectionType type;

Connection type (Local or Remote).

variable state

std::atomic< ConnectionState > state {ConnectionState::Disconnected};

Current connection state (query source).

variable pendingMsgMutex

std::mutex pendingMsgMutex;

Protects pendingMessages queue.

variable pendingMessages

std::vector< std::vector< uint8_t > > pendingMessages;

Messages received before callback was registered.

variable nextFree

std::atomic< uint32_t > nextFree {INVALID_INDEX};

Next free slot index (free list).

variable mutex

std::mutex mutex;

Per-slot mutex for connection operations.

variable lastPublishedState

std::atomic< ConnectionState > lastPublishedState {
            ConnectionState::Disconnected};

Last state sent to metrics (dedup tracking).

variable generation

std::atomic< uint32_t > generation {1};

Generation counter for handle validation.

variable connection

std::unique_ptr< NetworkConnection > connection;

Backend implementation (Unix/WebRTC/XPC).

---

Updated on 2026-01-26 at 17:14:35 -0500