Cleaning up paho at end of rpc sample

Azure · Oct 10, 2023 · 3c5a072 · 3c5a072
1 parent 15739fd
commit 3c5a072
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 0 deletions.
diff --git a/sdk/samples/core/paho_multiple_rpc_sample.c b/sdk/samples/core/paho_multiple_rpc_sample.c
@@ -577,6 +577,15 @@ int main(int argc, char* argv[])
   // clean-up functions shown for completeness
   LOG_AND_EXIT_IF_FAILED(az_mqtt5_connection_close(&mqtt_connection));
 
+  // Clean up Paho
+  while (!sample_finished)
+  {
+    LOG_AND_EXIT_IF_FAILED(az_platform_sleep_msec(1000));
+  }
+  MQTTProperties_free(&client_prop);
+  MQTTProperties_free(&server_prop);
+  MQTTAsync_destroy(&mqtt_handle);
+
   printf(LOG_APP "Done.                                \n");
   return 0;
 }
diff --git a/sdk/samples/core/paho_rpc_client_sample.c b/sdk/samples/core/paho_rpc_client_sample.c
@@ -304,6 +304,14 @@ int main(int argc, char* argv[])
   // clean-up functions shown for completeness
   LOG_AND_EXIT_IF_FAILED(az_mqtt5_connection_close(&mqtt_connection));
 
+  // Clean up Paho
+  while (!sample_finished)
+  {
+    LOG_AND_EXIT_IF_FAILED(az_platform_sleep_msec(1000));
+  }
+  MQTTProperties_free(&prop);
+  MQTTAsync_destroy(&mqtt_handle);
+
   printf(LOG_APP "Done.                                \n");
   return 0;
 }
diff --git a/sdk/samples/core/paho_rpc_server_sample.c b/sdk/samples/core/paho_rpc_server_sample.c
@@ -384,6 +384,14 @@ int main(int argc, char* argv[])
   // clean-up functions shown for completeness
   LOG_AND_EXIT_IF_FAILED(az_mqtt5_connection_close(&mqtt_connection));
 
+  // Clean up Paho
+  while (!sample_finished)
+  {
+    LOG_AND_EXIT_IF_FAILED(az_platform_sleep_msec(1000));
+  }
+  MQTTProperties_free(&prop);
+  MQTTAsync_destroy(&mqtt_handle);
+
   printf(LOG_APP "Done.                                \n");
   return 0;
 }