[hornetq-commits] JBoss hornetq SVN: r8023 - trunk/src/main/org/hornetq/core/remoting/impl.
do-not-reply at jboss.org
do-not-reply at jboss.org
Thu Oct 1 05:12:09 EDT 2009
Author: timfox
Date: 2009-10-01 05:12:08 -0400 (Thu, 01 Oct 2009)
New Revision: 8023
Modified:
trunk/src/main/org/hornetq/core/remoting/impl/ChannelImpl.java
Log:
fixed hanging test, slight improvement to fix
Modified: trunk/src/main/org/hornetq/core/remoting/impl/ChannelImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/remoting/impl/ChannelImpl.java 2009-10-01 09:09:08 UTC (rev 8022)
+++ trunk/src/main/org/hornetq/core/remoting/impl/ChannelImpl.java 2009-10-01 09:12:08 UTC (rev 8023)
@@ -346,8 +346,10 @@
if (sendSemaphore != null)
{
- //Any threads blocking on the send semaphore should be allowed to return
- sendSemaphore.release(Integer.MAX_VALUE - sendSemaphore.availablePermits());
+ //Any threads blocking on the send semaphore should be allowed to return - we do this by just giving it
+ //a lot of permits - note we don't give it Integer.MAX_VALUE since then if if more releases come in that
+ //could end up with permit count going -ve which would cause subsequent sends to block
+ sendSemaphore.release(Integer.MAX_VALUE / 2);
}
if (!connection.isDestroyed() && !connection.removeChannel(id))
More information about the hornetq-commits
mailing list