You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by zh...@apache.org on 2016/09/01 16:00:33 UTC
incubator-geode git commit: GEODE-1833: should save the reference
locally in case other thread closed the server location.
Repository: incubator-geode
Updated Branches:
refs/heads/develop fd3786a82 -> ea5516c53
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/develop
Commit: ea5516c53fa124da7ff7ee91f69d52e78949bbfd
Parents: fd3786a
Author: zhouxh <gz...@pivotal.io>
Authored: Wed Aug 31 16:48:13 2016 -0700
Committer: zhouxh <gz...@pivotal.io>
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. ");