Re: [jira] [Resolved] (AMQ-4328) Cross talk over duplex network connection can lead to blocking

2014-03-10 Thread lukejackson 
Also, is this fix dependent on any other changes made in 5.9?  Is it safe if
we decide to apply the fix to the 5.8.0 version in isolation?



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/jira-Resolved-AMQ-4328-Cross-talk-over-duplex-network-connection-can-lead-to-blocking-tp4678549p4678612.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.

[jira] [Resolved] (AMQ-4328) Cross talk over duplex network connection can lead to blocking

2014-03-05 Thread jing chen 
Hi,

We seem to run into this problem with the 5.8.   There is no obvious error in 
the log, but the thread dump shows the same stack.   Is there a workaround 
besides upgrade to 5.9 or replace the duplex with one way connectors?

Thanks,
-Jing

[jira] [Resolved] (AMQ-4328) Cross talk over duplex network connection can lead to blocking

2013-02-18 Thread Gary Tully (JIRA) 

 [ 
https://issues.apache.org/jira/browse/AMQ-4328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Gary Tully resolved AMQ-4328.
-

Resolution: Fixed

fix and test in http://svn.apache.org/r1447323

 Cross talk over duplex network connection can lead to blocking
 --

 Key: AMQ-4328
 URL: https://issues.apache.org/jira/browse/AMQ-4328
 Project: ActiveMQ
  Issue Type: Bug
  Components: Connector
Affects Versions: 5.7.0, 5.8.0
Reporter: Gary Tully
Assignee: Gary Tully
  Labels: bridge, duplex, hang, network
 Fix For: 5.9.0


 with active forwarding in both directions a duplex network connector can 
 block. in 5.8, threads of the form:{code}ActiveMQ BrokerService[xx] Task-10 
 daemon prio=10 tid=0xb35d1c00 nid=0xc64 runnable [0xb3369000]
java.lang.Thread.State: RUNNABLE
   at java.net.SocketOutputStream.socketWrite0(Native Method)
   at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
   at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
   at 
 org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:115)
   at java.io.DataOutputStream.flush(DataOutputStream.java:106)
   at 
 org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:176)
   at 
 org.apache.activemq.transport.AbstractInactivityMonitor.doOnewaySend(AbstractInactivityMonitor.java:322)
   at 
 org.apache.activemq.transport.AbstractInactivityMonitor.oneway(AbstractInactivityMonitor.java:304)
   at 
 org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85)
   at 
 org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104)
   at 
 org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)
   at 
 org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)
   at 
 org.apache.activemq.network.DemandForwardingBridgeSupport.serviceLocalCommand(DemandForwardingBridgeSupport.java:994)
   at 
 org.apache.activemq.network.DemandForwardingBridgeSupport$2.onCommand(DemandForwardingBridgeSupport.java:201)
   at 
 org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
   at 
 org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
   at 
 org.apache.activemq.transport.vm.VMTransport.doDispatch(VMTransport.java:138)
   at 
 org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:127)
   - locked 0x647f4650 (a java.util.concurrent.atomic.AtomicBoolean)
   at 
 org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:104)
   at 
 org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)
   at 
 org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
   at 
 org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1378)
   at 
 org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:897)
   at 
 org.apache.activemq.broker.TransportConnection.iterate(TransportConnection.java:943)
   at 
 org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:129)
   at 
 org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:47)
   at 
 java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
   at 
 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
   at java.lang.Thread.run(Thread.java:662)
 ActiveMQ Transport: tcp:///xx:61616@40803 prio=10 tid=0xb3525400 nid=0xbec 
 waiting on condition [0xb3276000]
java.lang.Thread.State: WAITING (parking)
   at sun.misc.Unsafe.park(Native Method)
   - parking to wait for  0x64657028 (a 
 java.util.concurrent.locks.ReentrantLock$NonfairSync)
   at java.util.concurrent.locks.LockSupport.park(LockSupport.java:156)
   at 
 java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
   at 
 java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:842)
   at 
 java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
   at 
 java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:186)
   at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
   at 
 org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:66)
   at 
 org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
   at