Do not add IdleTimeoutHandler while processing pipelined requests (#3124)

violetagg · web-flow · commit 049e332518b5 · 2024-03-29T15:59:01.000+02:00
diff --git a/reactor-netty-http/src/main/java/reactor/netty/http/server/HttpTrafficHandler.java b/reactor-netty-http/src/main/java/reactor/netty/http/server/HttpTrafficHandler.java
@@ -362,6 +362,8 @@ public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)
 				   .execute(this);
 			}
 			else {
+				IdleTimeoutHandler.addIdleTimeoutHandler(ctx.pipeline(), idleTimeout);
+
 				ctx.read();
 			}
 			return;
@@ -461,8 +463,6 @@ public void operationComplete(ChannelFuture future) {
 			}
 		}
 
-		IdleTimeoutHandler.addIdleTimeoutHandler(future.channel().pipeline(), idleTimeout);
-
 		HttpServerOperations.cleanHandlerTerminate(future.channel());
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -362,6 +362,8 @@ public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)`
`362`	`362`	`.execute(this);`
`363`	`363`	`}`
`364`	`364`	`else {`
	`365`	`+ IdleTimeoutHandler.addIdleTimeoutHandler(ctx.pipeline(), idleTimeout);`
	`366`	`+`
`365`	`367`	`ctx.read();`
`366`	`368`	`}`
`367`	`369`	`return;`
`@@ -461,8 +463,6 @@ public void operationComplete(ChannelFuture future) {`
`461`	`463`	`}`
`462`	`464`	`}`
`463`	`465`
`464`		`- IdleTimeoutHandler.addIdleTimeoutHandler(future.channel().pipeline(), idleTimeout);`
`465`		`-`
`466`	`466`	`HttpServerOperations.cleanHandlerTerminate(future.channel());`
`467`	`467`	`}`
`468`	`468`