Function udpReceive

modules/io/socket/zephyr/udp.c:209–251

}

static void udpReceive(struct net_context *context, struct net_pkt *pkt, union net_ip_header *ip_hdr, union net_proto_header *proto_hdr, int status, void *user_data)
{
	UDP udp = user_data;
	UDPPacket packet;

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

	packet = c_malloc(sizeof(UDPPacketRecord));
	if (!packet) {
		net_pkt_unref(pkt);
		return;
	}

	packet->next = NULL;
	packet->pkt = pkt;
	packet->port = ntohs(proto_hdr->udp->src_port);
	packet->address = *(struct net_addr *)ip_hdr->ipv4->src;

	modInstrumentationAdjust(NetworkBytesRead, net_pkt_get_len(pkt));

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

		for (walker = udp->packets; walker->next; walker = walker->next)
			;
		walker->next = packet;
	}
	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)
{