Change MQTT process timeout (#1492)

* Change MQTT process timeout

* Apply suggestions from code review

Co-authored-by: Shubham Divekar <[email protected]>

Author: pvyawaha

demos/ota/ota_demo_core_http/ota_demo_core_http.c

@@ -140,7 +140,12 @@
 /**
  * @brief Timeout for MQTT_ProcessLoop function in milliseconds.
  */
-#define MQTT_PROCESS_LOOP_TIMEOUT_MS             ( 500U )
+#define MQTT_PROCESS_LOOP_TIMEOUT_MS             ( 100U )
+
+/**
+ * @brief Period for demo loop sleep in milliseconds.
+ */
+#define OTA_EXAMPLE_LOOP_SLEEP_PERIOD_MS         ( 5000U )
 
 /**
  * @brief The delay used in the main OTA Demo task loop to periodically output the OTA
@@ -1979,7 +1984,7 @@ static int startOTADemo( void )
                 if( pthread_mutex_lock( &mqttMutex ) == 0 )
                 {
                     /* Loop to receive packet from transport interface. */
-                    mqttStatus = MQTT_ProcessLoop( &mqttContext, 0 );
+                    mqttStatus = MQTT_ProcessLoop( &mqttContext, MQTT_PROCESS_LOOP_TIMEOUT_MS );
 
                     pthread_mutex_unlock( &mqttMutex );
                 }
@@ -2000,6 +2005,12 @@ static int startOTADemo( void )
                                otaStatistics.otaPacketsQueued,
                                otaStatistics.otaPacketsProcessed,
                                otaStatistics.otaPacketsDropped ) );
+
+                    /* Delay if mqtt process loop is set to zero.*/
+                    if( !( MQTT_PROCESS_LOOP_TIMEOUT_MS > 0 ) )
+                    {
+                        Clock_SleepMs( OTA_EXAMPLE_LOOP_SLEEP_PERIOD_MS );
+                    }
                 }
                 else
                 {

demos/ota/ota_demo_core_mqtt/ota_demo_core_mqtt.c

@@ -131,7 +131,12 @@
 /**
  * @brief Timeout for MQTT_ProcessLoop function in milliseconds.
  */
-#define MQTT_PROCESS_LOOP_TIMEOUT_MS        ( 500U )
+#define MQTT_PROCESS_LOOP_TIMEOUT_MS        ( 100U )
+
+/**
+ * @brief Period for demo loop sleep in milliseconds.
+ */
+#define OTA_EXAMPLE_LOOP_SLEEP_PERIOD_MS    ( 5000U )
 
 /**
  * @brief Size of the network buffer to receive the MQTT message.
@@ -1547,7 +1552,7 @@ static int startOTADemo( void )
                 if( pthread_mutex_lock( &mqttMutex ) == 0 )
                 {
                     /* Loop to receive packet from transport interface. */
-                    mqttStatus = MQTT_ProcessLoop( &mqttContext, 0 );
+                    mqttStatus = MQTT_ProcessLoop( &mqttContext, MQTT_PROCESS_LOOP_TIMEOUT_MS );
 
                     pthread_mutex_unlock( &mqttMutex );
                 }
@@ -1568,6 +1573,12 @@ static int startOTADemo( void )
                                otaStatistics.otaPacketsQueued,
                                otaStatistics.otaPacketsProcessed,
                                otaStatistics.otaPacketsDropped ) );
+
+                    /* Delay if mqtt process loop is set to zero.*/
+                    if( !( MQTT_PROCESS_LOOP_TIMEOUT_MS > 0 ) )
+                    {
+                        Clock_SleepMs( OTA_EXAMPLE_LOOP_SLEEP_PERIOD_MS );
+                    }
                 }
                 else
                 {