Function fxReadSerialBuffer

tools/serial2xsbug/serial2xsbug.c:537–752

}

void fxReadSerialBuffer(txSerialTool self, char* buffer, int size)
{
	char* src = buffer;
	char* srcLimit = src + size;
	int offset = self->index;
	char* dst = self->buffer + offset;
	char* dstLimit = self->buffer + mxBufferSize;

	if (self->trace)
		fprintf(stderr, "%.*s", size, buffer);

	while (src < srcLimit) {
		if (dst == dstLimit) {
			txSerialMachine machine = self->currentMachine;
			if (machine && !machine->suppress)
				fxWriteNetwork(machine, self->buffer, mxBufferSize - mxTagSize);
			memmove(self->buffer, dstLimit - mxTagSize, mxTagSize);
			dst = self->buffer + mxTagSize;
			offset = mxTagSize;
		}
		*dst++ = *src++;
		offset++;
		if (gBinaryState) {
			if (1 == gBinaryState) {
				gBinaryLength = dst[-1] << 8;
				gBinaryState = 2;
			}
			else if (2 == gBinaryState) {
				gBinaryLength |= dst[-1];
				gBinaryState = 3;
			}
			if ((3 == gBinaryState) && ((2 + gBinaryLength) == (dst - self->buffer))) {
				fxCommandReceived(self, self->buffer + 2, gBinaryLength);

				dst = self->buffer;
				offset = 0;
				gBinaryState = 0;
			}
		}
		else
		if ((offset >= 2) && (dst[-2] == 13) && (dst[-1] == 10)) {
			uint8_t flag;
			uint32_t value;
			if ((offset >= mxTagSize) && fxMatchProcessingInstruction(dst - mxTagSize, &flag, &value)) {
				if (flag) {
					self->currentMachine = fxOpenNetwork(self, value);
					gBinaryState = 2 == flag;

					if (gRestarting)
						fxRestart(self);
				}
				else {
					fxCloseNetwork(self, value);
					gRestarting = 0;
				}
			}
			else if ((offset >= 10) && (dst[-10] == '<') && (dst[-9] == '/') && (dst[-8] == 'x') && (dst[-7] == 's') && (dst[-6] == 'b') && (dst[-5] == 'u') && (dst[-4] == 'g') && (dst[-3] == '>')) {
				txSerialMachine machine = self->currentMachine;