Class RingBufferReader

src/ringbuffer.js:291–457

* Ring buffer reader (used by worker thread)

 * Ring buffer reader (used by worker thread)
 */
class RingBufferReader {
    constructor(sharedBuffer) {
        this.buffer = sharedBuffer;
        this.int32 = new Int32Array(sharedBuffer);
        this.uint8 = new Uint8Array(sharedBuffer);
    }
    
    /**
     * Check if there's data available in the network ring buffer
     */
    hasNetworkData() {
        const head = Atomics.load(this.int32, NET_HEAD_INDEX);
        const tail = Atomics.load(this.int32, NET_TAIL_INDEX);
        return head !== tail;
    }
    
    /**
     * Check if there's stdin data available
     */
    hasStdinData() {
        return Atomics.load(this.int32, STDIN_FLAG_INDEX) !== 0;
    }
    
    /**
     * Read stdin data (returns null if none available)
     */
    readStdin() {
        if (Atomics.load(this.int32, STDIN_FLAG_INDEX) === 0) {
            return null;
        }
        
        const size = Atomics.load(this.int32, STDIN_SIZE_INDEX);
        const data = this.uint8.slice(STDIN_OFFSET, STDIN_OFFSET + size);
        
        // Clear flag and notify writer
        Atomics.store(this.int32, STDIN_SIZE_INDEX, 0);
        Atomics.store(this.int32, STDIN_FLAG_INDEX, 0);
        Atomics.notify(this.int32, STDIN_FLAG_INDEX);
        
        return data;
    }
    
    /**
     * Read next network message (returns null if none available)
     * @returns {Object|null} - { type, payload } or null
     */
    readNetworkMessage() {
        const head = Atomics.load(this.int32, NET_HEAD_INDEX);
        let tail = Atomics.load(this.int32, NET_TAIL_INDEX);
        
        if (head === tail) {
            return null; // Empty
        }
        
        const ringStart = NET_RING_OFFSET;
        
        // Read length (2 bytes, little-endian)
        const lenLow = this.uint8[ringStart + tail];