----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/49102/ -----------------------------------------------------------
Review request for geode, anilkumar gingade, Barry Oglesby, nabarun nag, Dan Smith, and xiaojian zhou. Repository: geode Description ------- When closing a sender, the close connection message is sent on the same connection that is used by the ack reader thread. This causes an issue as two threads are now reading off the same socket concurrently. The fix is to prevent this from happening but to do so, the input stream needs to be closed (to free up from a socket read()). The dispatcher also needs to shut down before the close connection is sent out or it will spawn off another ack reader thread. Diffs ----- geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySenderEventProcessor.java ce08e8d geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ConcurrentParallelGatewaySenderEventProcessor.java 07a3be5 geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/ConcurrentSerialGatewaySenderEventProcessor.java ff810ec geode-wan/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java b178192 Diff: https://reviews.apache.org/r/49102/diff/ Testing ------- Thanks, Jason Huynh
