Method processData

src/frontend/swo/sources/socket.ts:301–356

(buffer: Buffer)

    }

    protected processData(buffer: Buffer): void {
        let offset = 0;
        // PeMicro streams data in packets. Each packet has a 32 byte header, followed by the data
        // It only sends one packet per TCP packet, but this interface concatenates TCP packets
        // So we may need to process multiple in one callback
        while ((buffer.length - offset) >= PeMicroHeader.headerLength) {
            try {
                const header = PeMicroHeader.fromBuffer(buffer.subarray(offset, Math.min(offset + PeMicroHeader.headerLength, buffer.length)));
                // skip over header
                offset = offset + PeMicroHeader.headerLength;
                switch (this.state) {
                    case PeState.CREATE_PIPE: {
                        if (header.type === PeHeaderType.RX_COMMAND) {
                            const response = JSON.parse(buffer.subarray(offset, Math.min(offset + header.dataLength, buffer.length)).toString());
                            if (response.control['00000001'].result === 0) {
                                this.configureSWO();
                                this.state = PeState.CONFIGURE_SWO;
                            }
                        }
                        break;
                    }
                    case PeState.CONFIGURE_SWO: {
                        if (header.type === PeHeaderType.RX_COMMAND) {
                            const response = JSON.parse(buffer.subarray(offset, Math.min(offset + header.dataLength, buffer.length)).toString());
                            if (response.control['00000001'].result === 0) {
                                this.resumePipe();
                                this.state = PeState.RESUME_PIPE;
                            }
                        }
                        break;
                    }
                    case PeState.RESUME_PIPE: {
                        if (header.type === PeHeaderType.RX_COMMAND) {
                            const response = JSON.parse(buffer.subarray(offset, Math.min(offset + header.dataLength, buffer.length)).toString());
                            if (response.control['00000001'].result === 0) {
                                this.state = PeState.RECEIVING;
                            }
                        }
                        break;
                    }
                    case PeState.RECEIVING: {
                        if (header.type === PeHeaderType.RX_STREAM) {
                            this.emit('data', buffer.subarray(offset, Math.min(offset + header.dataLength, buffer.length)));
                        }
                        break;
                    }
                }
                offset = offset + header.dataLength;
            } catch (err) {
                console.log(err.message);
                // If we couldn't decode the header, just discard the data.
                // Its probably garbage or out of sync, so upstream would be confused anyway
            }
            
        }
    }

    public write(data) {