Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

#5150 - Infinite connection timeout support in ManagedSelector 

Signed-off-by: Oleg Mozzhechkov <oleg.mozzhechkov@gmail.com>
This commit is contained in:
Oleg Mozzhechkov 2020-08-13 16:34:06 +03:00
parent 1b3cb2ea8d
commit bffd6a2c0f
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
jetty-io/src/main/java/org/eclipse/jetty/io/ManagedSelector.java
View File

@ -888,7 +888,11 @@ public class ManagedSelector extends ContainerLifeCycle implements Dumpable
{ {
this.channel = channel; this.channel = channel;
this.attachment = attachment; this.attachment = attachment;
this.timeout = ManagedSelector.this._selectorManager.getScheduler().schedule(this, ManagedSelector.this._selectorManager.getConnectTimeout(), TimeUnit.MILLISECONDS); final long timeout = ManagedSelector.this._selectorManager.getConnectTimeout();
if (timeout > 0)
this.timeout = ManagedSelector.this._selectorManager.getScheduler().schedule(this, timeout, TimeUnit.MILLISECONDS);
else
this.timeout = null;
} }
@Override @Override
@ -919,6 +923,7 @@ public class ManagedSelector extends ContainerLifeCycle implements Dumpable
{ {
if (failed.compareAndSet(false, true)) if (failed.compareAndSet(false, true))
{ {
if (timeout != null)
timeout.cancel(); timeout.cancel();
IO.close(channel); IO.close(channel);
ManagedSelector.this._selectorManager.connectionFailed(channel, failure, attachment); ManagedSelector.this._selectorManager.connectionFailed(channel, failure, attachment);