fizzgate/fizz-gateway-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Comment requestDecorator.getHeaders().remove(HttpHeaders.CONTENT_LENGTH)

Browse Source
This commit is contained in:
hongqiaowei
2021-09-26 13:37:17 +08:00
parent 9231040e19
commit 37c09418f1
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fizz-common/src/main/java/we/util/NettyDataBufferUtils.java
View File

@@ -59,7 +59,7 @@ public abstract class NettyDataBufferUtils extends org.springframework.core.io.b
return dataBufferFactory.wrap(byteBuf); return dataBufferFactory.wrap(byteBuf);
} }
public static boolean release(@Nullable String reqId, @Nullable DataBuffer dataBuffer) { public static boolean release(@Nullable String traceId, @Nullable DataBuffer dataBuffer) {
if (dataBuffer instanceof PooledDataBuffer) { if (dataBuffer instanceof PooledDataBuffer) {
PooledDataBuffer pooledDataBuffer = (PooledDataBuffer) dataBuffer; PooledDataBuffer pooledDataBuffer = (PooledDataBuffer) dataBuffer;
if (pooledDataBuffer.isAllocated()) { if (pooledDataBuffer.isAllocated()) {
@@ -69,7 +69,7 @@ public abstract class NettyDataBufferUtils extends org.springframework.core.io.b
int refCnt = nativeBuffer.refCnt(); int refCnt = nativeBuffer.refCnt();
if (refCnt < 1) { if (refCnt < 1) {
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug(nativeBuffer + " ref cnt is " + refCnt, LogService.BIZ_ID, reqId); log.debug(nativeBuffer + " ref cnt is " + refCnt, LogService.BIZ_ID, traceId);
} }
return false; return false;
} }

2
fizz-core/src/main/java/we/plugin/requestbody/RequestBodyPlugin.java
View File

@@ -61,7 +61,7 @@ public class RequestBodyPlugin implements FizzPluginFilter {
} finally { } finally {
NettyDataBufferUtils.release(body); NettyDataBufferUtils.release(body);
} }
requestDecorator.getHeaders().remove(HttpHeaders.CONTENT_LENGTH); // requestDecorator.getHeaders().remove(HttpHeaders.CONTENT_LENGTH);
} }
ServerWebExchange mutatedExchange = exchange.mutate().request(requestDecorator).build(); ServerWebExchange mutatedExchange = exchange.mutate().request(requestDecorator).build();
ServerWebExchange newExchange = mutatedExchange; ServerWebExchange newExchange = mutatedExchange;