[GEODE-9573] DirectReplySender can fail with UnsupportedOperationException upon connection related exceptions

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.15.0
• Fix Version/s: 1.15.0
• Component/s: messaging
• Labels: pull-request-available
• Assignee: Jacob Barrett
• Reporter: Jacob Barrett
• Created: 01/Sep/21 21:16
• Updated: 22/Jun/22 20:46
• Resolved: 08/Sep/21 20:54

Description

java.lang.UnsupportedOperationException
    at java.base/java.util.Collections$1.remove(Collections.java:4714)
    at org.apache.geode.internal.tcp.MsgStreamer.realFlush(MsgStreamer.java:330)
    at org.apache.geode.internal.tcp.MsgStreamer.writeMessage(MsgStreamer.java:244)
    at org.apache.geode.internal.tcp.DirectReplySender.putOutgoing(DirectReplySender.java:69)
    at org.apache.geode.distributed.internal.ReplyMessage.send(ReplyMessage.java:115)
    at org.apache.geode.internal.cache.partitioned.PartitionMessage.sendReply(PartitionMessage.java:458)
    at org.apache.geode.internal.cache.partitioned.PartitionMessage.process(PartitionMessage.java:421)
    at org.apache.geode.distributed.internal.DistributionMessage.scheduleAction(DistributionMessage.java:376)
    at org.apache.geode.distributed.internal.DistributionMessage.schedule(DistributionMessage.java:432)
    at org.apache.geode.distributed.internal.ClusterDistributionManager.scheduleIncomingMessage(ClusterDistributionManager.java:2077)
    at org.apache.geode.distributed.internal.ClusterDistributionManager.handleIncomingDMsg(ClusterDistributionManager.java:1841)
    at org.apache.geode.distributed.internal.membership.gms.GMSMembership.dispatchMessage(GMSMembership.java:847)
    at org.apache.geode.distributed.internal.membership.gms.GMSMembership.handleOrDeferMessage(GMSMembership.java:804)
    at org.apache.geode.distributed.internal.membership.gms.GMSMembership.processMessage(GMSMembership.java:1102)
    at org.apache.geode.distributed.internal.DistributionImpl$MyDCReceiver.messageReceived(DistributionImpl.java:838)
    at org.apache.geode.distributed.internal.direct.DirectChannel.receive(DirectChannel.java:624)
    at org.apache.geode.internal.tcp.TCPConduit.messageReceived(TCPConduit.java:682)
    at org.apache.geode.internal.tcp.Connection.dispatchMessage(Connection.java:3264)
    at org.apache.geode.internal.tcp.Connection.readMessage(Connection.java:3015)
    at org.apache.geode.internal.tcp.Connection.processInputBuffer(Connection.java:2806)
    at org.apache.geode.internal.tcp.Connection.readMessages(Connection.java:1649)
    at org.apache.geode.internal.tcp.Connection.run(Connection.java:1489)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
    at java.base/java.lang.Thread.run(Thread.java:829)

Issue Links

• is caused by: GEODE-6588 Cleanup internal use of generics and other static analyzer warnings [PERMANENT]
• links to: GitHub Pull Request #6828