RDK-60001: [SPIKE] Decouple T2 Common Library From Rbus

source/bulkdata/profile.c

@@ -1,6 +1,6 @@
 /*
  * If not stated otherwise in this file or this component's LICENSE file the
  * following copyright and licenses apply:
  *
  * Copyright 2019 RDK Management
  *
@@ -1060,6 +1060,20 @@
             eMarker = (EventMarker *)Vector_At(profile->eMarkerList, emIndex);
             addT2EventMarker(eMarker->markerName, eMarker->compName, profile->name, eMarker->skipFreq);
         }
+#if 1
+        T2Info("Creating component-specific message queues after marker map update\n");
+        if (t2_daemon_create_component_queues() == T2ERROR_SUCCESS)
+        {
+            T2Info("Component-specific message queues created successfully\n");
+
+            // Broadcast initial marker lists to all component queues
+            // t2_daemon_mq_broadcast_markers_to_component("ALL");
+        }
+        else
+        {
+            T2Error("Failed to create component-specific message queues\n");
+        }
+#endif
         if(registerProfileWithScheduler(profile->name, profile->reportingInterval, profile->activationTimeoutPeriod, profile->deleteonTimeout, true, profile->reportOnUpdate, profile->firstReportingInterval, profile->timeRef) != T2ERROR_SUCCESS)
         {
             profile->enable = false;
@@ -1101,6 +1115,20 @@
         }
     }
     pthread_mutex_unlock(&plMutex);
+#if 1
+    T2Info("Creating component-specific message queues after marker map update\n");
+    if (t2_daemon_create_component_queues() == T2ERROR_SUCCESS)
+    {
+        T2Info("Component-specific message queues created successfully\n");
+
+        // Broadcast initial marker lists to all component queues
+        // t2_daemon_mq_broadcast_markers_to_component("ALL");
+    }
+    else
+    {
+        T2Error("Failed to create component-specific message queues\n");
+    }
+#endif
     T2Debug("%s --out\n", __FUNCTION__);
 }
 

source/bulkdata/t2markers.c

@@ -1,6 +1,6 @@
 /*
  * If not stated otherwise in this file or this component's LICENSE file the
  * following copyright and licenses apply:
  *
  * Copyright 2019 RDK Management
  *
@@ -265,14 +265,17 @@
  */
 void getComponentMarkerList(const char* compName, void **markerList)
 {
+    T2Info("%s, %d\n", __func__, __LINE__);
     Vector *compMarkers = NULL;
     if(T2ERROR_SUCCESS == Vector_Create(&compMarkers))
     {
         uint32_t index = 0;
 
+        T2Info("%s, %d\n", __func__, __LINE__);
         pthread_mutex_lock(&t2MarkersMutex);
         for (; index < hash_map_count(markerCompMap); index++)
         {
+            T2Info("%s, %d\n", __func__, __LINE__);
             T2Marker *t2Marker = (T2Marker *)hash_map_lookup(markerCompMap, index);
             if(t2Marker != NULL && !strcmp(t2Marker->componentName, compName))
             {
@@ -287,6 +290,7 @@
         T2Error("Unable to create Vector for Component Markers :: Malloc failure\n");
         return ;
     }
+    T2Info("%s, %d\n", __func__, __LINE__);
     return;
 }