Method writeMessage

src/ringbuffer.js:106–138

* Write a network message to the ring buffer * @param {number} type - Message type (NET_MSG_*) * @param {Uint8Array|Buffer} payload - Message payload * @returns {boolean} - True if written, false if no space

(type, payload)

     * @returns {boolean} - True if written, false if no space
     */
    writeMessage(type, payload) {
        const msgLen = 3 + payload.length; // 2 bytes length + 1 byte type + payload
        
        if (this.availableSpace() < msgLen) {
            return false; // No space
        }
        
        let head = Atomics.load(this.int32, NET_HEAD_INDEX);
        const ringStart = NET_RING_OFFSET;
        
        // Write length (2 bytes, little-endian)
        this.uint8[ringStart + head] = payload.length & 0xFF;
        head = (head + 1) % NET_RING_SIZE;
        this.uint8[ringStart + head] = (payload.length >> 8) & 0xFF;
        head = (head + 1) % NET_RING_SIZE;
        
        // Write type (1 byte)
        this.uint8[ringStart + head] = type;
        head = (head + 1) % NET_RING_SIZE;
        
        // Write payload
        for (let i = 0; i < payload.length; i++) {
            this.uint8[ringStart + head] = payload[i];
            head = (head + 1) % NET_RING_SIZE;
        }
        
        // Update head atomically and signal
        Atomics.store(this.int32, NET_HEAD_INDEX, head);
        Atomics.add(this.int32, IO_READY_INDEX, 1);
        Atomics.notify(this.int32, IO_READY_INDEX);
        
        return true;
    }
    
    /**
     * Write TCP connected event