maki/openairinterface5g
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

revert last change

Browse Source
This commit is contained in:
Laurent THOMAS
2023-09-25 15:21:21 +02:00
parent 91497ece94
commit d19302fb40
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/utils/ocp_itti/intertask_interface.cpp
+9 -9
View File
@@ -132,17 +132,17 @@ extern "C" {
int message_id = message->ittiMsgHeader.messageId;
size_t s=t->message_queue.size();
if (s > t->last_log_size * 1.1) {
// to reduce the number of logs, we give a message each increase of 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);
if (s > t->last_log_size * 1.1 && s > t->admin.queue_size) {
LOG_E(TMR, "Queue for %s task contains %ld messages\n", itti_get_task_name(destination_task_id), s);
t->last_log_size = s;
if (s > t->admin.queue_size / 10)
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));
} else if (s > t->last_log_size * 1.1 && s > t->admin.queue_size / 10) {
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;
}