diff options
| author | Robert Gemmell <robbie@apache.org> | 2014-01-24 13:42:30 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2014-01-24 13:42:30 +0000 |
| commit | 6516d329810ba477ea445c639b9d778a733d14ab (patch) | |
| tree | 2004968e42b748ffe3bfc4dba5bf6bbe92797a61 /java/common/src | |
| parent | 284cb000f17c236e7fa98897762a52cda7c6f303 (diff) | |
| download | qpid-python-6516d329810ba477ea445c639b9d778a733d14ab.tar.gz | |
QPID-5512: suppress exception sometimes seen due to race while closing the socket on Windows, prevent erroneous ConnectionTest failures.
Patch supplied by Andrew MacBean <andymacbean@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1561000 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common/src')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java b/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java index 0ab195ced8..fa2711ddde 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java +++ b/java/common/src/main/java/org/apache/qpid/transport/network/io/IoReceiver.java @@ -243,7 +243,12 @@ final class IoReceiver implements Runnable, Closeable t instanceof SocketException && "Socket is closed".equalsIgnoreCase(t.getMessage()); - return !brokenClose && !sslSocketClosed; + boolean recvFailed = closed.get() && + shutdownBroken && + t instanceof SocketException && + "Socket operation on nonsocket: recv failed".equalsIgnoreCase(t.getMessage()); + + return !brokenClose && !sslSocketClosed && !recvFailed; } public Ticker getTicker() |