Function fxReceive

xs/platforms/esp/xsPlatform.c:561–743

}

void fxReceive(txMachine* the)
{
	struct tcp_pcb *pcb = the->connection;
	if (!pcb) return;

	xmodLog("  fxReceive - ENTER");

	if (kSerialConnection != pcb) {
/*		struct pbuf *p;
		uint16_t use;

		modWatchDogReset();
		if (NULL == the->readers[0]) {
			modDelayMilliseconds(10);
			return;
		}

		p = the->readers[0];
		if (p->next)
			modLog("  fxReceive - cannot handle fragmented!!");

		mxDebugMutexTake();
			use = p->len - the->readerOffset;
			if (use > sizeof(the->debugBuffer))
				use = sizeof(the->debugBuffer);
#if 0
			c_memmove(the->debugBuffer, the->readerOffset + (char *)p->payload, use);
			the->readerOffset += use;
			the->debugOffset = use;
#else
			uint16_t i;
			uint8_t *debugBuffer = the->debugBuffer;
			for (i = 0; i < use; i++) {
				uint8_t byte = *(uint8_t *)(i + the->readerOffset + (char *)p->payload);
				switch (the->wsState) {
					case 0:
						the->wsState = 1;
						the->wsFin = 0 != (0x80 & byte);
						if (NULL == the->wsCmd) {
							if (8 == (byte & 0x0f)) {		// close
								fxDisconnect(the);
								use = 0;
								break;
							}
							the->wsCmd = (2 == (byte & 0x0f)) ? (void *)-1 : NULL;		// binary data is cmd; text is xsbug
						}
						break;
					case 1:
						byte &= 0x7F;
						if (126 == byte)
							the->wsState = 3;
						else {
							the->wsLength = byte;
							the->wsState = 5;
						}
						break;
					case 2:		//@@ unused
						break;