Commit b34ca188 authored by alexandr's avatar alexandr

UL traffic issue fixed-Support more than one apps

parent ac8f5ba7
...@@ -754,4 +754,5 @@ void rrc_lite_ue_update_ho_status(module_id_t Mod_idP){ ...@@ -754,4 +754,5 @@ void rrc_lite_ue_update_ho_status(module_id_t Mod_idP){
//UE_rrc_inst[Mod_idP].HandoverInfoUe.measFlag = 0; // Stop the measurements //UE_rrc_inst[Mod_idP].HandoverInfoUe.measFlag = 0; // Stop the measurements
UE_mac_inst[Mod_idP].RA_active = 0; UE_mac_inst[Mod_idP].RA_active = 0;
UE_rrc_inst[Mod_idP].Info[0].State = RRC_RECONFIGURED; UE_rrc_inst[Mod_idP].Info[0].State = RRC_RECONFIGURED;
LOG_D(RRC,"UE is updated: Mod_id: %d/State: %d\n",Mod_idP,UE_rrc_inst[Mod_idP].Info[0].State);
} }
0 0 1800 4800 1000 0 0 1800 4800 1000
1 0 4700 4840 1000 1 0 4700 4840 1000
2 0 1800 4800 1000 2 0 1800 4800 1000
3 0 4700 4840 1000
...@@ -273,8 +273,7 @@ unsigned char *packet_gen( ...@@ -273,8 +273,7 @@ unsigned char *packet_gen(
//LOG_I(OTG,"Src: %d - Dest: %d - before exit\n",src_instance,dst_instance); //LOG_I(OTG,"Src: %d - Dest: %d - before exit\n",src_instance,dst_instance);
// check if the app is configured // check if the app is configured
if (app >= g_otg->application_idx[src_instance][dst_instance]) { if (app >= g_otg->application_idx[src_instance][dst_instance]) {
//LOG_I(OTG,"Src: %d - Dest: %d - no packet to generate - no application\n",src_instance,dst_instance); return NULL;
return NULL;
} }
LOG_T(OTG,"[src %d] [dst %d ][APP %d] current time %d\n",src_instance, dst_instance, app, ctime); LOG_T(OTG,"[src %d] [dst %d ][APP %d] current time %d\n",src_instance, dst_instance, app, ctime);
......
...@@ -100,6 +100,7 @@ ...@@ -100,6 +100,7 @@
<SIZE_MIN_byte>850</SIZE_MIN_byte> <SIZE_MIN_byte>850</SIZE_MIN_byte>
<SIZE_MAX_byte>1408</SIZE_MAX_byte> <SIZE_MAX_byte>1408</SIZE_MAX_byte>
</CUSTOMIZED_TRAFFIC> </CUSTOMIZED_TRAFFIC>
<!--</APPLICATION_CONFIG> --> <!--</APPLICATION_CONFIG> -->
<!-- DL --> <!-- DL -->
......
...@@ -1468,16 +1468,17 @@ void update_otg_eNB(module_id_t enb_module_idP, unsigned int ctime) ...@@ -1468,16 +1468,17 @@ void update_otg_eNB(module_id_t enb_module_idP, unsigned int ctime)
void update_otg_UE(module_id_t ue_mod_idP, unsigned int ctime) void update_otg_UE(module_id_t ue_mod_idP, unsigned int ctime)
{ {
#if defined(USER_MODE) && defined(OAI_EMU) #if defined(USER_MODE) && defined(OAI_EMU)
int app_id;
if (oai_emulation.info.otg_enabled ==1 ) { if (oai_emulation.info.otg_enabled ==1 ) {
module_id_t dst_id, src_id; //dst_id = eNB_index module_id_t dst_id, src_id; //dst_id = eNB_index
module_id_t module_id = ue_mod_idP+NB_eNB_INST; module_id_t module_id = ue_mod_idP+NB_eNB_INST;
src_id = module_id; src_id = module_id;
for (dst_id=0; dst_id<NB_SIG_CNX_UE; dst_id++) { for (dst_id=0; dst_id<NB_SIG_CNX_UE; dst_id++) {
// only consider the first attached eNB // only consider the first attached eNB
if (mac_UE_get_rrc_status(ue_mod_idP, dst_id ) > 2 /*RRC_CONNECTED*/) { if (mac_UE_get_rrc_status(ue_mod_idP, dst_id ) > 2 /*RRC_CONNECTED*/) {
for (app_id=0; app_id<MAX_NUM_APPLICATION; app_id++) {
Packet_otg_elt_t *otg_pkt = malloc (sizeof(Packet_otg_elt_t)); Packet_otg_elt_t *otg_pkt = malloc (sizeof(Packet_otg_elt_t));
if (otg_pkt!=NULL) if (otg_pkt!=NULL)
...@@ -1487,7 +1488,7 @@ void update_otg_UE(module_id_t ue_mod_idP, unsigned int ctime) ...@@ -1487,7 +1488,7 @@ void update_otg_UE(module_id_t ue_mod_idP, unsigned int ctime)
exit(-1); exit(-1);
}// Manage to add this packet to the tail of your list }// Manage to add this packet to the tail of your list
(otg_pkt->otg_pkt).sdu_buffer = (uint8_t*) packet_gen(src_id, dst_id, 0, ctime, &((otg_pkt->otg_pkt).sdu_buffer_size)); (otg_pkt->otg_pkt).sdu_buffer = (uint8_t*) packet_gen(src_id, dst_id, app_id, ctime, &((otg_pkt->otg_pkt).sdu_buffer_size));
if ((otg_pkt->otg_pkt).sdu_buffer != NULL) { if ((otg_pkt->otg_pkt).sdu_buffer != NULL) {
(otg_pkt->otg_pkt).rb_id = DTCH-2; (otg_pkt->otg_pkt).rb_id = DTCH-2;
...@@ -1503,6 +1504,7 @@ void update_otg_UE(module_id_t ue_mod_idP, unsigned int ctime) ...@@ -1503,6 +1504,7 @@ void update_otg_UE(module_id_t ue_mod_idP, unsigned int ctime)
free(otg_pkt); free(otg_pkt);
otg_pkt=NULL; otg_pkt=NULL;
} }
}
} }
} }
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment