Advertisement
RuiViana

Mod_Bus_Modificada_C_Delay

Jan 14th, 2017
286
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
C++ 27.23 KB | None | 0 0
  1.     /**
  2.     @file
  3.     Arduino library for communicating with Modbus slaves over RS232/485 (via RTU protocol).
  4.     */
  5.     /*
  6.  
  7.       ModbusMaster.cpp - Arduino library for communicating with Modbus slaves
  8.       over RS232/485 (via RTU protocol).
  9.  
  10.       This file is part of ModbusMaster.
  11.  
  12.       ModbusMaster is free software: you can redistribute it and/or modify
  13.       it under the terms of the GNU General Public License as published by
  14.       the Free Software Foundation, either version 3 of the License, or
  15.       (at your option) any later version.
  16.  
  17.       ModbusMaster is distributed in the hope that it will be useful,
  18.       but WITHOUT ANY WARRANTY; without even the implied warranty of
  19.       MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  20.       GNU General Public License for more details.
  21.  
  22.       You should have received a copy of the GNU General Public License
  23.       along with ModbusMaster.  If not, see <http://www.gnu.org/licenses/>.
  24.  
  25.       Written by Doc Walker (Rx)
  26.       Copyright © 2009-2013 Doc Walker <4-20ma at wvfans dot net>
  27.  
  28.     */
  29.  
  30.  
  31.     /* _____PROJECT INCLUDES_____________________________________________________ */
  32. #include "ModbusMaster_Mod.h"
  33.  
  34.  
  35.     /* _____GLOBAL VARIABLES_____________________________________________________ */
  36. #if defined(ARDUINO_ARCH_AVR)
  37.   HardwareSerial* MBSerial = &Serial; ///< Pointer to Serial class object
  38. #elif defined(ARDUINO_ARCH_SAM)
  39.   UARTClass* MBSerial = &Serial; ///< Pointer to Serial class object
  40. #else
  41.   #error "This library only supports boards with an AVR or SAM processor. Please open an issue at https://github.com/4-20ma/ModbusMaster/issues and indicate which processor/platform you're using."
  42. #endif
  43.  
  44.  
  45.     /* _____PUBLIC FUNCTIONS_____________________________________________________ */
  46.     /**
  47.     Constructor.
  48.  
  49.     Creates class object using default serial port 0, Modbus slave ID 1.
  50.  
  51.     @ingroup setup
  52.     */
  53. ModbusMaster::ModbusMaster(void)
  54. {
  55.   _u8SerialPort = 0;
  56.   _u8MBSlave = 1;
  57. }
  58.  
  59.  
  60.     /**
  61.     Constructor.
  62.  
  63.     Creates class object using default serial port 0, specified Modbus slave ID.
  64.  
  65.     @overload void ModbusMaster::ModbusMaster(uint8_t u8MBSlave)
  66.     @param u8MBSlave Modbus slave ID (1..255)
  67.     @ingroup setup
  68.     */
  69. ModbusMaster::ModbusMaster(uint8_t u8MBSlave)
  70. {
  71.   _u8SerialPort = 0;
  72.   _u8MBSlave = u8MBSlave;
  73. }
  74.  
  75.  
  76.     /**
  77.     Constructor.
  78.  
  79.     Creates class object using specified serial port, Modbus slave ID.
  80.  
  81.     @overload void ModbusMaster::ModbusMaster(uint8_t u8SerialPort, uint8_t u8MBSlave)
  82.     @param u8SerialPort serial port (Serial, Serial1..Serial3)
  83.     @param u8MBSlave Modbus slave ID (1..255)
  84.     @ingroup setup
  85.     */
  86. ModbusMaster::ModbusMaster(uint8_t u8SerialPort, uint8_t u8MBSlave, uint8_t u8MBEna)
  87. {
  88.   _u8SerialPort = (u8SerialPort > 3) ? 0 : u8SerialPort;
  89.   _u8MBSlave = u8MBSlave;
  90.   _u8MBEna = u8MBEna;  
  91. }
  92.  
  93.  
  94.     /**
  95.     Initialize class object.
  96.  
  97.     Sets up the serial port using default 19200 baud rate.
  98.     Call once class has been instantiated, typically within setup().
  99.  
  100.     @ingroup setup
  101.     */
  102. void ModbusMaster::begin(void)
  103. {
  104.   begin(19200);
  105. }
  106.  
  107.  
  108.     /**
  109.     Initialize class object.
  110.  
  111.     Sets up the serial port using specified baud rate.
  112.     Call once class has been instantiated, typically within setup().
  113.  
  114.     @overload ModbusMaster::begin(uint16_t u16BaudRate)
  115.     @param u16BaudRate baud rate, in standard increments (300..115200)
  116.     @ingroup setup
  117.     */
  118. void ModbusMaster::begin(uint16_t u16BaudRate)
  119. {
  120.     //  txBuffer = (uint16_t*) calloc(ku8MaxBufferSize, sizeof(uint16_t));
  121.   _u8TransmitBufferIndex = 0;
  122.   u16TransmitBufferLength = 0;
  123.  
  124.   switch(_u8SerialPort)
  125.   {
  126. #if defined(UBRR1H)
  127.     case 1:
  128.       MBSerial = &Serial1;
  129.       break;
  130. #endif
  131.      
  132. #if defined(UBRR2H)
  133.     case 2:
  134.       MBSerial = &Serial2;
  135.       break;
  136. #endif
  137.      
  138. #if defined(UBRR3H)
  139.     case 3:
  140.       MBSerial = &Serial3;
  141.       break;
  142. #endif
  143.      
  144.     case 0:
  145.     default:
  146.       MBSerial = &Serial;
  147.       break;
  148.   }
  149.  
  150.   MBSerial->begin(u16BaudRate);
  151. #if __MODBUSMASTER_DEBUG__
  152. //  pinMode(4, OUTPUT);
  153.  // pinMode(5, OUTPUT);
  154.   pinMode(_u8MBEna, OUTPUT);        // <<----------------------------------------  Alterei
  155.   digitalWrite(_u8MBEna, true);     // <<----------------------------------------  Alterei
  156. #endif
  157. }
  158.  
  159.  
  160. void ModbusMaster::beginTransmission(uint16_t u16Address)
  161. {
  162.   _u16WriteAddress = u16Address;
  163.   _u8TransmitBufferIndex = 0;
  164.   u16TransmitBufferLength = 0;
  165. }
  166.  
  167.     // eliminate this function in favor of using existing MB request functions
  168. uint8_t ModbusMaster::requestFrom(uint16_t address, uint16_t quantity)
  169. {
  170.   uint8_t read;
  171.   // clamp to buffer length
  172.   if (quantity > ku8MaxBufferSize)
  173.   {
  174.     quantity = ku8MaxBufferSize;
  175.   }
  176.   // set rx buffer iterator vars
  177.   _u8ResponseBufferIndex = 0;
  178.   _u8ResponseBufferLength = read;
  179.  
  180.   return read;
  181. }
  182.  
  183.  
  184. void ModbusMaster::sendBit(bool data)
  185. {
  186.   uint8_t txBitIndex = u16TransmitBufferLength % 16;
  187.   if ((u16TransmitBufferLength >> 4) < ku8MaxBufferSize)
  188.   {
  189.     if (0 == txBitIndex)
  190.     {
  191.       _u16TransmitBuffer[_u8TransmitBufferIndex] = 0;
  192.     }
  193.     bitWrite(_u16TransmitBuffer[_u8TransmitBufferIndex], txBitIndex, data);
  194.     u16TransmitBufferLength++;
  195.     _u8TransmitBufferIndex = u16TransmitBufferLength >> 4;
  196.   }
  197. }
  198.  
  199.  
  200. void ModbusMaster::send(uint16_t data)
  201. {
  202.   if (_u8TransmitBufferIndex < ku8MaxBufferSize)
  203.   {
  204.     _u16TransmitBuffer[_u8TransmitBufferIndex++] = data;
  205.     u16TransmitBufferLength = _u8TransmitBufferIndex << 4;
  206.   }
  207. }
  208.  
  209.  
  210. void ModbusMaster::send(uint32_t data)
  211. {
  212.   send(lowWord(data));
  213.   send(highWord(data));
  214. }
  215.  
  216.  
  217. void ModbusMaster::send(uint8_t data)
  218. {
  219.   send(word(data));
  220. }
  221.  
  222.  
  223.  
  224.  
  225.  
  226.  
  227.  
  228.  
  229.  
  230. uint8_t ModbusMaster::available(void)
  231. {
  232.   return _u8ResponseBufferLength - _u8ResponseBufferIndex;
  233. }
  234.  
  235.  
  236. uint16_t ModbusMaster::receive(void)
  237. {
  238.   if (_u8ResponseBufferIndex < _u8ResponseBufferLength)
  239.   {
  240.     return _u16ResponseBuffer[_u8ResponseBufferIndex++];
  241.   }
  242.   else
  243.   {
  244.     return 0xFFFF;
  245.   }
  246. }
  247.  
  248.  
  249.  
  250.  
  251.  
  252.  
  253.  
  254.  
  255.     /**
  256.     Set idle time callback function (cooperative multitasking).
  257.  
  258.     This function gets called in the idle time between transmission of data
  259.     and response from slave. Do not call functions that read from the serial
  260.     buffer that is used by ModbusMaster. Use of i2c/TWI, 1-Wire, other
  261.     serial ports, etc. is permitted within callback function.
  262.  
  263.     @see ModbusMaster::ModbusMasterTransaction()
  264.     */
  265. void ModbusMaster::idle(void (*idle)())
  266. {
  267.   _idle = idle;
  268. }
  269.  
  270.  
  271.     /**
  272.     Retrieve data from response buffer.
  273.  
  274.     @see ModbusMaster::clearResponseBuffer()
  275.     @param u8Index index of response buffer array (0x00..0x3F)
  276.     @return value in position u8Index of response buffer (0x0000..0xFFFF)
  277.     @ingroup buffer
  278.     */
  279. uint16_t ModbusMaster::getResponseBuffer(uint8_t u8Index)
  280. {
  281.   if (u8Index < ku8MaxBufferSize)
  282.   {
  283.     return _u16ResponseBuffer[u8Index];
  284.   }
  285.   else
  286.   {
  287.     return 0xFFFF;
  288.   }
  289. }
  290.  
  291.  
  292.     /**
  293.     Clear Modbus response buffer.
  294.  
  295.     @see ModbusMaster::getResponseBuffer(uint8_t u8Index)
  296.     @ingroup buffer
  297.     */
  298. void ModbusMaster::clearResponseBuffer()
  299. {
  300.   uint8_t i;
  301.  
  302.   for (i = 0; i < ku8MaxBufferSize; i++)
  303.   {
  304.     _u16ResponseBuffer[i] = 0;
  305.   }
  306. }
  307.  
  308.  
  309.     /**
  310.     Place data in transmit buffer.
  311.  
  312.     @see ModbusMaster::clearTransmitBuffer()
  313.     @param u8Index index of transmit buffer array (0x00..0x3F)
  314.     @param u16Value value to place in position u8Index of transmit buffer (0x0000..0xFFFF)
  315.     @return 0 on success; exception number on failure
  316.     @ingroup buffer
  317.     */
  318. uint8_t ModbusMaster::setTransmitBuffer(uint8_t u8Index, uint16_t u16Value)
  319. {
  320.   if (u8Index < ku8MaxBufferSize)
  321.   {
  322.     _u16TransmitBuffer[u8Index] = u16Value;
  323.     return ku8MBSuccess;
  324.   }
  325.   else
  326.   {
  327.     return ku8MBIllegalDataAddress;
  328.   }
  329. }
  330.  
  331.  
  332.     /**
  333.     Clear Modbus transmit buffer.
  334.  
  335.     @see ModbusMaster::setTransmitBuffer(uint8_t u8Index, uint16_t u16Value)
  336.     @ingroup buffer
  337.     */
  338. void ModbusMaster::clearTransmitBuffer()
  339. {
  340.   uint8_t i;
  341.  
  342.   for (i = 0; i < ku8MaxBufferSize; i++)
  343.   {
  344.     _u16TransmitBuffer[i] = 0;
  345.   }
  346. }
  347.  
  348.  
  349.     /**
  350.     Modbus function 0x01 Read Coils.
  351.  
  352.     This function code is used to read from 1 to 2000 contiguous status of
  353.     coils in a remote device. The request specifies the starting address,
  354.     i.e. the address of the first coil specified, and the number of coils.
  355.     Coils are addressed starting at zero.
  356.  
  357.     The coils in the response buffer are packed as one coil per bit of the
  358.     data field. Status is indicated as 1=ON and 0=OFF. The LSB of the first
  359.     data word contains the output addressed in the query. The other coils
  360.     follow toward the high order end of this word and from low order to high
  361.     order in subsequent words.
  362.  
  363.     If the returned quantity is not a multiple of sixteen, the remaining
  364.     bits in the final data word will be padded with zeros (toward the high
  365.     order end of the word).
  366.  
  367.     @param u16ReadAddress address of first coil (0x0000..0xFFFF)
  368.     @param u16BitQty quantity of coils to read (1..2000, enforced by remote device)
  369.     @return 0 on success; exception number on failure
  370.     @ingroup discrete
  371.     */
  372. uint8_t ModbusMaster::readCoils(uint16_t u16ReadAddress, uint16_t u16BitQty)
  373. {
  374.   _u16ReadAddress = u16ReadAddress;
  375.   _u16ReadQty = u16BitQty;
  376.   return ModbusMasterTransaction(ku8MBReadCoils);
  377. }
  378.  
  379.  
  380.     /**
  381.     Modbus function 0x02 Read Discrete Inputs.
  382.  
  383.     This function code is used to read from 1 to 2000 contiguous status of
  384.     discrete inputs in a remote device. The request specifies the starting
  385.     address, i.e. the address of the first input specified, and the number
  386.     of inputs. Discrete inputs are addressed starting at zero.
  387.  
  388.     The discrete inputs in the response buffer are packed as one input per
  389.     bit of the data field. Status is indicated as 1=ON; 0=OFF. The LSB of
  390.     the first data word contains the input addressed in the query. The other
  391.     inputs follow toward the high order end of this word, and from low order
  392.     to high order in subsequent words.
  393.  
  394.     If the returned quantity is not a multiple of sixteen, the remaining
  395.     bits in the final data word will be padded with zeros (toward the high
  396.     order end of the word).
  397.  
  398.     @param u16ReadAddress address of first discrete input (0x0000..0xFFFF)
  399.     @param u16BitQty quantity of discrete inputs to read (1..2000, enforced by remote device)
  400.     @return 0 on success; exception number on failure
  401.     @ingroup discrete
  402.     */
  403. uint8_t ModbusMaster::readDiscreteInputs(uint16_t u16ReadAddress,
  404.   uint16_t u16BitQty)
  405. {
  406.   _u16ReadAddress = u16ReadAddress;
  407.   _u16ReadQty = u16BitQty;
  408.   return ModbusMasterTransaction(ku8MBReadDiscreteInputs);
  409. }
  410.  
  411.  
  412.     /**
  413.     Modbus function 0x03 Read Holding Registers.
  414.  
  415.     This function code is used to read the contents of a contiguous block of
  416.     holding registers in a remote device. The request specifies the starting
  417.     register address and the number of registers. Registers are addressed
  418.     starting at zero.
  419.  
  420.     The register data in the response buffer is packed as one word per
  421.     register.
  422.  
  423.     @param u16ReadAddress address of the first holding register (0x0000..0xFFFF)
  424.     @param u16ReadQty quantity of holding registers to read (1..125, enforced by remote device)
  425.     @return 0 on success; exception number on failure
  426.     @ingroup register
  427.     */
  428. uint8_t ModbusMaster::readHoldingRegisters(uint16_t u16ReadAddress,
  429.   uint16_t u16ReadQty)
  430. {
  431.   _u16ReadAddress = u16ReadAddress;
  432.   _u16ReadQty = u16ReadQty;
  433.   return ModbusMasterTransaction(ku8MBReadHoldingRegisters);
  434. }
  435.  
  436.  
  437.     /**
  438.     Modbus function 0x04 Read Input Registers.
  439.    
  440.     This function code is used to read from 1 to 125 contiguous input
  441.     registers in a remote device. The request specifies the starting
  442.     register address and the number of registers. Registers are addressed
  443.     starting at zero.
  444.  
  445.     The register data in the response buffer is packed as one word per
  446.     register.
  447.  
  448.     @param u16ReadAddress address of the first input register (0x0000..0xFFFF)
  449.     @param u16ReadQty quantity of input registers to read (1..125, enforced by remote device)
  450.     @return 0 on success; exception number on failure
  451.     @ingroup register
  452.     */
  453. uint8_t ModbusMaster::readInputRegisters(uint16_t u16ReadAddress,
  454.   uint8_t u16ReadQty)
  455. {
  456.   _u16ReadAddress = u16ReadAddress;
  457.   _u16ReadQty = u16ReadQty;
  458.   return ModbusMasterTransaction(ku8MBReadInputRegisters);
  459. }
  460.  
  461.  
  462.     /**
  463.     Modbus function 0x05 Write Single Coil.
  464.  
  465.     This function code is used to write a single output to either ON or OFF
  466.     in a remote device. The requested ON/OFF state is specified by a
  467.     constant in the state field. A non-zero value requests the output to be
  468.     ON and a value of 0 requests it to be OFF. The request specifies the
  469.     address of the coil to be forced. Coils are addressed starting at zero.
  470.  
  471.     @param u16WriteAddress address of the coil (0x0000..0xFFFF)
  472.     @param u8State 0=OFF, non-zero=ON (0x00..0xFF)
  473.     @return 0 on success; exception number on failure
  474.     @ingroup discrete
  475.     */
  476. uint8_t ModbusMaster::writeSingleCoil(uint16_t u16WriteAddress, uint8_t u8State)
  477. {
  478.   _u16WriteAddress = u16WriteAddress;
  479.   _u16WriteQty = (u8State ? 0xFF00 : 0x0000);
  480.   return ModbusMasterTransaction(ku8MBWriteSingleCoil);
  481. }
  482.  
  483.  
  484.     /**
  485.     Modbus function 0x06 Write Single Register.
  486.  
  487.     This function code is used to write a single holding register in a
  488.     remote device. The request specifies the address of the register to be
  489.     written. Registers are addressed starting at zero.
  490.  
  491.     @param u16WriteAddress address of the holding register (0x0000..0xFFFF)
  492.     @param u16WriteValue value to be written to holding register (0x0000..0xFFFF)
  493.     @return 0 on success; exception number on failure
  494.     @ingroup register
  495.     */
  496. uint8_t ModbusMaster::writeSingleRegister(uint16_t u16WriteAddress,
  497.   uint16_t u16WriteValue)
  498. {
  499.   _u16WriteAddress = u16WriteAddress;
  500.   _u16WriteQty = 0;
  501.   _u16TransmitBuffer[0] = u16WriteValue;
  502.   return ModbusMasterTransaction(ku8MBWriteSingleRegister);
  503. }
  504.  
  505.  
  506.     /**
  507.     Modbus function 0x0F Write Multiple Coils.
  508.  
  509.     This function code is used to force each coil in a sequence of coils to
  510.     either ON or OFF in a remote device. The request specifies the coil
  511.     references to be forced. Coils are addressed starting at zero.
  512.  
  513.     The requested ON/OFF states are specified by contents of the transmit
  514.     buffer. A logical '1' in a bit position of the buffer requests the
  515.     corresponding output to be ON. A logical '0' requests it to be OFF.
  516.  
  517.     @param u16WriteAddress address of the first coil (0x0000..0xFFFF)
  518.     @param u16BitQty quantity of coils to write (1..2000, enforced by remote device)
  519.     @return 0 on success; exception number on failure
  520.     @ingroup discrete
  521.     */
  522. uint8_t ModbusMaster::writeMultipleCoils(uint16_t u16WriteAddress,
  523.   uint16_t u16BitQty)
  524. {
  525.   _u16WriteAddress = u16WriteAddress;
  526.   _u16WriteQty = u16BitQty;
  527.   return ModbusMasterTransaction(ku8MBWriteMultipleCoils);
  528. }
  529. uint8_t ModbusMaster::writeMultipleCoils()
  530. {
  531.   _u16WriteQty = u16TransmitBufferLength;
  532.   return ModbusMasterTransaction(ku8MBWriteMultipleCoils);
  533. }
  534.  
  535.  
  536.     /**
  537.     Modbus function 0x10 Write Multiple Registers.
  538.  
  539.     This function code is used to write a block of contiguous registers (1
  540.     to 123 registers) in a remote device.
  541.  
  542.     The requested written values are specified in the transmit buffer. Data
  543.     is packed as one word per register.
  544.  
  545.     @param u16WriteAddress address of the holding register (0x0000..0xFFFF)
  546.     @param u16WriteQty quantity of holding registers to write (1..123, enforced by remote device)
  547.     @return 0 on success; exception number on failure
  548.     @ingroup register
  549.     */
  550. uint8_t ModbusMaster::writeMultipleRegisters(uint16_t u16WriteAddress,
  551.   uint16_t u16WriteQty)
  552.  
  553. {
  554.   _u16WriteAddress = u16WriteAddress;
  555.   _u16WriteQty = u16WriteQty;
  556.   return ModbusMasterTransaction(ku8MBWriteMultipleRegisters);
  557. }
  558.  
  559. // new version based on Wire.h
  560. uint8_t ModbusMaster::writeMultipleRegisters()
  561. {
  562.   _u16WriteQty = _u8TransmitBufferIndex;
  563.   return ModbusMasterTransaction(ku8MBWriteMultipleRegisters);
  564. }
  565.  
  566.  
  567.     /**
  568.     Modbus function 0x16 Mask Write Register.
  569.  
  570.     This function code is used to modify the contents of a specified holding
  571.     register using a combination of an AND mask, an OR mask, and the
  572.     register's current contents. The function can be used to set or clear
  573.     individual bits in the register.
  574.  
  575.     The request specifies the holding register to be written, the data to be
  576.     used as the AND mask, and the data to be used as the OR mask. Registers
  577.     are addressed starting at zero.
  578.  
  579.     The function's algorithm is:
  580.  
  581.     Result = (Current Contents && And_Mask) || (Or_Mask && (~And_Mask))
  582.  
  583.     @param u16WriteAddress address of the holding register (0x0000..0xFFFF)
  584.     @param u16AndMask AND mask (0x0000..0xFFFF)
  585.     @param u16OrMask OR mask (0x0000..0xFFFF)
  586.     @return 0 on success; exception number on failure
  587.     @ingroup register
  588.     */
  589. uint8_t ModbusMaster::maskWriteRegister(uint16_t u16WriteAddress,
  590.   uint16_t u16AndMask, uint16_t u16OrMask)
  591. {
  592.   _u16WriteAddress = u16WriteAddress;
  593.   _u16TransmitBuffer[0] = u16AndMask;
  594.   _u16TransmitBuffer[1] = u16OrMask;
  595.   return ModbusMasterTransaction(ku8MBMaskWriteRegister);
  596. }
  597.  
  598.  
  599.     /**
  600.     Modbus function 0x17 Read Write Multiple Registers.
  601.  
  602.     This function code performs a combination of one read operation and one
  603.     write operation in a single MODBUS transaction. The write operation is
  604.     performed before the read. Holding registers are addressed starting at
  605.     zero.
  606.  
  607.     The request specifies the starting address and number of holding
  608.     registers to be read as well as the starting address, and the number of
  609.     holding registers. The data to be written is specified in the transmit
  610.     buffer.
  611.  
  612.     @param u16ReadAddress address of the first holding register (0x0000..0xFFFF)
  613.     @param u16ReadQty quantity of holding registers to read (1..125, enforced by remote device)
  614.     @param u16WriteAddress address of the first holding register (0x0000..0xFFFF)
  615.     @param u16WriteQty quantity of holding registers to write (1..121, enforced by remote device)
  616.     @return 0 on success; exception number on failure
  617.     @ingroup register
  618.     */
  619. uint8_t ModbusMaster::readWriteMultipleRegisters(uint16_t u16ReadAddress,
  620.   uint16_t u16ReadQty, uint16_t u16WriteAddress, uint16_t u16WriteQty)
  621. {
  622.   _u16ReadAddress = u16ReadAddress;
  623.   _u16ReadQty = u16ReadQty;
  624.   _u16WriteAddress = u16WriteAddress;
  625.   _u16WriteQty = u16WriteQty;
  626.   return ModbusMasterTransaction(ku8MBReadWriteMultipleRegisters);
  627. }
  628. uint8_t ModbusMaster::readWriteMultipleRegisters(uint16_t u16ReadAddress,
  629.   uint16_t u16ReadQty)
  630. {
  631.   _u16ReadAddress = u16ReadAddress;
  632.   _u16ReadQty = u16ReadQty;
  633.   _u16WriteQty = _u8TransmitBufferIndex;
  634.   return ModbusMasterTransaction(ku8MBReadWriteMultipleRegisters);
  635. }
  636.  
  637.  
  638.     /* _____PRIVATE FUNCTIONS____________________________________________________ */
  639.     /**
  640.     Modbus transaction engine.
  641.     Sequence:
  642.       - assemble Modbus Request Application Data Unit (ADU),
  643.         based on particular function called
  644.       - transmit request over selected serial port
  645.       - wait for/retrieve response
  646.       - evaluate/disassemble response
  647.       - return status (success/exception)
  648.  
  649.     @param u8MBFunction Modbus function (0x01..0xFF)
  650.     @return 0 on success; exception number on failure
  651.     */
  652. //----------------------------------------------------------------------------------
  653. uint8_t ModbusMaster::ModbusMasterTransaction(uint8_t u8MBFunction)
  654. {
  655.   uint8_t u8ModbusADU[256];
  656.   uint8_t u8ModbusADUSize = 0;
  657.   uint8_t i, u8Qty;
  658.   uint16_t u16CRC;
  659.   uint32_t u32StartTime;
  660.   uint8_t u8BytesLeft = 8;
  661.   uint8_t u8MBStatus = ku8MBSuccess;
  662.  
  663.     // assemble Modbus Request Application Data Unit
  664.   u8ModbusADU[u8ModbusADUSize++] = _u8MBSlave;
  665.   u8ModbusADU[u8ModbusADUSize++] = u8MBFunction;
  666.  
  667.   switch(u8MBFunction)
  668.   {
  669.     case ku8MBReadCoils:
  670.     case ku8MBReadDiscreteInputs:
  671.     case ku8MBReadInputRegisters:
  672.     case ku8MBReadHoldingRegisters:
  673.     case ku8MBReadWriteMultipleRegisters:
  674.       u8ModbusADU[u8ModbusADUSize++] = highByte(_u16ReadAddress);
  675.       u8ModbusADU[u8ModbusADUSize++] = lowByte(_u16ReadAddress);
  676.       u8ModbusADU[u8ModbusADUSize++] = highByte(_u16ReadQty);
  677.       u8ModbusADU[u8ModbusADUSize++] = lowByte(_u16ReadQty);
  678.       break;
  679.   }
  680.  
  681.   switch(u8MBFunction)
  682.   {
  683.     case ku8MBWriteSingleCoil:
  684.     case ku8MBMaskWriteRegister:
  685.     case ku8MBWriteMultipleCoils:
  686.     case ku8MBWriteSingleRegister:
  687.     case ku8MBWriteMultipleRegisters:
  688.     case ku8MBReadWriteMultipleRegisters:
  689.       u8ModbusADU[u8ModbusADUSize++] = highByte(_u16WriteAddress);
  690.       u8ModbusADU[u8ModbusADUSize++] = lowByte(_u16WriteAddress);
  691.  
  692.       break;
  693.   }
  694.  
  695.   switch(u8MBFunction)
  696.   {
  697.     case ku8MBWriteSingleCoil:
  698.       u8ModbusADU[u8ModbusADUSize++] = highByte(_u16WriteQty);
  699.       u8ModbusADU[u8ModbusADUSize++] = lowByte(_u16WriteQty);
  700.       break;
  701.      
  702.     case ku8MBWriteSingleRegister:
  703.       u8ModbusADU[u8ModbusADUSize++] = highByte(_u16TransmitBuffer[0]);
  704.       u8ModbusADU[u8ModbusADUSize++] = lowByte(_u16TransmitBuffer[0]);
  705.       break;
  706.      
  707.     case ku8MBWriteMultipleCoils:
  708.       u8ModbusADU[u8ModbusADUSize++] = highByte(_u16WriteQty);
  709.       u8ModbusADU[u8ModbusADUSize++] = lowByte(_u16WriteQty);
  710.       u8Qty = (_u16WriteQty % 8) ? ((_u16WriteQty >> 3) + 1) : (_u16WriteQty >> 3);
  711.       u8ModbusADU[u8ModbusADUSize++] = u8Qty;
  712.       for (i = 0; i < u8Qty; i++)
  713.       {
  714.         switch(i % 2)
  715.         {
  716.           case 0: // i is even
  717.             u8ModbusADU[u8ModbusADUSize++] = lowByte(_u16TransmitBuffer[i >> 1]);
  718.             break;
  719.            
  720.           case 1: // i is odd
  721.             u8ModbusADU[u8ModbusADUSize++] = highByte(_u16TransmitBuffer[i >> 1]);
  722.             break;
  723.         }
  724.       }
  725.       break;
  726.      
  727.       case ku8MBWriteMultipleRegisters:
  728.       case ku8MBReadWriteMultipleRegisters:
  729.       u8ModbusADU[u8ModbusADUSize++] = highByte(_u16WriteQty);
  730.       u8ModbusADU[u8ModbusADUSize++] = lowByte(_u16WriteQty);
  731.       u8ModbusADU[u8ModbusADUSize++] = lowByte(_u16WriteQty << 1);
  732.      
  733.       for (i = 0; i < lowByte(_u16WriteQty); i++)
  734.       {
  735.         u8ModbusADU[u8ModbusADUSize++] = highByte(_u16TransmitBuffer[i]);
  736.         u8ModbusADU[u8ModbusADUSize++] = lowByte(_u16TransmitBuffer[i]);
  737.       }
  738.       break;
  739.      
  740.       case ku8MBMaskWriteRegister:
  741.       u8ModbusADU[u8ModbusADUSize++] = highByte(_u16TransmitBuffer[0]);
  742.       u8ModbusADU[u8ModbusADUSize++] = lowByte(_u16TransmitBuffer[0]);
  743.       u8ModbusADU[u8ModbusADUSize++] = highByte(_u16TransmitBuffer[1]);
  744.       u8ModbusADU[u8ModbusADUSize++] = lowByte(_u16TransmitBuffer[1]);
  745.       break;
  746.   }
  747.  
  748.     // append CRC
  749.   u16CRC = 0xFFFF;
  750.   for (i = 0; i < u8ModbusADUSize; i++)
  751.   {
  752.     u16CRC = crc16_update(u16CRC, u8ModbusADU[i]);
  753.   }
  754.   u8ModbusADU[u8ModbusADUSize++] = lowByte(u16CRC);
  755.   u8ModbusADU[u8ModbusADUSize++] = highByte(u16CRC);
  756.   u8ModbusADU[u8ModbusADUSize] = 0;
  757.  
  758.     // flush receive buffer before transmitting request
  759.   while (MBSerial->read() != -1);
  760.  
  761.     // transmit request
  762.   for (i = 0; i < u8ModbusADUSize; i++)
  763.   {
  764. #if defined(ARDUINO) && ARDUINO >= 100
  765.     MBSerial->write(u8ModbusADU[i]);
  766. #else
  767.     MBSerial->print(u8ModbusADU[i], BYTE);
  768. #endif
  769.   }
  770.  
  771.   u8ModbusADUSize = 0;
  772.   MBSerial->flush();    // flush transmit buffer
  773.  
  774.     // loop until we run out of time or bytes, or an error occurs
  775.   u32StartTime = millis();
  776.   while (u8BytesLeft && !u8MBStatus)
  777.   {
  778. //  delay(4);               // <<----------------------------------------  Alterei
  779.     digitalWrite(_u8MBEna, false);      // <<----------------------------------------  Alterei
  780.     if (MBSerial->available())
  781.     {
  782. #if __MODBUSMASTER_DEBUG__
  783. //      digitalWrite(4, true);
  784. #endif
  785.       u8ModbusADU[u8ModbusADUSize++] = MBSerial->read();
  786.       u8BytesLeft--;
  787. #if __MODBUSMASTER_DEBUG__
  788. //      digitalWrite(4, false);
  789. #endif
  790.     }
  791.     else
  792.     {
  793. //   digitalWrite(_u8MBEna, false);     // <<----------------------------------------  Alterei
  794. #if __MODBUSMASTER_DEBUG__
  795. //     digitalWrite(5, true);       // <<----------------------------------------  original
  796. #endif
  797.       if (_idle)
  798.       {
  799.         _idle();
  800.       }
  801. #if __MODBUSMASTER_DEBUG__
  802. //      digitalWrite(5, false);     // <<----------------------------------------  original
  803. #endif
  804.     }
  805.    
  806.         // evaluate slave ID, function code once enough bytes have been read
  807.     if (u8ModbusADUSize == 5)
  808.     {
  809.         // verify response is for correct Modbus slave
  810.       if (u8ModbusADU[0] != _u8MBSlave)
  811.       {
  812.         u8MBStatus = ku8MBInvalidSlaveID;
  813.         break;
  814.       }
  815.      
  816.         // verify response is for correct Modbus function code (mask exception bit 7)
  817.       if ((u8ModbusADU[1] & 0x7F) != u8MBFunction)
  818.       {
  819.         u8MBStatus = ku8MBInvalidFunction;
  820.         break;
  821.       }
  822.      
  823.         // check whether Modbus exception occurred; return Modbus Exception Code
  824.       if (bitRead(u8ModbusADU[1], 7))
  825.       {
  826.         u8MBStatus = u8ModbusADU[2];
  827.         break;
  828.       }
  829.      
  830.         // evaluate returned Modbus function code
  831.       switch(u8ModbusADU[1])
  832.       {
  833.         case ku8MBReadCoils:
  834.         case ku8MBReadDiscreteInputs:
  835.         case ku8MBReadInputRegisters:
  836.         case ku8MBReadHoldingRegisters:
  837.         case ku8MBReadWriteMultipleRegisters:
  838.           u8BytesLeft = u8ModbusADU[2];
  839.           break;
  840.          
  841.         case ku8MBWriteSingleCoil:
  842.         case ku8MBWriteMultipleCoils:
  843.         case ku8MBWriteSingleRegister:
  844.         case ku8MBWriteMultipleRegisters:
  845.           u8BytesLeft = 3;
  846.            break;
  847.          
  848.         case ku8MBMaskWriteRegister:
  849.           u8BytesLeft = 5;
  850.           break;
  851.       }
  852.     }
  853.        if ((millis() - u32StartTime) > ku16MBResponseTimeout)
  854.     {
  855.       u8MBStatus = ku8MBResponseTimedOut;
  856.     }
  857.   }
  858.       digitalWrite(_u8MBEna, true);     // <<----------------------------------------  Alterei
  859.     // verify response is large enough to inspect further
  860.   if (!u8MBStatus && u8ModbusADUSize >= 5)
  861.   {
  862.         // calculate CRC
  863.     u16CRC = 0xFFFF;
  864.     for (i = 0; i < (u8ModbusADUSize - 2); i++)
  865.     {
  866.       u16CRC = crc16_update(u16CRC, u8ModbusADU[i]);
  867.     }
  868.    
  869.         // verify CRC
  870.     if (!u8MBStatus && (lowByte(u16CRC) != u8ModbusADU[u8ModbusADUSize - 2] ||
  871.       highByte(u16CRC) != u8ModbusADU[u8ModbusADUSize - 1]))
  872.     {
  873.       u8MBStatus = ku8MBInvalidCRC;
  874.     }
  875.   }
  876.     // disassemble ADU into words
  877.   if (!u8MBStatus)
  878.   {
  879.         // evaluate returned Modbus function code
  880.     switch(u8ModbusADU[1])
  881.     {
  882.       case ku8MBReadCoils:
  883.       case ku8MBReadDiscreteInputs:
  884.             // load bytes into word; response bytes are ordered L, H, L, H, ...
  885.         for (i = 0; i < (u8ModbusADU[2] >> 1); i++)
  886.         {
  887.           if (i < ku8MaxBufferSize)
  888.           {
  889.             _u16ResponseBuffer[i] = word(u8ModbusADU[2 * i + 4], u8ModbusADU[2 * i + 3]);
  890.           }
  891.          
  892.           _u8ResponseBufferLength = i;
  893.         }
  894.        
  895.             // in the event of an odd number of bytes, load last byte into zero-padded word
  896.         if (u8ModbusADU[2] % 2)
  897.         {
  898.           if (i < ku8MaxBufferSize)
  899.           {
  900.             _u16ResponseBuffer[i] = word(0, u8ModbusADU[2 * i + 3]);
  901.           }
  902.          
  903.           _u8ResponseBufferLength = i + 1;
  904.         }
  905.         break;
  906.        
  907.       case ku8MBReadInputRegisters:
  908.       case ku8MBReadHoldingRegisters:
  909.       case ku8MBReadWriteMultipleRegisters:
  910.             // load bytes into word; response bytes are ordered H, L, H, L, ...
  911.         for (i = 0; i < (u8ModbusADU[2] >> 1); i++)
  912.         {
  913.           if (i < ku8MaxBufferSize)
  914.           {
  915.             _u16ResponseBuffer[i] = word(u8ModbusADU[2 * i + 3], u8ModbusADU[2 * i + 4]);
  916.           }
  917.          
  918.           _u8ResponseBufferLength = i;
  919.         }
  920.         break;
  921.     }
  922.   }
  923.   _u8TransmitBufferIndex = 0;
  924.   u16TransmitBufferLength = 0;
  925.   _u8ResponseBufferIndex = 0;
  926.   return u8MBStatus;
  927. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement