Function tcpReceive

modules/io/socket/zephyr/tcp.c:525–569

}

void tcpReceive(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)
{
	TCP tcp = user_data;
	TCPBuffer buffer;

	if ((NULL == pkt) || (status < 0)) {
		tcp->error = status;
		removeTCPCallbacks(tcp);
		tcpTrigger(tcp, kTCPError);
		return;
	}

// #ifdef mxDebug
// 	if (fxInNetworkDebugLoop(tcp->the))
// 		return;
// #endif

	buffer = c_malloc(sizeof(TCPBufferRecord));
	if (!buffer) {
		net_pkt_unref(buffer->pkt);
		return;		//@@ are we toast here?
	}

	buffer->next = NULL;
	buffer->pkt = pkt;
	buffer->bytes = net_pkt_remaining_data(pkt);
	buffer->total = buffer->bytes;

	modInstrumentationAdjust(NetworkBytesRead, buffer->bytes);

	if (tcp->buffers) {
		TCPBuffer walker;

		for (walker = tcp->buffers; walker->next; walker = walker->next)
			;
		walker->next = buffer;
	}
	else
		tcp->buffers = buffer;

	net_context_update_recv_wnd(tcp->context, -buffer->total);

	if (tcp->triggerable & kTCPReadable)
		tcpTrigger(tcp, kTCPReadable);
}

void tcpSent(struct net_context *context, int status, void *user_data)
{