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

Issue #3989 - Selector failure notification 

Signed-off-by: Joakim Erdfelt <joakim.erdfelt@gmail.com>
This commit is contained in:
Joakim Erdfelt 2019-09-04 11:16:24 -05:00
parent f6efff70d7
commit 9305914d6a
2 changed files with 22 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -107,7 +107,16 @@ public class ManagedSelector extends ContainerLifeCycle implements Dumpable
protected void doStart() throws Exception
{
super.doStart();
startSelector();
// Set started only if we really are started
Start start = new Start();
submit(start);
start._started.await();
}
protected void startSelector() throws IOException, InterruptedException
{
_selector = _selectorManager.newSelector();
// The producer used by the strategies will never
@ -116,16 +125,12 @@ public class ManagedSelector extends ContainerLifeCycle implements Dumpable
// The normal strategy obtains the produced task, schedules
// a new thread to produce more, runs the task and then exits.
_selectorManager.execute(_strategy::produce);
// Set started only if we really are started
Start start = new Start();
submit(start);
start._started.await();
}
protected void onSelectFailed(Throwable cause) throws IOException
protected void onSelectFailed(Throwable cause) throws Exception
{
LOG.info("Restarting selector: " + toString(), cause);
startSelector();
}
private void notifySelectFailed(Throwable cause)
@ -134,9 +139,9 @@ public class ManagedSelector extends ContainerLifeCycle implements Dumpable
{
onSelectFailed(cause);
}
catch (IOException e)
catch (Throwable x)
{
LOG.info("Failure while calling onSelectFailed()", e);
LOG.info("Failure while calling onSelectFailed()", x);
}
}
@ -515,7 +520,7 @@ public class ManagedSelector extends ContainerLifeCycle implements Dumpable
LOG.warn(x.toString());
LOG.debug(x);
}
IO.close(_selector);
IO.close(selector);
}
return false;
}
@ -552,13 +557,13 @@ public class ManagedSelector extends ContainerLifeCycle implements Dumpable
{
LOG.debug("Ignoring cancelled key for channel {}", key.channel());
if (attachment instanceof EndPoint)
IO.close((Closeable)(EndPoint)attachment);
IO.close((EndPoint)attachment);
}
catch (Throwable x)
{
LOG.warn("Could not process key for channel " + key.channel(), x);
if (attachment instanceof EndPoint)
IO.close((Closeable)(EndPoint)attachment);
IO.close((EndPoint)attachment);
}
}
else
@ -567,7 +572,7 @@ public class ManagedSelector extends ContainerLifeCycle implements Dumpable
LOG.debug("Selector loop ignoring invalid key for channel {}", key.channel());
Object attachment = key.attachment();
if (attachment instanceof EndPoint)
IO.close((Closeable)(EndPoint)attachment);
IO.close((EndPoint)attachment);
}
}
return null;
@ -905,7 +910,7 @@ public class ManagedSelector extends ContainerLifeCycle implements Dumpable
{
Object attachment = key.attachment();
if (attachment instanceof EndPoint)
IO.close((Closeable)(EndPoint)attachment);
IO.close((EndPoint)attachment);
}
}

9
tests/test-integration/src/test/java/org/eclipse/jetty/test/FailedSelectorTest.java
View File

@ -231,18 +231,17 @@ public class FailedSelectorTest
}
@Override
protected void onSelectFailed(Throwable cause)
protected void onSelectFailed(Throwable cause) throws Exception
{
try
{
LOG.debug("onSelectFailed()", cause);
// this.startSelector();
this.startSelector();
}
catch (Exception ex)
finally
{
LOG.warn(ex);
failedLatch.countDown();
}
failedLatch.countDown();
}
}