Method writeTcpData

src/ringbuffer.js:156–194

* Write TCP data - writes as much as will fit, returns amount written * @param {string} key - TCP session key * @param {Uint8Array|Buffer} data - TCP payload * @param {number} offset - Start offset in data (default 0) * @returns {number} - Number of bytes written (0 if buffer ful

(key, data, offset = 0)

     * @returns {number} - Number of bytes written (0 if buffer full)
     */
    writeTcpData(key, data, offset = 0) {
        // Format: keyLen(1) + key + data
        const keyBytes = Buffer.from(key, 'utf8');
        
        // Max payload size is 65535 - 1 (keyLen) - keyBytes.length
        // Use 60000 as safe chunk size to leave room for header
        const maxDataPerChunk = 60000;
        const perChunkOverhead = 3 + 1 + keyBytes.length; // 3 bytes msg header + 1 keyLen + key
        
        let bytesWritten = 0;
        
        while (offset + bytesWritten < data.length) {
            const remaining = data.length - offset - bytesWritten;
            const chunkSize = Math.min(maxDataPerChunk, remaining);
            const payloadSize = 1 + keyBytes.length + chunkSize;
            const msgSize = 3 + payloadSize;
            
            // Check if we have space for at least one chunk
            if (!this.hasSpace(msgSize)) {
                break; // No space, return what we've written so far
            }
            
            const payload = Buffer.alloc(payloadSize);
            payload[0] = keyBytes.length;
            keyBytes.copy(payload, 1);
            
            const srcOffset = offset + bytesWritten;
            if (Buffer.isBuffer(data)) {
                data.copy(payload, 1 + keyBytes.length, srcOffset, srcOffset + chunkSize);
            } else {
                payload.set(data.subarray(srcOffset, srcOffset + chunkSize), 1 + keyBytes.length);
            }
            
            this.writeMessage(NET_MSG_TCP_DATA, payload);
            bytesWritten += chunkSize;
        }
        
        return bytesWritten;
    }
    
    /**
     * Write TCP end event