Merge remote-tracking branch 'origin/bugfixes-2018-w12' into develop_integration_2018_w12
This commit is contained in:
@@ -325,8 +325,11 @@ int itti_send_msg_to_task(task_id_t destination_task_id, instance_t instance, Me
|
|||||||
/* Increment the global message number */
|
/* Increment the global message number */
|
||||||
message_number = itti_increment_message_number ();
|
message_number = itti_increment_message_number ();
|
||||||
|
|
||||||
|
#if 0
|
||||||
|
/* itti dump is disabled */
|
||||||
itti_dump_queue_message (origin_task_id, message_number, message, itti_desc.messages_info[message_id].name,
|
itti_dump_queue_message (origin_task_id, message_number, message, itti_desc.messages_info[message_id].name,
|
||||||
sizeof(MessageHeader) + message->ittiMsgHeader.ittiMsgSize);
|
sizeof(MessageHeader) + message->ittiMsgHeader.ittiMsgSize);
|
||||||
|
#endif
|
||||||
|
|
||||||
if (destination_task_id != TASK_UNKNOWN) {
|
if (destination_task_id != TASK_UNKNOWN) {
|
||||||
|
|
||||||
@@ -421,8 +424,11 @@ int itti_try_send_msg_to_task(task_id_t destination_task_id, instance_t instance
|
|||||||
/* Increment the global message number */
|
/* Increment the global message number */
|
||||||
message_number = itti_increment_message_number ();
|
message_number = itti_increment_message_number ();
|
||||||
|
|
||||||
|
#if 0
|
||||||
|
/* itti dump is disabled */
|
||||||
itti_dump_queue_message (origin_task_id, message_number, message, itti_desc.messages_info[message_id].name,
|
itti_dump_queue_message (origin_task_id, message_number, message, itti_desc.messages_info[message_id].name,
|
||||||
sizeof(MessageHeader) + message->ittiMsgHeader.ittiMsgSize);
|
sizeof(MessageHeader) + message->ittiMsgHeader.ittiMsgSize);
|
||||||
|
#endif
|
||||||
|
|
||||||
if (destination_task_id != TASK_UNKNOWN) {
|
if (destination_task_id != TASK_UNKNOWN) {
|
||||||
|
|
||||||
@@ -716,8 +722,11 @@ void itti_mark_task_ready(task_id_t task_id)
|
|||||||
|
|
||||||
AssertFatal (thread_id < itti_desc.thread_max, "Thread id (%d) is out of range (%d)!\n", thread_id, itti_desc.thread_max);
|
AssertFatal (thread_id < itti_desc.thread_max, "Thread id (%d) is out of range (%d)!\n", thread_id, itti_desc.thread_max);
|
||||||
|
|
||||||
|
#if 0
|
||||||
|
/* itti dump is disabled */
|
||||||
/* Register the thread in itti dump */
|
/* Register the thread in itti dump */
|
||||||
itti_dump_thread_use_ring_buffer();
|
itti_dump_thread_use_ring_buffer();
|
||||||
|
#endif
|
||||||
|
|
||||||
/* Mark the thread as using LFDS queue */
|
/* Mark the thread as using LFDS queue */
|
||||||
lfds611_queue_use(itti_desc.tasks[task_id].message_queue);
|
lfds611_queue_use(itti_desc.tasks[task_id].message_queue);
|
||||||
@@ -848,7 +857,10 @@ int itti_init(task_id_t task_max, thread_id_t thread_max, MessagesIds messages_i
|
|||||||
itti_desc.wait_tasks = 0;
|
itti_desc.wait_tasks = 0;
|
||||||
itti_desc.created_tasks = 0;
|
itti_desc.created_tasks = 0;
|
||||||
itti_desc.ready_tasks = 0;
|
itti_desc.ready_tasks = 0;
|
||||||
|
#if 0
|
||||||
|
/* itti dump is disabled */
|
||||||
itti_dump_init (messages_definition_xml, dump_file_name);
|
itti_dump_init (messages_definition_xml, dump_file_name);
|
||||||
|
#endif
|
||||||
|
|
||||||
CHECK_INIT_RETURN(timer_init ());
|
CHECK_INIT_RETURN(timer_init ());
|
||||||
|
|
||||||
@@ -915,7 +927,10 @@ void itti_wait_tasks_end(void)
|
|||||||
exit (0);
|
exit (0);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#if 0
|
||||||
|
/* itti dump is disabled */
|
||||||
itti_dump_exit();
|
itti_dump_exit();
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
void itti_send_terminate_message(task_id_t task_id)
|
void itti_send_terminate_message(task_id_t task_id)
|
||||||
|
|||||||
@@ -423,12 +423,15 @@ check_ul_failure(module_id_t module_idP, int CC_id, int UE_id,
|
|||||||
}
|
}
|
||||||
} // ul_failure_timer>0
|
} // ul_failure_timer>0
|
||||||
|
|
||||||
|
#if 0
|
||||||
|
/* U-plane inactivity timer is disabled. Uncomment to re-enable. */
|
||||||
UE_list->UE_sched_ctrl[UE_id].uplane_inactivity_timer++;
|
UE_list->UE_sched_ctrl[UE_id].uplane_inactivity_timer++;
|
||||||
if(UE_list->UE_sched_ctrl[UE_id].uplane_inactivity_timer > (U_PLANE_INACTIVITY_VALUE*subframe_num(&RC.eNB[module_idP][CC_id]->frame_parms))){
|
if(UE_list->UE_sched_ctrl[UE_id].uplane_inactivity_timer > (U_PLANE_INACTIVITY_VALUE*subframe_num(&RC.eNB[module_idP][CC_id]->frame_parms))){
|
||||||
LOG_D(MAC,"UE %d rnti %x: U-Plane Failure after repeated PDCCH orders: Triggering RRC \n",UE_id,rnti);
|
LOG_D(MAC,"UE %d rnti %x: U-Plane Failure after repeated PDCCH orders: Triggering RRC \n",UE_id,rnti);
|
||||||
mac_eNB_rrc_uplane_failure(module_idP,CC_id,frameP,subframeP,rnti);
|
mac_eNB_rrc_uplane_failure(module_idP,CC_id,frameP,subframeP,rnti);
|
||||||
UE_list->UE_sched_ctrl[UE_id].uplane_inactivity_timer = 0;
|
UE_list->UE_sched_ctrl[UE_id].uplane_inactivity_timer = 0;
|
||||||
}// time > 60s
|
}// time > 60s
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
void
|
void
|
||||||
|
|||||||
@@ -290,6 +290,7 @@ NwGtpv1uRcT gtpv1u_eNB_process_stack_req(
|
|||||||
hashtable_rc_t hash_rc = HASH_TABLE_KEY_NOT_EXISTS;
|
hashtable_rc_t hash_rc = HASH_TABLE_KEY_NOT_EXISTS;
|
||||||
gtpv1u_teid_data_t *gtpv1u_teid_data_p = NULL;
|
gtpv1u_teid_data_t *gtpv1u_teid_data_p = NULL;
|
||||||
protocol_ctxt_t ctxt;
|
protocol_ctxt_t ctxt;
|
||||||
|
NwGtpv1uRcT rc;
|
||||||
|
|
||||||
switch(pUlpApi->apiType) {
|
switch(pUlpApi->apiType) {
|
||||||
/* Here there are two type of messages handled:
|
/* Here there are two type of messages handled:
|
||||||
@@ -314,6 +315,12 @@ NwGtpv1uRcT gtpv1u_eNB_process_stack_req(
|
|||||||
gtpv1u_eNB_write_dump_socket(buffer,buffer_len);
|
gtpv1u_eNB_write_dump_socket(buffer,buffer_len);
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
rc = nwGtpv1uMsgDelete(RC.gtpv1u_data_g->gtpv1u_stack,
|
||||||
|
pUlpApi->apiInfo.recvMsgInfo.hMsg);
|
||||||
|
if (rc != NW_GTPV1U_OK) {
|
||||||
|
LOG_E(GTPU, "nwGtpv1uMsgDelete failed: 0x%x\n", rc);
|
||||||
|
}
|
||||||
|
|
||||||
//-----------------------
|
//-----------------------
|
||||||
// GTPV1U->PDCP mapping
|
// GTPV1U->PDCP mapping
|
||||||
//-----------------------
|
//-----------------------
|
||||||
|
|||||||
@@ -904,7 +904,6 @@ int main( int argc, char **argv )
|
|||||||
int ret;
|
int ret;
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
start_background_system();
|
|
||||||
if ( load_configmodule(argc,argv) == NULL) {
|
if ( load_configmodule(argc,argv) == NULL) {
|
||||||
exit_fun("[SOFTMODEM] Error, configuration module init failed\n");
|
exit_fun("[SOFTMODEM] Error, configuration module init failed\n");
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user