515 bool LMEConnection::_checkMinMsgSize(unsigned char *buf, unsigned int bytesRead)  in _checkMinMsgSize()  argument
519 		if (bytesRead < sizeof(APF_DISCONNECT_MESSAGE)) {  in _checkMinMsgSize()
524 		if (bytesRead < sizeof(APF_SERVICE_REQUEST)) {  in _checkMinMsgSize()
527 		if (bytesRead < (sizeof(APF_SERVICE_REQUEST) +  in _checkMinMsgSize()
533 		if (bytesRead < (3 * sizeof(UINT32))) {  in _checkMinMsgSize()
538 		if (bytesRead < (sizeof(APF_GENERIC_HEADER) + sizeof(UINT8))) {  in _checkMinMsgSize()
541 		if (bytesRead < (sizeof(APF_GENERIC_HEADER) + sizeof(UINT8) +  in _checkMinMsgSize()
547 		if (bytesRead < sizeof(APF_GENERIC_HEADER)) {  in _checkMinMsgSize()
550 		if (bytesRead < (sizeof(APF_GENERIC_HEADER) +  in _checkMinMsgSize()
556 		if (bytesRead < sizeof(APF_CHANNEL_OPEN_CONFIRMATION_MESSAGE)) {  in _checkMinMsgSize()
561 		if (bytesRead < sizeof(APF_CHANNEL_OPEN_FAILURE_MESSAGE)) {  in _checkMinMsgSize()
566 		if (bytesRead < sizeof(APF_CHANNEL_CLOSE_MESSAGE)) {  in _checkMinMsgSize()
571 		if (bytesRead < sizeof(APF_CHANNEL_DATA_MESSAGE)) {  in _checkMinMsgSize()
574 		if (bytesRead < (sizeof(APF_CHANNEL_DATA_MESSAGE) +  in _checkMinMsgSize()
580 		if (bytesRead < sizeof(APF_WINDOW_ADJUST_MESSAGE)) {  in _checkMinMsgSize()
585 		if (bytesRead < sizeof(APF_PROTOCOL_VERSION_MESSAGE)) {  in _checkMinMsgSize()
597 	unsigned int bytesRead;  in _doRX()  local
605 		bytesRead = (unsigned int)_receiveMessage(rxBuffer, _heci.GetBufferSize());  in _doRX()
607 		if ((int)bytesRead < 0) {  in _doRX()
613 		if (bytesRead == 0) {  in _doRX()
618 		PRINT("Received from LME %d bytes (msg type %02d)\n", bytesRead, rxBuffer[0]);  in _doRX()
620 		if (!_checkMinMsgSize(rxBuffer, bytesRead)) {  in _doRX()
626 		if (plugin.preprocess(rxBuffer, bytesRead) == LMS_DROPPED) {  in _doRX()
656 			_apfUserAuthRequest(rxBuffer, bytesRead, &status);  in _doRX()
660 			_apfGlobalRequest(rxBuffer, bytesRead, &status);  in _doRX()
664 			_apfChannelOpen(rxBuffer, bytesRead, &status);  in _doRX()
747 			plugin.postprocess(rxBuffer, bytesRead, status);  in _doRX()
756 void LMEConnection::_apfChannelOpen(unsigned char *rxBuffer, unsigned int bytesRead, int *status)  in _apfChannelOpen()  argument
766 		_apfChannelOpenDirect(rxBuffer, bytesRead, &senderChannel, status);  in _apfChannelOpen()
768 			if (plugin.retry(rxBuffer, bytesRead) != LMS_DROPPED) {  in _apfChannelOpen()
769 				_apfChannelOpenDirect(rxBuffer, bytesRead, NULL, status);  in _apfChannelOpen()
779 void LMEConnection::_apfChannelOpenDirect(unsigned char *rxBuffer, unsigned int bytesRead, UINT32 *…  in _apfChannelOpenDirect()  argument
784 	if (bytesRead < sizeof(APF_GENERIC_HEADER) +  in _apfChannelOpenDirect()
816 void LMEConnection::_apfGlobalRequest(unsigned char *rxBuffer, unsigned int bytesRead, int *status)  in _apfGlobalRequest()  argument
829 		bytesRead -= hsize;  in _apfGlobalRequest()
831 		if (bytesRead < sizeof(UINT32)) {  in _apfGlobalRequest()
840 		if (bytesRead < (sizeof(UINT32) + len + sizeof(UINT32))) {  in _apfGlobalRequest()
860 		bytesRead -= hsize;  in _apfGlobalRequest()
862 		if (bytesRead < sizeof(UINT32)) {  in _apfGlobalRequest()
871 		if (bytesRead < (sizeof(UINT32) + len + sizeof(UINT32))) {  in _apfGlobalRequest()
890 		bytesRead -= hsize;  in _apfGlobalRequest()
892 		if (bytesRead < sizeof(UINT32)) {  in _apfGlobalRequest()
901 		if (bytesRead < (sizeof(UINT32) + len + sizeof(UINT32))) {  in _apfGlobalRequest()
906 		bytesRead -= (sizeof(UINT32) + len + sizeof(UINT32));  in _apfGlobalRequest()
914 		if (bytesRead < sizeof(UINT32)) {  in _apfGlobalRequest()
924 		if (bytesRead < (sizeof(UINT32) + len + sizeof(UINT32))) {  in _apfGlobalRequest()
929 		bytesRead -= (sizeof(UINT32) + len + sizeof(UINT32));  in _apfGlobalRequest()
934 		if (bytesRead < sizeof(UINT32)) {  in _apfGlobalRequest()
944 		if (bytesRead < (sizeof(UINT32) + len)) {  in _apfGlobalRequest()
956 void LMEConnection::_apfUserAuthRequest(unsigned char *rxBuffer, unsigned int bytesRead, int *statu…  in _apfUserAuthRequest()  argument
967 	if ((bytesRead - (pCurrent - rxBuffer)) < len) {  in _apfUserAuthRequest()
976 	if ((unsigned int)(bytesRead - (pCurrent - rxBuffer)) < sizeof(UINT32)) {  in _apfUserAuthRequest()
985 	if ((bytesRead - (pCurrent - rxBuffer)) < len) {  in _apfUserAuthRequest()
994 	if ((unsigned int)(bytesRead - (pCurrent - rxBuffer)) < sizeof(UINT32)) {  in _apfUserAuthRequest()
1003 	if ((bytesRead - (pCurrent - rxBuffer)) < len) {  in _apfUserAuthRequest()
1015 		if ((unsigned int)(bytesRead - (pCurrent - rxBuffer)) < sizeof(UINT32) + 1) {  in _apfUserAuthRequest()
1026 		if ((bytesRead - (pCurrent - rxBuffer)) < len) {  in _apfUserAuthRequest()