diff options
| author | Greg Wilkins | 2014-07-03 05:10:48 +0000 |
|---|---|---|
| committer | Greg Wilkins | 2014-07-03 05:10:48 +0000 |
| commit | 0f70f28839b62d16fd3ad8612e6675180c97bbba (patch) | |
| tree | bfd59eb63dd33d8201b6a2c0e6ad304fc64fc8ec | |
| parent | 7fbf521d4e3294e204080b11b8ae1f1606718eef (diff) | |
| download | org.eclipse.jetty.project-0f70f28839b62d16fd3ad8612e6675180c97bbba.tar.gz org.eclipse.jetty.project-0f70f28839b62d16fd3ad8612e6675180c97bbba.tar.xz org.eclipse.jetty.project-0f70f28839b62d16fd3ad8612e6675180c97bbba.zip | |
avoid race test failures
| -rw-r--r-- | jetty-server/src/main/java/org/eclipse/jetty/server/LocalConnector.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/jetty-server/src/main/java/org/eclipse/jetty/server/LocalConnector.java b/jetty-server/src/main/java/org/eclipse/jetty/server/LocalConnector.java index 1f05003a3d..4047f871d3 100644 --- a/jetty-server/src/main/java/org/eclipse/jetty/server/LocalConnector.java +++ b/jetty-server/src/main/java/org/eclipse/jetty/server/LocalConnector.java @@ -138,7 +138,8 @@ public class LocalConnector extends AbstractConnector LocalEndPoint endp = executeRequest(requestsBuffer); endp.waitUntilClosedOrIdleFor(idleFor,units); ByteBuffer responses = endp.takeOutput(); - endp.getConnection().close(); + if (endp.isOutputShutdown()) + endp.close(); if (LOG.isDebugEnabled()) LOG.debug("responses {}", BufferUtil.toUTF8String(responses)); return responses; |