XIONE-15050: WPEFramework crash with function __libc_do_syscall. (rdkcentral#5654) (rdkcentral#5958)

* XIONE-15050: WPEFramework crash with function __libc_do_syscall. (rdkcentral#5654)
* detachable function change


(cherry picked from commit f02332a)

Author: cmuhammedrafi

Network/CHANGELOG.md

@@ -16,6 +16,11 @@ All notable changes to this RDK Service will be documented in this file.
 
 * For more details, refer to [versioning](https://github.com/rdkcentral/rdkservices#versioning) section under Main README.
 
+
+## [1.3.13] - 2025-01-07
+### Fixed
+- Fix crash in the WPEFramework connectivity monitor destructor
+
 ## [1.3.12] - 2025-01-02
 ### Security
 - Resolved security vulnerabilities

Network/Network.cpp

@@ -35,7 +35,7 @@ using namespace std;
 
 #define API_VERSION_NUMBER_MAJOR 1
 #define API_VERSION_NUMBER_MINOR 3
-#define API_VERSION_NUMBER_PATCH 12
+#define API_VERSION_NUMBER_PATCH 13
 
 /* Netsrvmgr Based Macros & Structures */
 #define IARM_BUS_NM_SRV_MGR_NAME "NET_SRV_MGR"

Network/NetworkConnectivity.cpp

@@ -21,6 +21,7 @@
 namespace WPEFramework {
     namespace Plugin {
 
+        static int threadCount = 0;
     bool EndpointCache::isEndpointCashFileExist()
     {
         std::ifstream fileStream(CachefilePath);
@@ -457,25 +458,18 @@ namespace WPEFramework {
 
         timeout.store(timeoutInSeconds >= MONITOR_TIMEOUT_INTERVAL_MIN ? timeoutInSeconds:defaultTimeoutInSec);
 
-        if (isMonitorThreadRunning() && stopFlag == false)
+        if (isMonitorThreadRunning())
         {
             isContinuesMonitoringNeeded = true;
             resetTimeout = true;
             cv_.notify_all();
         }
         else
         {
-            if (thread_.joinable())
-            {
-                LOGWARN("Connectivity Monitor joinable Thread is active");
-                stopFlag = true;
-                cv_.notify_all();
-                thread_.join();
-            }
-
             isContinuesMonitoringNeeded = true;
             stopFlag = false;
             thread_ = std::thread(&ConnectivityMonitor::connectivityMonitorFunction, this);
+            thread_.detach();
             LOGINFO("Connectivity monitor started with %d", timeout.load());
         }
 
@@ -490,34 +484,27 @@ namespace WPEFramework {
             return false;
         }
 
-        if (isMonitorThreadRunning() && stopFlag == false)
+        if (isMonitorThreadRunning())
         {
-            LOGINFO("Connectivity Monitor Thread is active so notify");
+            LOGINFO("Connectivity monitor thread is active so notify");
             g_internetState = nsm_internetState::UNKNOWN;
             cv_.notify_all();
         }
         else
         {
-            if (thread_.joinable())
-            {
-                LOGWARN("Connectivity Monitor joinable Thread is active");
-                stopFlag = true;
-                cv_.notify_all();
-                thread_.join();
-            }
-
             stopFlag = false;
             timeout.store(timeoutInSeconds >= MONITOR_TIMEOUT_INTERVAL_MIN ? timeoutInSeconds:defaultTimeoutInSec);
             thread_ = std::thread(&ConnectivityMonitor::connectivityMonitorFunction, this);
-            LOGINFO("Initial Connectivity Monitoring started with %d", timeout.load());
+            thread_.detach();
+            LOGINFO("Initial connectivity monitoring started with %d", timeout.load());
         }
 
         return true;
     }
 
     bool ConnectivityMonitor::isMonitorThreadRunning()
     {
-        return thread_.joinable();
+        return isRunning.load();
     }
 
     bool ConnectivityMonitor::stopInitialConnectivityMonitoring()
@@ -528,42 +515,55 @@ namespace WPEFramework {
             return true;
         }
 
-        stopFlag = true;
-        cv_.notify_all();
-
-        if (thread_.joinable())
-            thread_.join();
+        int tryCount = 5; // max 4 sec
+        do {
+            stopFlag = true;
+            cv_.notify_all();
+            sleep(1);
+        } while(isMonitorThreadRunning() && (--tryCount > 0));
 
-        LOGINFO("Initial Connectivity Monitor stopped");
+        if(isMonitorThreadRunning() && isContinuesMonitoringNeeded == false)
+        {
+            LOGERR("Initial connectivity monitor not stopped");
+            return false;
+        }
+        else
+           LOGINFO("Initial connectivity monitor stopped");
 
         return true;
     }
 
     bool ConnectivityMonitor::stopContinuousConnectivityMonitoring()
     {
-        stopFlag = true;
-        cv_.notify_all();
+        int tryCount = 5; // max 5 sec
+        do {
+            stopFlag = true;
+            cv_.notify_all();
+            sleep(1);
+        } while(isMonitorThreadRunning() && (--tryCount > 0));
 
-        if (thread_.joinable())
-            thread_.join();
+        if(isMonitorThreadRunning())
+        {
+            LOGERR("Continuous connectivity monitor not stopped");
+            return false;
+        }
+        else
+            LOGINFO("Continuous connectivity monitor stopped");
 
-        isContinuesMonitoringNeeded = false;
-        LOGINFO("Continuous Connectivity monitor stopped");
         return true;
     }
 
     void ConnectivityMonitor::signalConnectivityMonitor()
     {
-        if (isMonitorThreadRunning())
-        {
-            /* Reset the global value to UNKNOWN state so the cache is reset */
-            g_internetState = nsm_internetState::UNKNOWN;
-            cv_.notify_all();
-        }
+        /* Reset the global value to UNKNOWN state so the cache is reset */
+        g_internetState = nsm_internetState::UNKNOWN;
+        cv_.notify_all();
     }
 
     void ConnectivityMonitor::connectivityMonitorFunction()
     {
+        isRunning = true;
+        threadCount++;
         nsm_internetState InternetConnectionState = nsm_internetState::UNKNOWN;
         int notifyWaitCount = DEFAULT_MONITOR_RETRY_COUNT;
         int tempTimeout = defaultTimeoutInSec;
@@ -641,9 +641,18 @@ namespace WPEFramework {
             }
 
         } while (!stopFlag);
-
         g_internetState = nsm_internetState::UNKNOWN;
         LOGWARN("Connectivity monitor exiting");
+        threadCount--;
+        isRunning = false;
+    }
+
+        ConnectivityMonitor::~ConnectivityMonitor() {
+        LOGINFO("~ConnectivityMonitor");
+        stopContinuousConnectivityMonitoring();
+        sleep(1);
+        if(threadCount > 0)
+            LOGWARN("thread still active %d", threadCount);
     }
 
     } // namespace Plugin

Network/NetworkConnectivity.h

@@ -114,15 +114,12 @@ namespace WPEFramework {
                 bool isMonitorThreadRunning();
                 void signalConnectivityMonitor();
 
-                ConnectivityMonitor() : stopFlag(false), resetTimeout(false), isContinuesMonitoringNeeded(false)
+                ConnectivityMonitor() : isRunning(false), stopFlag(false), resetTimeout(false), isContinuesMonitoringNeeded(false)
                 {
                     setConnectivityMonitorEndpoints(getConnectivityDefaultEndpoints());
                 }
 
-                ~ConnectivityMonitor() {
-                    LOGINFO("~ConnectivityMonitor");
-                    stopContinuousConnectivityMonitoring();
-                }
+                ~ConnectivityMonitor();
             private:
 
                 std::vector<std::string> getConnectivityMonitorEndpoints();
@@ -133,6 +130,7 @@ namespace WPEFramework {
                 EndpointCache& endpointCache = EndpointCache::getInstance();
 
                 std::thread thread_;
+                std::atomic<bool> isRunning;
                 std::atomic<bool> stopFlag;
                 std::atomic<bool> resetTimeout;
                 std::atomic<bool> isContinuesMonitoringNeeded;