Add helper for fetching target-info (#190)

---
Signed-off-by: Kartik Nema <kartnema@qti.qualcomm.com>

Author: kartnema

contextual-classifier/NetLinkComm.cpp

@@ -107,7 +107,7 @@ int32_t NetLinkComm::setListen(int8_t enable) {
 
     nlcn_msg.cn_mcast = enable ? PROC_CN_MCAST_LISTEN : PROC_CN_MCAST_IGNORE;
 
-    if(send(mNlSock, &nlcn_msg, sizeof(nlcn_msg), 0) == -1) {
+    if(send(this->mNlSock, &nlcn_msg, sizeof(nlcn_msg), 0) == -1) {
         TYPELOGV(ERRNO_LOG, "netlink send", strerror(errno));
         return -1;
     }
@@ -125,11 +125,12 @@ int32_t NetLinkComm::recvEvent(ProcEvent &ev) {
         };
     } nlcn_msg;
 
-    rc = recv(mNlSock, &nlcn_msg, sizeof(nlcn_msg), 0);
+    rc = recv(this->mNlSock, &nlcn_msg, sizeof(nlcn_msg), 0);
     if(rc == 0) {
         // Socket shutdown or no more data.
         return 0;
     }
+
     if(rc == -1) {
         if(errno == EINTR) {
             // Caller (ContextualClassifier::HandleProcEv) will handle EINTR.

resource-tuner/core/Include/RestuneInternal.h

@@ -43,7 +43,9 @@ void submitResProvisionRequest(Request* request, int8_t isVerified);
 
 size_t submitPropGetRequest(void* request, std::string& result);
 
-size_t submitPropGetRequest(const std::string& propName, std::string& result, const std::string& defVal);
+size_t submitPropGetRequest(const std::string& propName,
+                            std::string& result,
+                            const std::string& defVal);
 
 ErrCode translateToPhysicalIDs(Resource* resource);
 

resource-tuner/core/Include/TargetRegistry.h

@@ -31,6 +31,14 @@
 #define ONLINE_CPU_FILE_PATH "/sys/devices/system/cpu/online"
 #define CPU_CAPACITY_FILE_PATH "/sys/devices/system/cpu/cpu%d/cpu_capacity"
 
+enum TargetQueries {
+    GET_MASK,
+    GET_CLUSTER_COUNT,
+    GET_CORE_COUNT,
+    GET_PHYSICAL_CLUSTER_ID,
+    GET_PHYSICAL_CORE_ID,
+};
+
 /**
  * @struct CGroupConfigInfo
  * @brief Representation of a single CGroup Configuration Info
@@ -220,4 +228,9 @@ class CacheInfoBuilder {
     CacheInfo* build();
 };
 
+// Utility to fetch target-specific information
+uint64_t getTargetInfo(int32_t option,
+                       int32_t numArgs,
+                       int32_t* args);
+
 #endif

resource-tuner/core/TargetRegistry.cpp

@@ -815,3 +815,62 @@ ErrCode CacheInfoBuilder::setPriorityAware(const std::string& isPriorityAwareStr
 CacheInfo* CacheInfoBuilder::build() {
     return this->mCacheInfo;
 }
+
+uint64_t getTargetInfo(int32_t option,
+                       int32_t numArgs,
+                       int32_t* args) {
+    std::shared_ptr<TargetRegistry> targetRegistry = TargetRegistry::getInstance();
+
+    switch(option) {
+        case GET_MASK: {
+            if(numArgs < 2) {
+                return 0;
+            }
+
+            uint64_t mask = 0;
+
+            int32_t cluster = args[0];
+            int32_t coreCount = args[1];
+            int32_t physicalClusterId = targetRegistry->getPhysicalClusterId(cluster);
+
+            ClusterInfo* clusInfo = targetRegistry->getClusterInfo(physicalClusterId);
+            if(clusInfo == nullptr) {
+                return 0;
+            }
+
+            if(coreCount == 0) {
+                // Iterate over all the cores in the cluster
+                coreCount = clusInfo->mNumCpus;
+            } else {
+                // Bound the count to the number of cores in the cluster
+                coreCount = std::min(coreCount, clusInfo->mNumCpus);
+            }
+
+            for(int32_t i = clusInfo->mStartCpu; i < (clusInfo->mStartCpu + coreCount); i++) {
+                mask |= (1UL << i);
+            }
+
+            return mask;
+        }
+
+        case GET_CLUSTER_COUNT:
+            return UrmSettings::targetConfigs.mTotalClusterCount;
+
+        case GET_CORE_COUNT:
+            return UrmSettings::targetConfigs.mTotalCoreCount;
+
+        case GET_PHYSICAL_CLUSTER_ID:
+            if(numArgs < 1) {
+                return 0;
+            }
+            return targetRegistry->getPhysicalClusterId(args[0]);
+
+        case GET_PHYSICAL_CORE_ID:
+            if(numArgs < 2) {
+                return 0;
+            }
+            return targetRegistry->getPhysicalCoreId(args[0], args[1]);
+    }
+
+    return 0;
+}