esp32/lteppp: added suspen/resume functinality to lteppp

Author: iwahdan88

esp32/lte/lteppp.c

@@ -48,6 +48,7 @@ extern TaskHandle_t xLTETaskHndl;
  DECLARE PRIVATE DATA
  ******************************************************************************/
 static char lteppp_trx_buffer[LTE_UART_BUFFER_SIZE];
+static char lteppp_queue_buffer[LTE_UART_BUFFER_SIZE];
 static uart_dev_t* lteppp_uart_reg;
 static QueueHandle_t xCmdQueue;
 static QueueHandle_t xRxQueue;
@@ -68,6 +69,8 @@ static bool lteppp_enabled = false;
 
 static bool ltepp_ppp_conn_up = false;
 
+static bool lteppp_suspended = false;
+
 /******************************************************************************
  DECLARE PRIVATE FUNCTIONS
  ******************************************************************************/
@@ -288,6 +291,16 @@ bool ltepp_is_ppp_conn_up(void)
 {
 	return ltepp_ppp_conn_up;
 }
+
+void lteppp_suspend(void)
+{
+    lteppp_suspended = true;
+}
+
+void lteppp_resume(void)
+{
+    lteppp_suspended = false;
+}
 /******************************************************************************
  DEFINE PRIVATE FUNCTIONS
  ******************************************************************************/
@@ -458,8 +471,28 @@ static bool lteppp_check_sim_present(void) {
 // PPP output callback
 static uint32_t lteppp_output_callback(ppp_pcb *pcb, u8_t *data, u32_t len, void *ctx) {
     LWIP_UNUSED_ARG(ctx);
-    uint32_t tx_bytes = uart_write_bytes(LTE_UART_ID, (const char*)data, len);
-    uart_wait_tx_done(LTE_UART_ID, LTE_TRX_WAIT_MS(len) / portTICK_RATE_MS);
+    uint32_t tx_bytes;
+    static uint32_t top =0;
+    if (!lteppp_suspended) {
+        if(top > 0)
+        {
+            uart_write_bytes(LTE_UART_ID, (const char*)lteppp_queue_buffer, top+1);
+            uart_wait_tx_done(LTE_UART_ID, LTE_TRX_WAIT_MS(top+1) / portTICK_RATE_MS);
+            top = 0;
+        }
+        tx_bytes = uart_write_bytes(LTE_UART_ID, (const char*)data, len);
+        uart_wait_tx_done(LTE_UART_ID, LTE_TRX_WAIT_MS(len) / portTICK_RATE_MS);
+    }
+    else
+    {
+        memcpy(&(lteppp_queue_buffer[top]), (const char*)data, len);
+        top += len;
+        if(top > LTE_UART_BUFFER_SIZE)
+        {
+            top = LTE_UART_BUFFER_SIZE -1;
+        }
+        return len;
+    }
     return tx_bytes;
 }
 

esp32/lte/lteppp.h

@@ -103,4 +103,8 @@ extern void connect_lte_uart (void);
 
 extern bool ltepp_is_ppp_conn_up(void);
 
+extern void lteppp_suspend(void);
+
+extern void lteppp_resume(void);
+
 #endif  // _LTEPPP_H_

esp32/mods/modlte.c

@@ -695,6 +695,7 @@ STATIC mp_obj_t lte_suspend(mp_obj_t self_in) {
     }
     lte_check_init();
     if (lteppp_get_state() == E_LTE_PPP) {
+        lteppp_suspend();
         //printf("Pausing ppp...\n");
         lte_pause_ppp();
         //printf("Pausing ppp done...\n");
@@ -808,6 +809,7 @@ STATIC mp_obj_t lte_resume(mp_uint_t n_args, const mp_obj_t *pos_args, mp_map_t
 
         if (lte_push_at_command_ext("ATO", LTE_RX_TIMEOUT_MAX_MS, LTE_CONNECT_RSP)) {
             lteppp_connect();
+            lteppp_resume();
             lteppp_set_state(E_LTE_PPP);
             vTaskDelay(1500);
         } else {