You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2018/08/15 15:10:07 UTC
qpid-jms git commit: NO-JIRA: update test to avoid race that could
result in illegal ref count state
Repository: qpid-jms
Updated Branches:
refs/heads/master c5c90534c -> 58162197f
NO-JIRA: update test to avoid race that could result in illegal ref count state
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/58162197
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/58162197
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/58162197
Branch: refs/heads/master
Commit: 58162197f7f735026a1de79ffd9049ff4ba79219
Parents: c5c9053
Author: Robbie Gemmell <ro...@apache.org>
Authored: Wed Aug 15 16:08:14 2018 +0100
Committer: Robbie Gemmell <ro...@apache.org>
Committed: Wed Aug 15 16:09:08 2018 +0100
----------------------------------------------------------------------
.../apache/qpid/jms/transports/netty/NettyWsTransportTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/58162197/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/netty/NettyWsTransportTest.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/netty/NettyWsTransportTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/netty/NettyWsTransportTest.java
index 390fd73..ead740c 100644
--- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/netty/NettyWsTransportTest.java
+++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/netty/NettyWsTransportTest.java
@@ -308,7 +308,7 @@ public class NettyWsTransportTest extends NettyTcpTransportTest {
@Override
public boolean isSatisfied() throws Exception {
try {
- transport.writeAndFlush(sendBuffer);
+ transport.writeAndFlush(sendBuffer.copy());
} catch (IOException e) {
LOG.info("Transport send caught error:", e);
return true;
@@ -316,7 +316,7 @@ public class NettyWsTransportTest extends NettyTcpTransportTest {
return false;
}
- }, 10000, 50));
+ }, 10000, 10));
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org