You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ji...@apache.org on 2016/04/26 17:24:55 UTC
[1/4] incubator-geode git commit: GEODE-1237 remove the check for
network-partition-detection uniformity
Repository: incubator-geode
Updated Branches:
refs/heads/feature/GEODE-17-2 adc885d14 -> 7927758a1
GEODE-1237 remove the check for network-partition-detection uniformity
Each member now determines whether to force shutdown due to loss of quorum.
They also decide whether locators are preferred as membership coordinators.
This primarily meant removing the method GMSJoinLeave
.inheritSettingsFromLocator() but the ID settings needed to be made in
other places (JGroupsMessenger.establishLocalAddress() and
GMSJoinLeave.started()).
I also noticed that some of the code was still using "splitBrain" and
"SB" instead of networkPartitionDetection and "NPD" and fixed that.
One test had to be removed from LocatorDUnitTest and a couple of others
needed to be adjusted to have all of the members set network-partition
-detection-enabled=true. Precheckin is running and I'll fix any other
tests that have this problem.
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/872f955c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/872f955c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/872f955c
Branch: refs/heads/feature/GEODE-17-2
Commit: 872f955c491b6ec3e3881be2d7f0c1d192478aee
Parents: 3c5a2e8
Author: Bruce Schuchardt <bs...@pivotal.io>
Authored: Mon Apr 25 11:49:15 2016 -0700
Committer: Bruce Schuchardt <bs...@pivotal.io>
Committed: Mon Apr 25 11:49:15 2016 -0700
----------------------------------------------------------------------
.../distributed/internal/InternalLocator.java | 6 +-
.../membership/InternalDistributedMember.java | 68 ++++++------
.../internal/membership/NetMember.java | 4 +-
.../internal/membership/gms/GMSMember.java | 36 +++---
.../internal/membership/gms/ServiceConfig.java | 18 +++
.../membership/gms/locator/GMSLocator.java | 2 +-
.../membership/gms/membership/GMSJoinLeave.java | 56 +++-------
.../gms/messenger/JGroupsMessenger.java | 7 +-
.../internal/i18n/ParentLocalizedStrings.java | 2 +-
.../gemfire/distributed/LocatorDUnitTest.java | 110 +++----------------
.../gms/membership/GMSJoinLeaveTestHelper.java | 2 +-
11 files changed, 110 insertions(+), 201 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/872f955c/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalLocator.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalLocator.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalLocator.java
old mode 100644
new mode 100755
index a5d269b..7effa3d
--- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalLocator.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalLocator.java
@@ -663,11 +663,7 @@ public class InternalLocator extends Locator implements ConnectListener {
locatorsAreCoordinators = Boolean.getBoolean(LOCATORS_PREFERRED_AS_COORDINATORS);
}
}
- if (locatorsAreCoordinators) {
- // LOG: changed from config to info
- logger.info(LocalizedMessage.create(LocalizedStrings.InternalLocator_FORCING_GROUP_COORDINATION_INTO_LOCATORS));
- }
-
+
this.locatorImpl = MemberFactory.newLocatorHandler(this.bindAddress, this.stateFile,
locatorsProp, locatorsAreCoordinators, networkPartitionDetectionEnabled, stats);
this.handler.addHandler(PeerLocatorRequest.class, this.locatorImpl);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/872f955c/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/InternalDistributedMember.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/InternalDistributedMember.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/InternalDistributedMember.java
index 81058f8..f7572af 100755
--- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/InternalDistributedMember.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/InternalDistributedMember.java
@@ -121,17 +121,17 @@ public class InternalDistributedMember
*/
private String uniqueTag = null;
- /** serialization bit mask */
- private static final int SB_ENABLED_MASK = 0x1;
+ /** serialization bit flag */
+ private static final int NPD_ENABLED_BIT = 0x1;
- /** serialization bit mask */
- private static final int COORD_ENABLED_MASK = 0x2;
+ /** serialization bit flag */
+ private static final int COORD_ENABLED_BIT = 0x2;
- /** partial ID bit mask */
- private static final int PARTIAL_ID_MASK = 0x4;
+ /** partial ID bit flag */
+ private static final int PARTIAL_ID_BIT = 0x4;
- /** product version bit mask */
- private static final int VERSION_MASK = 0x8;
+ /** product version bit flag */
+ private static final int VERSION_BIT = 0x8;
/**
* Representing the host name of this member.
@@ -832,7 +832,7 @@ public class InternalDistributedMember
}
private void readVersion(int flags, DataInput in) throws IOException {
- if ((flags & VERSION_MASK) != 0) {
+ if ((flags & VERSION_BIT) != 0) {
this.version = Version.readOrdinal(in);
this.versionObj = Version.fromOrdinalNoThrow(this.version, false);
} else {
@@ -863,12 +863,12 @@ public class InternalDistributedMember
DataSerializer.writeString(this.hostName, out);
int flags = 0;
- if (netMbr.splitBrainEnabled()) flags |= SB_ENABLED_MASK;
- if (netMbr.preferredForCoordinator()) flags |= COORD_ENABLED_MASK;
- if (this.isPartial) flags |= PARTIAL_ID_MASK;
+ if (netMbr.isNetworkPartitionDetectionEnabled()) flags |= NPD_ENABLED_BIT;
+ if (netMbr.preferredForCoordinator()) flags |= COORD_ENABLED_BIT;
+ if (this.isPartial) flags |= PARTIAL_ID_BIT;
// always write product version but enable reading from older versions
// that do not have it
- flags |= VERSION_MASK;
+ flags |= VERSION_BIT;
out.writeByte((byte)(flags & 0xff));
out.writeInt(dcPort);
@@ -901,9 +901,9 @@ public class InternalDistributedMember
this.hostName = DataSerializer.readString(in);
int flags = in.readUnsignedByte();
- boolean sbEnabled = (flags & SB_ENABLED_MASK) != 0;
- boolean elCoord = (flags & COORD_ENABLED_MASK) != 0;
- this.isPartial = (flags & PARTIAL_ID_MASK) != 0;
+ boolean sbEnabled = (flags & NPD_ENABLED_BIT) != 0;
+ boolean elCoord = (flags & COORD_ENABLED_BIT) != 0;
+ this.isPartial = (flags & PARTIAL_ID_BIT) != 0;
this.dcPort = in.readInt();
this.vmPid = in.readInt();
@@ -955,12 +955,12 @@ public class InternalDistributedMember
DataSerializer.writeString(this.hostName, out);
int flags = 0;
- if (netMbr.splitBrainEnabled()) flags |= SB_ENABLED_MASK;
- if (netMbr.preferredForCoordinator()) flags |= COORD_ENABLED_MASK;
- if (this.isPartial) flags |= PARTIAL_ID_MASK;
+ if (netMbr.isNetworkPartitionDetectionEnabled()) flags |= NPD_ENABLED_BIT;
+ if (netMbr.preferredForCoordinator()) flags |= COORD_ENABLED_BIT;
+ if (this.isPartial) flags |= PARTIAL_ID_BIT;
// always write product version but enable reading from older versions
// that do not have it
- flags |= VERSION_MASK;
+ flags |= VERSION_BIT;
out.writeByte((byte)(flags & 0xff));
out.writeInt(dcPort);
@@ -997,9 +997,9 @@ public class InternalDistributedMember
DataSerializer.writeString(this.hostName, out);
int flags = 0;
- if (netMbr.splitBrainEnabled()) flags |= SB_ENABLED_MASK;
- if (netMbr.preferredForCoordinator()) flags |= COORD_ENABLED_MASK;
- if (this.isPartial) flags |= PARTIAL_ID_MASK;
+ if (netMbr.isNetworkPartitionDetectionEnabled()) flags |= NPD_ENABLED_BIT;
+ if (netMbr.preferredForCoordinator()) flags |= COORD_ENABLED_BIT;
+ if (this.isPartial) flags |= PARTIAL_ID_BIT;
out.writeByte((byte)(flags & 0xff));
out.writeInt(dcPort);
@@ -1041,9 +1041,9 @@ public class InternalDistributedMember
this.hostName = SocketCreator.resolve_dns? SocketCreator.getCanonicalHostName(inetAddr, hostName) : inetAddr.getHostAddress();
int flags = in.readUnsignedByte();
- boolean sbEnabled = (flags & SB_ENABLED_MASK) != 0;
- boolean elCoord = (flags & COORD_ENABLED_MASK) != 0;
- this.isPartial = (flags & PARTIAL_ID_MASK) != 0;
+ boolean sbEnabled = (flags & NPD_ENABLED_BIT) != 0;
+ boolean elCoord = (flags & COORD_ENABLED_BIT) != 0;
+ this.isPartial = (flags & PARTIAL_ID_BIT) != 0;
this.dcPort = in.readInt();
this.vmPid = in.readInt();
@@ -1084,9 +1084,9 @@ public class InternalDistributedMember
this.hostName = SocketCreator.resolve_dns? SocketCreator.getCanonicalHostName(inetAddr, hostName) : inetAddr.getHostAddress();
int flags = in.readUnsignedByte();
- boolean sbEnabled = (flags & SB_ENABLED_MASK) != 0;
- boolean elCoord = (flags & COORD_ENABLED_MASK) != 0;
- this.isPartial = (flags & PARTIAL_ID_MASK) != 0;
+ boolean sbEnabled = (flags & NPD_ENABLED_BIT) != 0;
+ boolean elCoord = (flags & COORD_ENABLED_BIT) != 0;
+ this.isPartial = (flags & PARTIAL_ID_BIT) != 0;
this.dcPort = in.readInt();
this.vmPid = in.readInt();
@@ -1134,8 +1134,8 @@ public class InternalDistributedMember
this.hostName = SocketCreator.resolve_dns? SocketCreator.getHostName(inetAddr) : inetAddr.getHostAddress();
int flags = in.readUnsignedByte();
- boolean sbEnabled = (flags & SB_ENABLED_MASK) != 0;
- boolean elCoord = (flags & COORD_ENABLED_MASK) != 0;
+ boolean sbEnabled = (flags & NPD_ENABLED_BIT) != 0;
+ boolean elCoord = (flags & COORD_ENABLED_BIT) != 0;
this.vmKind = in.readUnsignedByte();
@@ -1170,9 +1170,9 @@ public class InternalDistributedMember
out.writeInt(getPort());
int flags = 0;
- if (netMbr.splitBrainEnabled()) flags |= SB_ENABLED_MASK;
- if (netMbr.preferredForCoordinator()) flags |= COORD_ENABLED_MASK;
- flags |= PARTIAL_ID_MASK;
+ if (netMbr.isNetworkPartitionDetectionEnabled()) flags |= NPD_ENABLED_BIT;
+ if (netMbr.preferredForCoordinator()) flags |= COORD_ENABLED_BIT;
+ flags |= PARTIAL_ID_BIT;
out.writeByte((byte)(flags & 0xff));
// out.writeInt(dcPort);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/872f955c/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/NetMember.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/NetMember.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/NetMember.java
index 43f3cf1..bdaf579 100755
--- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/NetMember.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/NetMember.java
@@ -50,9 +50,9 @@ public interface NetMember extends Comparable<NetMember>
* return a flag stating whether the member has network partition detection enabled
* @since 5.6
*/
- public boolean splitBrainEnabled();
+ public boolean isNetworkPartitionDetectionEnabled();
- public void setSplitBrainEnabled(boolean enabled);
+ public void setNetworkPartitionDetectionEnabled(boolean enabled);
/**
* return a flag stating whether the member can be the membership coordinator
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/872f955c/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/GMSMember.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/GMSMember.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/GMSMember.java
index 84ace6c..6089eb8 100755
--- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/GMSMember.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/GMSMember.java
@@ -50,7 +50,7 @@ public class GMSMember implements NetMember, DataSerializableFixedID {
private int udpPort=0;
private boolean preferredForCoordinator;
- private boolean splitBrainEnabled;
+ private boolean networkPartitionDetectionEnabled;
private byte memberWeight;
private InetAddress inetAddr;
private int processId;
@@ -112,19 +112,19 @@ public class GMSMember implements NetMember, DataSerializableFixedID {
*
* @param i the hostname, must be for the current host
* @param p the membership listening port
- * @param splitBrainEnabled whether the member has network partition detection enabled
+ * @param networkPartitionDetectionEnabled whether the member has network partition detection enabled
* @param preferredForCoordinator whether the member can be group coordinator
* @param version the member's version ordinal
* @param msbs - most significant bytes of UUID
* @param lsbs - least significant bytes of UUID
*/
- public GMSMember(MemberAttributes attr, InetAddress i, int p, boolean splitBrainEnabled, boolean preferredForCoordinator,
- short version,
- long msbs, long lsbs) {
+ public GMSMember(MemberAttributes attr, InetAddress i, int p, boolean networkPartitionDetectionEnabled, boolean preferredForCoordinator,
+ short version,
+ long msbs, long lsbs) {
setAttributes(attr);
this.inetAddr = i;
this.udpPort=p;
- this.splitBrainEnabled = splitBrainEnabled;
+ this.networkPartitionDetectionEnabled = networkPartitionDetectionEnabled;
this.preferredForCoordinator = preferredForCoordinator;
this.versionOrdinal = version;
this.uuidMSBs = msbs;
@@ -139,10 +139,6 @@ public class GMSMember implements NetMember, DataSerializableFixedID {
return false; //ipAddr.isMulticastAddress();
}
- public boolean splitBrainEnabled() {
- return this.splitBrainEnabled;
- }
-
public boolean preferredForCoordinator() {
return this.preferredForCoordinator;
}
@@ -284,8 +280,8 @@ public class GMSMember implements NetMember, DataSerializableFixedID {
return udpPort;
}
- public boolean isSplitBrainEnabled() {
- return splitBrainEnabled;
+ public boolean isNetworkPartitionDetectionEnabled() {
+ return networkPartitionDetectionEnabled;
}
public byte getMemberWeight() {
@@ -328,8 +324,8 @@ public class GMSMember implements NetMember, DataSerializableFixedID {
this.udpPort = udpPort;
}
- public void setSplitBrainEnabled(boolean splitBrainEnabled) {
- this.splitBrainEnabled = splitBrainEnabled;
+ public void setNetworkPartitionDetectionEnabled(boolean networkPartitionDetectionEnabled) {
+ this.networkPartitionDetectionEnabled = networkPartitionDetectionEnabled;
}
public void setMemberWeight(byte memberWeight) {
@@ -395,16 +391,16 @@ public class GMSMember implements NetMember, DataSerializableFixedID {
return GMSMEMBER;
}
- static final int SB_ENABLED = 0x01;
- static final int PREFERRED_FOR_COORD = 0x02;
+ static final int NPD_ENABLED_BIT = 0x01;
+ static final int PREFERRED_FOR_COORD_BIT = 0x02;
@Override
public void toData(DataOutput out) throws IOException {
Version.writeOrdinal(out, this.versionOrdinal, true);
int flags = 0;
- if (splitBrainEnabled) flags |= SB_ENABLED;
- if (preferredForCoordinator) flags |= PREFERRED_FOR_COORD;
+ if (networkPartitionDetectionEnabled) flags |= NPD_ENABLED_BIT;
+ if (preferredForCoordinator) flags |= PREFERRED_FOR_COORD_BIT;
out.writeShort(flags);
DataSerializer.writeInetAddress(inetAddr, out);
@@ -425,8 +421,8 @@ public class GMSMember implements NetMember, DataSerializableFixedID {
this.versionOrdinal = Version.readOrdinal(in);
int flags = in.readShort();
- this.splitBrainEnabled = (flags & SB_ENABLED) != 0;
- this.preferredForCoordinator = (flags & PREFERRED_FOR_COORD) != 0;
+ this.networkPartitionDetectionEnabled = (flags & NPD_ENABLED_BIT) != 0;
+ this.preferredForCoordinator = (flags & PREFERRED_FOR_COORD_BIT) != 0;
this.inetAddr = DataSerializer.readInetAddress(in);
this.udpPort = in.readInt();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/872f955c/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/ServiceConfig.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/ServiceConfig.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/ServiceConfig.java
index 9f0bbf7..3a48c3f 100755
--- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/ServiceConfig.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/ServiceConfig.java
@@ -20,6 +20,7 @@ import java.net.InetAddress;
import com.gemstone.gemfire.distributed.Locator;
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
+import com.gemstone.gemfire.distributed.internal.InternalLocator;
import com.gemstone.gemfire.distributed.internal.membership.gms.membership.GMSJoinLeave;
import com.gemstone.gemfire.internal.SocketCreator;
import com.gemstone.gemfire.internal.admin.remote.RemoteTransportConfig;
@@ -118,6 +119,23 @@ public class ServiceConfig {
}
}
+
+ public boolean areLocatorsPreferredAsCoordinators() {
+ boolean locatorsAreCoordinators = false;
+
+ if (networkPartitionDetectionEnabled) {
+ locatorsAreCoordinators = true;
+ }
+ else {
+ // check if security is enabled
+ String prop = dconfig.getSecurityPeerAuthInit();
+ locatorsAreCoordinators = (prop != null && prop.length() > 0);
+ if (!locatorsAreCoordinators) {
+ locatorsAreCoordinators = Boolean.getBoolean(InternalLocator.LOCATORS_PREFERRED_AS_COORDINATORS);
+ }
+ }
+ return locatorsAreCoordinators;
+ }
public DistributionConfig getDistributionConfig() {
return this.dconfig;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/872f955c/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/locator/GMSLocator.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/locator/GMSLocator.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/locator/GMSLocator.java
index c8b6aaa..aab9002 100755
--- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/locator/GMSLocator.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/locator/GMSLocator.java
@@ -218,7 +218,7 @@ public class GMSLocator implements Locator, NetLocator {
for (InternalDistributedMember mbr: registrants) {
if (mbr != coord && (coord==null || mbr.compareTo(coord) < 0)) {
if (!rejections.contains(mbr)
- && (mbr.getNetMember().preferredForCoordinator() || !mbr.getNetMember().splitBrainEnabled())) {
+ && (mbr.getNetMember().preferredForCoordinator() || !mbr.getNetMember().isNetworkPartitionDetectionEnabled())) {
coord = mbr;
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/872f955c/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/membership/GMSJoinLeave.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/membership/GMSJoinLeave.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/membership/GMSJoinLeave.java
index 05350e5..9f5648b 100755
--- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/membership/GMSJoinLeave.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/membership/GMSJoinLeave.java
@@ -800,7 +800,9 @@ public class GMSJoinLeave implements JoinLeave, MessageHandler {
}
if (recips.isEmpty()) {
- logger.info("no recipients for new view aside from myself");
+ if (!preparing) {
+ logger.info("no recipients for new view aside from myself");
+ }
return true;
}
@@ -958,7 +960,6 @@ public class GMSJoinLeave implements JoinLeave, MessageHandler {
int connectTimeout = (int) services.getConfig().getMemberTimeout() * 2;
boolean anyResponses = false;
- boolean flagsSet = false;
logger.debug("sending {} to {}", request, locators);
@@ -995,10 +996,6 @@ public class GMSJoinLeave implements JoinLeave, MessageHandler {
}
possibleCoordinators.add(response.getCoordinator());
- if (!flagsSet) {
- flagsSet = true;
- inheritSettingsFromLocator(addr, response);
- }
}
}
} catch (IOException | ClassNotFoundException problem) {
@@ -1124,36 +1121,6 @@ public class GMSJoinLeave implements JoinLeave, MessageHandler {
}
/**
- * Some settings are gleaned from locator responses and set into the local
- * configuration
- */
- private void inheritSettingsFromLocator(InetSocketAddress addr, FindCoordinatorResponse response) {
- boolean enabled = response.isNetworkPartitionDetectionEnabled();
- if (!enabled && services.getConfig().isNetworkPartitionDetectionEnabled()) {
- throw new GemFireConfigException("locator at " + addr
- + " does not have network-partition-detection enabled but my configuration has it enabled");
- }
-
- GMSMember mbr = (GMSMember) this.localAddress.getNetMember();
- mbr.setSplitBrainEnabled(enabled);
- services.getConfig().setNetworkPartitionDetectionEnabled(enabled);
- services.getConfig().getDistributionConfig().setEnableNetworkPartitionDetection(enabled);
-
- if (response.isUsePreferredCoordinators()) {
- this.quorumRequired = enabled;
- logger.debug("The locator indicates that all locators should be preferred as coordinators");
- if (services.getLocator() != null
- || Locator.hasLocator()
- || !services.getConfig().getDistributionConfig().getStartLocator().isEmpty()
- || localAddress.getVmKind() == DistributionManager.LOCATOR_DM_TYPE) {
- ((GMSMember) localAddress.getNetMember()).setPreferredForCoordinator(true);
- }
- } else {
- ((GMSMember) localAddress.getNetMember()).setPreferredForCoordinator(true);
- }
- }
-
- /**
* receives a JoinResponse holding a membership view or rejection message
*
* @param rsp
@@ -1238,7 +1205,6 @@ public class GMSJoinLeave implements JoinLeave, MessageHandler {
this.localAddress.setVmViewId(this.birthViewId);
GMSMember me = (GMSMember) this.localAddress.getNetMember();
me.setBirthViewId(birthViewId);
- me.setSplitBrainEnabled(mbr.getNetMember().splitBrainEnabled());
break;
}
}
@@ -1422,6 +1388,21 @@ public class GMSJoinLeave implements JoinLeave, MessageHandler {
@Override
public void started() {
this.localAddress = services.getMessenger().getMemberID();
+ GMSMember mbr = (GMSMember)this.localAddress.getNetMember();
+
+ if (services.getConfig().areLocatorsPreferredAsCoordinators()) {
+ boolean preferred = false;
+ if (services.getLocator() != null
+ || Locator.hasLocator()
+ || !services.getConfig().getDistributionConfig().getStartLocator().isEmpty()
+ || localAddress.getVmKind() == DistributionManager.LOCATOR_DM_TYPE) {
+ logger.info("This member is hosting a locator will be preferred as a membership coordinator");
+ preferred = true;
+ }
+ mbr.setPreferredForCoordinator(preferred);
+ } else {
+ mbr.setPreferredForCoordinator(true);
+ }
}
@Override
@@ -2144,7 +2125,6 @@ public class GMSJoinLeave implements JoinLeave, MessageHandler {
for (InternalDistributedMember mbr : joinReqs) {
mbr.setVmViewId(newView.getViewId());
- mbr.getNetMember().setSplitBrainEnabled(services.getConfig().isNetworkPartitionDetectionEnabled());
}
if (isShutdown()) {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/872f955c/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/messenger/JGroupsMessenger.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/messenger/JGroupsMessenger.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/messenger/JGroupsMessenger.java
index a9abea3..4a54e84 100755
--- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/messenger/JGroupsMessenger.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/messenger/JGroupsMessenger.java
@@ -477,8 +477,11 @@ public class JGroupsMessenger implements Messenger {
// add the JGroups logical address to the GMSMember
UUID uuid = this.jgAddress;
- ((GMSMember)localAddress.getNetMember()).setUUID(uuid);
- ((GMSMember)localAddress.getNetMember()).setMemberWeight((byte)(services.getConfig().getMemberWeight() & 0xff));
+ GMSMember gmsMember = (GMSMember)localAddress.getNetMember();
+ gmsMember.setUUID(uuid);
+ gmsMember.setMemberWeight((byte)(services.getConfig().getMemberWeight() & 0xff));
+ gmsMember.setNetworkPartitionDetectionEnabled(services.getConfig().getDistributionConfig().getEnableNetworkPartitionDetection());
+
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/872f955c/geode-core/src/main/java/com/gemstone/gemfire/internal/i18n/ParentLocalizedStrings.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/i18n/ParentLocalizedStrings.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/i18n/ParentLocalizedStrings.java
index 8285a65..c34c91a 100755
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/i18n/ParentLocalizedStrings.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/i18n/ParentLocalizedStrings.java
@@ -704,7 +704,7 @@ class ParentLocalizedStrings {
public static final StringId InternalInstantiator_COULD_NOT_LOAD_INSTANTIATOR_CLASS_0 = new StringId(1697, "Could not load instantiator class: {0}");
public static final StringId InternalLocator_0__IS_STOPPED = new StringId(1698, "{0} is stopped");
public static final StringId InternalLocator_COULD_NOT_STOP__0__IN_60_SECONDS = new StringId(1699, "Could not stop {0} in 60 seconds");
- public static final StringId InternalLocator_FORCING_GROUP_COORDINATION_INTO_LOCATORS = new StringId(1700, "Forcing group coordination into Locators.");
+ // ok to reuse 1700
public static final StringId InternalLocator_INTERRUPTED_WHILE_STOPPING__0 = new StringId(1701, "Interrupted while stopping {0}");
public static final StringId InternalLocator_LOCATOR_STARTED_ON__0 = new StringId(1702, "Locator started on {0}");
public static final StringId StartupMessage_REJECTED_NEW_SYSTEM_NODE_0_BECAUSE_MCAST_PORT_1_DOES_NOT_MATCH_THE_DISTRIBUTED_SYSTEM_2_IT_IS_ATTEMPTING_TO_JOIN = new StringId(1703, "Rejected new system node {0} because its mcast-port {1} does not match the mcast-port {2} of the distributed system it is attempting to join. To fix this make sure the \"mcast-port\" gemfire property is set the same on all members of the same distributed system.");
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/872f955c/geode-core/src/test/java/com/gemstone/gemfire/distributed/LocatorDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/distributed/LocatorDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/distributed/LocatorDUnitTest.java
old mode 100644
new mode 100755
index 702a859..a62a317
--- a/geode-core/src/test/java/com/gemstone/gemfire/distributed/LocatorDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/distributed/LocatorDUnitTest.java
@@ -1186,8 +1186,8 @@ public class LocatorDUnitTest extends DistributedTestCase {
try {
final Properties props = new Properties();
- props.setProperty("mcast-port", "0");
- props.setProperty("locators", locators);
+ props.setProperty(DistributionConfig.LOCATORS_NAME, locators);
+ props.setProperty(DistributionConfig.ENABLE_NETWORK_PARTITION_DETECTION_NAME, "true");
props.put(DistributionConfig.ENABLE_CLUSTER_CONFIGURATION_NAME, "false");
SerializableRunnable connect =
@@ -1438,10 +1438,9 @@ public class LocatorDUnitTest extends DistributedTestCase {
host0 + "[" + port3 + "]";
final Properties dsProps = new Properties();
- dsProps.setProperty("locators", locators);
- dsProps.setProperty("mcast-port", "0");
- dsProps.setProperty("log-level", LogWriterUtils.getDUnitLogLevel());
- dsProps.setProperty("enable-network-partition-detection", "true");
+ dsProps.setProperty(DistributionConfig.LOCATORS_NAME, locators);
+ dsProps.setProperty(DistributionConfig.LOG_LEVEL_NAME, LogWriterUtils.getDUnitLogLevel());
+ dsProps.setProperty(DistributionConfig.ENABLE_NETWORK_PARTITION_DETECTION_NAME, "true");
dsProps.setProperty(DistributionConfig.ENABLE_CLUSTER_CONFIGURATION_NAME, "false");
startLocatorSync(vm0, new Object[] { port1, dsProps });
@@ -1453,22 +1452,13 @@ public class LocatorDUnitTest extends DistributedTestCase {
SerializableRunnable connect =
new SerializableRunnable("Connect to " + locators) {
public void run() {
- Properties props = new Properties();
- props.setProperty("mcast-port", "0");
- props.setProperty("locators", locators);
- props.setProperty("log-level", LogWriterUtils.getDUnitLogLevel());
- props.setProperty("enable-network-partition-detection", "true");
- DistributedSystem.connect(props);
+ DistributedSystem.connect(dsProps);
}
};
vm3.invoke(connect);
vm4.invoke(connect);
- Properties props = new Properties();
- props.setProperty("mcast-port", "0");
- props.setProperty("locators", locators);
-
- system = (InternalDistributedSystem) DistributedSystem.connect(props);
+ system = (InternalDistributedSystem) DistributedSystem.connect(dsProps);
WaitCriterion waitCriterion = new WaitCriterion() {
public boolean done() {
@@ -1497,7 +1487,7 @@ public class LocatorDUnitTest extends DistributedTestCase {
waitCriterion = new WaitCriterion() {
public boolean done() {
try {
- return system.getDM().getAllHostedLocators().size() == 0;
+ return system.getDM().getMembershipManager().getView().size() <= 3;
} catch (Exception e) {
e.printStackTrace();
com.gemstone.gemfire.test.dunit.Assert.fail("unexpected exception", e);
@@ -1515,11 +1505,11 @@ public class LocatorDUnitTest extends DistributedTestCase {
host0 + "[" + port3 + "]";
dsProps.setProperty("locators", newLocators);
- assertTrue(vm3.invoke("Checking ViewCreator thread on Lead Server", () -> GMSJoinLeaveTestHelper.isViewCreator()));
- //Given the start up order of servers, this server is the elder server
- assertTrue(vm3.invoke("Checking ViewCreator thread on Lead Server", () -> GMSJoinLeaveTestHelper.isViewCreator()));
-
final InternalDistributedMember currentCoordinator = GMSJoinLeaveTestHelper.getCurrentCoordinator();
+ DistributedMember vm3ID = vm3.invoke(() -> GMSJoinLeaveTestHelper.getInternalDistributedSystem().getDM().getDistributionManagerId());
+ assertTrue("View is " + system.getDM().getMembershipManager().getView() +
+ " and vm3's ID is " + vm3ID,
+ vm3.invoke(() -> GMSJoinLeaveTestHelper.isViewCreator()));
startLocatorAsync(vm1, new Object[] { port2, dsProps });
startLocatorAsync(vm2, new Object[] { port3, dsProps });
@@ -1544,7 +1534,7 @@ public class LocatorDUnitTest extends DistributedTestCase {
return null;
}
};
- Wait.waitForCriterion(waitCriterion, 15 * 1000, 200, true);
+ Wait.waitForCriterion(waitCriterion, 30 * 1000, 1000, true);
int netviewId = vm1.invoke("Checking ViewCreator", () -> GMSJoinLeaveTestHelper.getViewId());
assertEquals(netviewId, (int) vm2.invoke("checking ViewID", () -> GMSJoinLeaveTestHelper.getViewId()));
@@ -1739,80 +1729,6 @@ public class LocatorDUnitTest extends DistributedTestCase {
}
/**
- * Tests that a VM cannot connect if the locator has a different
- * enable-network-partition-detection setting
- */
- public void testLocatorForcesDetection() throws Exception {
- disconnectAllFromDS();
- Host host = Host.getHost(0);
- VM vm1 = host.getVM(1);
- Locator locator = null;
-
- try {
- port1 = AvailablePort.getRandomAvailablePort(AvailablePort.SOCKET);
- DistributedTestUtils.deleteLocatorStateFile(port1);
- final String locators = NetworkUtils.getServerHostName(host) + "[" + port1 + "]";
- final Properties properties = new Properties();
- properties.put("mcast-port", "0");
- properties.put("locators", locators);
- properties.put(DistributionConfig.ENABLE_NETWORK_PARTITION_DETECTION_NAME, "true");
- properties.put("disable-auto-reconnect", "true");
- properties.put(DistributionConfig.ENABLE_CLUSTER_CONFIGURATION_NAME, "false");
- File logFile = new File("");
- locator = Locator.startLocatorAndDS(port1, logFile, properties);
-
- final Properties properties2 = new Properties();
- properties2.put("mcast-port", "0");
- properties2.put("locators", locators);
- properties2.put(DistributionConfig.ENABLE_NETWORK_PARTITION_DETECTION_NAME, "false");
- properties2.put(DistributionConfig.ENABLE_CLUSTER_CONFIGURATION_NAME, "false");
- properties2.put("disable-auto-reconnect", "true");
-
- vm1.invoke(new SerializableRunnable("try to connect") {
- public void run() {
- DistributedSystem s = null;
- try {
- s = DistributedSystem.connect(properties2);
- boolean enabled = ((InternalDistributedSystem) s).getConfig().getEnableNetworkPartitionDetection();
- s.disconnect();
- if (!enabled) {
- fail("should not have been able to connect with different enable-network-partition-detection settings");
- }
- } catch (GemFireConfigException e) {
- fail("should have been able to connect and have enable-network-partion-detection enabled");
- }
- }
- });
-
- locator.stop();
-
- // now start the locator with enable-network-partition-detection=false
- logFile = new File("");
- locator = Locator.startLocatorAndDS(port1, logFile, properties2);
-
- vm1.invoke(new SerializableRunnable("try to connect") {
- public void run() {
- DistributedSystem s = null;
- try {
- s = DistributedSystem.connect(properties);
- s.disconnect();
- fail("should not have been able to connect with different enable-network-partition-detection settings");
- } catch (GemFireConfigException e) {
- // passed
- }
- }
- });
-
- locator.stop();
- locator = null;
- } finally {
- if (locator != null) {
- locator.stop();
- }
- }
- }
-
- /**
* Tests that a single VM can NOT host multiple locators
*/
public void testHostingMultipleLocators() throws Exception {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/872f955c/geode-core/src/test/java/com/gemstone/gemfire/distributed/internal/membership/gms/membership/GMSJoinLeaveTestHelper.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/distributed/internal/membership/gms/membership/GMSJoinLeaveTestHelper.java b/geode-core/src/test/java/com/gemstone/gemfire/distributed/internal/membership/gms/membership/GMSJoinLeaveTestHelper.java
old mode 100644
new mode 100755
index bf13420..bc7324c
--- a/geode-core/src/test/java/com/gemstone/gemfire/distributed/internal/membership/gms/membership/GMSJoinLeaveTestHelper.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/distributed/internal/membership/gms/membership/GMSJoinLeaveTestHelper.java
@@ -80,7 +80,7 @@ public class GMSJoinLeaveTestHelper {
return getGmsJoinLeave().getView().getViewId();
}
- private static InternalDistributedSystem getInternalDistributedSystem() {
+ public static InternalDistributedSystem getInternalDistributedSystem() {
waitCriterion();
return getIDS();
}
[4/4] incubator-geode git commit: Merge branch 'develop' into
feature/GEODE-17-2
Posted by ji...@apache.org.
Merge branch 'develop' into feature/GEODE-17-2
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/7927758a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/7927758a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/7927758a
Branch: refs/heads/feature/GEODE-17-2
Commit: 7927758a12a1a6500ac08ef84957547bf33a305f
Parents: adc885d 9fbcb93
Author: Jinmei Liao <ji...@pivotal.io>
Authored: Tue Apr 26 08:23:52 2016 -0700
Committer: Jinmei Liao <ji...@pivotal.io>
Committed: Tue Apr 26 08:23:52 2016 -0700
----------------------------------------------------------------------
.../distributed/internal/InternalLocator.java | 6 +-
.../membership/InternalDistributedMember.java | 68 ++++++------
.../internal/membership/NetMember.java | 4 +-
.../internal/membership/gms/GMSMember.java | 36 +++---
.../internal/membership/gms/ServiceConfig.java | 18 +++
.../membership/gms/locator/GMSLocator.java | 2 +-
.../membership/gms/membership/GMSJoinLeave.java | 56 +++-------
.../gms/messenger/JGroupsMessenger.java | 7 +-
.../internal/i18n/ParentLocalizedStrings.java | 2 +-
.../gemfire/distributed/LocatorDUnitTest.java | 110 +++----------------
.../gms/membership/GMSJoinLeaveTestHelper.java | 2 +-
geode-site/website/content/docs/index.html | 2 +-
12 files changed, 111 insertions(+), 202 deletions(-)
----------------------------------------------------------------------
[3/4] incubator-geode git commit: Merge branch 'develop' of
https://git-wip-us.apache.org/repos/asf/incubator-geode into develop
Posted by ji...@apache.org.
Merge branch 'develop' of https://git-wip-us.apache.org/repos/asf/incubator-geode into develop
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/9fbcb93b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/9fbcb93b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/9fbcb93b
Branch: refs/heads/feature/GEODE-17-2
Commit: 9fbcb93b6937499c097c030ec356c81bb4659fa0
Parents: b2b4852 872f955
Author: Dave Barnes <db...@pivotal.io>
Authored: Mon Apr 25 11:54:57 2016 -0700
Committer: Dave Barnes <db...@pivotal.io>
Committed: Mon Apr 25 11:54:57 2016 -0700
----------------------------------------------------------------------
LICENSE | 60 +
.../apache/geode/gradle/PasswordDialog.groovy | 41 +
extensions/geode-modules-assembly/build.gradle | 1 +
.../SessionReplicationIntegrationJUnitTest.java | 10 +-
geode-assembly/build.gradle | 4 +-
geode-assembly/src/main/dist/LICENSE | 8 +-
geode-assembly/src/main/dist/NOTICE | 36 +-
.../LauncherLifecycleCommandsDUnitTest.java | 87 +-
.../SharedConfigurationEndToEndDUnitTest.java | 18 +-
.../client/internal/CloseConnectionOp.java | 26 +-
.../cache/client/internal/ConnectionImpl.java | 8 +-
.../client/internal/ServerRegionProxy.java | 3 +-
.../gemfire/cache/execute/Function.java | 2 +-
.../distributed/internal/InternalLocator.java | 24 +-
.../internal/WanLocatorDiscoverer.java | 4 +
.../membership/InternalDistributedMember.java | 68 +-
.../internal/membership/NetMember.java | 4 +-
.../internal/membership/gms/GMSMember.java | 36 +-
.../internal/membership/gms/ServiceConfig.java | 18 +
.../membership/gms/locator/GMSLocator.java | 2 +-
.../membership/gms/membership/GMSJoinLeave.java | 152 +-
.../gms/messenger/JGroupsMessenger.java | 7 +-
.../internal/tcpserver/TcpServer.java | 4 +-
.../gemfire/internal/AvailablePort.java | 6 +-
.../gemfire/internal/SocketCreator.java | 25 +-
.../gemfire/internal/SocketIOWithTimeout.java | 491 ----
.../gemfire/internal/SocketInputStream.java | 181 --
.../gemfire/internal/SocketInputWrapper.java | 93 -
.../gemfire/internal/SocketOutputStream.java | 174 --
.../gemstone/gemfire/internal/SocketUtils.java | 220 --
.../internal/admin/ClientStatsManager.java | 3 +-
.../cache/AbstractBucketRegionQueue.java | 3 +-
.../internal/cache/AbstractLRURegionMap.java | 4 +
.../internal/cache/AbstractRegionEntry.java | 2 +-
.../internal/cache/AbstractRegionMap.java | 15 +-
.../gemfire/internal/cache/BucketRegion.java | 14 +-
.../internal/cache/BucketRegionQueue.java | 7 +-
.../internal/cache/DestroyOperation.java | 6 +-
.../internal/cache/DistPeerTXStateStub.java | 2 +
.../gemfire/internal/cache/DistTXState.java | 9 +-
.../cache/DistTXStateOnCoordinator.java | 2 +
.../DistTXStateProxyImplOnCoordinator.java | 2 +
.../cache/DistributedCacheOperation.java | 4 +-
.../cache/DistributedPutAllOperation.java | 23 +-
.../internal/cache/DistributedRegion.java | 9 +-
.../cache/DistributedRemoveAllOperation.java | 22 +-
.../gemfire/internal/cache/EntryEventImpl.java | 41 +-
.../gemfire/internal/cache/EntryExpiryTask.java | 9 +-
.../gemfire/internal/cache/EventIDHolder.java | 35 +
.../gemfire/internal/cache/FilterProfile.java | 13 +-
.../internal/cache/GemFireCacheImpl.java | 14 +-
.../gemfire/internal/cache/HARegion.java | 5 +-
.../internal/cache/InitialImageOperation.java | 2 +-
.../internal/cache/InvalidateOperation.java | 5 +-
.../gemfire/internal/cache/LocalRegion.java | 141 +-
.../internal/cache/PartitionedRegion.java | 13 +-
.../gemfire/internal/cache/ProxyRegionMap.java | 7 +-
.../gemfire/internal/cache/QueuedOperation.java | 3 +-
.../internal/cache/RemoteDestroyMessage.java | 3 +-
.../internal/cache/RemoteInvalidateMessage.java | 4 +-
.../internal/cache/RemotePutAllMessage.java | 5 +-
.../internal/cache/RemotePutMessage.java | 4 +-
.../internal/cache/RemoteRemoveAllMessage.java | 5 +-
.../cache/SearchLoadAndWriteProcessor.java | 6 +-
.../gemfire/internal/cache/TXCommitMessage.java | 4 +-
.../gemfire/internal/cache/TXEntryState.java | 6 +-
.../gemfire/internal/cache/TXRegionState.java | 1 +
.../gemfire/internal/cache/TXRmtEvent.java | 9 +-
.../gemfire/internal/cache/TXState.java | 9 +-
.../cache/TimestampedEntryEventImpl.java | 2 +
.../cache/UpdateEntryVersionOperation.java | 4 +-
.../gemfire/internal/cache/UpdateOperation.java | 8 +-
.../internal/cache/VersionTagHolder.java | 34 +
.../cache/partitioned/DestroyMessage.java | 11 +-
.../partitioned/FetchBulkEntriesMessage.java | 4 +-
.../internal/cache/partitioned/GetMessage.java | 5 +-
.../cache/partitioned/InvalidateMessage.java | 3 +-
.../PRUpdateEntryVersionMessage.java | 1 +
.../cache/partitioned/PutAllPRMessage.java | 12 +-
.../internal/cache/partitioned/PutMessage.java | 11 +-
.../cache/partitioned/RemoveAllPRMessage.java | 13 +-
.../cache/tier/sockets/AcceptorImpl.java | 3 +-
.../cache/tier/sockets/BaseCommand.java | 12 +-
.../cache/tier/sockets/CacheClientNotifier.java | 105 +-
.../cache/tier/sockets/CacheClientUpdater.java | 8 +-
.../internal/cache/tier/sockets/HandShake.java | 13 +-
.../internal/cache/tier/sockets/Message.java | 3 +-
.../cache/tier/sockets/ServerConnection.java | 5 +-
.../tier/sockets/ServerHandShakeProcessor.java | 26 +-
.../tier/sockets/command/CloseConnection.java | 17 +-
.../cache/tier/sockets/command/Destroy.java | 3 +-
.../cache/tier/sockets/command/Destroy65.java | 3 +-
.../sockets/command/GatewayReceiverCommand.java | 11 +-
.../cache/tier/sockets/command/Get70.java | 15 +-
.../cache/tier/sockets/command/Invalidate.java | 3 +-
.../cache/tier/sockets/command/Put.java | 5 +-
.../cache/tier/sockets/command/Put61.java | 5 +-
.../cache/tier/sockets/command/Put65.java | 3 +-
.../internal/cache/tx/DistTxEntryEvent.java | 13 +-
.../cache/tx/PartitionedTXRegionStub.java | 17 +-
.../cache/wan/AbstractGatewaySender.java | 5 +-
.../AbstractGatewaySenderEventProcessor.java | 2 +
.../cache/wan/serial/BatchDestroyOperation.java | 5 +-
...urrentSerialGatewaySenderEventProcessor.java | 3 +-
.../wan/serial/SerialGatewaySenderQueue.java | 2 +-
.../serial/SerialSecondaryGatewayListener.java | 19 +-
.../internal/i18n/ParentLocalizedStrings.java | 2 +-
.../gemfire/internal/lang/ThrowableUtils.java | 101 +
.../gemfire/internal/shared/NativeCalls.java | 2 +-
.../gemfire/internal/tcp/Connection.java | 5 +-
.../gemfire/management/internal/RestAgent.java | 51 +-
.../internal/cli/commands/ShellCommands.java | 2 +-
.../cli/functions/ShutDownFunction.java | 52 +-
.../com/gemstone/gemfire/TXExpiryJUnitTest.java | 6 +-
.../gemfire/cache/ConnectionPoolDUnitTest.java | 24 +-
.../pooling/ConnectionManagerJUnitTest.java | 8 +-
.../management/MemoryThresholdsDUnitTest.java | 4 +
.../MemoryThresholdsOffHeapDUnitTest.java | 9 +-
.../management/ResourceManagerDUnitTest.java | 16 +-
.../gemfire/cache/query/QueryTestUtils.java | 238 +-
.../cache/query/QueryTestUtilsJUnitTest.java | 1 +
.../query/dunit/CompactRangeIndexDUnitTest.java | 1 +
.../cache/query/dunit/HashIndexDUnitTest.java | 1 +
.../dunit/QueryDataInconsistencyDUnitTest.java | 12 +-
.../QueryUsingFunctionContextDUnitTest.java | 11 +-
.../query/dunit/QueryUsingPoolDUnitTest.java | 2714 ++++++++----------
.../cache/query/dunit/RemoteQueryDUnitTest.java | 3 +
.../query/dunit/SelectStarQueryDUnitTest.java | 216 +-
.../QueryREUpdateInProgressJUnitTest.java | 3 +-
.../index/CompactRangeIndexJUnitTest.java | 1 +
...pdateWithInplaceObjectModFalseDUnitTest.java | 9 +-
...itializeIndexEntryDestroyQueryDUnitTest.java | 14 +-
.../partitioned/PRQueryCacheCloseDUnitTest.java | 29 +-
.../gemfire/cache30/Bug44418JUnitTest.java | 10 +-
.../gemfire/cache30/CacheLogRollDUnitTest.java | 13 +-
.../cache30/ClientMembershipDUnitTest.java | 4 +
...iskDistributedNoAckAsyncRegionDUnitTest.java | 4 -
.../DiskDistributedNoAckRegionTestCase.java | 7 +-
...tributedAckPersistentRegionCCEDUnitTest.java | 80 +-
.../DistributedAckRegionCCEDUnitTest.java | 76 +-
.../cache30/DistributedAckRegionDUnitTest.java | 2 -
.../DistributedNoAckRegionCCEDUnitTest.java | 76 +-
.../DistributedNoAckRegionDUnitTest.java | 3 +-
.../gemfire/cache30/MultiVMRegionTestCase.java | 62 +-
.../cache30/PartitionedRegionDUnitTest.java | 6 +-
.../cache30/RegionReliabilityTestCase.java | 4 +
.../gemfire/cache30/RegionTestCase.java | 11 +-
.../gemfire/cache30/TXDistributedDUnitTest.java | 5 +-
.../gemfire/distributed/LocatorDUnitTest.java | 570 ++--
.../LocatorLauncherRemoteJUnitTest.java | 13 +-
.../ServerLauncherRemoteJUnitTest.java | 11 +-
.../internal/LocatorLoadSnapshotJUnitTest.java | 2 +
.../GemFireDeadlockDetectorDUnitTest.java | 12 +-
.../gms/membership/GMSJoinLeaveJUnitTest.java | 7 +-
.../gms/membership/GMSJoinLeaveTestHelper.java | 7 +-
.../gemfire/disttx/DistTXExpiryJUnitTest.java | 1 -
.../gemfire/internal/JSSESocketJUnitTest.java | 11 +-
...hreadPoolExecutorWithKeepAliveJUnitTest.java | 9 +-
.../cache/FixedPRSinglehopDUnitTest.java | 4 +
.../internal/cache/GIIDeltaDUnitTest.java | 9 +-
.../cache/NetSearchMessagingDUnitTest.java | 12 +-
.../gemfire/internal/cache/OplogJUnitTest.java | 13 +-
.../PartitionedRegionCreationDUnitTest.java | 17 +-
...rtitionedRegionDelayedRecoveryDUnitTest.java | 13 +-
.../PartitionedRegionSingleHopDUnitTest.java | 5 +
.../internal/cache/SingleHopStatsDUnitTest.java | 9 +-
.../internal/cache/UpdateVersionJUnitTest.java | 4 +-
...ributedRegionFunctionExecutionDUnitTest.java | 11 +-
...onFunctionExecutionNoSingleHopDUnitTest.java | 7 +-
.../PRFunctionExecutionTimeOutDUnitTest.java | 17 +-
.../internal/cache/ha/Bug48571DUnitTest.java | 6 +-
.../cache/ha/EventIdOptimizationDUnitTest.java | 5 +-
.../cache/ha/HARegionQueueDUnitTest.java | 14 +-
...tentColocatedPartitionedRegionDUnitTest.java | 16 +-
.../PersistentPartitionedRegionDUnitTest.java | 15 +-
...tentPartitionedRegionOldConfigDUnitTest.java | 6 +-
.../cache/partitioned/ShutdownAllDUnitTest.java | 10 +-
.../fixed/FixedPartitioningDUnitTest.java | 12 +-
.../PersistentRecoveryOrderDUnitTest.java | 6 +-
.../DestroyEntryPropagationDUnitTest.java | 19 +-
.../sockets/HAStartupAndFailoverDUnitTest.java | 21 +-
.../sockets/ReliableMessagingDUnitTest.java | 12 +-
.../sockets/UpdatePropagationDUnitTest.java | 17 +-
.../asyncqueue/AsyncEventListenerDUnitTest.java | 3 +
.../AsyncEventListenerOffHeapDUnitTest.java | 4 +-
.../internal/lang/ThrowableUtilsTest.java | 242 ++
.../management/DLockManagementDUnitTest.java | 22 +-
...ersalMembershipListenerAdapterDUnitTest.java | 5 +-
.../AbstractCommandsSupportJUnitTest.java | 16 +-
.../cli/commands/CliCommandTestBase.java | 108 +-
.../cli/commands/ConfigCommandsDUnitTest.java | 85 +-
...eateAlterDestroyRegionCommandsDUnitTest.java | 117 +-
.../cli/commands/DeployCommandsDUnitTest.java | 33 +-
.../commands/DiskStoreCommandsDUnitTest.java | 85 +-
.../commands/DiskStoreCommandsJUnitTest.java | 19 +-
.../cli/commands/FunctionCommandsDUnitTest.java | 97 +-
.../commands/GemfireDataCommandsDUnitTest.java | 269 +-
...WithCacheLoaderDuringCacheMissDUnitTest.java | 20 +-
.../HTTPServiceSSLSupportJUnitTest.java | 12 +-
.../cli/commands/IndexCommandsDUnitTest.java | 33 +-
.../cli/commands/IndexCommandsJUnitTest.java | 18 +-
...stAndDescribeDiskStoreCommandsDUnitTest.java | 23 +-
.../ListAndDescribeRegionDUnitTest.java | 52 +-
.../cli/commands/ListIndexCommandDUnitTest.java | 29 +-
.../cli/commands/MemberCommandsDUnitTest.java | 60 +-
.../MiscellaneousCommandsDUnitTest.java | 85 +-
...laneousCommandsExportLogsPart1DUnitTest.java | 37 +-
...laneousCommandsExportLogsPart2DUnitTest.java | 38 +-
...laneousCommandsExportLogsPart3DUnitTest.java | 41 +-
...laneousCommandsExportLogsPart4DUnitTest.java | 36 +-
.../cli/commands/QueueCommandsDUnitTest.java | 41 +-
.../SharedConfigurationCommandsDUnitTest.java | 55 +-
.../cli/commands/ShellCommandsDUnitTest.java | 94 +-
.../cli/commands/ShowDeadlockDUnitTest.java | 56 +-
.../cli/commands/ShowMetricsDUnitTest.java | 71 +-
.../cli/commands/ShowStackTraceDUnitTest.java | 43 +-
.../cli/commands/UserCommandsDUnitTest.java | 24 +-
.../SharedConfigurationUsingDirDUnitTest.java | 2 +
.../GemcachedDevelopmentJUnitTest.java | 2 +
.../pdx/DistributedSystemIdDUnitTest.java | 13 +-
.../gemfire/redis/RedisDistDUnitTest.java | 4 +
.../security/ClientAuthenticationDUnitTest.java | 8 +-
.../ClientAuthenticationPart2DUnitTest.java | 6 +-
.../security/ClientAuthenticationTestCase.java | 3 +
.../security/ClientAuthorizationDUnitTest.java | 16 +-
.../security/ClientAuthorizationTestCase.java | 26 +-
.../security/ClientMultiUserAuthzDUnitTest.java | 10 +-
.../DeltaClientAuthorizationDUnitTest.java | 10 +-
.../DeltaClientPostAuthorizationDUnitTest.java | 14 +-
.../security/GemFireSecurityExceptionTest.java | 6 +-
.../security/NotAuthorizedExceptionTest.java | 6 +-
.../security/P2PAuthenticationDUnitTest.java | 15 +-
.../gemfire/security/SecurityTestUtils.java | 13 +-
.../generator/AuthzCredentialGenerator.java | 15 +-
.../security/generator/CredentialGenerator.java | 3 +-
.../generator/DummyCredentialGenerator.java | 6 +-
.../generator/LdapUserCredentialGenerator.java | 15 +-
.../generator/PKCSCredentialGenerator.java | 8 +-
.../generator/SSLCredentialGenerator.java | 9 +-
.../UserPasswordWithExtraPropsAuthInit.java | 6 +-
.../generator/XmlAuthzCredentialGenerator.java | 10 +-
.../security/templates/DummyAuthorization.java | 8 +-
.../templates/LdapUserAuthenticator.java | 3 +-
.../security/templates/PKCSAuthInit.java | 3 +-
.../security/templates/PKCSAuthenticator.java | 3 +-
.../security/templates/PKCSPrincipalTest.java | 9 +-
.../templates/UserPasswordAuthInit.java | 4 +-
.../templates/UsernamePrincipalTest.java | 9 +-
.../security/templates/XmlAuthorization.java | 19 +-
.../security/templates/XmlErrorHandler.java | 5 +-
.../gemfire/test/dunit/AsyncInvocation.java | 511 +++-
.../gemfire/test/dunit/DistributedTestCase.java | 8 +-
.../test/dunit/DistributedTestUtils.java | 2 +-
.../gemfire/test/dunit/ThreadUtils.java | 13 +-
.../com/gemstone/gemfire/test/dunit/VM.java | 521 ++--
.../com/gemstone/gemfire/test/dunit/Wait.java | 2 +-
.../cache/internal/JUnit4CacheTestCase.java | 4 +-
.../internal/JUnit3DistributedTestCase.java | 9 +-
.../internal/JUnit4DistributedTestCase.java | 19 +-
.../internal/tests/JUnit3BasicDUnitTest.java | 189 --
.../JUnit3GetDefaultDiskStoreNameDUnitTest.java | 66 -
.../tests/JUnit3GetTestMethodNameDUnitTest.java | 53 -
.../dunit/internal/tests/JUnit3VMDUnitTest.java | 192 --
.../internal/tests/JUnit4BasicDUnitTest.java | 202 --
.../JUnit4GetDefaultDiskStoreNameDUnitTest.java | 65 -
.../tests/JUnit4GetTestMethodNameDUnitTest.java | 52 -
.../dunit/internal/tests/JUnit4VMDUnitTest.java | 200 --
.../DistributedRestoreSystemProperties.java | 3 +-
.../gemfire/test/dunit/rules/RemoteInvoker.java | 3 +-
.../gemfire/test/dunit/standalone/ChildVM.java | 5 +-
.../test/dunit/standalone/DUnitLauncher.java | 10 +-
.../test/dunit/standalone/ProcessManager.java | 7 +-
.../test/dunit/standalone/RemoteDUnitVM.java | 5 +-
.../test/dunit/standalone/RemoteDUnitVMIF.java | 4 +-
.../test/dunit/tests/BasicDUnitTest.java | 221 +-
.../tests/GetDefaultDiskStoreNameDUnitTest.java | 1 -
.../dunit/tests/GetTestMethodNameDUnitTest.java | 1 -
.../test/dunit/tests/JUnit4BasicDUnitTest.java | 234 ++
.../JUnit4GetDefaultDiskStoreNameDUnitTest.java | 66 +
.../tests/JUnit4GetTestMethodNameDUnitTest.java | 53 +
...ingGetPropertiesDisconnectsAllDUnitTest.java | 60 +
.../test/dunit/tests/JUnit4VMDUnitTest.java | 201 ++
...ingGetPropertiesDisconnectsAllDUnitTest.java | 3 +
.../cache/query/cq/dunit/CqPerfDUnitTest.java | 5 +-
.../cq/dunit/CqPerfUsingPoolDUnitTest.java | 9 +-
.../cache/query/cq/dunit/CqQueryDUnitTest.java | 2 +-
.../cq/dunit/CqQueryUsingPoolDUnitTest.java | 22 +-
.../query/cq/dunit/PrCqUsingPoolDUnitTest.java | 18 +-
.../query/dunit/QueryMonitorDUnitTest.java | 8 +-
.../cache/RemoteCQTransactionDUnitTest.java | 17 +-
.../sockets/DurableClientSimpleDUnitTest.java | 203 +-
.../tier/sockets/DurableClientTestCase.java | 1 -
.../cli/commands/ClientCommandsDUnitTest.java | 1813 +++++-------
.../DurableClientCommandsDUnitTest.java | 53 +-
.../ClientAuthorizationTwoDUnitTest.java | 8 +-
.../security/ClientAuthzObjectModDUnitTest.java | 48 +-
.../ClientCQPostAuthorizationDUnitTest.java | 16 +-
.../ClientPostAuthorizationDUnitTest.java | 28 +-
.../gemfire/security/MultiUserAPIDUnitTest.java | 8 +-
.../MultiUserDurableCQAuthzDUnitTest.java | 16 +-
.../test/junit/categories/FlakyTest.java | 24 +
.../test/junit/categories/SecurityTest.java | 23 +
.../gemfire/test/junit/rules/RetryRule.java | 2 +-
.../test/junit/categories/CategoryOne.java | 20 +
.../test/junit/categories/CategoryTest.java | 169 ++
.../test/junit/categories/CategoryTwo.java | 20 +
.../cache/lucene/LuceneServiceProvider.java | 9 +-
.../LuceneIndexForPartitionedRegion.java | 123 +-
.../internal/directory/RegionDirectory.java | 20 +-
.../lucene/internal/filesystem/FileSystem.java | 5 +
.../repository/IndexRepositoryImpl.java | 2 +-
.../repository/serializer/SerializerUtil.java | 16 +-
.../LuceneIndexForPartitionedRegionTest.java | 348 +++
.../LuceneIndexRecoveryHAJUnitTest.java | 25 +-
.../internal/LuceneServiceImplJUnitTest.java | 240 +-
.../IndexRepositoryImplPerformanceTest.java | 4 +-
geode-pulse/src/main/webapp/META-INF/NOTICE | 18 +-
geode-site/website/content/releases/index.html | 52 +
geode-spark-connector/doc/10_demos.md | 12 +-
geode-spark-connector/doc/1_building.md | 18 +-
geode-spark-connector/doc/2_quick.md | 26 +-
geode-spark-connector/doc/3_connecting.md | 38 +-
geode-spark-connector/doc/4_loading.md | 30 +-
geode-spark-connector/doc/5_rdd_join.md | 26 +-
geode-spark-connector/doc/6_save_rdd.md | 20 +-
geode-spark-connector/doc/7_save_dstream.md | 10 +-
geode-spark-connector/doc/8_oql.md | 8 +-
geode-spark-connector/doc/9_java_api.md | 36 +-
.../connector/internal/RegionMetadata.java | 93 -
.../gemfirefunctions/QueryFunction.java | 99 -
.../RetrieveRegionFunction.java | 208 --
.../RetrieveRegionMetadataFunction.java | 118 -
.../StructStreamingResultSender.java | 219 --
.../gemfire/spark/connector/Employee.java | 54 -
.../spark/connector/JavaApiIntegrationTest.java | 424 ---
.../gemfire/spark/connector/Portfolio.java | 109 -
.../gemfire/spark/connector/Position.java | 73 -
.../src/it/resources/test-regions.xml | 49 -
.../src/it/resources/test-retrieve-regions.xml | 57 -
.../spark/connector/BasicIntegrationTest.scala | 598 ----
.../RDDJoinRegionIntegrationTest.scala | 300 --
.../RetrieveRegionIntegrationTest.scala | 253 --
.../gemfire/spark/connector/package.scala | 29 -
.../connector/testkit/GemFireCluster.scala | 47 -
.../spark/connector/testkit/GemFireRunner.scala | 148 -
.../spark/connector/testkit/IOUtils.scala | 94 -
.../spark/streaming/ManualClockHelper.scala | 28 -
.../spark/streaming/TestInputDStream.scala | 44 -
.../javaapi/GemFireJavaDStreamFunctions.java | 86 -
.../GemFireJavaPairDStreamFunctions.java | 77 -
.../javaapi/GemFireJavaPairRDDFunctions.java | 238 --
.../javaapi/GemFireJavaRDDFunctions.java | 178 --
.../javaapi/GemFireJavaSQLContextFunctions.java | 49 -
.../GemFireJavaSparkContextFunctions.java | 87 -
.../connector/javaapi/GemFireJavaUtil.java | 122 -
.../spark/connector/GemFireConnection.scala | 67 -
.../spark/connector/GemFireConnectionConf.scala | 73 -
.../connector/GemFireConnectionManager.scala | 31 -
.../connector/GemFireFunctionDeployer.scala | 81 -
.../connector/GemFireKryoRegistrator.scala | 29 -
.../connector/GemFirePairRDDFunctions.scala | 140 -
.../spark/connector/GemFireRDDFunctions.scala | 120 -
.../connector/GemFireSQLContextFunctions.scala | 42 -
.../GemFireSparkContextFunctions.scala | 39 -
.../internal/DefaultGemFireConnection.scala | 164 --
.../DefaultGemFireConnectionManager.scala | 77 -
.../connector/internal/LocatorHelper.scala | 135 -
.../StructStreamingResultCollector.scala | 152 -
.../connector/internal/oql/QueryParser.scala | 58 -
.../spark/connector/internal/oql/QueryRDD.scala | 83 -
.../internal/oql/QueryResultCollector.scala | 69 -
.../connector/internal/oql/RDDConverter.scala | 40 -
.../connector/internal/oql/RowBuilder.scala | 38 -
.../connector/internal/oql/SchemaBuilder.scala | 73 -
.../internal/oql/UndefinedSerializer.scala | 46 -
.../connector/internal/rdd/GemFireJoinRDD.scala | 67 -
.../internal/rdd/GemFireOuterJoinRDD.scala | 69 -
.../internal/rdd/GemFireRDDPartition.scala | 36 -
.../internal/rdd/GemFireRDDPartitioner.scala | 59 -
.../rdd/GemFireRDDPartitionerImpl.scala | 89 -
.../internal/rdd/GemFireRDDWriter.scala | 82 -
.../internal/rdd/GemFireRegionRDD.scala | 138 -
.../javaapi/GemFireJavaRegionRDD.scala | 26 -
.../spark/connector/javaapi/JavaAPIHelper.scala | 53 -
.../gemfire/spark/connector/package.scala | 69 -
.../streaming/GemFireDStreamFunctions.scala | 89 -
.../spark/connector/streaming/package.scala | 32 -
.../gemfire/spark/connector/JavaAPITest.java | 163 --
.../connector/GemFireFunctionDeployerTest.scala | 58 -
.../DefaultGemFireConnectionManagerTest.scala | 82 -
...tStreamingResultSenderAndCollectorTest.scala | 254 --
.../internal/oql/QueryParserTest.scala | 83 -
.../connector/ConnectorImplicitsTest.scala | 50 -
.../connector/GemFireConnectionConfTest.scala | 100 -
.../connector/GemFireDStreamFunctionsTest.scala | 79 -
.../connector/GemFireRDDFunctionsTest.scala | 139 -
.../spark/connector/LocatorHelperTest.scala | 168 --
.../rdd/GemFireRDDPartitionerTest.scala | 190 --
.../connector/rdd/GemFireRegionRDDTest.scala | 117 -
.../basic-demos/src/main/java/demo/Emp.java | 95 -
.../src/main/java/demo/OQLJavaDemo.java | 59 -
.../src/main/java/demo/PairRDDSaveJavaDemo.java | 86 -
.../src/main/java/demo/RDDSaveJavaDemo.java | 85 -
.../src/main/java/demo/RegionToRDDJavaDemo.java | 57 -
.../src/main/scala/demo/NetworkWordCount.scala | 75 -
.../connector/internal/RegionMetadata.java | 93 +
.../internal/geodefunctions/QueryFunction.java | 99 +
.../geodefunctions/RetrieveRegionFunction.java | 208 ++
.../RetrieveRegionMetadataFunction.java | 118 +
.../StructStreamingResultSender.java | 219 ++
.../pivotal/geode/spark/connector/Employee.java | 54 +
.../spark/connector/JavaApiIntegrationTest.java | 424 +++
.../geode/spark/connector/Portfolio.java | 109 +
.../pivotal/geode/spark/connector/Position.java | 73 +
.../src/it/resources/test-regions.xml | 49 +
.../src/it/resources/test-retrieve-regions.xml | 57 +
.../spark/connector/BasicIntegrationTest.scala | 598 ++++
.../RDDJoinRegionIntegrationTest.scala | 300 ++
.../RetrieveRegionIntegrationTest.scala | 253 ++
.../pivotal/geode/spark/connector/package.scala | 29 +
.../spark/connector/testkit/GeodeCluster.scala | 47 +
.../spark/connector/testkit/GeodeRunner.scala | 148 +
.../geode/spark/connector/testkit/IOUtils.scala | 94 +
.../spark/streaming/ManualClockHelper.scala | 28 +
.../spark/streaming/TestInputDStream.scala | 44 +
.../javaapi/GeodeJavaDStreamFunctions.java | 86 +
.../javaapi/GeodeJavaPairDStreamFunctions.java | 77 +
.../javaapi/GeodeJavaPairRDDFunctions.java | 238 ++
.../javaapi/GeodeJavaRDDFunctions.java | 178 ++
.../javaapi/GeodeJavaSQLContextFunctions.java | 49 +
.../javaapi/GeodeJavaSparkContextFunctions.java | 87 +
.../spark/connector/javaapi/GeodeJavaUtil.java | 122 +
.../geode/spark/connector/GeodeConnection.scala | 67 +
.../spark/connector/GeodeConnectionConf.scala | 73 +
.../connector/GeodeConnectionManager.scala | 31 +
.../spark/connector/GeodeFunctionDeployer.scala | 81 +
.../spark/connector/GeodeKryoRegistrator.scala | 29 +
.../spark/connector/GeodePairRDDFunctions.scala | 140 +
.../spark/connector/GeodeRDDFunctions.scala | 120 +
.../connector/GeodeSQLContextFunctions.scala | 42 +
.../connector/GeodeSparkContextFunctions.scala | 39 +
.../internal/DefaultGeodeConnection.scala | 164 ++
.../DefaultGeodeConnectionManager.scala | 77 +
.../connector/internal/LocatorHelper.scala | 135 +
.../StructStreamingResultCollector.scala | 152 +
.../connector/internal/oql/QueryParser.scala | 58 +
.../spark/connector/internal/oql/QueryRDD.scala | 83 +
.../internal/oql/QueryResultCollector.scala | 69 +
.../connector/internal/oql/RDDConverter.scala | 40 +
.../connector/internal/oql/RowBuilder.scala | 38 +
.../connector/internal/oql/SchemaBuilder.scala | 73 +
.../internal/oql/UndefinedSerializer.scala | 46 +
.../connector/internal/rdd/GeodeJoinRDD.scala | 67 +
.../internal/rdd/GeodeOuterJoinRDD.scala | 69 +
.../internal/rdd/GeodeRDDPartition.scala | 36 +
.../internal/rdd/GeodeRDDPartitioner.scala | 59 +
.../internal/rdd/GeodeRDDPartitionerImpl.scala | 89 +
.../connector/internal/rdd/GeodeRDDWriter.scala | 82 +
.../connector/internal/rdd/GeodeRegionRDD.scala | 138 +
.../connector/javaapi/GeodeJavaRegionRDD.scala | 26 +
.../spark/connector/javaapi/JavaAPIHelper.scala | 53 +
.../pivotal/geode/spark/connector/package.scala | 69 +
.../streaming/GeodeDStreamFunctions.scala | 89 +
.../spark/connector/streaming/package.scala | 32 +
.../geode/spark/connector/JavaAPITest.java | 163 ++
.../connector/GeodeFunctionDeployerTest.scala | 58 +
.../DefaultGeodeConnectionManagerTest.scala | 82 +
...tStreamingResultSenderAndCollectorTest.scala | 254 ++
.../internal/oql/QueryParserTest.scala | 83 +
.../connector/ConnectorImplicitsTest.scala | 50 +
.../connector/GeodeConnectionConfTest.scala | 100 +
.../connector/GeodeDStreamFunctionsTest.scala | 79 +
.../spark/connector/GeodeRDDFunctionsTest.scala | 139 +
.../spark/connector/LocatorHelperTest.scala | 168 ++
.../connector/rdd/GeodeRDDPartitionerTest.scala | 190 ++
.../connector/rdd/GeodeRegionRDDTest.scala | 117 +
.../basic-demos/src/main/java/demo/Emp.java | 95 +
.../src/main/java/demo/OQLJavaDemo.java | 59 +
.../src/main/java/demo/PairRDDSaveJavaDemo.java | 86 +
.../src/main/java/demo/RDDSaveJavaDemo.java | 85 +
.../src/main/java/demo/RegionToRDDJavaDemo.java | 57 +
.../src/main/scala/demo/NetworkWordCount.scala | 75 +
.../project/Dependencies.scala | 8 +-
.../project/GemFireSparkBuild.scala | 76 -
.../project/GeodeSparkBuild.scala | 76 +
geode-spark-connector/project/Settings.scala | 4 +-
.../client/internal/GatewaySenderBatchOp.java | 9 +-
.../internal/locator/wan/LocatorDiscovery.java | 16 +-
.../locator/wan/WanLocatorDiscovererImpl.java | 19 +-
.../cache/CacheXml70GatewayDUnitTest.java | 22 +-
.../cache/CacheXml80GatewayDUnitTest.java | 4 +-
.../internal/cache/UpdateVersionDUnitTest.java | 4 +-
.../cache/wan/CacheClientNotifierDUnitTest.java | 6 +-
.../gemfire/internal/cache/wan/WANTestBase.java | 1866 ++----------
...oncurrentParallelGatewaySenderDUnitTest.java | 38 +-
...allelGatewaySenderOperation_1_DUnitTest.java | 27 +-
...allelGatewaySenderOperation_2_DUnitTest.java | 168 +-
.../ConcurrentWANPropogation_1_DUnitTest.java | 16 +-
.../ConcurrentWANPropogation_2_DUnitTest.java | 39 +-
.../cache/wan/disttx/DistTXWANDUnitTest.java | 10 +-
.../CommonParallelGatewaySenderDUnitTest.java | 8 +-
...wWANConcurrencyCheckForDestroyDUnitTest.java | 18 +-
.../cache/wan/misc/PDXNewWanDUnitTest.java | 31 +-
...dRegion_ParallelWANPersistenceDUnitTest.java | 19 +-
...dRegion_ParallelWANPropogationDUnitTest.java | 51 +-
...downAllPersistentGatewaySenderDUnitTest.java | 4 +-
.../wan/misc/WANConfigurationJUnitTest.java | 11 +-
.../cache/wan/misc/WANSSLDUnitTest.java | 6 +-
.../wan/misc/WanAutoDiscoveryDUnitTest.java | 42 +-
.../cache/wan/misc/WanValidationsDUnitTest.java | 27 +-
.../ParallelWANPropogationOffHeapDUnitTest.java | 3 +-
.../SerialWANPropogationOffHeapDUnitTest.java | 3 +-
...ation_PartitionedRegionOffHeapDUnitTest.java | 3 +-
...arallelGatewaySenderOperationsDUnitTest.java | 16 +-
...llelGatewaySenderQueueOverflowDUnitTest.java | 24 +-
.../ParallelWANConflationDUnitTest.java | 20 +-
...ersistenceEnabledGatewaySenderDUnitTest.java | 35 +-
...lelWANPropagationConcurrentOpsDUnitTest.java | 6 +-
.../ParallelWANPropagationDUnitTest.java | 51 +-
...ParallelWANPropagationLoopBackDUnitTest.java | 21 +-
.../wan/parallel/ParallelWANStatsDUnitTest.java | 23 +-
...tewaySenderDistributedDeadlockDUnitTest.java | 12 +-
...rialGatewaySenderEventListenerDUnitTest.java | 16 +-
.../SerialGatewaySenderOperationsDUnitTest.java | 25 +-
.../SerialGatewaySenderQueueDUnitTest.java | 6 +-
...ersistenceEnabledGatewaySenderDUnitTest.java | 14 +-
.../SerialWANPropagationLoopBackDUnitTest.java | 28 +-
.../serial/SerialWANPropogationDUnitTest.java | 119 +-
...NPropogation_PartitionedRegionDUnitTest.java | 24 +-
.../SerialWANPropogationsFeatureDUnitTest.java | 19 +-
.../wan/serial/SerialWANStatsDUnitTest.java | 49 +-
.../wan/wancommand/WANCommandTestBase.java | 35 +-
...anCommandCreateGatewayReceiverDUnitTest.java | 45 +-
.../WanCommandCreateGatewaySenderDUnitTest.java | 45 +-
...WanCommandGatewayReceiverStartDUnitTest.java | 39 +-
.../WanCommandGatewayReceiverStopDUnitTest.java | 37 +-
.../WanCommandGatewaySenderStartDUnitTest.java | 44 +-
.../WanCommandGatewaySenderStopDUnitTest.java | 39 +-
.../wan/wancommand/WanCommandListDUnitTest.java | 52 +-
.../WanCommandPauseResumeDUnitTest.java | 138 +-
.../wancommand/WanCommandStatusDUnitTest.java | 79 +-
.../management/WANManagementDUnitTest.java | 6 +-
.../ClusterConfigurationDUnitTest.java | 64 +-
.../pulse/TestRemoteClusterDUnitTest.java | 2 +-
.../web/swagger/config/RestApiPathProvider.java | 27 +-
geode-web-api/src/main/webapp/META-INF/NOTICE | 12 +-
gradle/dependency-versions.properties | 2 +-
gradle/publish.gradle | 35 +
gradle/utilities.gradle | 5 +
549 files changed, 17514 insertions(+), 19093 deletions(-)
----------------------------------------------------------------------
[2/4] incubator-geode git commit: GEODE-54: Missing Javadocs
Posted by ji...@apache.org.
GEODE-54: Missing Javadocs
Relocate javadocs to a consistently-named directory ('latest' rather than '<release-id>')
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/b2b4852b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/b2b4852b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/b2b4852b
Branch: refs/heads/feature/GEODE-17-2
Commit: b2b4852b0ec0a65362b33407633403fa9e16f308
Parents: f473fac
Author: Dave Barnes <db...@pivotal.io>
Authored: Mon Apr 25 11:54:18 2016 -0700
Committer: Dave Barnes <db...@pivotal.io>
Committed: Mon Apr 25 11:54:18 2016 -0700
----------------------------------------------------------------------
geode-site/website/content/docs/index.html | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/b2b4852b/geode-site/website/content/docs/index.html
----------------------------------------------------------------------
diff --git a/geode-site/website/content/docs/index.html b/geode-site/website/content/docs/index.html
index f848dc1..f7f4a50 100644
--- a/geode-site/website/content/docs/index.html
+++ b/geode-site/website/content/docs/index.html
@@ -35,7 +35,7 @@ under the License. -->
<p>Installation Instructions, User Manual, other product docs</p>
</div>
<div class="col-md-4">
- <h3><a href="http://geode.incubator.apache.org/releases/10M2SNAP/javadocs/index.html" style="color: #1275ff;">Javadocs</a></h3>
+ <h3><a href="http://geode.incubator.apache.org/releases/latest/javadoc/index.html" style="color: #1275ff;">Javadocs</a></h3>
<p>API Reference in conventional Javadoc format<p>
</div>
<div class="col-md-4">