cmd/lms/LMEConnection.cpp

602 	unsigned char *rxBuffer = new unsigned char[_heci.GetBufferSize()];
605 		bytesRead = (unsigned int)_receiveMessage(rxBuffer, _heci.GetBufferSize());
618 		PRINT("Received from LME %d bytes (msg type %02d)\n", bytesRead, rxBuffer[0]);
620 		if (!_checkMinMsgSize(rxBuffer, bytesRead)) {
626 		if (plugin.preprocess(rxBuffer, bytesRead) == LMS_DROPPED) {
630 		switch (rxBuffer[0]) {
635 					((APF_DISCONNECT_MESSAGE *)rxBuffer)->ReasonCode));
644 					(APF_SERVICE_REQUEST_MESSAGE *)rxBuffer;
656 			_apfUserAuthRequest(rxBuffer, bytesRead, &status);
660 			_apfGlobalRequest(rxBuffer, bytesRead, &status);
664 			_apfChannelOpen(rxBuffer, bytesRead, &status);
670 				    (APF_CHANNEL_OPEN_CONFIRMATION_MESSAGE *)rxBuffer;
683 				    (APF_CHANNEL_OPEN_FAILURE_MESSAGE *)rxBuffer;
696 				    (APF_CHANNEL_CLOSE_MESSAGE *)rxBuffer;
707 				    (APF_CHANNEL_DATA_MESSAGE *)rxBuffer;
718 				    (APF_WINDOW_ADJUST_MESSAGE *)rxBuffer;
730 				    (APF_PROTOCOL_VERSION_MESSAGE *)rxBuffer;
747 			plugin.postprocess(rxBuffer, bytesRead, status);
751 	if (rxBuffer != NULL) {
752 		delete[] rxBuffer;
756 void LMEConnection::_apfChannelOpen(unsigned char *rxBuffer, unsigned int bytesRead, int *status)
758 	APF_GENERIC_HEADER *pHeader = (APF_GENERIC_HEADER *)rxBuffer;
766 		_apfChannelOpenDirect(rxBuffer, bytesRead, &senderChannel, status);
768 			if (plugin.retry(rxBuffer, bytesRead) != LMS_DROPPED) {
769 				_apfChannelOpenDirect(rxBuffer, bytesRead, NULL, status);
779 void LMEConnection::_apfChannelOpenDirect(unsigned char *rxBuffer, unsigned int bytesRead, UINT32 *senderChannel, int *status)
782 	APF_GENERIC_HEADER *pHeader = (APF_GENERIC_HEADER *)rxBuffer;
792 	pCurrent = rxBuffer + sizeof(APF_GENERIC_HEADER) +
816 void LMEConnection::_apfGlobalRequest(unsigned char *rxBuffer, unsigned int bytesRead, int *status)
819 	APF_GENERIC_HEADER *pHeader = (APF_GENERIC_HEADER *)rxBuffer;
828 		pCurrent = rxBuffer + hsize;
859 		pCurrent = rxBuffer + hsize;
889 		pCurrent = rxBuffer + hsize;
956 void LMEConnection::_apfUserAuthRequest(unsigned char *rxBuffer, unsigned int bytesRead, int *status)
958 	unsigned char *pCurrent = rxBuffer;
967 	if ((bytesRead - (pCurrent - rxBuffer)) < len) {
976 	if ((unsigned int)(bytesRead - (pCurrent - rxBuffer)) < sizeof(UINT32)) {
985 	if ((bytesRead - (pCurrent - rxBuffer)) < len) {
994 	if ((unsigned int)(bytesRead - (pCurrent - rxBuffer)) < sizeof(UINT32)) {
1003 	if ((bytesRead - (pCurrent - rxBuffer)) < len) {
1015 		if ((unsigned int)(bytesRead - (pCurrent - rxBuffer)) < sizeof(UINT32) + 1) {
1026 		if ((bytesRead - (pCurrent - rxBuffer)) < len) {