Code Review
/
ric-app
/
bouncer.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Updating Bouncer code for Multiple E2Sim
[ric-app/bouncer.git]
/
Bouncer
/
src
/
xapp.cc
diff --git
a/Bouncer/src/xapp.cc
b/Bouncer/src/xapp.cc
index
64beee4
..
94d190e
100644
(file)
--- a/
Bouncer/src/xapp.cc
+++ b/
Bouncer/src/xapp.cc
@@
-126,11
+126,13
@@
void Xapp::startup_subscribe_requests(void ){
if(sz <= 0)
mdclog_write(MDCLOG_INFO,"Subscriptions cannot be sent as GNBList in RNIB is NULL");
if(sz <= 0)
mdclog_write(MDCLOG_INFO,"Subscriptions cannot be sent as GNBList in RNIB is NULL");
- for(int i = 0; i<sz; i++){
-
+ for(int i = 0; i<sz; i++)
+ {
+ sleep(15);
//give the message to subscription handler, along with the transmitter.
strcpy((char*)meid,gnblist[i].c_str());
//give the message to subscription handler, along with the transmitter.
strcpy((char*)meid,gnblist[i].c_str());
+ mdclog_write(MDCLOG_INFO,"GNBList size : %d", sz);
subscription_helper din;
subscription_helper dout;
subscription_helper din;
subscription_helper dout;
@@
-158,25
+160,28
@@
void Xapp::startup_subscribe_requests(void ){
res = sub_req.encode_e2ap_subscription(&buf[0], &buf_size, din);
res = sub_req.encode_e2ap_subscription(&buf[0], &buf_size, din);
- xapp_rmr_header rmr_header;
+ //mdclog_write(MDCLOG_INFO,"GNBList = %s and ith val = %d", gnblist[i], i);
+
+ mdclog_write(MDCLOG_INFO,"Sending subscription in file= %s, line=%d for MEID %s",__FILE__,__LINE__, meid);
+
+ xapp_rmr_header rmr_header;
rmr_header.message_type = RIC_SUB_REQ;
rmr_header.payload_length = buf_size; //data_size
rmr_header.message_type = RIC_SUB_REQ;
rmr_header.payload_length = buf_size; //data_size
- strcpy((char*)rmr_header.meid,gnblist[i].c_str());
- mdclog_write(MDCLOG_INFO,"Sending subscription in file= %s, line=%d for MEID %s",__FILE__,__LINE__, meid);
-
- auto transmitter = std::bind(&XappRmr::xapp_rmr_send,rmr_ref, &rmr_header, (void*)buf );//(void*)data);
+ strcpy((char*)rmr_header.meid,gnblist[i].c_str());
+ auto transmitter = std::bind(&XappRmr::xapp_rmr_send,rmr_ref, &rmr_header, (void*)buf); //(void*)data);
+
int result = subhandler_ref->manage_subscription_request(gnblist[i], transmitter);
int result = subhandler_ref->manage_subscription_request(gnblist[i], transmitter);
- if(result==SUBSCR_SUCCESS){
+ if(result==SUBSCR_SUCCESS){
+
mdclog_write(MDCLOG_INFO,"Subscription SUCCESSFUL in file= %s, line=%d for MEID %s",__FILE__,__LINE__, meid);
}
mdclog_write(MDCLOG_INFO,"Subscription SUCCESSFUL in file= %s, line=%d for MEID %s",__FILE__,__LINE__, meid);
}
-
else {
- mdclog_write(MDCLOG_ERR,"Subscription FAILED in file= %s, line=%d for MEID %s",__FILE__,__LINE__, meid);
+ else {
+
mdclog_write(MDCLOG_ERR,"Subscription FAILED in file= %s, line=%d for MEID %s",__FILE__,__LINE__, meid);
}
}
- }
-
+ }
}
void Xapp::startup_get_policies(void){
}
void Xapp::startup_get_policies(void){
@@
-247,8
+252,3
@@
void Xapp::set_rnib_gnblist(void) {
}
}
-
-
-
-
-