From 0122b442333da5fad1582b649bdfcb20c5d54176 Mon Sep 17 00:00:00 2001 From: doleyzi Date: Wed, 6 Mar 2024 20:21:15 +0800 Subject: [PATCH] Optimize sending memory management when the audit-proxy config is null --- .../main/java/org/apache/inlong/audit/send/SenderGroup.java | 5 ++++- 1 file changed, 4 insertions(+), 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 index 44cfca4dba5..40e287bd775 100644 --- 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 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(); } }