4 #include <e2sm/wrapper.h>
5 #cgo LDFLAGS: -le2smwrapper -lm
6 #cgo CFLAGS: -I/usr/local/include/e2sm
12 "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
25 func (c *E2sm) SetRicControlHeader(buffer []byte, ueIdData *UEid, ricControlStyleType int64, ricControlActionID int64) (newBuffer []byte, err error) {
27 xapp.Logger.Info("SetRicControlHeader Enter \n")
28 cptr := unsafe.Pointer(&buffer[0])
29 //cptr_ueIDbuf := unsafe.Pointer(&ueIDbuf[0])
31 lplmnIdBuf := strings.Join(strings.Fields(ueIdData.pLMNIdentitybuf), "")
33 lIntvar, _ := strconv.Atoi(lplmnIdBuf)
34 xapp.Logger.Info("lIntvar = %d\n", lIntvar)
36 lIntegerByte := ConverIntegerToByte(lIntvar)
37 //ml.MavLog(ml.INFO, lTransId, " lIntegerByte = %v\n", lIntegerByte)
38 xapp.Logger.Info(" lIntegerByte = %v\n", lIntegerByte)
39 lOutByte := get_bytepack_plmnId(lIntegerByte)
41 lOutByte, err := hex.DecodeString(lplmnIdBuf)
46 fmt.Printf("% x", lOutByte)
47 xapp.Logger.Info("lOutByte Len:%d\n", len(lOutByte))
48 xapp.Logger.Info("lOutByte = %02X\n", lOutByte)
49 cptrRanParameterValue := unsafe.Pointer(&lOutByte[0])
52 pLMNIdentity := C.CString(ueIdData.pLMNIdentitybuf)
53 defer C.free(unsafe.Pointer(pLMNIdentity))
54 pLMNIdentity_size := C.size_t(len(ueIdData.pLMNIdentitybuf))
55 aMFRegionID := C.CString(ueIdData.aMFRegionIDbuf)
56 defer C.free(unsafe.Pointer(aMFRegionID))
57 aMFSetID := C.CString(ueIdData.aMFSetIDbuf)
58 defer C.free(unsafe.Pointer(aMFSetID))
59 aMFPointer := C.CString(ueIdData.aMFPointerbuf)
60 defer C.free(unsafe.Pointer(aMFPointer))
62 uEID_C := C.struct_uEID{
63 amf_UE_NGAP_Id: C.long(ueIdData.amf_UE_NGAP_Id),
64 pLMNIdentity : pLMNIdentity,
65 pLMNIdentity_size : pLMNIdentity_size,
66 aMFRegionID : aMFRegionID,
67 aMFRegionID_size : 1, //AMFRegionID ::= BIT STRING (SIZE(8))
69 aMFSetID_size: 2, //BIT STRING (SIZE(10))
70 aMFPointer : aMFPointer,
71 aMFPointer_size : 1, //BIT STRING (SIZE(6))
74 xapp.Logger.Debug("uEID_C amf_UE_NGAP_Id = %l",uEID_C.amf_UE_NGAP_Id)
75 xapp.Logger.Debug("uEID_C pLMNIdentity = %s",uEID_C.pLMNIdentity)
76 xapp.Logger.Debug("uEID_C aMFRegionID %s = ",uEID_C.aMFRegionID)
77 xapp.Logger.Debug("uEID_C aMFSetID %s = ",uEID_C.aMFSetID)
78 xapp.Logger.Debug("uEID_C aMFPointer %s = ",uEID_C.aMFPointer)
80 size := C.e2sm_encode_ric_control_header(cptr, C.size_t(len(buffer)),&uEID_C ,(*C.long)(&ueIdData.F1AP_id[0]),C.size_t(len(ueIdData.F1AP_id)),(*C.long)(&ueIdData.E1AP_id[0]),C.size_t(len(ueIdData.E1AP_id)),(C.long)(ricControlStyleType), (C.long)(ricControlActionID), cptrRanParameterValue,C.size_t(len(lOutByte)))
82 //size := C.e2sm_encode_ric_control_header(cptr, C.size_t(len(buffer)),&uEID_C ,(*C.long)(&ueIdData.F1AP_id[0]),(*C.long)(&ueIdData.E1AP_id[0]),(C.long)(ricControlStyleType), (C.long)(ricControlActionID))
85 return make([]byte, 0), errors.New("e2sm wrapper is unable to set EventTriggerDefinition due to wrong or invalid input")
87 newBuffer = C.GoBytes(cptr, (C.int(size)+7)/8)
88 xapp.Logger.Info("E2sm SetRicControlHeader is success")
92 func (c *E2sm) SetRicControlMessage(buffer []byte, targetPrimaryCell int64, targetCell int64, nrCGIOrECGI int64, nrOrEUtraCell int64, pLMNIdentitybuf string,NRcellIdbuf []byte) (newBuffer []byte, err error) {
94 xapp.Logger.Info("SetRicControlMessagei Enter ")
95 //lOutByte, err := hex.DecodeString(string(ranParameterValue))
96 lplmnIdBuf := strings.Join(strings.Fields(pLMNIdentitybuf), "")
97 //lOutByte, err := hex.DecodeString(lplmnIdBuf)
101 NRCGI:="00"+lplmnIdBuf+string(NRcellIdbuf)
102 lOutByte, _ := hex.DecodeString(NRCGI)
103 //tmp_plmn:=[]byte(lplmnIdBuf)
104 cptrRanParameterValue := unsafe.Pointer(&lOutByte[0])
107 cptr := unsafe.Pointer(&buffer[0])
108 //cptrRanParameterValue2 := unsafe.Pointer(&NRcellIdbuf[0])
111 lIntvar, _ := strconv.Atoi(string(ranParameterValue))
112 xapp.Logger.Info("lIntvar %d\n", lIntvar)
113 lIntegerByte := ConverIntegerToByte(lIntvar)
114 xapp.Logger.Info("lIntegerByte %v\n", lIntegerByte)
115 lOutByte := get_bytepack_plmnId(lIntegerByte)
116 xapp.Logger.Info("lOutByte Len:%d\n", len(lOutByte))
117 xapp.Logger.Info("lOutByte %02X\n", lOutByte)
118 cptrRanParameterValue := unsafe.Pointer(&lOutByte[0])
119 xapp.Logger.Info("cptrRanParameterValue = %v\n ", cptrRanParameterValue)
122 size := C.e2sm_encode_ric_control_message(cptr, C.size_t(len(buffer)), C.long(targetPrimaryCell),
123 C.long(targetCell), C.long(nrOrEUtraCell), C.long(nrCGIOrECGI), cptrRanParameterValue,C.size_t(len(lOutByte)))
126 return make([]byte, 0), errors.New("e2sm wrapper is unable to set RicControlMessage due to wrong or invalid input")
128 newBuffer = C.GoBytes(cptr, (C.int(size)+7)/8) //TOCHECK: if C.int(size) is returning bits not bytes to get correct size of the buffer.
129 xapp.Logger.Info("E2sm SetRicControlMessage is success")
133 func (c *E2sm) GetControlOutcome(buffer []byte) (controlOutcome *ControlOutcomeMsg, err error) {
134 cptr := unsafe.Pointer(&buffer[0])
135 controlOutcome = &ControlOutcomeMsg{}
136 //lTransId := gTransIdDefVal
137 //ml.MavLog(ml.INFO, lTransId, "Decode Control Outcome: ")
138 xapp.Logger.Info("Decode Control Outcome: ")
139 decodedMsg := C.e2sm_decode_ric_call_process_outcome(cptr, C.size_t(len(buffer)))
140 defer C.e2sm_free_ric_call_process_outcome(decodedMsg)
141 if decodedMsg == nil {
142 return controlOutcome, errors.New("e2sm wrapper is unable to get ControlOutcome due to wrong or invalid input")
144 //ml.MavLog(ml.INFO, lTransId, "Decoded Control Outcome: ")
145 controlOutcome.ControlOutcomeType = int32(decodedMsg.ric_controlOutcome_formats.present)
146 if controlOutcome.ControlOutcomeType == 1 {
147 controlOutcome := &ControlOutcomeFormat1{}
148 controlOutcomeFormat1_C := *(**C.E2SM_RC_ControlOutcome_Format1_t)(unsafe.Pointer(&decodedMsg.ric_controlOutcome_formats.choice[0]))
149 controlOutcome.ControlOutcomeFormat1ItemCount = int(controlOutcomeFormat1_C.ranP_List.list.count)
150 controlOutcome.ControlOutcomeFormat1Item = make([]ControlOutcomeFormat1ItemType, controlOutcome.ControlOutcomeFormat1ItemCount +1)
151 //ml.MavLog(ml.INFO, lTransId, "RIC Control Outcome Format1 Item Count = %d ", controlOutcome.ControlOutcomeFormat1ItemCount)
152 for i := 0; i < controlOutcome.ControlOutcomeFormat1ItemCount; i++ {
153 ControlOutcomeFormat1Item := &controlOutcome.ControlOutcomeFormat1Item[i]
154 var sizeof_E2SM_RC_ControlOutcome_Format1_Item_t *C.E2SM_RC_ControlOutcome_Format1_Item_t
155 ControlOutcomeFormat1Item_C := *(*(**C.E2SM_RC_ControlOutcome_Format1_Item_t)(unsafe.Pointer(uintptr(unsafe.Pointer(controlOutcomeFormat1_C.ranP_List.list.array)) + (uintptr)(i)*unsafe.Sizeof(sizeof_E2SM_RC_ControlOutcome_Format1_Item_t))))
156 ControlOutcomeFormat1Item.RanParameterID = int64(ControlOutcomeFormat1Item_C.ranParameter_ID)
157 ControlOutcomeFormat1Item.RANParameterValueType = int(ControlOutcomeFormat1Item_C.ranParameter_value.present)
158 ranParameterValue_C := (C.RANParameter_Value_t)(ControlOutcomeFormat1Item_C.ranParameter_value)
159 if ControlOutcomeFormat1Item.RANParameterValueType == 5 {
160 //ml.MavLog(ml.INFO, lTransId, "RANParameterValueType is RANParameter_Value_PR_valueOctS")
161 ranParameterValue := &OctetString{}
162 ranParameter_C := (*C.OCTET_STRING_t)(unsafe.Pointer(&ranParameterValue_C.choice[0]))
163 ranParameterValue.Size = int(ranParameter_C.size)
164 ranParameterValue.Buf = C.GoBytes(unsafe.Pointer(ranParameter_C.buf), C.int(ranParameter_C.size))
165 ControlOutcomeFormat1Item.RANParameterValue = ranParameterValue
166 //ml.MavLog(ml.INFO, lTransId, "RANParameterValue = ", ControlOutcomeFormat1Item.RANParameterValue)
170 return controlOutcome, errors.New("Unknown RIC Control Outcome type")
172 return controlOutcome , err
175 func (c *E2sm) get_plmn_from_mcc_mnc(plmnIdBuf []byte)(bytePackedPlmnId []uint8) {
176 //lTransId := gTransIdDefVal
177 hexResp, _ := hex.DecodeString(string(plmnIdBuf))
178 //ml.MavLog(ml.INFO, lTransId, "get_plmn_from_mcc_mnc plmnIdBuf and hexResp = ", plmnIdBuf,hexResp)
179 var mcc []uint8 = make([]uint8, 3)
180 var mnc []uint8 = make([]uint8, 3)
182 mcc[0] = hexResp[0] >> 4
183 mcc[1] = hexResp[0] & 0xf
184 mcc[2] = hexResp[1] >> 4
185 mnc[0] = hexResp[1] & 0xf
186 mnc[1] = hexResp[2] >> 4
187 mnc[2] = hexResp[2] & 0xf
189 var tmpPlmnId []uint8 = make([]uint8, 6)
190 tmpPlmnId[0] = mcc[0]
191 tmpPlmnId[1] = mcc[1]
192 tmpPlmnId[2] = mcc[2]
195 tmpPlmnId[4] = mnc[0]
196 tmpPlmnId[5] = mnc[1]
198 tmpPlmnId[3] = mnc[0]
199 tmpPlmnId[4] = mnc[1]
200 tmpPlmnId[5] = mnc[2]
202 //ml.MavLog(ml.INFO, lTransId, "\n tmpPlmnId " , tmpPlmnId)
203 bytePackedPlmnId = make([]uint8,3)
204 bytePackedPlmnId[0] = ((tmpPlmnId[1] & 0x0F) << 4) | (tmpPlmnId[0] & 0x0F)
205 bytePackedPlmnId[1] = ((tmpPlmnId[3] & 0x0F) << 4) | (tmpPlmnId[2] & 0x0F)
206 bytePackedPlmnId[2] = ((tmpPlmnId[5] & 0x0F) << 4) | (tmpPlmnId[4] & 0x0F)
207 //ml.MavLog(ml.INFO, lTransId, "\n bytePackedPlmnId " , bytePackedPlmnId)