--- /dev/null
+/*******************************************************************************
+################################################################################
+# Copyright (c) [2020-2021] [HCL Technologies Ltd.] #
+# #
+# Licensed under the Apache License, Version 2.0 (the "License"); #
+# you may not use this file except in compliance with the License. #
+# You may obtain a copy of the License at #
+# #
+# http://www.apache.org/licenses/LICENSE-2.0 #
+# #
+# Unless required by applicable law or agreed to in writing, software #
+# distributed under the License is distributed on an "AS IS" BASIS, #
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. #
+# See the License for the specific language governing permissions and #
+# limitations under the License. #
+################################################################################
+*******************************************************************************/
+
+/* This file contains implementation of RRM Policy get and update handler along
+ * with some supporting funtion. It handles get and change callback for
+ * rrmpolicy yang module */
+
+#include <sstream>
+#include "RrmPolicyCb.hpp"
+
+RrmPolicyList rrmPolicy[MAX_POLICY];
+
+uint8_t policyNum = 0;
+uint8_t policyIndex = 0;
+uint8_t policyMemberListNum =0;
+
+/*******************************************************************
+ *
+ * @brief override oper_get_items to handle callback
+ *
+ * @details
+ *
+ * Function : oper_get_items
+ *
+ * Functionality:
+ * - override oper_get_items to handle callback of get of
+ * o-ran-sc-du-hello-world yang module
+ *
+ *
+ * @params[in] sysrepo::S_Session session, const char *module_name,
+ * const char *path, const char *request_xpath,
+ * uint32_t request_id, libyang::S_Data_Node &parent,
+ * void *private_data
+ * @return SR_ERR_OK - success
+ * SR_ERR_OK - failure
+ ******************************************************************/
+
+int RrmPolicyCb::oper_get_items(sysrepo::S_Session session, \
+ const char *module_name, \
+ const char *path, \
+ const char *request_xpath, \
+ uint32_t request_id, \
+ libyang::S_Data_Node &parent, \
+ void *private_data)
+{
+ O1_LOG("\nO1 RrmPolicyCb : Callback called for path=%s on get request", \
+ path);
+ return SR_ERR_OK;
+}
+
+/*******************************************************************
+ *
+ * @brief convert string resouce type to enum
+ *
+ * @details
+ *
+ * Function : resourceTypeToEnum
+ *
+ * Functionality:
+ * - convert string resouce type to enum
+ *
+ *
+ * @params[in] string resouceType
+ * @return Enum resouceType
+ ******************************************************************/
+RrmResourceType RrmPolicyCb::resourceTypeToEnum(string &val)
+{
+ RrmResourceType ret;
+
+ if(val == "PRB")
+ {
+ ret = PRB;
+ }
+ else if(val == "PRB_UL")
+ {
+ ret = PRB_UL;
+ }
+ else if(val == "PRB_DL")
+ {
+ ret = PRB_DL;
+ }
+ else if(val == "RRC")
+ {
+ ret = RRC;
+ }
+ else if(val == "DRB")
+ {
+ ret = DRB;
+ }
+ else
+ {
+ O1_LOG("\nO1 RrmPolicyCb::updateParams non handeled value of "
+ "ResourceType = %s", val.c_str());
+ }
+ O1_LOG("\nO1 rrmPolicy resourceTypeToEnum : val [%d]", ret);
+ return ret;
+}
+
+/*******************************************************************
+ *
+ * @brief fill the parameters value into the structure instance
+ *
+ * @details
+ *
+ * Function : updateParams
+ *
+ * Functionality:
+ * - fill the parameters value into the structure instance
+ *
+ *
+ * @params[in] string leafNode, string val
+ * @return void
+ ******************************************************************/
+
+bool RrmPolicyCb::updateParams(string &parent, string &leafNode, string &val)
+{
+
+ O1_LOG("\nO1 RrmPolicyCb::updateParams parameter name=%s val = %s", \
+ leafNode.c_str(), val.c_str());
+ bool ret = true;
+
+ if(val != "")
+ {
+ if (leafNode == "id")
+ {
+ policyIndex++;
+ policyNum = policyIndex -1 ;
+ memset(rrmPolicy[policyNum].id, '\0', ID_MAX_LEN);
+ strncpy(rrmPolicy[policyNum].id, val.c_str(), ID_MAX_LEN-1);
+ O1_LOG("\nO1 RrmPolicyCb::updateParams id = %s", rrmPolicy[policyNum].id);
+ rrmPolicy[policyNum].rRMMemberNum = 0;
+ }
+ else if(leafNode == "resourceType")
+ {
+ rrmPolicy[policyNum].resourceType = resourceTypeToEnum(val);
+ O1_LOG("\nO1 RrmPolicyCb::updateParams ResourceType = %d", \
+ rrmPolicy[policyNum].resourceType);
+ }
+ else if(leafNode == "rRMPolicyMaxRatio")
+ {
+ rrmPolicy[policyNum].rRMPolicyMaxRatio = atoi(val.c_str());
+ O1_LOG("\nO1 RrmPolicyCb::updateParams rRMPolicyMaxRatio = %d", \
+ rrmPolicy[policyNum].rRMPolicyMaxRatio);
+ }
+ else if(leafNode == "rRMPolicyMinRatio")
+ {
+ rrmPolicy[policyNum].rRMPolicyMinRatio = atoi(val.c_str());
+ O1_LOG("\nO1 RrmPolicyCb::updateParams rRMPolicyMinRatio = %d", \
+ rrmPolicy[policyNum].rRMPolicyMinRatio);
+ }
+ else if(leafNode == "rRMPolicyDedicatedRatio")
+ {
+ rrmPolicy[policyNum].rRMPolicyDedicatedRatio = atoi(val.c_str());
+ O1_LOG("\nO1 RrmPolicyCb::updateParams rRMPolicyDedicatedRatio = %d", \
+ rrmPolicy[policyNum].rRMPolicyDedicatedRatio);
+ }
+ else if((leafNode == "mcc") || (leafNode == "mnc")
+ || leafNode == "sst" || leafNode == "sd")
+ {
+ int memberNum = policyMemberListNum/MAX_POLICY_LIST;
+ rrmPolicy[policyNum].rRMMemberNum = memberNum+1;
+ if(leafNode == "mcc")
+ {
+ memset(rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].mcc, \
+ '\0', MCC_LEN);
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].mcc[0] = std::stoi(val.substr(0,1).c_str(),0,10);
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].mcc[1] = std::stoi(val.substr(1,1).c_str(),0,10);
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].mcc[2] = std::stoi(val.substr(2,1).c_str(),0,10);
+ //strncpy((char *)rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].mcc, \
+ val.c_str(), MCC_LEN);
+ O1_LOG("\nO1 RrmPolicyCb::updateParams rrmPolicy[%d]."
+ "rRMPolicyMemberList[%d].mcc[2] = %c", policyNum, memberNum, \
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].mcc[2]);
+ }
+ else if(leafNode == "mnc")
+ {
+ memset(rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].mnc, \
+ '\0', MNC_LEN);
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].mnc[0] = std::stoi(val.substr(0,1).c_str(),0,10);
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].mnc[1] = std::stoi(val.substr(1,1).c_str(),0,10);
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].mnc[2] = std::stoi(val.substr(2,1).c_str(),0,10);
+ //strncpy((char *) rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].mnc, \
+ val.c_str(), MNC_LEN);
+ O1_LOG("\nO1 RrmPolicyCb::updateParams rrmPolicy[%d]."
+ "rRMPolicyMemberList[%d].mnc[1] = %c", policyNum, memberNum, \
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].mnc[1]);
+ }
+ else if(leafNode == "sst")
+ {
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].sst = \
+ atoi(val.c_str());
+ O1_LOG("\nO1 RrmPolicyCb::updateParams sst val = %d",
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].sst);
+ }
+ else if(leafNode == "sd")
+ {
+ memset(rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].sd, \
+ '\0', SD_LEN);
+
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].sd[0] = \
+ std::stoi(val.substr(0,2).c_str(),0,16);
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].sd[1] = \
+ std::stoi(val.substr(2,2).c_str(),0,16);
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].sd[2] = \
+ std::stoi(val.substr(4,2).c_str(),0,16);
+ O1_LOG("\nO1 RrmPolicyCb::updateParams rrmPolicy[%d]."
+ "rRMPolicyMemberList[%d].sd[2] = %c", policyNum, memberNum, \
+ rrmPolicy[policyNum].rRMPolicyMemberList[memberNum].sd[SD_LEN-1]);
+ }
+ policyMemberListNum++;
+ }
+ else
+ {
+ O1_LOG("\nO1 RrmPolicyCb::updateParams some parameter not handled name=%s "
+ "val = %s", leafNode.c_str(), val.c_str());
+ ret = false;
+ }
+ }
+ else
+ {
+ O1_LOG("\nO1 RrmPolicyCb::updateParams without value node name=%s val = %s",
+ leafNode.c_str(), val.c_str());
+ }
+ return ret;
+}
+
+/*******************************************************************
+ *
+ * @brief override module_change to handle callback
+ *
+ * @details
+ *
+ * Function : module_change
+ *
+ * Functionality:
+ * - override module_change to handle callback of modification of
+ * o-ran-sc-du-hello-world yang module
+ *
+ *
+ * @params[in] sysrepo::S_Session session, const char *module_name,
+ * const char *xpath, sr_event_t event, uint32_t request_id,
+ * void *private_data
+ * @return SR_ERR_OK - success
+ * SR_ERR_OK - failure
+ ******************************************************************/
+
+int RrmPolicyCb::module_change(sysrepo::S_Session sess, \
+ const char *module_name, \
+ const char *xpath, \
+ sr_event_t event, \
+ uint32_t request_id, \
+ void *private_data)
+{
+ char change_path[MAX_LEN];
+
+ try {
+ O1_LOG("\nO1 RrmPolicyCb : Notification %s", NetconfUtils::evToStr(event));
+ if (SR_EV_CHANGE == event)
+ {
+ snprintf(change_path, MAX_LEN, "/%s:*//.", module_name);
+ auto it = sess->get_changes_iter(change_path);
+ while (auto change = sess->get_change_next(it)) {
+ //NetconfUtils::printChange(change); //enable only for debugging
+ if(nullptr != change->new_val())
+ {
+ O1_LOG("\n\nO1 RrmPolicyCb : Parameter value has been \
+changed val=%s", change->new_val()->val_to_string().c_str());
+ string val = change->new_val()->val_to_string();
+ string parent, leafNode;
+ NetconfUtils::getLeafInfo(change->new_val()->to_string(), parent, leafNode);
+ O1_LOG("\nO1 RrmPolicy : LeafNode name = [%s]", leafNode.c_str());
+ if(!updateParams(parent, leafNode, val)){
+ O1_LOG("\nO1 RrmPolicy : LeafNode [%s] not handled", leafNode.c_str());
+ //later error handling can be done
+ }
+ }
+ }
+#ifndef ODU_TEST_STUB
+ if(ROK != setRrmPolicy(rrmPolicy, policyIndex))
+ {
+ O1_LOG("\nO1 RrmPolicy : updateRrmPolicy failed");
+ return SR_ERR_INTERNAL;
+ //later error handling can be done
+ }
+#endif
+ }
+ }
+ catch( const std::exception& e ) {
+ O1_LOG("\nO1 RrmPolicyCb exception : %s\n", e.what());
+ }
+ return SR_ERR_OK;
+}
+
+/**********************************************************************
+ End of file
+**********************************************************************/
Code Review / o-du / l2.git / blobdiff