Eric Jung / Mbed OS WIZnet-IoTShield-BG96-MQTT

BG96 Cat.M1 MQTT Pub/Sub client sample for WIZnet IoT Shield

Files at this revision

API Documentation at this revision

Revision 3:e5d7640ce142, committed 2019-03-27

Comitter:
hkjung
Date:
Wed Mar 27 11:43:49 2019 +0000
Parent:
2:b766209b5cff
Commit message:
bug fixed: function checkRecvMqttMessage_BG96()

Changed in this revision

main.cpp Show annotated file Show diff for this revision Revisions of this file 
--- a/main.cpp	Fri Mar 22 06:47:02 2019 +0000
+++ b/main.cpp	Wed Mar 27 11:43:49 2019 +0000
@@ -617,12 +617,42 @@
 {
     int8_t ret = RET_NOK;
     int id = 0;    
+    int idx = 0;
+    char * search_pt;
+    bool done = false;
+    bool received = false;    
+    Timer t;
+    
+    _parser->set_timeout(1);
+    received = _parser->recv("+QMTRECV: %d,%d,\"%[^\"]\",", &id, msgid, topic);    
+    _parser->set_timeout(BG96_DEFAULT_TIMEOUT);
+     
+    if(received) {
+        idx = 0;
+        t.start();
+        do {        
+            _parser->read(&msg[idx++], 1);        
+            search_pt = strstr(msg, "\r\n");
+            if (search_pt != 0) {
+                done = true; // break;
+                ret = RET_OK;
+            }
+        } while(!done && (t.read_ms() < BG96_DEFAULT_TIMEOUT));                
+        t.stop();
+    }
+    return ret;
+    
+    /*
+    // Simple ver.    
+    int8_t ret = RET_NOK;
+    int id = 0;    
     bool received = false;
     
     _parser->set_timeout(1);
     received = _parser->recv("+QMTRECV: %d,%d,\"%[^\"]\",\"%[^\"]\"", &id, msgid, topic, msg);    
-    _parser->set_timeout(BG96_DEFAULT_TIMEOUT);
-     
-    if(received) ret = RET_OK;    
+    _parser->set_timeout(BG96_DEFAULT_TIMEOUT);     
+    
+    if(received) ret = RET_OK;
     return ret;
+    */    
 }