--- /dev/null
+/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
+/*
+ * Copyright (c) 2022 Northeastern University
+ * Copyright (c) 2022 Sapienza, University of Rome
+ * Copyright (c) 2022 University of Padova
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License version 2 as
+ * published by the Free Software Foundation;
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+ *
+ * Author: Andrea Lacava <thecave003@gmail.com>
+ * Tommaso Zugno <tommasozugno@gmail.com>
+ * Michele Polese <michele.polese@gmail.com>
+ */
+
+#include <ns3/ric-control-message.h>
+#include <ns3/asn1c-types.h>
+#include <ns3/log.h>
+#include <bitset>
+namespace ns3 {
+
+NS_LOG_COMPONENT_DEFINE ("RicControlMessage");
+
+
+RicControlMessage::RicControlMessage (E2AP_PDU_t* pdu)
+{
+ DecodeRicControlMessage (pdu);
+ NS_LOG_INFO ("End of RicControlMessage::RicControlMessage()");
+}
+
+RicControlMessage::~RicControlMessage ()
+{
+
+}
+
+void
+RicControlMessage::DecodeRicControlMessage(E2AP_PDU_t* pdu)
+{
+ InitiatingMessage_t* mess = pdu->choice.initiatingMessage;
+ auto *request = (RICcontrolRequest_t *) &mess->value.choice.RICcontrolRequest;
+ NS_LOG_INFO (xer_fprint(stderr, &asn_DEF_RICcontrolRequest, request));
+
+ size_t count = request->protocolIEs.list.count;
+ if (count <= 0) {
+ NS_LOG_ERROR("[E2SM] received empty list");
+ return;
+ }
+
+ for (size_t i = 0; i < count; i++)
+ {
+ RICcontrolRequest_IEs_t *ie = request->protocolIEs.list.array [i];
+ switch (ie->value.present) {
+ case RICcontrolRequest_IEs__value_PR_RICrequestID: {
+ NS_LOG_DEBUG("[E2SM] RICcontrolRequest_IEs__value_PR_RICrequestID");
+ m_ricRequestId = ie->value.choice.RICrequestID;
+ switch (m_ricRequestId.ricRequestorID) {
+ case 1001: {
+ NS_LOG_DEBUG("TS xApp message");
+ m_requestType = ControlMessageRequestIdType::TS;
+ break;
+ }
+ case 1002: {
+ NS_LOG_DEBUG("QoS xApp message");
+ m_requestType = ControlMessageRequestIdType::QoS;
+ break;
+ }
+ }
+ break;
+ }
+ case RICcontrolRequest_IEs__value_PR_RANfunctionID: {
+ m_ranFunctionId = ie->value.choice.RANfunctionID;
+
+ NS_LOG_DEBUG("[E2SM] RICcontrolRequest_IEs__value_PR_RANfunctionID");
+ break;
+ }
+ case RICcontrolRequest_IEs__value_PR_RICcallProcessID: {
+ m_ricCallProcessId = ie->value.choice.RICcallProcessID;
+ NS_LOG_DEBUG("[E2SM] RICcontrolRequest_IEs__value_PR_RICcallProcessID");
+ break;
+ }
+ case RICcontrolRequest_IEs__value_PR_RICcontrolHeader: {
+ NS_LOG_DEBUG("[E2SM] RICcontrolRequest_IEs__value_PR_RICcontrolHeader");
+ // xer_fprint(stderr, &asn_DEF_RICcontrolHeader, &ie->value.choice.RICcontrolHeader);
+
+ auto *e2smControlHeader = (E2SM_RC_ControlHeader_t *) calloc(1,
+ sizeof(E2SM_RC_ControlHeader_t));
+ ASN_STRUCT_RESET(asn_DEF_E2SM_RC_ControlHeader, e2smControlHeader);
+ asn_decode (nullptr, ATS_ALIGNED_BASIC_PER, &asn_DEF_E2SM_RC_ControlHeader,
+ (void **) &e2smControlHeader, ie->value.choice.RICcontrolHeader.buf,
+ ie->value.choice.RICcontrolHeader.size);
+
+ NS_LOG_INFO (xer_fprint (stderr, &asn_DEF_E2SM_RC_ControlHeader, e2smControlHeader));
+ if (e2smControlHeader->present == E2SM_RC_ControlHeader_PR_controlHeader_Format1) {
+ m_e2SmRcControlHeaderFormat1 = e2smControlHeader->choice.controlHeader_Format1;
+ //m_e2SmRcControlHeaderFormat1->ric_ControlAction_ID;
+ //m_e2SmRcControlHeaderFormat1->ric_ControlStyle_Type;
+ //m_e2SmRcControlHeaderFormat1->ueId;
+ } else {
+ NS_LOG_DEBUG("[E2SM] Error in checking format of E2SM Control Header");
+ }
+ break;
+ }
+ case RICcontrolRequest_IEs__value_PR_RICcontrolMessage: {
+ NS_LOG_DEBUG("[E2SM] RICcontrolRequest_IEs__value_PR_RICcontrolMessage");
+ // xer_fprint(stderr, &asn_DEF_RICcontrolMessage, &ie->value.choice.RICcontrolMessage);
+
+ auto *e2SmControlMessage = (E2SM_RC_ControlMessage_t *) calloc(1,
+ sizeof(E2SM_RC_ControlMessage_t));
+ ASN_STRUCT_RESET(asn_DEF_E2SM_RC_ControlMessage, e2SmControlMessage);
+
+ asn_decode (nullptr, ATS_ALIGNED_BASIC_PER, &asn_DEF_E2SM_RC_ControlMessage,
+ (void **) &e2SmControlMessage, ie->value.choice.RICcontrolMessage.buf,
+ ie->value.choice.RICcontrolMessage.size);
+
+ NS_LOG_INFO (xer_fprint(stderr, &asn_DEF_E2SM_RC_ControlMessage, e2SmControlMessage));
+
+ if (e2SmControlMessage->present == E2SM_RC_ControlMessage_PR_controlMessage_Format1)
+ {
+ NS_LOG_DEBUG ("[E2SM] E2SM_RC_ControlMessage_PR_controlMessage_Format1");
+ E2SM_RC_ControlMessage_Format1_t *e2SmRcControlMessageFormat1 =
+ e2SmControlMessage->choice.controlMessage_Format1;
+ m_valuesExtracted =
+ ExtractRANParametersFromControlMessage (e2SmRcControlMessageFormat1);
+ if (m_requestType == ControlMessageRequestIdType::TS)
+ {
+ // Get and parse the secondaty cell id according to 3GPP TS 38.473, Section 9.2.2.1
+ for (RANParameterItem item : m_valuesExtracted)
+ {
+ if (item.m_valueType == RANParameterItem::ValueType::OctectString)
+ {
+ // First 3 digits are the PLMNID (always 111), last digit is CellId
+ std::string cgi = item.m_valueStr->DecodeContent ();
+ NS_LOG_INFO ("Decoded CGI value is: " << cgi);
+ m_secondaryCellId = cgi.back();
+ }
+ }
+ }
+ }
+ else
+ {
+ NS_LOG_DEBUG("[E2SM] Error in checking format of E2SM Control Message");
+ }
+ break;
+ }
+ case RICcontrolRequest_IEs__value_PR_RICcontrolAckRequest: {
+ NS_LOG_DEBUG("[E2SM] RICcontrolRequest_IEs__value_PR_RICcontrolAckRequest");
+
+ switch (ie->value.choice.RICcontrolAckRequest) {
+ case RICcontrolAckRequest_noAck: {
+ NS_LOG_DEBUG("[E2SM] RIC Control ack value: NO ACK");
+ break;
+ }
+ case RICcontrolAckRequest_ack: {
+ NS_LOG_DEBUG("[E2SM] RIC Control ack value: ACK");
+ break;
+ }
+ case RICcontrolAckRequest_nAck: {
+ NS_LOG_DEBUG("[E2SM] RIC Control ack value: NACK");
+ break;
+ }
+ default: {
+ NS_LOG_DEBUG("[E2SM] RIC Control ack value unknown");
+ break;
+ }
+ }
+ break;
+ }
+ case RICcontrolRequest_IEs__value_PR_NOTHING: {
+ NS_LOG_DEBUG("[E2SM] RICcontrolRequest_IEs__value_PR_NOTHING");
+ NS_LOG_DEBUG("[E2SM] Nothing");
+ break;
+ }
+ default: {
+ NS_LOG_DEBUG("[E2SM] RIC Control value unknown");
+ break;
+ }
+ }
+ }
+
+ NS_LOG_INFO ("End of DecodeRicControlMessage");
+}
+
+std::string
+RicControlMessage::GetSecondaryCellIdHO ()
+{
+ return m_secondaryCellId;
+}
+
+std::vector<RANParameterItem>
+RicControlMessage::ExtractRANParametersFromControlMessage (
+ E2SM_RC_ControlMessage_Format1_t *e2SmRcControlMessageFormat1)
+{
+ std::vector<RANParameterItem> ranParameterList;
+ int count = e2SmRcControlMessageFormat1->ranParameters_List->list.count;
+ for (int i = 0; i < count; i++)
+ {
+ RANParameter_Item_t *ranParameterItem =
+ e2SmRcControlMessageFormat1->ranParameters_List->list.array[i];
+ for (RANParameterItem extractedParameter :
+ RANParameterItem::ExtractRANParametersFromRANParameter (ranParameterItem))
+ {
+ ranParameterList.push_back (extractedParameter);
+ }
+ }
+
+ return ranParameterList;
+}
+
+} // namespace ns3
Code Review / sim / ns3-o-ran-e2.git / blobdiff