Function udpReceive

modules/io/socket/lwip/udp.c:302–347

}

void udpReceive(void *arg, struct udp_pcb *pcb, struct pbuf *p, const ip_addr_t *addr, u16_t port)
{
	UDP udp = arg;
	UDPPacket packet;

#ifdef mxDebug
	if (fxInNetworkDebugLoop(udp->the)) {
		pbuf_free_safe(p);
		return;
	}
#endif

	packet = c_malloc(sizeof(UDPPacketRecord));
	if (!packet) {
		pbuf_free_safe(p);
		return;
	}

	packet->next = NULL;
	packet->pb = p;
	packet->port = port;
	packet->address = *addr;

	modInstrumentationAdjust(NetworkBytesRead, p->len);

	builtinCriticalSectionBegin();
	uint8_t readablePending = udp->readablePending;
	if (udp->packets) {
		UDPPacket walker;

		for (walker = udp->packets; walker->next; walker = walker->next)
			;
		walker->next = packet;

		builtinCriticalSectionEnd();
	}
	else {
		udp->packets = packet;
		builtinCriticalSectionEnd();
	}

	if (!readablePending && udp->onReadable) {
		udp->readablePending = true;
		modMessagePostToMachine(udp->the, NULL, 0, udpDeliver, udp);
	}
}

void udpDeliver(void *the, void *refcon, uint8_t *message, uint16_t messageLength)
{