You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@geode.apache.org by "Eric Shu (Jira)" <ji...@apache.org> on 2021/02/09 17:00:01 UTC
[jira] [Updated] (GEODE-8930) Hang in
tx.RemoteOperationMessage$RemoteOperationResponse.waitForRemoteResponse
[ https://issues.apache.org/jira/browse/GEODE-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Eric Shu updated GEODE-8930:
----------------------------
Affects Version/s: 1.1.0
> Hang in tx.RemoteOperationMessage$RemoteOperationResponse.waitForRemoteResponse
> -------------------------------------------------------------------------------
>
> Key: GEODE-8930
> URL: https://issues.apache.org/jira/browse/GEODE-8930
> Project: Geode
> Issue Type: Bug
> Components: transactions
> Affects Versions: 1.1.0
> Reporter: Eric Shu
> Priority: Major
>
> In a race condition that 2 nodes can be deadlocked. The thread processing the other node's request can send a request to the other node when performing create in certain condition. If the other node is doing the same, both nodes can be deadlocked.
> {noformat}
> "P2P message reader for rs-FullRegression04235130a0i3large-hydra-client-68(gemfire_host1_5646:5646)<ec><v1>:41001 shared ordered uid=3 port=38198" #65 daemon prio=10 os_prio=0 tid=0x00007fd3e4016800 nid=0x16b7 waiting on condition [0x00007fd3d3afa000]
> java.lang.Thread.State: TIMED_WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000fdc0d4f0> (a java.util.concurrent.CountDownLatch$Sync)
> at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328)
> at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:277)
> at org.apache.geode.internal.util.concurrent.StoppableCountDownLatch.await(StoppableCountDownLatch.java:72)
> at org.apache.geode.distributed.internal.ReplyProcessor21.basicWait(ReplyProcessor21.java:731)
> at org.apache.geode.distributed.internal.ReplyProcessor21.waitForRepliesUninterruptibly(ReplyProcessor21.java:802)
> at org.apache.geode.distributed.internal.ReplyProcessor21.waitForRepliesUninterruptibly(ReplyProcessor21.java:779)
> at org.apache.geode.distributed.internal.ReplyProcessor21.waitForRepliesUninterruptibly(ReplyProcessor21.java:865)
> at org.apache.geode.internal.cache.tx.RemoteOperationMessage$RemoteOperationResponse.waitForRemoteResponse(RemoteOperationMessage.java:554)
> at org.apache.geode.internal.cache.tx.RemoteFetchVersionMessage$FetchVersionResponse.waitForResponse(RemoteFetchVersionMessage.java:229)
> at org.apache.geode.internal.cache.DistributedRegion.fetchRemoteVersionTag(DistributedRegion.java:3920)
> at org.apache.geode.internal.cache.TXEntryState.fetchRemoteVersionTag(TXEntryState.java:1062)
> at org.apache.geode.internal.cache.TXEntryState.basicPut(TXEntryState.java:1046)
> at org.apache.geode.internal.cache.TXState.txPutEntry(TXState.java:1375)
> at org.apache.geode.internal.cache.TXState.putEntry(TXState.java:1723)
> at org.apache.geode.internal.cache.TXState.putEntry(TXState.java:1707)
> at org.apache.geode.internal.cache.TXStateProxyImpl.putEntry(TXStateProxyImpl.java:683)
> at org.apache.geode.internal.cache.TXStateProxyImpl.putEntry(TXStateProxyImpl.java:673)
> at org.apache.geode.internal.cache.tx.RemotePutMessage.operateOnRegion(RemotePutMessage.java:640)
> at org.apache.geode.internal.cache.tx.RemoteOperationMessage.process(RemoteOperationMessage.java:207)
> at org.apache.geode.distributed.internal.DistributionMessage.scheduleAction(DistributionMessage.java:376)
> at org.apache.geode.distributed.internal.DistributionMessage.schedule(DistributionMessage.java:431)
> at org.apache.geode.distributed.internal.ClusterDistributionManager.scheduleIncomingMessage(ClusterDistributionManager.java:2063)
> at org.apache.geode.distributed.internal.ClusterDistributionManager.handleIncomingDMsg(ClusterDistributionManager.java:1828)
> at org.apache.geode.distributed.internal.ClusterDistributionManager$$Lambda$82/323166441.messageReceived(Unknown Source)
> at org.apache.geode.distributed.internal.membership.gms.GMSMembership.dispatchMessage(GMSMembership.java:936)
> at org.apache.geode.distributed.internal.membership.gms.GMSMembership.handleOrDeferMessage(GMSMembership.java:867)
> at org.apache.geode.distributed.internal.membership.gms.GMSMembership.processMessage(GMSMembership.java:1209)
> at org.apache.geode.distributed.internal.DistributionImpl$MyDCReceiver.messageReceived(DistributionImpl.java:826)
> at org.apache.geode.distributed.internal.direct.DirectChannel.receive(DirectChannel.java:614)
> at org.apache.geode.internal.tcp.TCPConduit.messageReceived(TCPConduit.java:661)
> at org.apache.geode.internal.tcp.Connection.dispatchMessage(Connection.java:3243)
> at org.apache.geode.internal.tcp.Connection.readMessage(Connection.java:2972)
> at org.apache.geode.internal.tcp.Connection.processInputBuffer(Connection.java:2778)
> at org.apache.geode.internal.tcp.Connection.readMessages(Connection.java:1638)
> {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)