Cellular: retry logic for CellularContext connect

State machine has retry logic until device is attached to network.
After this CellularContext does the context activation e.g. connect.
There was no retry logic for context activation. Added logic to
CellularContext level so it's available for at and (upcoming)ril layers.

Author: Teppo Järvelin

UNITTESTS/features/cellular/framework/AT/at_cellularcontext/unittest.cmake

@@ -41,4 +41,5 @@ set(unittest-test-sources
   stubs/us_ticker_stub.cpp
   stubs/UARTSerial_stub.cpp
   stubs/SerialBase_stub.cpp
+  stubs/CellularContext_stub.cpp
 )

UNITTESTS/features/cellular/framework/AT/at_cellulardevice/unittest.cmake

@@ -43,6 +43,7 @@ set(unittest-test-sources
   stubs/UARTSerial_stub.cpp
   stubs/SerialBase_stub.cpp
   stubs/CellularStateMachine_stub.cpp
+  stubs/CellularContext_stub.cpp
 )
 
 # defines

UNITTESTS/features/cellular/framework/device/cellulardevice/unittest.cmake

@@ -32,6 +32,7 @@ set(unittest-test-sources
   stubs/Semaphore_stub.cpp
   stubs/NetworkInterface_stub.cpp
   stubs/NetworkInterfaceDefaults_stub.cpp
+  stubs/CellularContext_stub.cpp
 )
 
 # defines

UNITTESTS/features/cellular/framework/device/cellularstatemachine/unittest.cmake

@@ -38,6 +38,7 @@ set(unittest-test-sources
   stubs/Mutex_stub.cpp
   stubs/EventQueue_stub.cpp
   stubs/equeue_stub.c
+  stubs/CellularContext_stub.cpp
 )
 
 # defines

UNITTESTS/features/netsocket/cellular/CellularNonIPSocket/test_CellularNonIPSocket.cpp

@@ -17,7 +17,7 @@
 
 #include "gtest/gtest.h"
 #include "features/netsocket/cellular/CellularNonIPSocket.h"
-#include "CellularContext_stub.h"
+#include "myCellularContext.h"
 
 using namespace mbed;
 
@@ -34,7 +34,7 @@ class TestCellularNonIPSocket : public testing::Test {
 protected:
     CellularNonIPSocket *socket;
     ControlPlane_netif_stub *cp_netif;
-    CellularContext_stub cellular_context;
+    myCellularContext cellular_context;
     nsapi_size_t dataSize;
     char dataBuf[10];
 

UNITTESTS/features/netsocket/cellular/CellularNonIPSocket/unittest.cmake

@@ -19,4 +19,5 @@ set(unittest-test-sources
   stubs/NetworkStack_stub.cpp
   stubs/EventFlags_stub.cpp
   stubs/Mutex_stub.cpp
+  stubs/CellularContext_stub.cpp
 )

UNITTESTS/stubs/AT_CellularContext_stub.cpp

@@ -20,8 +20,8 @@
 using namespace mbed;
 
 AT_CellularContext::AT_CellularContext(ATHandler &at, CellularDevice *device, const char *apn,  bool cp_req, bool nonip_req) :
-    AT_CellularBase(at), _is_blocking(true), _is_connected(false),
-    _current_op(OP_INVALID), _device(device), _nw(0), _fh(0), _cp_req(cp_req), _nonip_req(nonip_req), _cp_in_use(false)
+    AT_CellularBase(at), _is_connected(false),
+    _current_op(OP_INVALID), _fh(0), _cp_req(cp_req), _nonip_req(nonip_req), _cp_in_use(false)
 {
     _stack = NULL;
     _pdp_type = DEFAULT_PDP_TYPE;
@@ -37,6 +37,12 @@ AT_CellularContext::AT_CellularContext(ATHandler &at, CellularDevice *device, co
     _new_context_set = false;
     _next = NULL;
     _cp_netif = NULL;
+    memset(_retry_timeout_array, 0, CELLULAR_RETRY_ARRAY_SIZE);
+    _retry_array_length = 0;
+    _retry_count = 0;
+    _is_blocking = true;
+    _device = device;
+    _nw = NULL;
 }
 
 AT_CellularContext::~AT_CellularContext()
@@ -240,10 +246,6 @@ void AT_CellularContext::cellular_callback(nsapi_event_t ev, intptr_t ptr)
 {
 }
 
-void AT_CellularContext::call_network_cb(nsapi_connection_status_t status)
-{
-}
-
 ControlPlane_netif *AT_CellularContext::get_cp_netif()
 {
     return NULL;
@@ -270,3 +272,8 @@ void AT_CellularContext::deactivate_non_ip_context()
 void AT_CellularContext::set_disconnect()
 {
 }
+
+void AT_CellularContext::do_connect_with_retry()
+{
+
+}

UNITTESTS/stubs/CellularContext_stub.cpp

@@ -0,0 +1,47 @@
+/*
+ * Copyright (c) 2018, Arm Limited and affiliates.
+ * SPDX-License-Identifier: Apache-2.0
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include "CellularContext.h"
+
+namespace mbed {
+
+void CellularContext::cp_data_received()
+{
+    _cp_netif->data_received();
+}
+
+void CellularContext::do_connect_with_retry()
+{
+    do_connect();
+}
+
+void CellularContext::do_connect()
+{
+    _cb_data.error = NSAPI_ERROR_OK;
+}
+
+void CellularContext::call_network_cb(nsapi_connection_status_t status)
+{
+    if (_connect_status != status) {
+        _connect_status = status;
+        if (_status_cb) {
+            _status_cb(NSAPI_EVENT_CONNECTION_STATUS_CHANGE, _connect_status);
+        }
+    }
+}
+
+}

UNITTESTS/stubs/CellularStateMachine_stub.cpp

@@ -74,3 +74,8 @@ void CellularStateMachine::set_cellular_callback(mbed::Callback<void(nsapi_event
 void CellularStateMachine::cellular_event_changed(nsapi_event_t ev, intptr_t ptr)
 {
 }
+
+void CellularStateMachine::get_retry_timeout_array(uint16_t *timeout, int &array_len) const
+{
+
+}

UNITTESTS/stubs/CellularContext_stub.h renamed to UNITTESTS/target_h/myCellularContext.h

@@ -15,23 +15,23 @@
  * limitations under the License.
  */
 
-#include "cellular/framework/API/CellularContext.h"
+#include "CellularContext.h"
 #include "ControlPlane_netif_stub.h"
 
 namespace mbed {
 
-class CellularContext_stub : public CellularContext {
+class myCellularContext : public CellularContext {
 public:
     std::list<nsapi_error_t> return_values;
     nsapi_error_t return_value;
     ControlPlane_netif_stub *my_cp_netif;
 
-    CellularContext_stub()
+    myCellularContext()
     {
         return_value = 0;
         my_cp_netif = NULL;
     }
-    ~CellularContext_stub()
+    ~myCellularContext()
     {
         if (my_cp_netif) {
             delete my_cp_netif;
@@ -186,10 +186,6 @@ class CellularContext_stub : public CellularContext {
     {
     };
 
-    void call_network_cb(nsapi_connection_status_t status)
-    {
-    };
-
     ControlPlane_netif_stub *get_cp_netif()
     {
         if (!my_cp_netif) {
@@ -219,6 +215,11 @@ class CellularContext_stub : public CellularContext {
     void set_disconnect()
     {
     };
+
+    void do_connect_with_retry()
+    {
+    };
+
 };
 
 }

features/cellular/framework/API/CellularContext.h

@@ -306,6 +306,22 @@ class CellularContext : public CellularInterface {
      */
     void cp_data_received();
 
+    /** Retry logic after device attached to network. Retry to find and activate pdp context or in case
+     *  of PPP find correct pdp context and open data channel. Retry logic is the same which is used in
+     *  CellularStateMachine.
+     */
+    virtual void do_connect_with_retry();
+
+    /** Helper method to call callback function if it is provided
+     *
+     *  @param status connection status which is parameter in callback function
+     */
+    void call_network_cb(nsapi_connection_status_t status);
+
+    /** Find and activate pdp context or in case of PPP find correct pdp context and open data channel.
+     */
+    virtual void do_connect();
+
     // member variables needed in target override methods
     NetworkStack *_stack; // must be pointer because of PPP
     pdp_type_t _pdp_type;
@@ -324,6 +340,12 @@ class CellularContext : public CellularInterface {
     bool _active_high;
 
     ControlPlane_netif *_cp_netif;
+    uint16_t _retry_timeout_array[CELLULAR_RETRY_ARRAY_SIZE];
+    int _retry_array_length;
+    int _retry_count;
+    CellularDevice *_device;
+    CellularNetwork *_nw;
+    bool _is_blocking;
 };
 
 /**

features/cellular/framework/API/CellularDevice.h

@@ -414,6 +414,16 @@ class CellularDevice {
 protected:
     friend class AT_CellularNetwork;
     friend class AT_CellularContext;
+    friend class CellularContext;
+
+    /** Get the retry array from the CellularStateMachine. Array is used in retry logic.
+     *  Array contains seconds and retry logic uses those second to wait before trying again.
+     *
+     *  @param timeout      timeout array containing seconds for retry logic. Must have space for
+     *                      CELLULAR_RETRY_ARRAY_SIZE (defined in CellularCommon.h)
+     *  @param array_len    length of the timeout array on return
+     */
+    void get_retry_timeout_array(uint16_t *timeout, int &array_len) const;
 
     /** Cellular callback to be attached to Network and CellularStateMachine classes.
      *  CellularContext calls this when in PPP mode to provide network changes.

features/cellular/framework/AT/AT_CellularContext.cpp

@@ -45,8 +45,8 @@ using namespace mbed_cellular_util;
 using namespace mbed;
 
 AT_CellularContext::AT_CellularContext(ATHandler &at, CellularDevice *device, const char *apn, bool cp_req, bool nonip_req) :
-    AT_CellularBase(at), _is_connected(false), _is_blocking(true),
-    _current_op(OP_INVALID), _device(device), _nw(0), _fh(0), _cp_req(cp_req), _nonip_req(nonip_req), _cp_in_use(false)
+    AT_CellularBase(at), _is_connected(false), _current_op(OP_INVALID), _fh(0), _cp_req(cp_req),
+    _nonip_req(nonip_req), _cp_in_use(false)
 {
     tr_info("New CellularContext %s (%p)", apn ? apn : "", this);
     _stack = NULL;
@@ -65,6 +65,12 @@ AT_CellularContext::AT_CellularContext(ATHandler &at, CellularDevice *device, co
     _dcd_pin = NC;
     _active_high = false;
     _cp_netif = NULL;
+    memset(_retry_timeout_array, 0, CELLULAR_RETRY_ARRAY_SIZE);
+    _retry_array_length = 0;
+    _retry_count = 0;
+    _is_blocking = true;
+    _device = device;
+    _nw = NULL;
 }
 
 AT_CellularContext::~AT_CellularContext()
@@ -106,6 +112,11 @@ void AT_CellularContext::enable_hup(bool enable)
     }
 }
 
+void AT_CellularContext::do_connect_with_retry()
+{
+    CellularContext::do_connect_with_retry();
+}
+
 nsapi_error_t AT_CellularContext::connect()
 {
     tr_info("CellularContext connect");
@@ -116,15 +127,15 @@ nsapi_error_t AT_CellularContext::connect()
 
     nsapi_error_t err = _device->attach_to_network();
     _cb_data.error = check_operation(err, OP_CONNECT);
-
+    _retry_count = 0;
     if (_is_blocking) {
         if (_cb_data.error == NSAPI_ERROR_OK || _cb_data.error == NSAPI_ERROR_ALREADY) {
-            do_connect();
+            do_connect_with_retry();
         }
     } else {
         if (_cb_data.error == NSAPI_ERROR_ALREADY) {
             // device is already attached, to be async we must use queue to connect and give proper callbacks
-            int id = _device->get_queue()->call_in(0, this, &AT_CellularContext::do_connect);
+            int id = _device->get_queue()->call_in(0, this, &AT_CellularContext::do_connect_with_retry);
             if (id == 0) {
                 return NSAPI_ERROR_NO_MEMORY;
             }
@@ -571,8 +582,6 @@ void AT_CellularContext::do_connect()
         _cb_data.error = open_data_channel();
         _at.unlock();
         if (_cb_data.error != NSAPI_ERROR_OK) {
-            tr_error("Failed to open data channel!");
-            call_network_cb(NSAPI_STATUS_DISCONNECTED);
             _is_connected = false;
         } else {
             _is_context_activated = true;
@@ -970,7 +979,8 @@ void AT_CellularContext::cellular_callback(nsapi_event_t ev, intptr_t ptr)
                 if (_status_cb) {
                     _status_cb(ev, ptr);
                 }
-                do_connect();
+                _retry_count = 0;
+                do_connect_with_retry();
                 return;
             }
         }
@@ -1000,19 +1010,6 @@ void AT_CellularContext::cellular_callback(nsapi_event_t ev, intptr_t ptr)
     }
 }
 
-void AT_CellularContext::call_network_cb(nsapi_connection_status_t status)
-{
-    if (_connect_status != status) {
-        _connect_status = status;
-        if (_status_cb) {
-            _status_cb(NSAPI_EVENT_CONNECTION_STATUS_CHANGE, _connect_status);
-        }
-        if (_nw && _connect_status == NSAPI_STATUS_DISCONNECTED) {
-            tr_info("CellularContext disconnected");
-        }
-    }
-}
-
 ControlPlane_netif *AT_CellularContext::get_cp_netif()
 {
     tr_error("No control plane interface available from base context!");

features/cellular/framework/AT/AT_CellularContext.h

@@ -88,12 +88,6 @@ class AT_CellularContext : public CellularContext, public AT_CellularBase {
      */
     virtual uint32_t get_timeout_for_operation(ContextOperation op) const;
 
-    /** Helper method to call callback function if it is provided
-     *
-     *  @param status connection status which is parameter in callback function
-     */
-    void call_network_cb(nsapi_connection_status_t status);
-
     virtual nsapi_error_t activate_non_ip_context();
     virtual nsapi_error_t setup_control_plane_opt();
     virtual void deactivate_non_ip_context();
@@ -117,14 +111,11 @@ class AT_CellularContext : public CellularContext, public AT_CellularBase {
     nsapi_error_t check_operation(nsapi_error_t err, ContextOperation op);
     AT_CellularBase::CellularProperty pdp_type_t_to_cellular_property(pdp_type_t pdp_type);
     void ciot_opt_cb(mbed::CellularNetwork::CIoT_Supported_Opt ciot_opt);
-
+    virtual void do_connect_with_retry();
 private:
     bool _is_connected;
-    bool _is_blocking;
     ContextOperation  _current_op;
     char _found_apn[MAX_APN_LENGTH];
-    CellularDevice *_device;
-    CellularNetwork *_nw;
     FileHandle *_fh;
     rtos::Semaphore _semaphore;
     rtos::Semaphore _cp_opt_semaphore;

features/cellular/framework/common/CellularCommon.h

@@ -21,6 +21,8 @@
 #include <stdint.h>
 #include "nsapi_types.h"
 
+const int CELLULAR_RETRY_ARRAY_SIZE = 10;
+
 struct cell_callback_data_t {
     nsapi_error_t error; /* possible error code */
     int status_data;     /* cellular_event_status related enum or other info in int format. Check cellular_event_status comments.*/