Introduces background thread for OOB processing

Author: Veijo Pesonen

ESP8266/ESP8266.cpp

@@ -590,6 +590,13 @@ void ESP8266::_process_oob(uint32_t timeout, bool all) {
     set_timeout();
 }
 
+void ESP8266::bg_process_oob(uint32_t timeout, bool all)
+{
+    _smutex.lock();
+    _process_oob(timeout, all);
+    _smutex.unlock();
+}
+
 int32_t ESP8266::_recv_tcp_passive(int id, void *data, uint32_t amount, uint32_t timeout)
 {
     int32_t len;

ESP8266/ESP8266.h

@@ -343,6 +343,14 @@ class ESP8266
      */
     bool cond_enable_tcp_passive_mode();
 
+    /**
+     * For executing OOB processing on background
+     *
+     * @param timeout AT parser receive timeout
+     * @param if TRUE, process all OOBs instead of only one
+     */
+    void bg_process_oob(uint32_t timeout, bool all);
+
     static const int8_t WIFIMODE_STATION = 1;
     static const int8_t WIFIMODE_SOFTAP = 2;
     static const int8_t WIFIMODE_STATION_SOFTAP = 3;

ESP8266Interface.cpp

@@ -15,6 +15,7 @@
  */
 
 #include <cstring>
+#include "Callback.h"
 #include "ESP8266.h"
 #include "ESP8266Interface.h"
 #include "mbed_debug.h"
@@ -123,6 +124,10 @@ int ESP8266Interface::connect()
         return status;
     }
 
+    if (_oob_thread.get_state() == rtos::Thread::Deleted) {
+        _oob_thread.start(callback(this, &ESP8266Interface::bg_process_oob));
+    }
+
     if(get_ip_address()) {
         return NSAPI_ERROR_IS_CONNECTED;
     }
@@ -196,9 +201,6 @@ int ESP8266Interface::set_channel(uint8_t channel)
 
 int ESP8266Interface::disconnect()
 {
-    _started = false;
-    _initialized = false;
-
     return _esp.disconnect() ? NSAPI_ERROR_OK : NSAPI_ERROR_DEVICE_ERROR;
 }
 
@@ -627,3 +629,11 @@ void ESP8266Interface::update_conn_state_cb()
         _conn_stat_cb(NSAPI_EVENT_CONNECTION_STATUS_CHANGE, _conn_stat);
     }
 }
+
+void ESP8266Interface::bg_process_oob()
+{
+    for(;;) {
+        _esp.bg_process_oob(ESP8266_RECV_TIMEOUT, true);
+        wait_ms(ESP8266_RECV_TIMEOUT);
+    }
+}

ESP8266Interface.h

@@ -19,6 +19,7 @@
 
 #include "mbed.h"
 
+#include "Thread.h"
 #include "Callback.h"
 #include "netsocket/nsapi_types.h"
 #include "netsocket/NetworkInterface.h"
@@ -361,6 +362,10 @@ class ESP8266Interface : public NetworkStack, public WiFiInterface
     // Connection state reporting to application
     nsapi_connection_status_t _conn_stat;
     Callback<void(nsapi_event_t, intptr_t)> _conn_stat_cb;
+
+    // Background OOB processing
+    rtos::Thread _oob_thread;
+    void bg_process_oob();
 };
 
 #endif