Added Configupdate for E2AP v1.01
[sim/e2-interface.git] / e2sim / src / encoding / encode_e2apv1.cpp
1
2
3 /*****************************************************************************
4 #                                                                            *
5 # Copyright 2020 AT&T Intellectual Property                                  *
6 # Copyright (c) 2020 Samsung Electronics Co., Ltd. All Rights Reserved.      *
7 #                                                                            *
8 # Licensed under the Apache License, Version 2.0 (the "License");            *
9 # you may not use this file except in compliance with the License.           *
10 # You may obtain a copy of the License at                                    *
11 #                                                                            *
12 #      http://www.apache.org/licenses/LICENSE-2.0                            *
13 #                                                                            *
14 # Unless required by applicable law or agreed to in writing, software        *
15 # distributed under the License is distributed on an "AS IS" BASIS,          *
16 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   *
17 # See the License for the specific language governing permissions and        *
18 # limitations under the License.                                             *
19 #                                                                            *
20 ******************************************************************************/
21
22 #include <stdio.h>
23 #include <string.h>
24 #include <iostream>
25 #include <unistd.h>
26
27 #include <iterator>
28 #include <vector>
29
30
31 #include "encode_e2apv1.hpp"
32
33 extern "C" {
34
35
36 #include "e2ap_asn1c_codec.h"
37 #include "GlobalE2node-ID.h"
38 #include "GlobalE2node-gNB-ID.h"
39 #include "GlobalgNB-ID.h"
40 #include "OCTET_STRING.h"
41 #include "asn_application.h"
42 #include "GNB-ID-Choice.h"
43 #include "ProtocolIE-Field.h"
44 #include "E2setupRequest.h"
45 #include "RICaction-ToBeSetup-Item.h"
46 #include "RICactions-ToBeSetup-List.h"
47 #include "RICeventTriggerDefinition.h"
48 #include "RICsubscriptionRequest.h"
49 #include "RICsubscriptionResponse.h"
50 #include "ProtocolIE-SingleContainer.h"
51 #include "RANfunctions-List.h"
52 #include "RICindication.h"
53 #include "RICsubsequentActionType.h"
54 #include "RICsubsequentAction.h"  
55 #include "RICtimeToWait.h"
56 #include "E2nodeComponentGNB-CU-UP-ID.h"
57 #include "E2nodeComponentID.h"
58 #include "E2nodeComponentConfigUpdate.h"
59 #include "E2nodeComponentConfigUpdateGNB.h"
60   
61 }
62
63 long encoding::get_function_id_from_subscription(E2AP_PDU_t *e2ap_pdu) {
64
65   RICsubscriptionRequest_t orig_req =
66     e2ap_pdu->choice.initiatingMessage->value.choice.RICsubscriptionRequest;
67
68   int count = orig_req.protocolIEs.list.count;
69   int size = orig_req.protocolIEs.list.size;
70   
71   RICsubscriptionRequest_IEs_t **ies = (RICsubscriptionRequest_IEs_t**)orig_req.protocolIEs.list.array;
72
73   fprintf(stderr, "count%d\n", count);
74   fprintf(stderr, "size%d\n", size);
75
76   RICsubscriptionRequest_IEs__value_PR pres;
77
78   long func_id;
79
80   for (int i=0; i < count; i++) {
81     RICsubscriptionRequest_IEs_t *next_ie = ies[i];
82     pres = next_ie->value.present;
83     
84     fprintf(stderr, "next present value %d\n", pres);
85     fprintf(stderr, "value of pres ranfuncid is %d\n", RICsubscriptionRequest_IEs__value_PR_RANfunctionID);
86
87     if (pres == RICsubscriptionRequest_IEs__value_PR_RANfunctionID) {
88       fprintf(stderr, "equal pres to ranfuncid\n");
89       func_id = next_ie->value.choice.RANfunctionID;
90     }
91     
92   }
93
94   fprintf(stderr, "After loop, func_id is %d\n", func_id);
95
96   return func_id;  
97
98 }
99
100 void encoding::generate_e2apv1_service_update(E2AP_PDU_t *e2ap_pdu, std::vector<encoding::ran_func_info> all_funcs) {
101   char* ran_function_op_type = getenv("RAN_FUNCTION_OP_TYPE");
102   LOG_D("Ran funciton : %s", ran_function_op_type);
103   ProtocolIE_ID_t prID;
104   if (ran_function_op_type != NULL)
105   {
106     if (strcmp(ran_function_op_type, "ADD") == 0)
107     {
108       prID = ProtocolIE_ID_id_RANfunctionsAdded;
109     }
110     else if (strcmp(ran_function_op_type, "DELETE"))
111     {
112       prID = ProtocolIE_ID_id_RANfunctionsDeleted;
113     }
114   }
115   else
116   {
117     prID = ProtocolIE_ID_id_RANfunctionsModified;
118   }
119
120
121   RICserviceUpdate_IEs_t *e2serviceUpdateList = (RICserviceUpdate_IEs_t *)calloc(1, sizeof(RICserviceUpdate_IEs_t));
122   e2serviceUpdateList->id = prID;
123   e2serviceUpdateList->criticality = Criticality_reject;
124   e2serviceUpdateList->value.present = RICserviceUpdate_IEs__value_PR_RANfunctions_List;
125
126
127   for (int i=0; i<all_funcs.size(); i++) {
128
129     encoding::ran_func_info nextRanFunc = all_funcs.at(i);
130     long nextRanFuncId = nextRanFunc.ranFunctionId;
131     OCTET_STRING_t *nextRanFuncDesc = nextRanFunc.ranFunctionDesc;
132     long nextRanFuncRev = nextRanFunc.ranFunctionRev;
133
134     auto *itemIes = (RANfunction_ItemIEs_t *)calloc(1, sizeof(RANfunction_ItemIEs_t));
135     itemIes->id = ProtocolIE_ID_id_RANfunction_Item;
136     itemIes->criticality = Criticality_reject;
137     itemIes->value.present = RANfunction_ItemIEs__value_PR_RANfunction_Item;
138     itemIes->value.choice.RANfunction_Item.ranFunctionID = 1;
139
140     itemIes->value.choice.RANfunction_Item.ranFunctionDefinition = *nextRanFuncDesc;
141     itemIes->value.choice.RANfunction_Item.ranFunctionRevision = nextRanFuncRev + 1;
142
143     ASN_SEQUENCE_ADD(&e2serviceUpdateList->value.choice.RANfunctions_List.list, itemIes);
144   }
145
146   RICserviceUpdate_t *ricServiceUpdate = (RICserviceUpdate_t *)calloc(1, sizeof(RICserviceUpdate_t));
147   ASN_SEQUENCE_ADD(&ricServiceUpdate->protocolIEs.list, e2serviceUpdateList);
148
149   InitiatingMessage_t *initiatingMessage = (InitiatingMessage_t *)calloc(1, sizeof(InitiatingMessage_t));
150   initiatingMessage->criticality = Criticality_reject;
151   initiatingMessage->procedureCode = ProcedureCode_id_RICserviceUpdate;
152   initiatingMessage->value.present = InitiatingMessage__value_PR_RICserviceUpdate;
153   initiatingMessage->value.choice.RICserviceUpdate = *ricServiceUpdate;
154
155   E2AP_PDU_PR pres6 = E2AP_PDU_PR_initiatingMessage;
156   e2ap_pdu->present = pres6;
157   e2ap_pdu->choice.initiatingMessage = initiatingMessage;
158 }
159
160 void encoding::generate_e2apv1_setup_request_parameterized(E2AP_PDU_t *e2ap_pdu, std::vector<ran_func_info> all_funcs) {
161   //                                             long ranFunctionId, uint8_t *ranFuncDescEncoded, int ranFuncLength) {
162
163   //  uint8_t *buf = (uint8_t *)"gnb1"
164
165   BIT_STRING_t *gnb_bstring = (BIT_STRING_t*)calloc(1, sizeof(BIT_STRING_t));;
166   gnb_bstring->buf = (uint8_t*)calloc(1,4);
167   gnb_bstring->size = 4;
168   gnb_bstring->buf[0] = 0xB5;
169   gnb_bstring->buf[1] = 0xC6;
170   gnb_bstring->buf[2] = 0x77;
171   gnb_bstring->buf[3] = 0x88;
172
173   gnb_bstring->bits_unused = 3;
174
175   uint8_t *buf2 = (uint8_t *)"747";
176   OCTET_STRING_t *plmn = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
177   plmn->buf = (uint8_t*)calloc(1,3);
178   memcpy(plmn->buf, buf2, 3);
179   plmn->size = 3;
180
181   GNB_ID_Choice_t *gnbchoice = (GNB_ID_Choice_t*)calloc(1,sizeof(GNB_ID_Choice_t));
182   GNB_ID_Choice_PR pres2 = GNB_ID_Choice_PR_gnb_ID;
183   gnbchoice->present = pres2;
184   gnbchoice->choice.gnb_ID = *gnb_bstring;
185   if (gnb_bstring) free(gnb_bstring);
186
187   GlobalgNB_ID_t *gnb = (GlobalgNB_ID_t*)calloc(1, sizeof(GlobalgNB_ID_t));
188   gnb->plmn_id = *plmn;
189   gnb->gnb_id = *gnbchoice;
190   if (plmn) free(plmn);
191   if (gnbchoice) free(gnbchoice);
192
193   GlobalE2node_gNB_ID_t *e2gnb = (GlobalE2node_gNB_ID_t*)calloc(1, sizeof(GlobalE2node_gNB_ID_t));
194   e2gnb->global_gNB_ID = *gnb;
195   if (gnb) free(gnb);
196
197   GlobalE2node_ID_t *globale2nodeid = (GlobalE2node_ID_t*)calloc(1, sizeof(GlobalE2node_ID_t));
198   GlobalE2node_ID_PR pres;
199   pres = GlobalE2node_ID_PR_gNB;
200   globale2nodeid->present = pres;
201   globale2nodeid->choice.gNB = e2gnb;
202   
203   E2setupRequestIEs_t *e2setuprid = (E2setupRequestIEs_t*)calloc(1, sizeof(E2setupRequestIEs_t));
204   E2setupRequestIEs__value_PR pres3;
205   pres3 = E2setupRequestIEs__value_PR_GlobalE2node_ID;
206   e2setuprid->id = 3;
207   e2setuprid->criticality = 0;
208   e2setuprid->value.choice.GlobalE2node_ID = *globale2nodeid;
209   e2setuprid->value.present = pres3;
210   if(globale2nodeid) free(globale2nodeid);
211
212
213   auto *ranFlistIEs = (E2setupRequestIEs_t *)calloc(1, sizeof(E2setupRequestIEs_t));
214   ASN_STRUCT_RESET(asn_DEF_E2setupRequestIEs, ranFlistIEs);
215   ranFlistIEs->criticality = 0;
216   ranFlistIEs->id = ProtocolIE_ID_id_RANfunctionsAdded;
217   ranFlistIEs->value.present = E2setupRequestIEs__value_PR_RANfunctions_List;
218
219
220   for (int i = 0; i < all_funcs.size(); i++) {
221
222     ran_func_info nextRanFunc = all_funcs.at(i);
223     long nextRanFuncId = nextRanFunc.ranFunctionId;
224     OCTET_STRING_t *nextRanFuncDesc = nextRanFunc.ranFunctionDesc;
225     long nextRanFuncRev = nextRanFunc.ranFunctionRev;
226
227     auto *itemIes = (RANfunction_ItemIEs_t *)calloc(1, sizeof(RANfunction_ItemIEs_t));
228     itemIes->id = ProtocolIE_ID_id_RANfunction_Item;
229     itemIes->criticality = Criticality_reject;
230     itemIes->value.present = RANfunction_ItemIEs__value_PR_RANfunction_Item;
231     itemIes->value.choice.RANfunction_Item.ranFunctionID = nextRanFuncId;
232     itemIes->value.choice.RANfunction_Item.ranFunctionOID = nextRanFunc.ranFunctionOId;
233     int ranFuncLength = strlen((char*)nextRanFuncDesc);
234
235     itemIes->value.choice.RANfunction_Item.ranFunctionDefinition = *nextRanFuncDesc;
236     itemIes->value.choice.RANfunction_Item.ranFunctionRevision = nextRanFuncRev;
237     
238     ASN_SEQUENCE_ADD(&ranFlistIEs->value.choice.RANfunctions_List.list, itemIes);
239
240   }
241
242     auto *e2nodeconfigupdatelistIEs = (E2setupRequestIEs_t *)calloc(1, sizeof(E2setupRequestIEs_t));
243   ASN_STRUCT_RESET(asn_DEF_E2setupRequestIEs, e2nodeconfigupdatelistIEs);
244   e2nodeconfigupdatelistIEs->criticality = 0;
245   e2nodeconfigupdatelistIEs->id = ProtocolIE_ID_id_E2nodeComponentConfigUpdate;
246   e2nodeconfigupdatelistIEs->value.present = E2setupRequestIEs__value_PR_E2nodeComponentConfigUpdate_List;
247
248
249   OCTET_STRING_t *ngAPconfigUpdate =  (OCTET_STRING_t *)calloc(1,sizeof(OCTET_STRING_t));
250   ngAPconfigUpdate->buf = (uint8_t*)calloc(1,13);
251   memcpy(ngAPconfigUpdate->buf, (uint8_t *)"gnbngapupdate", 13);
252   ngAPconfigUpdate->size = 13;
253
254   OCTET_STRING_t *xnAPconfigUpdate =  (OCTET_STRING_t *)calloc(1,sizeof(OCTET_STRING_t));
255   xnAPconfigUpdate->buf = (uint8_t*)calloc(1,13);
256   memcpy(xnAPconfigUpdate->buf, (uint8_t *)"gnbxnapupdate", 13);
257   xnAPconfigUpdate->size = 13;
258
259   OCTET_STRING_t *e1APconfigUpdate =  (OCTET_STRING_t *)calloc(1,sizeof(OCTET_STRING_t));
260   e1APconfigUpdate->buf = (uint8_t*)calloc(1,13);
261   memcpy(e1APconfigUpdate->buf, (uint8_t *)"gnbe1apupdate", 13);
262   e1APconfigUpdate->size = 13;
263
264   OCTET_STRING_t *f1APconfigUpdate =  (OCTET_STRING_t *)calloc(1,sizeof(OCTET_STRING_t));
265   f1APconfigUpdate->buf = (uint8_t*)calloc(1,13);
266   memcpy(f1APconfigUpdate->buf, (uint8_t *)"gnbf1apupdate", 13);
267   f1APconfigUpdate->size = 13;
268
269   E2nodeComponentConfigUpdateGNB_t *e2nodecomponentconfigupdategnb = (E2nodeComponentConfigUpdateGNB_t *)calloc(1,sizeof(E2nodeComponentConfigUpdateGNB_t));
270   e2nodecomponentconfigupdategnb->ngAPconfigUpdate = ngAPconfigUpdate;
271   e2nodecomponentconfigupdategnb->xnAPconfigUpdate = xnAPconfigUpdate;
272   e2nodecomponentconfigupdategnb->e1APconfigUpdate = e1APconfigUpdate;
273   e2nodecomponentconfigupdategnb->f1APconfigUpdate = f1APconfigUpdate;
274
275   E2nodeComponentConfigUpdate_t e2nodecomponentconfigupdate = {};
276   e2nodecomponentconfigupdate.present = E2nodeComponentConfigUpdate_PR_gNBconfigUpdate;
277   e2nodecomponentconfigupdate.choice.gNBconfigUpdate = e2nodecomponentconfigupdategnb;
278
279   GNB_CU_UP_ID_t gnbcuupid = {};
280   gnbcuupid.buf = (uint8_t*)calloc(1,4);
281   memcpy(gnbcuupid.buf, (uint8_t *)"1234", 4);
282   gnbcuupid.size = 4;
283
284   E2nodeComponentGNB_CU_UP_ID_t *e2nodecomponentgnbcuupid = (E2nodeComponentGNB_CU_UP_ID_t *)calloc(1,sizeof(E2nodeComponentGNB_CU_UP_ID_t));
285   e2nodecomponentgnbcuupid->gNB_CU_UP_ID = gnbcuupid;
286
287   E2nodeComponentID_t *e2nodecomponentid = (E2nodeComponentID_t*)calloc(1, sizeof(E2nodeComponentID_t));
288
289   e2nodecomponentid->present = E2nodeComponentID_PR_e2nodeComponentTypeGNB_CU_UP;
290   e2nodecomponentid->choice.e2nodeComponentTypeGNB_CU_UP = e2nodecomponentgnbcuupid;
291
292   auto *configupdateitemIes = (E2nodeComponentConfigUpdate_ItemIEs_t *)calloc(1, sizeof(E2nodeComponentConfigUpdate_ItemIEs_t));
293   configupdateitemIes->id = ProtocolIE_ID_id_E2nodeComponentConfigUpdate_Item;
294   configupdateitemIes->criticality = Criticality_reject;
295   configupdateitemIes->value.present = E2nodeComponentConfigUpdate_ItemIEs__value_PR_E2nodeComponentConfigUpdate_Item;
296   configupdateitemIes->value.choice.E2nodeComponentConfigUpdate_Item.e2nodeComponentType = E2nodeComponentType_gNB_CU_UP;
297   configupdateitemIes->value.choice.E2nodeComponentConfigUpdate_Item.e2nodeComponentID = e2nodecomponentid;
298   configupdateitemIes->value.choice.E2nodeComponentConfigUpdate_Item.e2nodeComponentConfigUpdate = e2nodecomponentconfigupdate;
299
300   ASN_SEQUENCE_ADD(&e2nodeconfigupdatelistIEs->value.choice.E2nodeComponentConfigUpdate_List.list, configupdateitemIes);
301
302   E2setupRequest_t *e2setupreq = (E2setupRequest_t*)calloc(1, sizeof(E2setupRequest_t));
303   ASN_SEQUENCE_ADD(&e2setupreq->protocolIEs.list, e2setuprid);
304   ASN_SEQUENCE_ADD(&e2setupreq->protocolIEs.list, ranFlistIEs);
305   ASN_SEQUENCE_ADD(&e2setupreq->protocolIEs.list, e2nodeconfigupdatelistIEs);
306
307
308   InitiatingMessage__value_PR pres4;
309   pres4 = InitiatingMessage__value_PR_E2setupRequest;
310   InitiatingMessage_t *initmsg = (InitiatingMessage_t*)calloc(1, sizeof(InitiatingMessage_t));
311
312   initmsg->procedureCode = ProcedureCode_id_E2setup;
313   initmsg->criticality = Criticality_reject;
314   initmsg->value.present = pres4;
315   initmsg->value.choice.E2setupRequest = *e2setupreq;
316   if (e2setupreq) free(e2setupreq);
317
318   E2AP_PDU_PR pres5;
319   pres5 = E2AP_PDU_PR_initiatingMessage;
320   
321
322   e2ap_pdu->present = pres5;
323   e2ap_pdu->choice.initiatingMessage = initmsg;  
324
325 }
326
327
328
329 void encoding::generate_e2apv1_setup_response(E2AP_PDU_t *e2ap_pdu) {
330
331   E2setupResponseIEs *resp_ies1 = (E2setupResponseIEs_t*)calloc(1, sizeof(E2setupResponseIEs_t));
332   E2setupResponseIEs *resp_ies2 = (E2setupResponseIEs_t*)calloc(1, sizeof(E2setupResponseIEs_t));
333   E2setupResponseIEs *resp_ies3 = (E2setupResponseIEs_t*)calloc(1, sizeof(E2setupResponseIEs_t));
334
335   uint8_t *buf = (uint8_t *)"gnb1";
336
337   BIT_STRING_t *ricid_bstring = (BIT_STRING_t*)calloc(1,sizeof(BIT_STRING_t));
338   ricid_bstring->buf = buf;
339   ricid_bstring->size = 4;
340   ricid_bstring->bits_unused = 0;
341
342   uint8_t *buf2 = (uint8_t *)"plmn3";
343   OCTET_STRING_t *plmn = (OCTET_STRING_t*)calloc(1,sizeof(OCTET_STRING_t));
344   plmn->buf = buf2;
345   plmn->size = 5;
346
347   GlobalRIC_ID_t *globalricid = (GlobalRIC_ID_t*)calloc(1,sizeof(GlobalRIC_ID_t));
348   globalricid->pLMN_Identity = *plmn;
349   globalricid->ric_ID = *ricid_bstring;
350
351   E2setupResponseIEs__value_PR pres1;
352   pres1 = E2setupResponseIEs__value_PR_GlobalRIC_ID;
353   
354   resp_ies1->id = ProtocolIE_ID_id_GlobalRIC_ID;
355   resp_ies1->criticality = 0;
356   resp_ies1->value.present = pres1;
357   resp_ies1->value.choice.GlobalRIC_ID = *globalricid;
358
359   E2setupResponse_t *e2setupresp = (E2setupResponse_t*)calloc(1,sizeof(E2setupResponse_t));
360   int ret = ASN_SEQUENCE_ADD(&e2setupresp->protocolIEs.list, resp_ies1);
361
362
363   SuccessfulOutcome__value_PR pres;
364   pres = SuccessfulOutcome__value_PR_E2setupResponse;
365   SuccessfulOutcome_t *successoutcome = (SuccessfulOutcome_t*)calloc(1, sizeof(SuccessfulOutcome_t));
366   successoutcome->procedureCode = 1;
367   successoutcome->criticality = 0;
368   successoutcome->value.present = pres;
369   successoutcome->value.choice.E2setupResponse = *e2setupresp;
370
371   E2AP_PDU_PR pres5 = E2AP_PDU_PR_successfulOutcome;
372   
373   e2ap_pdu->present = pres5;
374   e2ap_pdu->choice.successfulOutcome = successoutcome;
375   
376 }
377
378
379 void encoding::generate_e2apv1_subscription_request(E2AP_PDU *e2ap_pdu) {
380
381   fprintf(stderr, "in sub 1\n");
382   RICsubscriptionRequest_IEs_t *ricreqid = (RICsubscriptionRequest_IEs_t*)calloc(1, sizeof(RICsubscriptionRequest_IEs_t));
383   fprintf(stderr, "in sub 2\n");  
384   ASN_STRUCT_RESET(asn_DEF_RICsubscriptionRequest_IEs, ricreqid);
385   fprintf(stderr, "in sub 3\n");  
386   auto *ricsubrid = (RICsubscriptionRequest_IEs_t*)calloc(1, sizeof(RICsubscriptionRequest_IEs_t));
387   fprintf(stderr, "in sub 4\n");  
388   ASN_STRUCT_RESET(asn_DEF_RICsubscriptionRequest_IEs, ricsubrid);
389   
390   fprintf(stderr, "in generate sub\n");
391   uint8_t *buf2 = (uint8_t *)"SubscriptionTriggers";
392   fprintf(stderr, "in gen sub 1\n");
393   OCTET_STRING_t *triggerdef = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
394   triggerdef->buf = (uint8_t *)calloc(1,20);
395   triggerdef->size = 20;  
396   memcpy(triggerdef->buf, buf2, triggerdef->size);
397
398
399   fprintf(stderr, "sub1\n");
400   ProtocolIE_ID_t proto_id= ProtocolIE_ID_id_RICaction_ToBeSetup_Item;
401
402   RICaction_ToBeSetup_ItemIEs__value_PR pres6;
403   pres6 = RICaction_ToBeSetup_ItemIEs__value_PR_RICaction_ToBeSetup_Item;
404
405   printf("sub2\n");
406
407   uint8_t *buf5 = (uint8_t *)"ActionDef";
408
409   OCTET_STRING_t *actdef = (OCTET_STRING_t*)calloc(1, sizeof(OCTET_STRING_t));
410   actdef->buf = (uint8_t *)calloc(1,9);
411   actdef->size = 9;  
412   memcpy(triggerdef->buf, buf5, 9);
413
414   auto *sa = (RICsubsequentAction_t *) calloc(1, sizeof(RICsubsequentAction_t));
415   ASN_STRUCT_RESET(asn_DEF_RICsubsequentAction, sa);
416   
417   sa->ricTimeToWait = RICtimeToWait_w500ms;
418   sa->ricSubsequentActionType = RICsubsequentActionType_continue;
419     
420   printf("sub3\n");
421
422   RICaction_ToBeSetup_ItemIEs_t *action_item_ies = (RICaction_ToBeSetup_ItemIEs_t *)calloc(1, sizeof(RICaction_ToBeSetup_Item_t));
423   action_item_ies->id = proto_id;
424   action_item_ies->criticality = 0;
425
426   action_item_ies->value.present = pres6;
427   action_item_ies->value.choice.RICaction_ToBeSetup_Item.ricActionID = 5;
428   action_item_ies->value.choice.RICaction_ToBeSetup_Item.ricActionType = RICactionType_report;
429   action_item_ies->value.choice.RICaction_ToBeSetup_Item.ricActionDefinition = actdef;
430   action_item_ies->value.choice.RICaction_ToBeSetup_Item.ricSubsequentAction = sa;
431
432
433   printf("sub5\n");
434   
435
436   RICsubscriptionRequest_IEs__value_PR pres3;
437   printf("sub6.1\n");
438   pres3 = RICsubscriptionRequest_IEs__value_PR_RICsubscriptionDetails;
439   ricsubrid->id = ProtocolIE_ID_id_RICsubscriptionDetails;
440   printf("sub6.2\n");
441   
442   ricsubrid->criticality = 0;
443   ricsubrid->value.present = pres3;
444   printf("sub6.3\n");
445
446   ricsubrid->value.choice.RICsubscriptionDetails.ricEventTriggerDefinition = *triggerdef;
447   printf("sub6.4\n");
448   
449   ASN_SEQUENCE_ADD(&ricsubrid->value.choice.RICsubscriptionDetails.ricAction_ToBeSetup_List.list, action_item_ies);
450
451   printf("sub7\n");
452
453
454   ricreqid->id = ProtocolIE_ID_id_RICrequestID;
455   ricreqid->criticality = 0;
456   ricreqid->value.present = RICsubscriptionRequest_IEs__value_PR_RICrequestID;
457   ricreqid->value.choice.RICrequestID.ricRequestorID = 22;
458   ricreqid->value.choice.RICrequestID.ricInstanceID = 6;
459
460   RICsubscriptionRequest_t *ricsubreq = (RICsubscriptionRequest_t*)calloc(1, sizeof(RICsubscriptionRequest_t));
461
462   ASN_SEQUENCE_ADD(&ricsubreq->protocolIEs.list,ricreqid);
463   ASN_SEQUENCE_ADD(&ricsubreq->protocolIEs.list,ricsubrid);
464
465
466
467   InitiatingMessage__value_PR pres4;
468   pres4 = InitiatingMessage__value_PR_RICsubscriptionRequest;
469   InitiatingMessage_t *initmsg = (InitiatingMessage_t*)calloc(1, sizeof(InitiatingMessage_t));
470   initmsg->procedureCode = ProcedureCode_id_RICsubscription;
471   initmsg->criticality = Criticality_reject;
472   initmsg->value.present = pres4;
473   initmsg->value.choice.RICsubscriptionRequest = *ricsubreq;
474
475   E2AP_PDU_PR pres5;
476   pres5 = E2AP_PDU_PR_initiatingMessage;
477   
478
479   e2ap_pdu->present = pres5;
480   e2ap_pdu->choice.initiatingMessage = initmsg;
481
482   char error_buf[300] = {0, };
483   size_t errlen = 0;
484                                                                           
485   asn_check_constraints(&asn_DEF_E2AP_PDU, e2ap_pdu, error_buf, &errlen);
486   printf("error length %d\n", errlen);
487   printf("error buf %s\n", error_buf);
488
489
490 }
491
492 void encoding::generate_e2apv1_subscription_response_success(E2AP_PDU *e2ap_pdu, long reqActionIdsAccepted[],
493                                                    long reqActionIdsRejected[], int accept_size, int reject_size,
494                                                    long reqRequestorId, long reqInstanceId) {
495
496   RICsubscriptionResponse_IEs_t *respricreqid =
497     (RICsubscriptionResponse_IEs_t*)calloc(1, sizeof(RICsubscriptionResponse_IEs_t));
498   
499   respricreqid->id = ProtocolIE_ID_id_RICrequestID;
500   respricreqid->criticality = 0;
501   respricreqid->value.present = RICsubscriptionResponse_IEs__value_PR_RICrequestID;
502   respricreqid->value.choice.RICrequestID.ricRequestorID = reqRequestorId;
503   
504   respricreqid->value.choice.RICrequestID.ricInstanceID = reqInstanceId;
505
506   RICsubscriptionResponse_IEs_t *respfuncid =
507     (RICsubscriptionResponse_IEs_t*)calloc(1, sizeof(RICsubscriptionResponse_IEs_t));
508   respfuncid->id = ProtocolIE_ID_id_RANfunctionID;
509   respfuncid->criticality = 0;
510   respfuncid->value.present = RICsubscriptionResponse_IEs__value_PR_RANfunctionID;
511   respfuncid->value.choice.RANfunctionID = (long)0;
512   
513
514   RICsubscriptionResponse_IEs_t *ricactionadmitted =
515     (RICsubscriptionResponse_IEs_t*)calloc(1, sizeof(RICsubscriptionResponse_IEs_t));
516   ricactionadmitted->id = ProtocolIE_ID_id_RICactions_Admitted;
517   ricactionadmitted->criticality = 0;
518   ricactionadmitted->value.present = RICsubscriptionResponse_IEs__value_PR_RICaction_Admitted_List;
519
520   RICaction_Admitted_List_t* admlist = 
521     (RICaction_Admitted_List_t*)calloc(1,sizeof(RICaction_Admitted_List_t));
522   ricactionadmitted->value.choice.RICaction_Admitted_List = *admlist;
523   if (admlist) free(admlist);
524
525
526   int numAccept = accept_size;
527   int numReject = reject_size;
528
529
530   
531   for (int i=0; i < numAccept ; i++) {
532     fprintf(stderr, "in for loop i = %d\n", i);
533
534     long aid = reqActionIdsAccepted[i];
535
536     RICaction_Admitted_ItemIEs_t *admitie = (RICaction_Admitted_ItemIEs_t*)calloc(1,sizeof(RICaction_Admitted_ItemIEs_t));
537     admitie->id = ProtocolIE_ID_id_RICaction_Admitted_Item;
538     admitie->criticality = 0;
539     admitie->value.present = RICaction_Admitted_ItemIEs__value_PR_RICaction_Admitted_Item;
540     admitie->value.choice.RICaction_Admitted_Item.ricActionID = aid;
541     
542     ASN_SEQUENCE_ADD(&ricactionadmitted->value.choice.RICaction_Admitted_List.list, admitie);
543
544   }
545
546   RICsubscriptionResponse_t *ricsubresp = (RICsubscriptionResponse_t*)calloc(1,sizeof(RICsubscriptionResponse_t));
547   ASN_SEQUENCE_ADD(&ricsubresp->protocolIEs.list, respricreqid);
548   ASN_SEQUENCE_ADD(&ricsubresp->protocolIEs.list, respfuncid);
549   ASN_SEQUENCE_ADD(&ricsubresp->protocolIEs.list, ricactionadmitted);
550   
551
552   if (numReject > 0) {
553
554     RICsubscriptionResponse_IEs_t *ricactionrejected =
555       (RICsubscriptionResponse_IEs_t*)calloc(1, sizeof(RICsubscriptionResponse_IEs_t));
556     ricactionrejected->id = ProtocolIE_ID_id_RICactions_NotAdmitted;
557     ricactionrejected->criticality = 0;
558     ricactionrejected->value.present = RICsubscriptionResponse_IEs__value_PR_RICaction_NotAdmitted_List;
559     
560     RICaction_NotAdmitted_List_t* rejectlist = 
561       (RICaction_NotAdmitted_List_t*)calloc(1,sizeof(RICaction_NotAdmitted_List_t));
562     ricactionadmitted->value.choice.RICaction_NotAdmitted_List = *rejectlist;
563     
564     for (int i=0; i < numReject; i++) {
565       fprintf(stderr, "in for loop i = %d\n", i);
566       
567       long aid = reqActionIdsRejected[i];
568       
569       RICaction_NotAdmitted_ItemIEs_t *noadmitie = (RICaction_NotAdmitted_ItemIEs_t*)calloc(1,sizeof(RICaction_NotAdmitted_ItemIEs_t));
570       noadmitie->id = ProtocolIE_ID_id_RICaction_NotAdmitted_Item;
571       noadmitie->criticality = 0;
572       noadmitie->value.present = RICaction_NotAdmitted_ItemIEs__value_PR_RICaction_NotAdmitted_Item;
573       noadmitie->value.choice.RICaction_NotAdmitted_Item.ricActionID = aid;
574       
575       ASN_SEQUENCE_ADD(&ricactionrejected->value.choice.RICaction_NotAdmitted_List.list, noadmitie);
576       ASN_SEQUENCE_ADD(&ricsubresp->protocolIEs.list, ricactionrejected);      
577     }
578   }
579
580
581   SuccessfulOutcome__value_PR pres2;
582   pres2 = SuccessfulOutcome__value_PR_RICsubscriptionResponse;
583   SuccessfulOutcome_t *successoutcome = (SuccessfulOutcome_t*)calloc(1, sizeof(SuccessfulOutcome_t));
584   successoutcome->procedureCode = ProcedureCode_id_RICsubscription;
585   successoutcome->criticality = 0;
586   successoutcome->value.present = pres2;
587   successoutcome->value.choice.RICsubscriptionResponse = *ricsubresp;
588   if (ricsubresp) free(ricsubresp);
589
590   E2AP_PDU_PR pres5 = E2AP_PDU_PR_successfulOutcome;
591   
592   e2ap_pdu->present = pres5;
593   e2ap_pdu->choice.successfulOutcome = successoutcome;
594
595   char error_buf[300] = {0, };
596   size_t errlen = 0;
597
598   asn_check_constraints(&asn_DEF_E2AP_PDU, e2ap_pdu, error_buf, &errlen);
599   printf("error length %d\n", errlen);
600   printf("error buf %s\n", error_buf);
601
602   printf("now printing xer of subscription response\n");
603   xer_fprint(stderr, &asn_DEF_E2AP_PDU, e2ap_pdu);
604   printf("done printing xer of subscription response\n");  
605
606   
607 }
608
609 void encoding::generate_e2apv1_subscription_response(E2AP_PDU *e2ap_pdu, E2AP_PDU *sub_req_pdu) {
610
611   //Gather details of the request
612
613   RICsubscriptionRequest_t orig_req =
614     sub_req_pdu->choice.initiatingMessage->value.choice.RICsubscriptionRequest;
615   
616   RICsubscriptionResponse_IEs_t *ricreqid =
617     (RICsubscriptionResponse_IEs_t*)calloc(1, sizeof(RICsubscriptionResponse_IEs_t));
618                                            
619   int count = orig_req.protocolIEs.list.count;
620   int size = orig_req.protocolIEs.list.size;
621   
622   RICsubscriptionRequest_IEs_t **ies = (RICsubscriptionRequest_IEs_t**)orig_req.protocolIEs.list.array;
623
624   fprintf(stderr, "count%d\n", count);
625   fprintf(stderr, "size%d\n", size);
626
627   RICsubscriptionRequest_IEs__value_PR pres;
628
629   long responseRequestorId;
630   long responseInstanceId;
631   long responseActionId;
632
633   std::vector<long> actionIds;
634
635   for (int i=0; i < count; i++) {
636     RICsubscriptionRequest_IEs_t *next_ie = ies[i];
637     pres = next_ie->value.present;
638     
639     fprintf(stderr, "next present value %d\n", pres);
640
641     switch(pres) {
642     case RICsubscriptionRequest_IEs__value_PR_RICrequestID:
643       {
644         RICrequestID_t reqId = next_ie->value.choice.RICrequestID;
645         long requestorId = reqId.ricRequestorID;
646         long instanceId = reqId.ricInstanceID;
647         fprintf(stderr, "requestorId %d\n", requestorId);
648         fprintf(stderr, "instanceId %d\n", instanceId);
649         responseRequestorId = requestorId;
650         responseInstanceId = instanceId;
651                 
652         break;
653       }
654     case RICsubscriptionRequest_IEs__value_PR_RANfunctionID:
655       break;
656     case RICsubscriptionRequest_IEs__value_PR_RICsubscriptionDetails:
657       {
658         RICsubscriptionDetails_t subDetails = next_ie->value.choice.RICsubscriptionDetails; 
659         RICeventTriggerDefinition_t triggerDef = subDetails.ricEventTriggerDefinition;
660         RICactions_ToBeSetup_List_t actionList = subDetails.ricAction_ToBeSetup_List;
661         
662         int actionCount = actionList.list.count;
663         fprintf(stderr, "action count%d\n", actionCount);
664
665         auto **item_array = actionList.list.array;
666
667         for (int i=0; i < actionCount; i++) {
668           //RICaction_ToBeSetup_Item_t
669           auto *next_item = item_array[i];
670           RICactionID_t actionId = ((RICaction_ToBeSetup_ItemIEs*)next_item)->value.choice.RICaction_ToBeSetup_Item.ricActionID;
671           fprintf(stderr, "Next Action ID %ld\n", actionId);
672           responseActionId = actionId;
673           actionIds.push_back(responseActionId);
674         }
675         
676         break;
677       }
678     }
679     
680   }
681
682   fprintf(stderr, "After Processing Subscription Request\n");
683
684   fprintf(stderr, "requestorId %d\n", responseRequestorId);
685   fprintf(stderr, "instanceId %d\n", responseInstanceId);
686
687
688   for (int i=0; i < actionIds.size(); i++) {
689     fprintf(stderr, "Action ID %d %ld\n", i, actionIds.at(i));
690     
691   }
692
693
694   RICsubscriptionResponse_IEs_t *respricreqid =
695     (RICsubscriptionResponse_IEs_t*)calloc(1, sizeof(RICsubscriptionResponse_IEs_t));
696   
697   respricreqid->id = ProtocolIE_ID_id_RICrequestID;
698   respricreqid->criticality = 0;
699   respricreqid->value.present = RICsubscriptionResponse_IEs__value_PR_RICrequestID;
700   respricreqid->value.choice.RICrequestID.ricRequestorID = responseRequestorId;
701   
702   respricreqid->value.choice.RICrequestID.ricInstanceID = responseInstanceId;
703
704
705   RICsubscriptionResponse_IEs_t *ricactionadmitted =
706     (RICsubscriptionResponse_IEs_t*)calloc(1, sizeof(RICsubscriptionResponse_IEs_t));
707   ricactionadmitted->id = ProtocolIE_ID_id_RICactions_Admitted;
708   ricactionadmitted->criticality = 0;
709   ricactionadmitted->value.present = RICsubscriptionResponse_IEs__value_PR_RICaction_Admitted_List;
710
711   RICaction_Admitted_List_t* admlist = 
712     (RICaction_Admitted_List_t*)calloc(1,sizeof(RICaction_Admitted_List_t));
713   ricactionadmitted->value.choice.RICaction_Admitted_List = *admlist;
714
715   for (int i=0; i < actionIds.size(); i++) {
716     fprintf(stderr, "in for loop i = %d\n", i);
717
718     long aid = actionIds.at(i);
719
720     RICaction_Admitted_ItemIEs_t *admitie = (RICaction_Admitted_ItemIEs_t*)calloc(1,sizeof(RICaction_Admitted_ItemIEs_t));
721     admitie->id = ProtocolIE_ID_id_RICaction_Admitted_Item;
722     admitie->criticality = 0;
723     admitie->value.present = RICaction_Admitted_ItemIEs__value_PR_RICaction_Admitted_Item;
724     admitie->value.choice.RICaction_Admitted_Item.ricActionID = aid;
725     
726     ASN_SEQUENCE_ADD(&ricactionadmitted->value.choice.RICaction_Admitted_List.list, admitie);
727
728   }
729
730
731   RICsubscriptionResponse_t *ricsubresp = (RICsubscriptionResponse_t*)calloc(1,sizeof(RICsubscriptionResponse_t));
732   
733   ASN_SEQUENCE_ADD(&ricsubresp->protocolIEs.list, respricreqid);
734   ASN_SEQUENCE_ADD(&ricsubresp->protocolIEs.list, ricactionadmitted);
735
736
737   SuccessfulOutcome__value_PR pres2;
738   pres2 = SuccessfulOutcome__value_PR_RICsubscriptionResponse;
739   SuccessfulOutcome_t *successoutcome = (SuccessfulOutcome_t*)calloc(1, sizeof(SuccessfulOutcome_t));
740   successoutcome->procedureCode = ProcedureCode_id_RICsubscription;
741   successoutcome->criticality = 0;
742   successoutcome->value.present = pres2;
743   successoutcome->value.choice.RICsubscriptionResponse = *ricsubresp;
744
745   E2AP_PDU_PR pres5 = E2AP_PDU_PR_successfulOutcome;
746   
747   e2ap_pdu->present = pres5;
748   e2ap_pdu->choice.successfulOutcome = successoutcome;
749
750   char error_buf[300] = {0, };
751   size_t errlen = 0;
752
753   asn_check_constraints(&asn_DEF_E2AP_PDU, e2ap_pdu, error_buf, &errlen);
754   printf("error length %d\n", errlen);
755   printf("error buf %s\n", error_buf);
756
757
758   
759 }
760
761 void encoding::generate_e2apv1_indication_request_parameterized(E2AP_PDU *e2ap_pdu,
762                                                                 long requestorId,
763                                                                 long instanceId,
764                                                                 long ranFunctionId,
765                                                                 long actionId,
766                                                                 long seqNum,
767                                                                 uint8_t *ind_header_buf,
768                                                                 int header_length,
769                                                                 uint8_t *ind_message_buf,
770                                                                 int message_length) {
771   
772   fprintf(stderr, "ind1\n");
773   RICindication_IEs_t *ricind_ies = (RICindication_IEs_t*)calloc(1, sizeof(RICindication_IEs_t));
774   RICindication_IEs_t *ricind_ies2 = (RICindication_IEs_t*)calloc(1, sizeof(RICindication_IEs_t));
775   RICindication_IEs_t *ricind_ies3 = (RICindication_IEs_t*)calloc(1, sizeof(RICindication_IEs_t));
776   RICindication_IEs_t *ricind_ies4 = (RICindication_IEs_t*)calloc(1, sizeof(RICindication_IEs_t));
777   RICindication_IEs_t *ricind_ies5 = (RICindication_IEs_t*)calloc(1, sizeof(RICindication_IEs_t));
778   RICindication_IEs_t *ricind_ies6 = (RICindication_IEs_t*)calloc(1, sizeof(RICindication_IEs_t));
779   RICindication_IEs_t *ricind_ies7 = (RICindication_IEs_t*)calloc(1, sizeof(RICindication_IEs_t));
780   RICindication_IEs_t *ricind_ies8 = (RICindication_IEs_t*)calloc(1, sizeof(RICindication_IEs_t));
781
782   RICindication_IEs__value_PR pres3;
783
784   pres3 = RICindication_IEs__value_PR_RICrequestID;
785   ricind_ies->id = ProtocolIE_ID_id_RICrequestID;
786   ricind_ies->criticality = 0;
787   ricind_ies->value.present = pres3;
788   ricind_ies->value.choice.RICrequestID.ricRequestorID = requestorId;
789   ricind_ies->value.choice.RICrequestID.ricInstanceID = instanceId;
790
791   fprintf(stderr, "ind2\n");
792
793   pres3 = RICindication_IEs__value_PR_RANfunctionID;
794   ricind_ies2->id = ProtocolIE_ID_id_RANfunctionID;
795   ricind_ies2->criticality = 0;
796   ricind_ies2->value.present = pres3;
797   ricind_ies2->value.choice.RANfunctionID = ranFunctionId;
798
799   
800   ricind_ies3->id = ProtocolIE_ID_id_RICactionID;
801   ricind_ies3->criticality = 0;
802   pres3 =  RICindication_IEs__value_PR_RICactionID;
803   ricind_ies3->value.present = pres3;
804   ricind_ies3->value.choice.RICactionID = actionId;
805
806
807   pres3 = RICindication_IEs__value_PR_RICindicationSN;
808   ricind_ies4->id = ProtocolIE_ID_id_RICindicationSN;
809   ricind_ies4->criticality = 0;
810   ricind_ies4->value.present = pres3;
811   ricind_ies4->value.choice.RICindicationSN = seqNum;
812
813   //Indication type is REPORT
814   pres3 = RICindication_IEs__value_PR_RICindicationType;
815   ricind_ies5->id = ProtocolIE_ID_id_RICindicationType;
816   ricind_ies5->criticality = 0;
817   ricind_ies5->value.present = pres3;
818   ricind_ies5->value.choice.RICindicationType = 0;
819
820   fprintf(stderr, "ind3\n");
821
822   ricind_ies6->value.choice.RICindicationHeader.buf = (uint8_t*)calloc(1,header_length);
823
824   pres3 = RICindication_IEs__value_PR_RICindicationHeader;
825   ricind_ies6->id = ProtocolIE_ID_id_RICindicationHeader;
826   ricind_ies6->criticality = 0;
827   ricind_ies6->value.present = pres3;
828   ricind_ies6->value.choice.RICindicationHeader.size = header_length;
829   memcpy(ricind_ies6->value.choice.RICindicationHeader.buf, ind_header_buf, header_length);
830   
831   ricind_ies7->value.choice.RICindicationMessage.buf = (uint8_t*)calloc(1,8192);
832
833
834   
835
836   pres3 = RICindication_IEs__value_PR_RICindicationMessage;
837   ricind_ies7->id = ProtocolIE_ID_id_RICindicationMessage;
838   fprintf(stderr, "after encoding message 1\n");
839
840   ricind_ies7->criticality = 0;
841   ricind_ies7->value.present = pres3;
842
843   fprintf(stderr, "after encoding message 2\n");
844
845   fprintf(stderr, "after encoding message 3\n");      
846   ricind_ies7->value.choice.RICindicationMessage.size = message_length;
847
848   fprintf(stderr, "after encoding message 4\n");
849   memcpy(ricind_ies7->value.choice.RICindicationMessage.buf, ind_message_buf, message_length);
850
851   fprintf(stderr, "after encoding message 5\n");
852
853   uint8_t *cpid_buf = (uint8_t *)"cpid";
854   OCTET_STRING_t cpid_str;
855
856   printf("5.1\n");
857
858   int cpid_buf_len = strlen((char*)cpid_buf);
859   pres3 = RICindication_IEs__value_PR_RICcallProcessID;
860   ricind_ies8->id = ProtocolIE_ID_id_RICcallProcessID;
861
862   ricind_ies8->criticality = 0;
863   ricind_ies8->value.present = pres3;
864
865   ricind_ies8->value.choice.RICcallProcessID.buf = (uint8_t*)calloc(1,cpid_buf_len);
866   ricind_ies8->value.choice.RICcallProcessID.size = cpid_buf_len;
867
868   memcpy(ricind_ies8->value.choice.RICcallProcessID.buf, cpid_buf, cpid_buf_len);
869
870   printf("5.2\n");
871
872   RICindication_t *ricindication = (RICindication_t*)calloc(1, sizeof(RICindication_t));
873
874   
875   int ret;
876
877   ret = ASN_SEQUENCE_ADD(&ricindication->protocolIEs.list, ricind_ies);
878   
879   ret = ASN_SEQUENCE_ADD(&ricindication->protocolIEs.list, ricind_ies2);
880
881   printf("5.3\n");
882
883   ret = ASN_SEQUENCE_ADD(&ricindication->protocolIEs.list, ricind_ies3);
884
885   printf("5.35\n");
886   
887   ret = ASN_SEQUENCE_ADD(&ricindication->protocolIEs.list, ricind_ies4);
888
889   printf("5.36\n");
890   
891   ret = ASN_SEQUENCE_ADD(&ricindication->protocolIEs.list, ricind_ies5);
892
893   printf("5.4\n");
894   
895   ret = ASN_SEQUENCE_ADD(&ricindication->protocolIEs.list, ricind_ies6);
896
897   printf("5.5\n");
898
899   ret = ASN_SEQUENCE_ADD(&ricindication->protocolIEs.list, ricind_ies7);  
900   
901   ret = ASN_SEQUENCE_ADD(&ricindication->protocolIEs.list, ricind_ies8);    
902
903
904   InitiatingMessage__value_PR pres4;
905   pres4 = InitiatingMessage__value_PR_RICindication;
906   InitiatingMessage_t *initmsg = (InitiatingMessage_t*)calloc(1, sizeof(InitiatingMessage_t));
907   initmsg->procedureCode = 5;
908   initmsg->criticality = 1;
909   initmsg->value.present = pres4;
910   initmsg->value.choice.RICindication = *ricindication;
911   if (ricindication) free(ricindication);
912
913   E2AP_PDU_PR pres5;
914   pres5 = E2AP_PDU_PR_initiatingMessage;
915   
916   e2ap_pdu->present = pres5;
917   e2ap_pdu->choice.initiatingMessage = initmsg;
918   char error_buf[300] = {0, };
919   size_t errlen = 0;
920
921   asn_check_constraints(&asn_DEF_E2AP_PDU, e2ap_pdu, error_buf, &errlen);
922   printf("error length %d\n", errlen);
923   printf("error buf %s\n", error_buf);
924
925   xer_fprint(stderr, &asn_DEF_E2AP_PDU, e2ap_pdu);  
926
927 }
928
929