This is an automated email from the ASF dual-hosted git repository.
xiaoyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shenyu.git
The following commit(s) were added to refs/heads/master by this push:
new 9529642022 [fix] fix data buffer leak (#5988)
9529642022 is described below
commit 9529642022c0ebf9f829631811f6798b8f5f3b9f
Author: aias00 <[email protected]>
AuthorDate: Mon May 26 14:59:53 2025 +0800
[fix] fix data buffer leak (#5988)
* [fix] fix data buffer leak
* [fix] fix data buffer leak
---------
Co-authored-by: zhengpeng <[email protected]>
---
.../java/org/apache/shenyu/plugin/base/support/ResponseDecorator.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/shenyu-plugin/shenyu-plugin-base/src/main/java/org/apache/shenyu/plugin/base/support/ResponseDecorator.java
b/shenyu-plugin/shenyu-plugin-base/src/main/java/org/apache/shenyu/plugin/base/support/ResponseDecorator.java
index 5e1fc279c4..ae697c67f0 100644
---
a/shenyu-plugin/shenyu-plugin-base/src/main/java/org/apache/shenyu/plugin/base/support/ResponseDecorator.java
+++
b/shenyu-plugin/shenyu-plugin-base/src/main/java/org/apache/shenyu/plugin/base/support/ResponseDecorator.java
@@ -52,9 +52,10 @@ public class ResponseDecorator extends
ServerHttpResponseDecorator {
return dataBufferMono.flatMap(dataBuffer -> {
byte[] bytes = new byte[dataBuffer.readableByteCount()];
dataBuffer.read(bytes);
+ DataBufferUtils.release(dataBuffer);
String bodyString = new String(bytes, StandardCharsets.UTF_8);
final String convertStr = convert.apply(bodyString);
- return WebFluxResultUtils.result(this.exchange, convertStr);
+ return WebFluxResultUtils.result(this.exchange,
convertStr).doFinally(signalType -> DataBufferUtils.release(dataBuffer));
});
}
}