GEODE-1833: should save the reference locally in case other thread closed the server location.
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/ea5516c5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/ea5516c5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/ea5516c5 Branch: refs/heads/feature/GEODE-420 Commit: ea5516c53fa124da7ff7ee91f69d52e78949bbfd Parents: fd3786a Author: zhouxh <[email protected]> Authored: Wed Aug 31 16:48:13 2016 -0700 Committer: zhouxh <[email protected]> Committed: Thu Sep 1 08:57:48 2016 -0700 ---------------------------------------------------------------------- .../cache/wan/GatewaySenderEventRemoteDispatcher.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/ea5516c5/geode-wan/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java b/geode-wan/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java index 2625ad2..d2302c4 100644 --- a/geode-wan/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java +++ b/geode-wan/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventRemoteDispatcher.java @@ -398,12 +398,12 @@ public class GatewaySenderEventRemoteDispatcher implements } else { synchronized (this.sender .getLockForConcurrentDispatcher()) { - if (this.sender.getServerLocation() != null) { + ServerLocation server = this.sender.getServerLocation(); + if (server != null) { if (logger.isDebugEnabled()) { - logger.debug("ServerLocation is: {}. Connecting to this serverLocation...", sender.getServerLocation()); + logger.debug("ServerLocation is: {}. Connecting to this serverLocation...", server); } - con = this.sender.getProxy().acquireConnection( - this.sender.getServerLocation()); + con = this.sender.getProxy().acquireConnection(server); } else { if (logger.isDebugEnabled()) { logger.debug("ServerLocation is null. Creating new connection. ");
