Gabriel Rivas / Mbed 2 deprecated Nucleo_modbus_protocol_test

Example of how to handle the Modbus Slave RTU protocol using the mbed RTOS. This example can also be used as reference to implement other slow serial protocols.

Dependencies:   MessageQueue ModbusSlaveRTU SerialPortHandler mbed-rtos mbed

Files at this revision

API Documentation at this revision

Revision 1:544f5f721159, committed 2015-01-21

Comitter:
gabrielrivas
Date:
Wed Jan 21 03:00:29 2015 +0000
Parent:
0:220ae68e7dd4
Commit message:
Added timer based synchronization to the receiving side tasks.

Changed in this revision

MessageQueue.lib Show annotated file Show diff for this revision Revisions of this file
ModbusSlaveRTU.lib Show annotated file Show diff for this revision Revisions of this file
SerialPortHandler.lib Show annotated file Show diff for this revision Revisions of this file
main.cpp Show annotated file Show diff for this revision Revisions of this file 
diff -r 220ae68e7dd4 -r 544f5f721159 MessageQueue.lib
--- a/MessageQueue.lib	Mon Jan 19 04:07:15 2015 +0000
+++ b/MessageQueue.lib	Wed Jan 21 03:00:29 2015 +0000
@@ -1,1 +1,1 @@
-http://developer.mbed.org/users/gabrielrivas/code/MessageQueue/#faed68cc9fff
+http://developer.mbed.org/users/gabrielrivas/code/MessageQueue/#5e151e3834db

diff -r 220ae68e7dd4 -r 544f5f721159 ModbusSlaveRTU.lib
--- a/ModbusSlaveRTU.lib	Mon Jan 19 04:07:15 2015 +0000
+++ b/ModbusSlaveRTU.lib	Wed Jan 21 03:00:29 2015 +0000
@@ -1,1 +1,1 @@
-http://developer.mbed.org/users/gabrielrivas/code/ModbusSlaveRTU/#81fee41d95f1
+http://developer.mbed.org/users/gabrielrivas/code/ModbusSlaveRTU/#0143a57e0c8e

diff -r 220ae68e7dd4 -r 544f5f721159 SerialPortHandler.lib
--- a/SerialPortHandler.lib	Mon Jan 19 04:07:15 2015 +0000
+++ b/SerialPortHandler.lib	Wed Jan 21 03:00:29 2015 +0000
@@ -1,1 +1,1 @@
-http://developer.mbed.org/users/gabrielrivas/code/SerialPortHandler/#f66dd1c93477
+http://developer.mbed.org/users/gabrielrivas/code/SerialPortHandler/#aa72cb66762f

diff -r 220ae68e7dd4 -r 544f5f721159 main.cpp
--- a/main.cpp	Mon Jan 19 04:07:15 2015 +0000
+++ b/main.cpp	Wed Jan 21 03:00:29 2015 +0000
@@ -9,9 +9,12 @@
 MessageQueue<uint8_t> txQueue(64);
 MessageQueue<uint8_t> rxQueue(64);
 SerialPortHandler sph(&pc, &txQueue, &rxQueue);
+Timer receiveTimer;
+bool isReceiveTimerInitialized = false;
 ModbusSlaveRTU* mbus;
 Thread* modbus_process_thread;
 Thread* data_send_thread;
+Thread* receive_timer_check_thread;
 
 uint8_t cRegs[]  = {1,2,3,4,5,6,7,8,9,0,1,2,3,4,5,6,7,8,9,0};
 uint8_t inRegs[] = {1,2,3,4,5,6,7,8,9,0,1,2,3,4,5,6,7,8,9,0};
@@ -43,6 +46,20 @@
     }    
 }
 
+void timer_check(void const *args)
+{
+    while(true) {
+        if (receiveTimer.read_ms() >= 1) {
+            mbus->trigger();
+            isReceiveTimerInitialized = false;
+            receiveTimer.reset();
+            receiveTimer.stop();
+        }
+        /*Waits for 5 ms*/
+        Thread::wait(5);
+    }
+}
+
 int main (void) {
     pc.attach(&rx_interrupt);
     
@@ -58,16 +75,24 @@
     mbus = new ModbusSlaveRTU(0x01, &txQueue, &rxQueue, &cR, &iR, &hR);    
     modbus_process_thread = new Thread(modbus_process);
     data_send_thread= new Thread(data_send_process);
-    
+    receive_timer_check_thread = new Thread(timer_check);
     while(true)
     {
         Thread::wait(1000);     
         led = !led;
-        mbus->trigger();
     }
 }
 
 void rx_interrupt(void) {
+    if (!isReceiveTimerInitialized)
+    {
+        isReceiveTimerInitialized = true;
+        receiveTimer.start();
+    }    
+    else
+    {
+        receiveTimer.reset();
+    }            
     sph.receivePacket();
     return;
 }