diff --git a/ci-scripts/cls_physim1.py b/ci-scripts/cls_physim1.py index b0c9012d7d..70f8729764 100644 --- a/ci-scripts/cls_physim1.py +++ b/ci-scripts/cls_physim1.py @@ -161,7 +161,7 @@ class PhySim: isRunning = False count = 0 # Check whether the containers are in Running state or not under 2 mins - while(count < 2 and isRunning == False): + while(count < 5 and isRunning == False): time.sleep(60) mySSH.command('oc get pods -o wide -l app=physim | tee -a cmake_targets/log/physim_pods_summary.txt', '\$', 30, resync=True) running_count = mySSH.getBefore().count('Running') diff --git a/common/utils/ocp_itti/intertask_interface.cpp b/common/utils/ocp_itti/intertask_interface.cpp index b0d05c6aca..941e4de6ef 100644 --- a/common/utils/ocp_itti/intertask_interface.cpp +++ b/common/utils/ocp_itti/intertask_interface.cpp @@ -49,6 +49,7 @@ extern "C" { int nb_fd_epoll=0; int epoll_fd=-1; int sem_fd=-1; + size_t last_log_size = 0; } task_list_t; int timer_expired(int fd); @@ -131,11 +132,23 @@ extern "C" { int message_id = message->ittiMsgHeader.messageId; size_t s=t->message_queue.size(); - if ( s > t->admin.queue_size ) - LOG_E(TMR,"Queue for %s task contains %ld messages\n", itti_get_task_name(destination_task_id), s ); - - if ( s > 50 ) - LOG_I(ITTI,"Queue for %s task size: %ld (last message %s)\n",itti_get_task_name(destination_task_id), s+1,ITTI_MSG_NAME(message)); + // to reduce the number of logs, we give a message each increase of 25% + if ((s > t->last_log_size * 1.25) && (s > t->admin.queue_size / 10)) { + if (s > t->admin.queue_size) { + LOG_E(TMR, "Queue for %s task contains %ld messages\n", itti_get_task_name(destination_task_id), s); + } else { + LOG_I(ITTI, + "Queue for %s task size: %ld (last message %s)\n", + itti_get_task_name(destination_task_id), + s + 1, + ITTI_MSG_NAME(message)); + } + t->last_log_size = s; + } else if (t->last_log_size && s < t->admin.queue_size / 10) { + // Inform when the queue decreases + LOG_I(ITTI, "Queue for %s task size is back under 10%% of max size\n", itti_get_task_name(destination_task_id)); + t->last_log_size = 0; + } t->message_queue.insert(t->message_queue.begin(), message); eventfd_t sem_counter = 1;