Function socketReadable

modules/network/socket/qca4020/modSocket.c:412–447

}

void socketReadable(void *the, void *refcon, uint8_t *message, uint16_t messageLength)
{
	xsSocket xss = (xsSocket)refcon;
	uint8_t buffer[kRxBufferSize];
	int count;

	if (xss->done)
		return;
		
	socketUpUseCount(the, xss);
	
	count = recv(xss->skt, (char*)buffer, sizeof(buffer), 0);
	if (count < 0) {
		xsBeginHost(the);
			xsCall1(xss->obj, xsID_callback, xsInteger(kSocketMsgDisconnect));
		xsEndHost(the);
		socketDownUseCount(the, xss);
		doDestructor(xss);
		return;
	}
	else if (count > 0) {
		modInstrumentationAdjust(NetworkBytesRead, count);

		xss->readBuffer = buffer;
		xss->readBytes = count;

		xsBeginHost(the);
		xsCall2(xss->obj, xsID_callback, xsInteger(kSocketMsgDataReceived), xsInteger(count));
		xsEndHost(the);

		xss->readBuffer = NULL;
		xss->readBytes = 0;
	}
	
	socketDownUseCount(the, xss);
}

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