Wayne Lin / Modbus

modified for nuc472

Dependents:   modbus-over-rs485-sample NTOUEE-mbed-modbus-RTU NuMaker_NuWicam_Lite

Fork of Modbus by Matthew Waddilove

mb.cpp@7:be466464a18c, 2017-10-06 (annotated)

Committer:
wclin
Date:
Fri Oct 06 02:54:27 2017 +0000
Revision:
7:be466464a18c
Parent:
3:419ee4c5e10f 
Support M487 board.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
giryan 0:274eb57e1df3 1 /*
giryan 0:274eb57e1df3 2 * FreeModbus Libary: A portable Modbus implementation for Modbus ASCII/RTU.
giryan 0:274eb57e1df3 3 * Copyright (c) 2006 Christian Walter <wolti@sil.at>
giryan 0:274eb57e1df3 4 * All rights reserved.
giryan 0:274eb57e1df3 5 *
giryan 0:274eb57e1df3 6 * Redistribution and use in source and binary forms, with or without
giryan 0:274eb57e1df3 7 * modification, are permitted provided that the following conditions
giryan 0:274eb57e1df3 8 * are met:
giryan 0:274eb57e1df3 9 * 1. Redistributions of source code must retain the above copyright
giryan 0:274eb57e1df3 10 * notice, this list of conditions and the following disclaimer.
giryan 0:274eb57e1df3 11 * 2. Redistributions in binary form must reproduce the above copyright
giryan 0:274eb57e1df3 12 * notice, this list of conditions and the following disclaimer in the
giryan 0:274eb57e1df3 13 * documentation and/or other materials provided with the distribution.
giryan 0:274eb57e1df3 14 * 3. The name of the author may not be used to endorse or promote products
giryan 0:274eb57e1df3 15 * derived from this software without specific prior written permission.
giryan 0:274eb57e1df3 16 *
giryan 0:274eb57e1df3 17 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
giryan 0:274eb57e1df3 18 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
giryan 0:274eb57e1df3 19 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
giryan 0:274eb57e1df3 20 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
giryan 0:274eb57e1df3 21 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
giryan 0:274eb57e1df3 22 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
giryan 0:274eb57e1df3 23 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
giryan 0:274eb57e1df3 24 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
giryan 0:274eb57e1df3 25 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
giryan 0:274eb57e1df3 26 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
giryan 0:274eb57e1df3 27 *
giryan 0:274eb57e1df3 28 * File: $Id: mb.c,v 1.27 2007/02/18 23:45:41 wolti Exp $
giryan 0:274eb57e1df3 29 */
giryan 0:274eb57e1df3 30
giryan 0:274eb57e1df3 31 /* ----------------------- System includes ----------------------------------*/
giryan 0:274eb57e1df3 32 #include "stdlib.h"
giryan 0:274eb57e1df3 33 #include "string.h"
giryan 0:274eb57e1df3 34
giryan 0:274eb57e1df3 35 /* ----------------------- Platform includes --------------------------------*/
giryan 0:274eb57e1df3 36 #include "port.h"
giryan 0:274eb57e1df3 37
giryan 0:274eb57e1df3 38 /* ----------------------- Modbus includes ----------------------------------*/
giryan 0:274eb57e1df3 39 #include "mb.h"
giryan 0:274eb57e1df3 40 #include "mbconfig.h"
giryan 0:274eb57e1df3 41 #include "mbframe.h"
giryan 0:274eb57e1df3 42 #include "mbproto.h"
giryan 0:274eb57e1df3 43 #include "mbfunc.h"
giryan 0:274eb57e1df3 44 #include "mbport.h"
giryan 0:274eb57e1df3 45 #if MB_RTU_ENABLED == 1
giryan 0:274eb57e1df3 46 #include "mbrtu.h"
giryan 0:274eb57e1df3 47 #endif
giryan 0:274eb57e1df3 48 #if MB_ASCII_ENABLED == 1
giryan 0:274eb57e1df3 49 #include "mbascii.h"
giryan 0:274eb57e1df3 50 #endif
giryan 0:274eb57e1df3 51 #if MB_TCP_ENABLED == 1
giryan 0:274eb57e1df3 52 #include "mbtcp.h"
giryan 0:274eb57e1df3 53 #endif
giryan 0:274eb57e1df3 54
giryan 0:274eb57e1df3 55 #ifndef MB_PORT_HAS_CLOSE
giryan 0:274eb57e1df3 56 #define MB_PORT_HAS_CLOSE 0
giryan 0:274eb57e1df3 57 #endif
giryan 0:274eb57e1df3 58
giryan 0:274eb57e1df3 59 /* ----------------------- Static variables ---------------------------------*/
giryan 0:274eb57e1df3 60
wclin 3:419ee4c5e10f 61 #include "mbed.h"
giryan 0:274eb57e1df3 62
giryan 0:274eb57e1df3 63 static UCHAR ucMBAddress;
giryan 0:274eb57e1df3 64 static eMBMode eMBCurrentMode;
giryan 0:274eb57e1df3 65
giryan 0:274eb57e1df3 66 static enum {
giryan 0:274eb57e1df3 67 STATE_ENABLED,
giryan 0:274eb57e1df3 68 STATE_DISABLED,
giryan 0:274eb57e1df3 69 STATE_NOT_INITIALIZED
giryan 0:274eb57e1df3 70 } eMBState = STATE_NOT_INITIALIZED;
giryan 0:274eb57e1df3 71
giryan 0:274eb57e1df3 72 /* Functions pointer which are initialized in eMBInit( ). Depending on the
giryan 0:274eb57e1df3 73 * mode (RTU or ASCII) the are set to the correct implementations.
giryan 0:274eb57e1df3 74 */
giryan 0:274eb57e1df3 75 static peMBFrameSend peMBFrameSendCur;
giryan 0:274eb57e1df3 76 static pvMBFrameStart pvMBFrameStartCur;
giryan 0:274eb57e1df3 77 static pvMBFrameStop pvMBFrameStopCur;
giryan 0:274eb57e1df3 78 static peMBFrameReceive peMBFrameReceiveCur;
giryan 0:274eb57e1df3 79 static pvMBFrameClose pvMBFrameCloseCur;
giryan 0:274eb57e1df3 80
giryan 0:274eb57e1df3 81 /* Callback functions required by the porting layer. They are called when
giryan 0:274eb57e1df3 82 * an external event has happend which includes a timeout or the reception
giryan 0:274eb57e1df3 83 * or transmission of a character.
giryan 0:274eb57e1df3 84 */
giryan 0:274eb57e1df3 85 BOOL( *pxMBFrameCBByteReceived ) ( void );
giryan 0:274eb57e1df3 86 BOOL( *pxMBFrameCBTransmitterEmpty ) ( void );
giryan 0:274eb57e1df3 87 BOOL( *pxMBPortCBTimerExpired ) ( void );
giryan 0:274eb57e1df3 88
giryan 0:274eb57e1df3 89 BOOL( *pxMBFrameCBReceiveFSMCur ) ( void );
giryan 0:274eb57e1df3 90 BOOL( *pxMBFrameCBTransmitFSMCur ) ( void );
giryan 0:274eb57e1df3 91
giryan 0:274eb57e1df3 92 /* An array of Modbus functions handlers which associates Modbus function
giryan 0:274eb57e1df3 93 * codes with implementing functions.
giryan 0:274eb57e1df3 94 */
giryan 0:274eb57e1df3 95 static xMBFunctionHandler xFuncHandlers[MB_FUNC_HANDLERS_MAX] = {
giryan 0:274eb57e1df3 96 #if MB_FUNC_OTHER_REP_SLAVEID_ENABLED > 0
giryan 0:274eb57e1df3 97 {MB_FUNC_OTHER_REPORT_SLAVEID, eMBFuncReportSlaveID},
giryan 0:274eb57e1df3 98 #endif
giryan 0:274eb57e1df3 99 #if MB_FUNC_READ_INPUT_ENABLED > 0
giryan 0:274eb57e1df3 100 {MB_FUNC_READ_INPUT_REGISTER, eMBFuncReadInputRegister},
giryan 0:274eb57e1df3 101 #endif
giryan 0:274eb57e1df3 102 #if MB_FUNC_READ_HOLDING_ENABLED > 0
giryan 0:274eb57e1df3 103 {MB_FUNC_READ_HOLDING_REGISTER, eMBFuncReadHoldingRegister},
giryan 0:274eb57e1df3 104 #endif
giryan 0:274eb57e1df3 105 #if MB_FUNC_WRITE_MULTIPLE_HOLDING_ENABLED > 0
giryan 0:274eb57e1df3 106 {MB_FUNC_WRITE_MULTIPLE_REGISTERS, eMBFuncWriteMultipleHoldingRegister},
giryan 0:274eb57e1df3 107 #endif
giryan 0:274eb57e1df3 108 #if MB_FUNC_WRITE_HOLDING_ENABLED > 0
giryan 0:274eb57e1df3 109 {MB_FUNC_WRITE_REGISTER, eMBFuncWriteHoldingRegister},
giryan 0:274eb57e1df3 110 #endif
giryan 0:274eb57e1df3 111 #if MB_FUNC_READWRITE_HOLDING_ENABLED > 0
giryan 0:274eb57e1df3 112 {MB_FUNC_READWRITE_MULTIPLE_REGISTERS, eMBFuncReadWriteMultipleHoldingRegister},
giryan 0:274eb57e1df3 113 #endif
giryan 0:274eb57e1df3 114 #if MB_FUNC_READ_COILS_ENABLED > 0
giryan 0:274eb57e1df3 115 {MB_FUNC_READ_COILS, eMBFuncReadCoils},
giryan 0:274eb57e1df3 116 #endif
giryan 0:274eb57e1df3 117 #if MB_FUNC_WRITE_COIL_ENABLED > 0
giryan 0:274eb57e1df3 118 {MB_FUNC_WRITE_SINGLE_COIL, eMBFuncWriteCoil},
giryan 0:274eb57e1df3 119 #endif
giryan 0:274eb57e1df3 120 #if MB_FUNC_WRITE_MULTIPLE_COILS_ENABLED > 0
giryan 0:274eb57e1df3 121 {MB_FUNC_WRITE_MULTIPLE_COILS, eMBFuncWriteMultipleCoils},
giryan 0:274eb57e1df3 122 #endif
giryan 0:274eb57e1df3 123 #if MB_FUNC_READ_DISCRETE_INPUTS_ENABLED > 0
giryan 0:274eb57e1df3 124 {MB_FUNC_READ_DISCRETE_INPUTS, eMBFuncReadDiscreteInputs},
giryan 0:274eb57e1df3 125 #endif
giryan 0:274eb57e1df3 126 };
giryan 0:274eb57e1df3 127
giryan 0:274eb57e1df3 128 /* ----------------------- Start implementation -----------------------------*/
giryan 0:274eb57e1df3 129 eMBErrorCode
giryan 0:274eb57e1df3 130 eMBInit( eMBMode eMode, UCHAR ucSlaveAddress, UCHAR ucPort, ULONG ulBaudRate, eMBParity eParity ) {
giryan 0:274eb57e1df3 131 eMBErrorCode eStatus = MB_ENOERR;
giryan 0:274eb57e1df3 132
giryan 0:274eb57e1df3 133 /* check preconditions */
giryan 0:274eb57e1df3 134 if ( ( ucSlaveAddress == MB_ADDRESS_BROADCAST ) ||
giryan 0:274eb57e1df3 135 ( ucSlaveAddress < MB_ADDRESS_MIN ) || ( ucSlaveAddress > MB_ADDRESS_MAX ) ) {
giryan 0:274eb57e1df3 136 eStatus = MB_EINVAL;
giryan 0:274eb57e1df3 137 } else {
giryan 0:274eb57e1df3 138 ucMBAddress = ucSlaveAddress;
giryan 0:274eb57e1df3 139
giryan 0:274eb57e1df3 140 switch ( eMode ) {
giryan 0:274eb57e1df3 141 #if MB_RTU_ENABLED > 0
giryan 0:274eb57e1df3 142 case MB_RTU:
giryan 0:274eb57e1df3 143 pvMBFrameStartCur = eMBRTUStart;
giryan 0:274eb57e1df3 144 pvMBFrameStopCur = eMBRTUStop;
giryan 0:274eb57e1df3 145 peMBFrameSendCur = eMBRTUSend;
giryan 0:274eb57e1df3 146 peMBFrameReceiveCur = eMBRTUReceive;
giryan 0:274eb57e1df3 147 pvMBFrameCloseCur = MB_PORT_HAS_CLOSE ? vMBPortClose : NULL;
giryan 0:274eb57e1df3 148 pxMBFrameCBByteReceived = xMBRTUReceiveFSM;
giryan 0:274eb57e1df3 149 pxMBFrameCBTransmitterEmpty = xMBRTUTransmitFSM;
giryan 0:274eb57e1df3 150 pxMBPortCBTimerExpired = xMBRTUTimerT35Expired;
giryan 0:274eb57e1df3 151
giryan 0:274eb57e1df3 152 eStatus = eMBRTUInit( ucMBAddress, ucPort, ulBaudRate, eParity );
giryan 0:274eb57e1df3 153 break;
giryan 0:274eb57e1df3 154 #endif
giryan 0:274eb57e1df3 155 #if MB_ASCII_ENABLED > 0
giryan 0:274eb57e1df3 156 case MB_ASCII:
giryan 0:274eb57e1df3 157 pvMBFrameStartCur = eMBASCIIStart;
giryan 0:274eb57e1df3 158 pvMBFrameStopCur = eMBASCIIStop;
giryan 0:274eb57e1df3 159 peMBFrameSendCur = eMBASCIISend;
giryan 0:274eb57e1df3 160 peMBFrameReceiveCur = eMBASCIIReceive;
giryan 0:274eb57e1df3 161 pvMBFrameCloseCur = MB_PORT_HAS_CLOSE ? vMBPortClose : NULL;
giryan 0:274eb57e1df3 162 pxMBFrameCBByteReceived = xMBASCIIReceiveFSM;
giryan 0:274eb57e1df3 163 pxMBFrameCBTransmitterEmpty = xMBASCIITransmitFSM;
giryan 0:274eb57e1df3 164 pxMBPortCBTimerExpired = xMBASCIITimerT1SExpired;
giryan 0:274eb57e1df3 165
giryan 0:274eb57e1df3 166 eStatus = eMBASCIIInit( ucMBAddress, ucPort, ulBaudRate, eParity );
giryan 0:274eb57e1df3 167 break;
giryan 0:274eb57e1df3 168 #endif
giryan 0:274eb57e1df3 169 default:
giryan 0:274eb57e1df3 170 eStatus = MB_EINVAL;
giryan 0:274eb57e1df3 171 }
giryan 0:274eb57e1df3 172
giryan 0:274eb57e1df3 173 if ( eStatus == MB_ENOERR ) {
giryan 0:274eb57e1df3 174 if ( !xMBPortEventInit( ) ) {
giryan 0:274eb57e1df3 175 /* port dependent event module initalization failed. */
giryan 0:274eb57e1df3 176 eStatus = MB_EPORTERR;
giryan 0:274eb57e1df3 177 } else {
giryan 0:274eb57e1df3 178 eMBCurrentMode = eMode;
giryan 0:274eb57e1df3 179 eMBState = STATE_DISABLED;
giryan 0:274eb57e1df3 180 }
giryan 0:274eb57e1df3 181 }
giryan 0:274eb57e1df3 182 }
giryan 0:274eb57e1df3 183 return eStatus;
giryan 0:274eb57e1df3 184 }
giryan 0:274eb57e1df3 185
giryan 0:274eb57e1df3 186 #if MB_TCP_ENABLED > 0
giryan 0:274eb57e1df3 187 eMBErrorCode
giryan 0:274eb57e1df3 188 eMBTCPInit( USHORT ucTCPPort ) {
giryan 0:274eb57e1df3 189 eMBErrorCode eStatus = MB_ENOERR;
giryan 0:274eb57e1df3 190
giryan 0:274eb57e1df3 191 if ( ( eStatus = eMBTCPDoInit( ucTCPPort ) ) != MB_ENOERR ) {
giryan 0:274eb57e1df3 192 eMBState = STATE_DISABLED;
giryan 0:274eb57e1df3 193 } else if ( !xMBPortEventInit( ) ) {
giryan 0:274eb57e1df3 194 /* Port dependent event module initalization failed. */
giryan 0:274eb57e1df3 195 eStatus = MB_EPORTERR;
giryan 0:274eb57e1df3 196 } else {
giryan 0:274eb57e1df3 197 pvMBFrameStartCur = eMBTCPStart;
giryan 0:274eb57e1df3 198 pvMBFrameStopCur = eMBTCPStop;
giryan 0:274eb57e1df3 199 peMBFrameReceiveCur = eMBTCPReceive;
giryan 0:274eb57e1df3 200 peMBFrameSendCur = eMBTCPSend;
giryan 0:274eb57e1df3 201 pvMBFrameCloseCur = MB_PORT_HAS_CLOSE ? vMBTCPPortClose : NULL;
giryan 0:274eb57e1df3 202 ucMBAddress = MB_TCP_PSEUDO_ADDRESS;
giryan 0:274eb57e1df3 203 eMBCurrentMode = MB_TCP;
giryan 0:274eb57e1df3 204 eMBState = STATE_DISABLED;
giryan 0:274eb57e1df3 205 }
giryan 0:274eb57e1df3 206 return eStatus;
giryan 0:274eb57e1df3 207 }
giryan 0:274eb57e1df3 208 #endif
giryan 0:274eb57e1df3 209
giryan 0:274eb57e1df3 210
giryan 0:274eb57e1df3 211 eMBErrorCode
giryan 0:274eb57e1df3 212 eMBRegisterCB( UCHAR ucFunctionCode, pxMBFunctionHandler pxHandler ) {
giryan 0:274eb57e1df3 213 int i;
giryan 0:274eb57e1df3 214 eMBErrorCode eStatus;
giryan 0:274eb57e1df3 215
giryan 0:274eb57e1df3 216 if ( ( 0 < ucFunctionCode ) && ( ucFunctionCode <= 127 ) ) {
giryan 0:274eb57e1df3 217 ENTER_CRITICAL_SECTION( );
giryan 0:274eb57e1df3 218 if ( pxHandler != NULL ) {
giryan 0:274eb57e1df3 219 for ( i = 0; i < MB_FUNC_HANDLERS_MAX; i++ ) {
giryan 0:274eb57e1df3 220 if ( ( xFuncHandlers[i].pxHandler == NULL ) ||
giryan 0:274eb57e1df3 221 ( xFuncHandlers[i].pxHandler == pxHandler ) ) {
giryan 0:274eb57e1df3 222 xFuncHandlers[i].ucFunctionCode = ucFunctionCode;
giryan 0:274eb57e1df3 223 xFuncHandlers[i].pxHandler = pxHandler;
giryan 0:274eb57e1df3 224 break;
giryan 0:274eb57e1df3 225 }
giryan 0:274eb57e1df3 226 }
giryan 0:274eb57e1df3 227 eStatus = ( i != MB_FUNC_HANDLERS_MAX ) ? MB_ENOERR : MB_ENORES;
giryan 0:274eb57e1df3 228 } else {
giryan 0:274eb57e1df3 229 for ( i = 0; i < MB_FUNC_HANDLERS_MAX; i++ ) {
giryan 0:274eb57e1df3 230 if ( xFuncHandlers[i].ucFunctionCode == ucFunctionCode ) {
giryan 0:274eb57e1df3 231 xFuncHandlers[i].ucFunctionCode = 0;
giryan 0:274eb57e1df3 232 xFuncHandlers[i].pxHandler = NULL;
giryan 0:274eb57e1df3 233 break;
giryan 0:274eb57e1df3 234 }
giryan 0:274eb57e1df3 235 }
giryan 0:274eb57e1df3 236 /* Remove can't fail. */
giryan 0:274eb57e1df3 237 eStatus = MB_ENOERR;
giryan 0:274eb57e1df3 238 }
giryan 0:274eb57e1df3 239 EXIT_CRITICAL_SECTION( );
giryan 0:274eb57e1df3 240 } else {
giryan 0:274eb57e1df3 241 eStatus = MB_EINVAL;
giryan 0:274eb57e1df3 242 }
giryan 0:274eb57e1df3 243 return eStatus;
giryan 0:274eb57e1df3 244 }
giryan 0:274eb57e1df3 245
giryan 0:274eb57e1df3 246
giryan 0:274eb57e1df3 247 eMBErrorCode
giryan 0:274eb57e1df3 248 eMBClose( void ) {
giryan 0:274eb57e1df3 249 eMBErrorCode eStatus = MB_ENOERR;
giryan 0:274eb57e1df3 250
giryan 0:274eb57e1df3 251 if ( eMBState == STATE_DISABLED ) {
giryan 0:274eb57e1df3 252 if ( pvMBFrameCloseCur != NULL ) {
giryan 0:274eb57e1df3 253 pvMBFrameCloseCur( );
giryan 0:274eb57e1df3 254 }
giryan 0:274eb57e1df3 255 } else {
giryan 0:274eb57e1df3 256 eStatus = MB_EILLSTATE;
giryan 0:274eb57e1df3 257 }
giryan 0:274eb57e1df3 258 return eStatus;
giryan 0:274eb57e1df3 259 }
giryan 0:274eb57e1df3 260
giryan 0:274eb57e1df3 261 eMBErrorCode
giryan 0:274eb57e1df3 262 eMBEnable( void ) {
giryan 0:274eb57e1df3 263 eMBErrorCode eStatus = MB_ENOERR;
giryan 0:274eb57e1df3 264
giryan 0:274eb57e1df3 265 if ( eMBState == STATE_DISABLED ) {
giryan 0:274eb57e1df3 266 /* Activate the protocol stack. */
giryan 0:274eb57e1df3 267 pvMBFrameStartCur( );
giryan 0:274eb57e1df3 268 eMBState = STATE_ENABLED;
giryan 0:274eb57e1df3 269 } else {
giryan 0:274eb57e1df3 270 eStatus = MB_EILLSTATE;
giryan 0:274eb57e1df3 271 }
giryan 0:274eb57e1df3 272 return eStatus;
giryan 0:274eb57e1df3 273 }
giryan 0:274eb57e1df3 274
giryan 0:274eb57e1df3 275 eMBErrorCode
giryan 0:274eb57e1df3 276 eMBDisable( void ) {
giryan 0:274eb57e1df3 277 eMBErrorCode eStatus;
giryan 0:274eb57e1df3 278
giryan 0:274eb57e1df3 279 if ( eMBState == STATE_ENABLED ) {
giryan 0:274eb57e1df3 280 pvMBFrameStopCur( );
giryan 0:274eb57e1df3 281 eMBState = STATE_DISABLED;
giryan 0:274eb57e1df3 282 eStatus = MB_ENOERR;
giryan 0:274eb57e1df3 283 } else if ( eMBState == STATE_DISABLED ) {
giryan 0:274eb57e1df3 284 eStatus = MB_ENOERR;
giryan 0:274eb57e1df3 285 } else {
giryan 0:274eb57e1df3 286 eStatus = MB_EILLSTATE;
giryan 0:274eb57e1df3 287 }
giryan 0:274eb57e1df3 288 return eStatus;
giryan 0:274eb57e1df3 289 }
giryan 0:274eb57e1df3 290
giryan 0:274eb57e1df3 291 eMBErrorCode
giryan 0:274eb57e1df3 292 eMBPoll( void ) {
giryan 0:274eb57e1df3 293 static UCHAR *ucMBFrame;
giryan 0:274eb57e1df3 294 static UCHAR ucRcvAddress;
giryan 0:274eb57e1df3 295 static UCHAR ucFunctionCode;
giryan 0:274eb57e1df3 296 static USHORT usLength;
giryan 0:274eb57e1df3 297 static eMBException eException;
giryan 0:274eb57e1df3 298
giryan 0:274eb57e1df3 299 int i;
giryan 0:274eb57e1df3 300 eMBErrorCode eStatus = MB_ENOERR;
giryan 0:274eb57e1df3 301 eMBEventType eEvent;
giryan 0:274eb57e1df3 302
giryan 0:274eb57e1df3 303 /* Check if the protocol stack is ready. */
giryan 0:274eb57e1df3 304 if ( eMBState != STATE_ENABLED ) {
giryan 0:274eb57e1df3 305 return MB_EILLSTATE;
giryan 0:274eb57e1df3 306 }
giryan 0:274eb57e1df3 307
giryan 0:274eb57e1df3 308 /* Check if there is a event available. If not return control to caller.
giryan 0:274eb57e1df3 309 * Otherwise we will handle the event. */
giryan 0:274eb57e1df3 310 if ( xMBPortEventGet( &eEvent ) == TRUE ) {
giryan 0:274eb57e1df3 311 switch ( eEvent ) {
giryan 0:274eb57e1df3 312 case EV_READY:
giryan 0:274eb57e1df3 313 break;
giryan 0:274eb57e1df3 314
giryan 0:274eb57e1df3 315 case EV_FRAME_RECEIVED:
giryan 0:274eb57e1df3 316 eStatus = peMBFrameReceiveCur( &ucRcvAddress, &ucMBFrame, &usLength );
wclin 3:419ee4c5e10f 317 //printf("[EV_FRAME_RECEIVED] usLength=%d \r\n", usLength );
giryan 0:274eb57e1df3 318 if ( eStatus == MB_ENOERR ) {
wclin 3:419ee4c5e10f 319 #if 0
wclin 3:419ee4c5e10f 320 if ( ucMBFrame )
wclin 3:419ee4c5e10f 321 {
wclin 3:419ee4c5e10f 322 printf( "\r\n" );
wclin 3:419ee4c5e10f 323 printf( "-->" );
wclin 3:419ee4c5e10f 324 for ( int i=0; i< usLength; i++ )
wclin 3:419ee4c5e10f 325 printf("%02x ", ucMBFrame[i]);
wclin 3:419ee4c5e10f 326 printf( "\r\n" );
wclin 3:419ee4c5e10f 327 }
wclin 3:419ee4c5e10f 328 #endif
giryan 0:274eb57e1df3 329 /* Check if the frame is for us. If not ignore the frame. */
giryan 0:274eb57e1df3 330 if ( ( ucRcvAddress == ucMBAddress ) || ( ucRcvAddress == MB_ADDRESS_BROADCAST ) ) {
giryan 0:274eb57e1df3 331 ( void )xMBPortEventPost( EV_EXECUTE );
wclin 3:419ee4c5e10f 332 } //else
wclin 3:419ee4c5e10f 333 //printf("Drop\r\n");
wclin 3:419ee4c5e10f 334 } //else printf("Error\r\n");
giryan 0:274eb57e1df3 335 break;
giryan 0:274eb57e1df3 336
giryan 0:274eb57e1df3 337 case EV_EXECUTE:
giryan 0:274eb57e1df3 338 ucFunctionCode = ucMBFrame[MB_PDU_FUNC_OFF];
giryan 0:274eb57e1df3 339 eException = MB_EX_ILLEGAL_FUNCTION;
giryan 0:274eb57e1df3 340
giryan 0:274eb57e1df3 341
giryan 0:274eb57e1df3 342 for ( i = 0; i < MB_FUNC_HANDLERS_MAX; i++ ) {
giryan 0:274eb57e1df3 343 /* No more function handlers registered. Abort. */
giryan 0:274eb57e1df3 344 if ( xFuncHandlers[i].ucFunctionCode == 0 ) {
giryan 0:274eb57e1df3 345 break;
giryan 0:274eb57e1df3 346 } else if ( xFuncHandlers[i].ucFunctionCode == ucFunctionCode ) {
giryan 0:274eb57e1df3 347 eException = xFuncHandlers[i].pxHandler( ucMBFrame, &usLength );
giryan 0:274eb57e1df3 348 break;
giryan 0:274eb57e1df3 349 }
giryan 0:274eb57e1df3 350 }
giryan 0:274eb57e1df3 351
giryan 0:274eb57e1df3 352 /* If the request was not sent to the broadcast address we
giryan 0:274eb57e1df3 353 * return a reply. */
giryan 0:274eb57e1df3 354 if ( ucRcvAddress != MB_ADDRESS_BROADCAST ) {
giryan 0:274eb57e1df3 355 if ( eException != MB_EX_NONE ) {
giryan 0:274eb57e1df3 356 /* An exception occured. Build an error frame. */
giryan 0:274eb57e1df3 357 usLength = 0;
giryan 0:274eb57e1df3 358 ucMBFrame[usLength++] = ( UCHAR )( ucFunctionCode | MB_FUNC_ERROR );
giryan 0:274eb57e1df3 359 ucMBFrame[usLength++] = eException;
giryan 0:274eb57e1df3 360 }
giryan 0:274eb57e1df3 361 eStatus = peMBFrameSendCur( ucMBAddress, ucMBFrame, usLength );
wclin 3:419ee4c5e10f 362 #if 0
wclin 3:419ee4c5e10f 363 if ( ucMBFrame )
wclin 3:419ee4c5e10f 364 {
wclin 3:419ee4c5e10f 365 printf( "\r\n" );
wclin 3:419ee4c5e10f 366 printf( "<--" );
wclin 3:419ee4c5e10f 367 for ( int i=0; i< usLength; i++ )
wclin 3:419ee4c5e10f 368 printf("%02x ", ucMBFrame[i]);
wclin 3:419ee4c5e10f 369 printf( "\r\n" );
wclin 3:419ee4c5e10f 370 #endif
giryan 0:274eb57e1df3 371 }
giryan 0:274eb57e1df3 372 break;
giryan 0:274eb57e1df3 373
giryan 0:274eb57e1df3 374 case EV_FRAME_SENT:
giryan 0:274eb57e1df3 375 break;
giryan 0:274eb57e1df3 376 }
giryan 0:274eb57e1df3 377 }
giryan 0:274eb57e1df3 378 return MB_ENOERR;
giryan 0:274eb57e1df3 379 }