Function tcpReceive

modules/io/socket/lwip/tcp.c:541–586

}

err_t tcpReceive(void *arg, struct tcp_pcb *pcb, struct pbuf *pb, err_t err)
{
	TCP tcp = arg;
	TCPBuffer buffer;

	if ((NULL == pb) || (ERR_OK != err)) {		//@@ when is err set here?
		removeTCPCallbacks(tcp);
#if ESP32
//@@		tcp->skt = NULL;			// no close on socket if disconnected.
#endif
		tcpTrigger(tcp, kTCPError);
		return ERR_OK;
	}

#ifdef mxDebug
	if (pb && fxInNetworkDebugLoop(tcp->the))
		return ERR_MEM;
#endif

	buffer = c_malloc(sizeof(TCPBufferRecord));
	if (!buffer)
		return ERR_MEM;		// retry later

	buffer->next = NULL;
	buffer->pb = pb;
	buffer->bytes = pb->tot_len;
	buffer->fragment = pb;
	buffer->fragmentOffset = 0;

	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;

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

	return ERR_OK;
}

err_t tcpSent(void *arg, struct tcp_pcb *pcb, u16_t len)
{