[skywalking] branch queue created (now 2fa2490749)

[wu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a change to branch queue
in repository https://gitbox.apache.org/repos/asf/skywalking.git


      at 2fa2490749 Add logs.

This branch includes the following new commits:

     new 2fa2490749 Add logs.

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[skywalking] 01/01: Add logs.

[wu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch queue
in repository https://gitbox.apache.org/repos/asf/skywalking.git

commit 2fa24907490616db0b2cab62e2f278cc0bbbebd8
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Thu Apr 21 17:19:24 2022 +0800

    Add logs.
---
 .../library/datacarrier/consumer/MultipleChannelsConsumer.java    | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/oap-server/server-library/library-datacarrier-queue/src/main/java/org/apache/skywalking/oap/server/library/datacarrier/consumer/MultipleChannelsConsumer.java b/oap-server/server-library/library-datacarrier-queue/src/main/java/org/apache/skywalking/oap/server/library/datacarrier/consumer/MultipleChannelsConsumer.java
index 282f6db0ac..f99a92906c 100644
--- a/oap-server/server-library/library-datacarrier-queue/src/main/java/org/apache/skywalking/oap/server/library/datacarrier/consumer/MultipleChannelsConsumer.java
+++ b/oap-server/server-library/library-datacarrier-queue/src/main/java/org/apache/skywalking/oap/server/library/datacarrier/consumer/MultipleChannelsConsumer.java
@@ -20,6 +20,7 @@ package org.apache.skywalking.oap.server.library.datacarrier.consumer;
 
 import java.util.ArrayList;
 import java.util.List;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.skywalking.oap.server.library.datacarrier.buffer.Channels;
 import org.apache.skywalking.oap.server.library.datacarrier.buffer.QueueBuffer;
 
@@ -48,8 +49,8 @@ public class MultipleChannelsConsumer extends Thread {
         while (running) {
             boolean hasData = false;
             for (Group target : consumeTargets) {
-                boolean consume = target.consume(consumeList);
-                hasData = hasData || consume;
+                boolean consumed = target.consume(consumeList);
+                hasData = hasData || consumed;
             }
 
             if (!hasData) {
@@ -88,6 +89,7 @@ public class MultipleChannelsConsumer extends Thread {
         running = false;
     }
 
+    @Slf4j
     private static class Group {
         private Channels channels;
         private IConsumer consumer;
@@ -133,6 +135,7 @@ public class MultipleChannelsConsumer extends Thread {
          */
         private boolean consume(List consumeList) {
             try {
+                log.debug("consumer {}, priority {}", consumer.getClass().getName(), priority);
                 if (priority < 50) {
                     priority += 10;
                     return false;
@@ -169,6 +172,7 @@ public class MultipleChannelsConsumer extends Thread {
                 consumer.nothingToConsume();
                 return false;
             } finally {
+                log.debug("consumer {}, new priority {}", consumer.getClass().getName(), priority);
                 consumer.onExit();
             }
         }