Optimize sending memory management when the audit-proxy config is null

doleyzi · Mar 6, 2024 · 0122b44 · 0122b44
1 parent 36d7e92
commit 0122b44
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderGroup.java b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderGroup.java
@@ -81,6 +81,9 @@ public SenderGroup(SenderManager senderManager) {
      * @return
      */
     public SenderResult send(ByteBuf dataBuf) {
+        if (dataBuf == null) {
+            return new SenderResult("dataBuf is null", 0, false);
+        }
         LinkedBlockingQueue<SenderChannel> channels = channelGroups.get(mIndex);
         SenderChannel channel = null;
         boolean dataBufReleased = false;
@@ -163,7 +166,7 @@ public SenderResult send(ByteBuf dataBuf) {
                 channel.release();
                 channels.offer(channel);
             }
-            if (!dataBufReleased && dataBuf != null) {
+            if (!dataBufReleased) {
                 dataBuf.release();
             }
         }