You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by up...@apache.org on 2016/04/27 22:49:48 UTC
[02/25] incubator-geode git commit: GEODE-10: Reinstating HDFS
persistence code
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9f3f10fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/functions/DescribeHDFSStoreFunctionJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/functions/DescribeHDFSStoreFunctionJUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/functions/DescribeHDFSStoreFunctionJUnitTest.java
new file mode 100644
index 0000000..f3c66b0
--- /dev/null
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/functions/DescribeHDFSStoreFunctionJUnitTest.java
@@ -0,0 +1,364 @@
+/*=========================================================================
+ * Copyright (c) 2002-2014 Pivotal Software, Inc. All Rights Reserved.
+ * This product is protected by U.S. and international copyright
+ * and intellectual property laws. Pivotal products are covered by
+ * one or more patents listed at http://www.pivotal.io/patents.
+ *=========================================================================
+ */
+
+package com.gemstone.gemfire.management.internal.cli.functions;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertTrue;
+
+import java.util.Collections;
+import java.util.LinkedList;
+import java.util.List;
+
+import org.apache.logging.log4j.Logger;
+import org.jmock.Expectations;
+import org.jmock.Mockery;
+import org.jmock.lib.legacy.ClassImposteriser;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import com.gemstone.gemfire.cache.Cache;
+import com.gemstone.gemfire.cache.execute.FunctionContext;
+import com.gemstone.gemfire.cache.execute.ResultSender;
+import com.gemstone.gemfire.cache.hdfs.internal.HDFSStoreConfigHolder;
+import com.gemstone.gemfire.cache.hdfs.internal.HDFSStoreImpl;
+import com.gemstone.gemfire.distributed.DistributedMember;
+import com.gemstone.gemfire.internal.cache.GemFireCacheImpl;
+import com.gemstone.gemfire.internal.logging.LogService;
+import com.gemstone.gemfire.management.internal.cli.util.HDFSStoreNotFoundException;
+import com.gemstone.gemfire.test.junit.categories.HoplogTest;
+import com.gemstone.gemfire.test.junit.categories.IntegrationTest
+;
+
+/**
+ * The DescribeHDFSStoreFunctionJUnitTest test suite class tests the contract
+ * and functionality of the DescribeHDFSStoreFunction class. </p>
+ *
+ * @author Namrata Thanvi
+ * @see com.gemstone.gemfire.cache.hdfs.internal.HDFSStoreImpl
+ * @see com.gemstone.gemfire.cache.hdfs.internal.HDFSStoreConfigHolder
+ * @see com.gemstone.gemfire.management.internal.cli.functions.DescribeHDFSStoreFunction
+ * @see org.jmock.Expectations
+ * @see org.jmock.Mockery
+ * @see org.junit.Assert
+ * @see org.junit.Test
+ */
+@SuppressWarnings( { "unused" })
+@Category({IntegrationTest.class, HoplogTest.class})
+public class DescribeHDFSStoreFunctionJUnitTest {
+
+ private static final Logger logger = LogService.getLogger();
+
+ private Mockery mockContext;
+
+ @Before
+ public void setup() {
+ mockContext = new Mockery() {
+ {
+ setImposteriser(ClassImposteriser.INSTANCE);
+ }
+ };
+ }
+
+ @After
+ public void tearDown() {
+ mockContext.assertIsSatisfied();
+ mockContext = null;
+ }
+
+ @Test
+ public void testExecute() throws Throwable {
+ final String hdfsStoreName = "mockHdfsStore";
+ final String memberId = "mockMemberId";
+ final String memberName = "mockMemberName";
+
+ final GemFireCacheImpl mockCache = mockContext.mock(GemFireCacheImpl.class, "Cache");
+ final DistributedMember mockMember = mockContext.mock(DistributedMember.class, "DistributedMember");
+
+ final HDFSStoreImpl mockHdfsStore = createMockHDFSStore(hdfsStoreName, "hdfs://localhost:9000", "testDir", 1024, 20, .25f,
+ null, 20, 20, null, false, 0, 1024, false, false, true, 20, 20, 10, 100);
+
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "FunctionContext");
+ final LogService mockLogService = mockContext.mock(LogService.class, "LogService");
+
+ final TestResultSender testResultSender = new TestResultSender();
+
+ mockContext.checking(new Expectations() {
+ {
+ oneOf(mockCache).findHDFSStore(hdfsStoreName);
+ will(returnValue(mockHdfsStore));
+ oneOf(mockMember).getName();
+ will(returnValue(memberName));
+ oneOf(mockFunctionContext).getArguments();
+ will(returnValue(hdfsStoreName));
+ oneOf(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+ }
+ });
+
+ final DescribeHDFSStoreFunction function = createDescribeHDFSStoreFunction(mockCache, mockMember);
+
+ function.execute(mockFunctionContext);
+
+ final List<?> results = testResultSender.getResults();
+
+ assertNotNull(results);
+ assertEquals(1, results.size());
+
+ final HDFSStoreConfigHolder hdfsStoreDetails = (HDFSStoreConfigHolder)results.get(0);
+
+ assertNotNull(hdfsStoreDetails);
+ assertEquals(hdfsStoreName, hdfsStoreDetails.getName());
+ assertEquals("hdfs://localhost:9000", hdfsStoreDetails.getNameNodeURL());
+ assertEquals("testDir", hdfsStoreDetails.getHomeDir());
+ assertEquals(1024, hdfsStoreDetails.getWriteOnlyFileRolloverSize());
+ assertEquals(20, hdfsStoreDetails.getWriteOnlyFileRolloverInterval());
+ assertFalse(hdfsStoreDetails.getMinorCompaction());
+ assertEquals("0.25", Float.toString(hdfsStoreDetails.getBlockCacheSize()));
+ assertNull(hdfsStoreDetails.getHDFSClientConfigFile());
+ assertTrue(hdfsStoreDetails.getMajorCompaction());
+ assertEquals(20, hdfsStoreDetails.getMajorCompactionInterval());
+ assertEquals(20, hdfsStoreDetails.getMajorCompactionThreads());
+ assertEquals(10, hdfsStoreDetails.getMinorCompactionThreads());
+ assertEquals(100, hdfsStoreDetails.getPurgeInterval());
+
+ assertEquals(20, hdfsStoreDetails.getBatchSize());
+ assertEquals(20, hdfsStoreDetails.getBatchInterval());
+ assertNull(hdfsStoreDetails.getDiskStoreName());
+ assertFalse(hdfsStoreDetails.getSynchronousDiskWrite());
+ assertEquals(0, hdfsStoreDetails.getDispatcherThreads());
+ assertEquals(1024, hdfsStoreDetails.getMaxMemory());
+ assertFalse(hdfsStoreDetails.getBufferPersistent());
+ }
+
+
+ @Test
+ public void testExecuteOnMemberHavingANonGemFireCache() throws Throwable {
+ final Cache mockCache = mockContext.mock(Cache.class, "Cache");
+
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "FunctionContext");
+ final DistributedMember mockMember = mockContext.mock(DistributedMember.class, "DistributedMember");
+ final TestResultSender testResultSender = new TestResultSender();
+
+ mockContext.checking(new Expectations() {{
+ exactly(0).of(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+
+ }});
+
+ final DescribeHDFSStoreFunction function = createDescribeHDFSStoreFunction(mockCache , mockMember);
+
+ function.execute(mockFunctionContext);
+
+ final List<?> results = testResultSender.getResults();
+
+ assertNotNull(results);
+ assertTrue(results.isEmpty());
+ }
+
+
+ @Test(expected = HDFSStoreNotFoundException.class)
+ public void testExecuteThrowingResourceNotFoundException() throws Throwable{
+ final String hdfsStoreName = "testHdfsStore";
+ final String memberId = "mockMemberId";
+ final String memberName = "mockMemberName";
+
+ final GemFireCacheImpl mockCache = mockContext.mock(GemFireCacheImpl.class, "Cache");
+
+ final DistributedMember mockMember = mockContext.mock(DistributedMember.class, "DistributedMember");
+
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "FunctionContext");
+
+ final TestResultSender testResultSender = new TestResultSender();
+
+ mockContext.checking(new Expectations() {{
+ oneOf(mockCache).findHDFSStore(hdfsStoreName);
+ will(returnValue(null));
+ oneOf(mockMember).getName();
+ will(returnValue(memberName));
+ oneOf(mockFunctionContext).getArguments();
+ will(returnValue(hdfsStoreName));
+ oneOf(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+ }});
+
+ final DescribeHDFSStoreFunction function = createDescribeHDFSStoreFunction(mockCache,mockMember);
+
+ function.execute(mockFunctionContext);
+
+ try {
+ testResultSender.getResults();
+ }
+ catch (HDFSStoreNotFoundException e) {
+ assertEquals(String.format("A hdfs store with name (%1$s) was not found on member (%2$s).",
+ hdfsStoreName, memberName), e.getMessage());
+ throw e;
+ }
+ }
+
+
+ @Test(expected = RuntimeException.class)
+ public void testExecuteThrowingRuntimeException() throws Throwable {
+ final String hdfsStoreName = "testHdfsStore";
+ final String memberId = "mockMemberId";
+ final String memberName = "mockMemberName";
+
+ final GemFireCacheImpl mockCache = mockContext.mock(GemFireCacheImpl.class, "Cache");
+
+ final DistributedMember mockMember = mockContext.mock(DistributedMember.class, "DistributedMember");
+
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "FunctionContext");
+
+ final TestResultSender testResultSender = new TestResultSender();
+
+ mockContext.checking(new Expectations() {{
+ oneOf(mockCache).findHDFSStore(hdfsStoreName);
+ will(throwException(new RuntimeException("ExpectedStrings")));
+ oneOf(mockMember).getName();
+ will(returnValue(memberName));
+ oneOf(mockFunctionContext).getArguments();
+ will(returnValue(hdfsStoreName));
+ oneOf(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+ }});
+
+ final DescribeHDFSStoreFunction function = createDescribeHDFSStoreFunction(mockCache, mockMember);
+
+ function.execute(mockFunctionContext);
+
+ try {
+ testResultSender.getResults();
+ }
+ catch (RuntimeException e) {
+ assertEquals("ExpectedStrings", e.getMessage());
+ throw e;
+ }
+ }
+
+
+ protected HDFSStoreImpl createMockHDFSStore(final String storeName, final String namenode, final String homeDir,
+ final int maxFileSize, final int fileRolloverInterval, final float blockCachesize, final String clientConfigFile,
+ final int batchSize, final int batchInterval, final String diskStoreName, final boolean syncDiskwrite,
+ final int dispatcherThreads, final int maxMemory, final boolean bufferPersistent, final boolean minorCompact,
+ final boolean majorCompact, final int majorCompactionInterval, final int majorCompactionThreads,
+ final int minorCompactionThreads, final int purgeInterval) {
+
+ final HDFSStoreImpl mockHdfsStore = mockContext.mock(HDFSStoreImpl.class, storeName);
+
+ mockContext.checking(new Expectations() {
+ {
+ oneOf(mockHdfsStore).getMajorCompaction();
+ will(returnValue(majorCompact));
+ oneOf(mockHdfsStore).getMajorCompactionInterval();
+ will(returnValue(majorCompactionInterval));
+ oneOf(mockHdfsStore).getMajorCompactionThreads();
+ will(returnValue(majorCompactionThreads));
+ oneOf(mockHdfsStore).getMinorCompactionThreads();
+ will(returnValue(minorCompactionThreads));
+ oneOf(mockHdfsStore).getPurgeInterval();
+ will(returnValue(purgeInterval));
+ oneOf(mockHdfsStore).getInputFileCountMax();
+ will(returnValue(10));
+ oneOf(mockHdfsStore).getInputFileSizeMax();
+ will(returnValue(1024));
+ oneOf(mockHdfsStore).getInputFileCountMin();
+ will(returnValue(2));
+ oneOf(mockHdfsStore).getBatchSize();
+ will(returnValue(batchSize));
+ oneOf(mockHdfsStore).getBatchInterval();
+ will(returnValue(batchInterval));
+ oneOf(mockHdfsStore).getDiskStoreName();
+ will(returnValue(diskStoreName));
+ oneOf(mockHdfsStore).getSynchronousDiskWrite();
+ will(returnValue(syncDiskwrite));
+ oneOf(mockHdfsStore).getBufferPersistent();
+ will(returnValue(bufferPersistent));
+ oneOf(mockHdfsStore).getDispatcherThreads();
+ will(returnValue(dispatcherThreads));
+ oneOf(mockHdfsStore).getMaxMemory();
+ will(returnValue(maxMemory));
+ oneOf(mockHdfsStore).getName();
+ will(returnValue(storeName));
+ oneOf(mockHdfsStore).getNameNodeURL();
+ will(returnValue(namenode));
+ oneOf(mockHdfsStore).getHomeDir();
+ will(returnValue(homeDir));
+ oneOf(mockHdfsStore).getWriteOnlyFileRolloverSize();
+ will(returnValue(maxFileSize));
+ oneOf(mockHdfsStore).getWriteOnlyFileRolloverInterval();
+ will(returnValue(fileRolloverInterval));
+ oneOf(mockHdfsStore).getMinorCompaction();
+ will(returnValue(minorCompact));
+ oneOf(mockHdfsStore).getBlockCacheSize();
+ will(returnValue(blockCachesize));
+ allowing(mockHdfsStore).getHDFSClientConfigFile();
+ will(returnValue(clientConfigFile));
+ }
+ });
+ return mockHdfsStore;
+ }
+
+ protected TestDescribeHDFSStoreFunction createDescribeHDFSStoreFunction(final Cache cache, DistributedMember member) {
+ return new TestDescribeHDFSStoreFunction(cache, member);
+ }
+
+ protected static class TestDescribeHDFSStoreFunction extends DescribeHDFSStoreFunction {
+ private static final long serialVersionUID = 1L;
+
+ private final Cache cache;
+
+ private final DistributedMember member;
+
+ public TestDescribeHDFSStoreFunction(final Cache cache, DistributedMember member) {
+ this.cache = cache;
+ this.member = member;
+ }
+
+ @Override
+ protected Cache getCache() {
+ return this.cache;
+ }
+
+ @Override
+ protected DistributedMember getDistributedMemberId(Cache cache) {
+ return member;
+ }
+ }
+
+ protected static class TestResultSender implements ResultSender {
+
+ private final List<Object> results = new LinkedList<Object>();
+
+ private Throwable t;
+
+ protected List<Object> getResults() throws Throwable {
+ if (t != null) {
+ throw t;
+ }
+ return Collections.unmodifiableList(results);
+ }
+
+ public void lastResult(final Object lastResult) {
+ results.add(lastResult);
+ }
+
+ public void sendResult(final Object oneResult) {
+ results.add(oneResult);
+ }
+
+ public void sendException(final Throwable t) {
+ this.t = t;
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9f3f10fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/functions/DestroyHDFSStoreFunctionJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/functions/DestroyHDFSStoreFunctionJUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/functions/DestroyHDFSStoreFunctionJUnitTest.java
new file mode 100644
index 0000000..08e18ec
--- /dev/null
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/functions/DestroyHDFSStoreFunctionJUnitTest.java
@@ -0,0 +1,305 @@
+/*=========================================================================
+ * Copyright (c) 2002-2014 Pivotal Software, Inc. All Rights Reserved.
+ * This product is protected by U.S. and international copyright
+ * and intellectual property laws. Pivotal products are covered by
+ * one or more patents listed at http://www.pivotal.io/patents.
+ *=========================================================================
+ */
+
+package com.gemstone.gemfire.management.internal.cli.functions;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
+
+import java.util.Collections;
+import java.util.LinkedList;
+import java.util.List;
+
+import org.apache.logging.log4j.Logger;
+import org.jmock.Expectations;
+import org.jmock.Mockery;
+import org.jmock.lib.legacy.ClassImposteriser;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import com.gemstone.gemfire.cache.Cache;
+import com.gemstone.gemfire.cache.CacheClosedException;
+import com.gemstone.gemfire.cache.execute.FunctionContext;
+import com.gemstone.gemfire.cache.execute.ResultSender;
+import com.gemstone.gemfire.cache.hdfs.internal.HDFSStoreImpl;
+import com.gemstone.gemfire.distributed.DistributedMember;
+import com.gemstone.gemfire.internal.cache.GemFireCacheImpl;
+import com.gemstone.gemfire.internal.logging.LogService;
+import com.gemstone.gemfire.management.internal.configuration.domain.XmlEntity;
+import com.gemstone.gemfire.test.junit.categories.HoplogTest;
+import com.gemstone.gemfire.test.junit.categories.IntegrationTest
+;
+
+/**
+ * The DestroyHDFSStoreFunctionJUnitTest test suite class tests the contract and
+ * functionality of the DestroyHDFSStoreFunction class. </p>
+ *
+ * @author Namrata Thanvi
+ * @see com.gemstone.gemfire.cache.hdfs.internal.HDFSStoreImpl
+ * @see com.gemstone.gemfire.cache.hdfs.internal.HDFSStoreConfigHolder
+ * @see com.gemstone.gemfire.management.internal.cli.functions.DestroyHDFSStoreFunction
+ * @see org.jmock.Expectations
+ * @see org.jmock.Mockery
+ * @see org.junit.Assert
+ * @see org.junit.Test
+ */
+@SuppressWarnings( { "unused" })
+@Category({IntegrationTest.class, HoplogTest.class})
+public class DestroyHDFSStoreFunctionJUnitTest {
+
+ private static final Logger logger = LogService.getLogger();
+
+ private Mockery mockContext;
+
+ @Before
+ public void setup() {
+ mockContext = new Mockery() {
+ {
+ setImposteriser(ClassImposteriser.INSTANCE);
+ }
+ };
+ }
+
+ @After
+ public void tearDown() {
+ mockContext.assertIsSatisfied();
+ mockContext = null;
+ }
+
+ @Test
+ public void testExecute() throws Throwable {
+ final GemFireCacheImpl mockCache = mockContext.mock(GemFireCacheImpl.class, "Cache");
+ final DistributedMember mockMember = mockContext.mock(DistributedMember.class, "DistributedMember");
+ final XmlEntity xmlEntity = mockContext.mock(XmlEntity.class, "XmlEntity");
+ final HDFSStoreImpl mockHdfsStore = mockContext.mock(HDFSStoreImpl.class, "HDFSStoreImpl");
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "FunctionContext");
+
+ final String hdfsStoreName = "mockHdfsStore";
+ final String memberId = "mockMemberId";
+ final String memberName = "mockMemberName";
+ final TestResultSender testResultSender = new TestResultSender();
+ final DestroyHDFSStoreFunction function = createDestroyHDFSStoreFunction(mockCache, mockMember, xmlEntity);
+
+ mockContext.checking(new Expectations() {
+ {
+ oneOf(mockCache).findHDFSStore(hdfsStoreName);
+ will(returnValue(mockHdfsStore));
+ one(mockHdfsStore).destroy();
+ oneOf(mockMember).getId();
+ will(returnValue(memberId));
+ exactly(2).of(mockMember).getName();
+ will(returnValue(memberName));
+ oneOf(mockFunctionContext).getArguments();
+ will(returnValue(hdfsStoreName));
+ oneOf(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+ }
+ });
+
+ function.execute(mockFunctionContext);
+
+ final List<?> results = testResultSender.getResults();
+
+ assertNotNull(results);
+ assertEquals(1, results.size());
+
+ final CliFunctionResult result = (CliFunctionResult)results.get(0);
+ assertEquals(memberName, result.getMemberIdOrName());
+ assertEquals("Success", result.getMessage());
+
+ }
+
+ @Test
+ @SuppressWarnings("unchecked")
+ public void testExecuteOnMemberHavingNoHDFSStore() throws Throwable {
+ final String hdfsStoreName = "mockHdfsStore";
+ final String memberId = "mockMemberId";
+ final String memberName = "mockMemberName";
+
+ final GemFireCacheImpl mockCache = mockContext.mock(GemFireCacheImpl.class, "Cache");
+ final DistributedMember mockMember = mockContext.mock(DistributedMember.class, "DistributedMember");
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "FunctionContext");
+ final XmlEntity xmlEntity = mockContext.mock(XmlEntity.class, "XmlEntity");
+
+ final TestResultSender testResultSender = new TestResultSender();
+ final DestroyHDFSStoreFunction function = createDestroyHDFSStoreFunction(mockCache, mockMember, xmlEntity);
+
+ mockContext.checking(new Expectations() {
+ {
+ oneOf(mockCache).findHDFSStore(hdfsStoreName);
+ will(returnValue(null));
+ oneOf(mockMember).getId();
+ will(returnValue(memberId));
+ exactly(2).of(mockMember).getName();
+ will(returnValue(memberName));
+ oneOf(mockFunctionContext).getArguments();
+ will(returnValue(hdfsStoreName));
+ oneOf(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+ }
+ });
+
+ function.execute(mockFunctionContext);
+
+ final List<?> results = testResultSender.getResults();
+
+ assertNotNull(results);
+ assertEquals(1, results.size());
+
+ final CliFunctionResult result = (CliFunctionResult)results.get(0);
+ assertEquals(memberName, result.getMemberIdOrName());
+ assertEquals("Hdfs store not found on this member", result.getMessage());
+ }
+
+ @Test
+ public void testExecuteOnMemberWithNoCache() throws Throwable {
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "MockFunctionContext");
+ final DistributedMember mockMember = mockContext.mock(DistributedMember.class, "DistributedMember");
+ final GemFireCacheImpl mockCache = mockContext.mock(GemFireCacheImpl.class, "Cache");
+ final XmlEntity xmlEntity = mockContext.mock(XmlEntity.class, "XmlEntity");
+
+ final String hdfsStoreName = "mockHdfsStore";
+
+ final TestResultSender testResultSender = new TestResultSender();
+ final DestroyHDFSStoreFunction function = new TestDestroyHDFSStoreFunction(mockCache, mockMember, xmlEntity) {
+ private static final long serialVersionUID = 1L;
+
+ @Override
+ protected Cache getCache() {
+ throw new CacheClosedException("Expected");
+ }
+ };
+
+ mockContext.checking(new Expectations() {
+ {
+ oneOf(mockFunctionContext).getArguments();
+ will(returnValue(hdfsStoreName));
+ oneOf(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+ }
+ });
+
+ function.execute(mockFunctionContext);
+ final List<?> results = testResultSender.getResults();
+
+ assertNotNull(results);
+ assertEquals(1, results.size());
+
+ final CliFunctionResult result = (CliFunctionResult)results.get(0);
+ assertEquals("", result.getMemberIdOrName());
+ assertNull(result.getMessage());
+ }
+
+ @Test
+ public void testExecuteHandleRuntimeException() throws Throwable {
+ final GemFireCacheImpl mockCache = mockContext.mock(GemFireCacheImpl.class, "Cache");
+ final DistributedMember mockMember = mockContext.mock(DistributedMember.class, "DistributedMember");
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "FunctionContext");
+ final XmlEntity xmlEntity = mockContext.mock(XmlEntity.class, "XmlEntity");
+
+ final String hdfsStoreName = "mockHdfsStore";
+ final String memberId = "mockMemberId";
+ final String memberName = "mockMemberName";
+
+ final TestResultSender testResultSender = new TestResultSender();
+ final DestroyHDFSStoreFunction function = createDestroyHDFSStoreFunction(mockCache, mockMember, xmlEntity);
+
+ mockContext.checking(new Expectations() {
+ {
+ oneOf(mockMember).getId();
+ will(returnValue(memberId));
+ exactly(2).of(mockMember).getName();
+ will(returnValue(memberName));
+ oneOf(mockFunctionContext).getArguments();
+ will(returnValue(hdfsStoreName));
+ oneOf(mockCache).findHDFSStore(hdfsStoreName);
+ will(throwException(new RuntimeException("expected")));
+ oneOf(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+ }
+ });
+
+ function.execute(mockFunctionContext);
+ final List<?> results = testResultSender.getResults();
+
+ assertNotNull(results);
+ assertEquals(1, results.size());
+
+ final CliFunctionResult result = (CliFunctionResult)results.get(0);
+ assertEquals(memberName, result.getMemberIdOrName());
+ assertEquals("expected", result.getThrowable().getMessage());
+
+ }
+
+ protected TestDestroyHDFSStoreFunction createDestroyHDFSStoreFunction(final Cache cache, DistributedMember member,
+ XmlEntity xml) {
+ return new TestDestroyHDFSStoreFunction(cache, member, xml);
+ }
+
+ protected static class TestDestroyHDFSStoreFunction extends DestroyHDFSStoreFunction {
+ private static final long serialVersionUID = 1L;
+
+ private final Cache cache;
+
+ private final DistributedMember member;
+
+ private final XmlEntity xml;
+
+ public TestDestroyHDFSStoreFunction(final Cache cache, DistributedMember member, XmlEntity xml) {
+ this.cache = cache;
+ this.member = member;
+ this.xml = xml;
+ }
+
+ @Override
+ protected Cache getCache() {
+ return this.cache;
+ }
+
+ @Override
+ protected DistributedMember getDistributedMember(Cache cache) {
+ return member;
+ }
+
+ @Override
+ protected XmlEntity getXMLEntity(String storeName) {
+ return xml;
+ }
+
+ }
+
+ protected static class TestResultSender implements ResultSender {
+
+ private final List<Object> results = new LinkedList<Object>();
+
+ private Throwable t;
+
+ protected List<Object> getResults() throws Throwable {
+ if (t != null) {
+ throw t;
+ }
+ return Collections.unmodifiableList(results);
+ }
+
+ public void lastResult(final Object lastResult) {
+ results.add(lastResult);
+ }
+
+ public void sendResult(final Object oneResult) {
+ results.add(oneResult);
+ }
+
+ public void sendException(final Throwable t) {
+ this.t = t;
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9f3f10fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/functions/ListHDFSStoresFunctionJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/functions/ListHDFSStoresFunctionJUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/functions/ListHDFSStoresFunctionJUnitTest.java
new file mode 100644
index 0000000..11bc430
--- /dev/null
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/functions/ListHDFSStoresFunctionJUnitTest.java
@@ -0,0 +1,319 @@
+/*=========================================================================
+ * Copyright (c) 2002-2014 Pivotal Software, Inc. All Rights Reserved.
+ * This product is protected by U.S. and international copyright
+ * and intellectual property laws. Pivotal products are covered by
+ * one or more patents listed at http://www.pivotal.io/patents.
+ *=========================================================================
+ */
+
+package com.gemstone.gemfire.management.internal.cli.functions;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Set;
+
+import org.jmock.Expectations;
+import org.jmock.Mockery;
+import org.jmock.lib.legacy.ClassImposteriser;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import com.gemstone.gemfire.cache.Cache;
+import com.gemstone.gemfire.cache.CacheClosedException;
+import com.gemstone.gemfire.cache.execute.FunctionContext;
+import com.gemstone.gemfire.cache.execute.ResultSender;
+import com.gemstone.gemfire.cache.hdfs.internal.HDFSStoreImpl;
+import com.gemstone.gemfire.distributed.DistributedMember;
+import com.gemstone.gemfire.internal.cache.GemFireCacheImpl;
+import com.gemstone.gemfire.management.internal.cli.functions.ListHDFSStoresFunction.HdfsStoreDetails;
+import com.gemstone.gemfire.test.junit.categories.HoplogTest;
+import com.gemstone.gemfire.test.junit.categories.IntegrationTest;
+
+/**
+ * The ListHDFSStoreFunctionJUnitTest test suite class tests the contract and functionality of the
+ * ListHDFSStoreFunction.
+ * </p>
+ * @author Namrata Thanvi
+ * @see com.gemstone.gemfire.cache.hdfs.internal.HDFSStoreImpl
+ * @see com.gemstone.gemfire.cache.hdfs.internal.HDFSStoreConfigHolder
+ * @see com.gemstone.gemfire.management.internal.cli.functions.ListHDFSStoresFunction
+ * @see org.jmock.Expectations
+ * @see org.jmock.Mockery
+ * @see org.junit.Assert
+ * @see org.junit.Test
+ */
+
+@Category({IntegrationTest.class, HoplogTest.class})
+public class ListHDFSStoresFunctionJUnitTest {
+ private Mockery mockContext;
+
+ @Before
+ public void setup() {
+ mockContext = new Mockery() {
+ {
+ setImposteriser(ClassImposteriser.INSTANCE);
+ }
+ };
+ }
+
+ @After
+ public void tearDown() {
+ mockContext.assertIsSatisfied();
+ mockContext = null;
+ }
+
+
+ @Test
+ public void testExecute() throws Throwable {
+ final String memberId = "mockMemberId";
+ final String memberName = "mockMemberName";
+ final GemFireCacheImpl mockCache = mockContext.mock(GemFireCacheImpl.class, "Cache");
+ final DistributedMember mockMember = mockContext.mock(DistributedMember.class, "DistributedMember");
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "FunctionContext");
+ final TestResultSender testResultSender = new TestResultSender();
+
+ final HDFSStoreImpl mockHdfsStoreOne = mockContext.mock(HDFSStoreImpl.class, "HDFSStoreOne");
+ final HDFSStoreImpl mockHdfsStoreTwo = mockContext.mock(HDFSStoreImpl.class, "HDFSStoreTwo");
+ final HDFSStoreImpl mockHdfsStoreThree = mockContext.mock(HDFSStoreImpl.class, "HDFSStoreThree");
+
+ final List<HDFSStoreImpl> mockHdfsStores = new ArrayList<HDFSStoreImpl>();
+
+ mockHdfsStores.add(mockHdfsStoreOne);
+ mockHdfsStores.add(mockHdfsStoreTwo);
+ mockHdfsStores.add(mockHdfsStoreThree);
+
+ final List<String> storeNames = new ArrayList<String>();
+ storeNames.add("hdfsStoreOne");
+ storeNames.add("hdfsStoreTwo");
+ storeNames.add("hdfsStoreThree");
+
+ mockContext.checking(new Expectations() {
+ {
+ oneOf(mockCache).getHDFSStores();
+ will(returnValue(mockHdfsStores));
+ exactly(3).of(mockMember).getId();
+ will(returnValue(memberId));
+ exactly(3).of(mockMember).getName();
+ will(returnValue(memberName));
+ oneOf(mockHdfsStoreOne).getName();
+ will(returnValue(storeNames.get(0)));
+ oneOf(mockHdfsStoreTwo).getName();
+ will(returnValue(storeNames.get(1)));
+ oneOf(mockHdfsStoreThree).getName();
+ will(returnValue(storeNames.get(2)));
+ oneOf(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+ }
+ });
+
+ final ListHDFSStoresFunction function = createListHDFSStoresFunction(mockCache, mockMember);
+
+ function.execute(mockFunctionContext);
+
+ final List<?> results = testResultSender.getResults();
+
+ assertNotNull(results);
+ assertEquals(1, results.size());
+
+ final Set<HdfsStoreDetails> listHdfsStoreFunctionresults = (Set<HdfsStoreDetails>)results.get(0);
+
+ assertNotNull(listHdfsStoreFunctionresults);
+ assertEquals(3, listHdfsStoreFunctionresults.size());
+
+ Collections.sort(storeNames);
+
+ for (HdfsStoreDetails listHdfsStoreFunctionresult : listHdfsStoreFunctionresults) {
+ assertTrue(storeNames.contains(listHdfsStoreFunctionresult.getStoreName()));
+ assertTrue(storeNames.remove(listHdfsStoreFunctionresult.getStoreName()));
+ assertEquals(memberId, listHdfsStoreFunctionresult.getMemberId());
+ assertEquals(memberName, listHdfsStoreFunctionresult.getMemberName());
+ }
+ }
+
+
+ @Test(expected = CacheClosedException.class)
+ public void testExecuteOnMemberWithNoCache() throws Throwable {
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "MockFunctionContext");
+ final DistributedMember mockMember = mockContext.mock(DistributedMember.class, "DistributedMember");
+ final TestListHDFSStoresFunction testListHdfsStoresFunction =
+ new TestListHDFSStoresFunction(mockContext.mock(Cache.class, "MockCache"), mockMember) {
+ @Override protected Cache getCache() {
+ throw new CacheClosedException("Expected");
+ }
+ };
+
+ final TestResultSender testResultSender = new TestResultSender();
+
+ mockContext.checking(new Expectations() {{
+ oneOf(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+ }});
+
+ testListHdfsStoresFunction.execute(mockFunctionContext);
+
+ try {
+ testResultSender.getResults();
+ }
+ catch (CacheClosedException expected) {
+ assertEquals("Expected", expected.getMessage());
+ throw expected;
+ }
+ }
+
+ @Test
+ @SuppressWarnings("unchecked")
+ public void testExecuteOnMemberHavingNoHDFSStores() throws Throwable {
+ final GemFireCacheImpl mockCache = mockContext.mock(GemFireCacheImpl.class, "Cache");
+ final DistributedMember mockMember = mockContext.mock(DistributedMember.class, "DistributedMember");
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "FunctionContext");
+
+ final TestResultSender testResultSender = new TestResultSender();
+
+ mockContext.checking(new Expectations() {{
+ oneOf(mockCache).getHDFSStores();
+ will(returnValue(Collections.emptyList()));
+ oneOf(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+ }});
+
+ final ListHDFSStoresFunction function = createListHDFSStoresFunction(mockCache, mockMember);
+
+ function.execute(mockFunctionContext);
+
+ final List<?> results = testResultSender.getResults();
+
+ assertNotNull(results);
+ assertEquals(1, results.size());
+
+ final Set<HdfsStoreDetails> hdfsStoreDetails = (Set<HdfsStoreDetails>) results.get(0);
+
+ assertNotNull(hdfsStoreDetails);
+ assertTrue(hdfsStoreDetails.isEmpty());
+ }
+
+ @Test
+ @SuppressWarnings("unchecked")
+ public void testExecuteOnMemberWithANonGemFireCache() throws Throwable {
+ final Cache mockCache = mockContext.mock(Cache.class, "Cache");
+
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "FunctionContext");
+
+ final TestResultSender testResultSender = new TestResultSender();
+
+ mockContext.checking(new Expectations() {
+ {
+ oneOf(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+ }
+ });
+
+ final ListHDFSStoresFunction function = createListHDFSStoresFunction(mockCache, null);
+
+ function.execute(mockFunctionContext);
+
+ final List<?> results = testResultSender.getResults();
+
+ assertNotNull(results);
+ assertEquals(1, results.size());
+
+ final Set<HdfsStoreDetails> hdfsStoreDetails = (Set<HdfsStoreDetails>)results.get(0);
+
+ assertNotNull(hdfsStoreDetails);
+ assertTrue(hdfsStoreDetails.isEmpty());
+ }
+
+
+ @Test(expected = RuntimeException.class)
+ public void testExecuteThrowsRuntimeException() throws Throwable {
+ final GemFireCacheImpl mockCache = mockContext.mock(GemFireCacheImpl.class, "Cache");
+
+ final DistributedMember mockMember = mockContext.mock(DistributedMember.class, "DistributedMember");
+
+ final FunctionContext mockFunctionContext = mockContext.mock(FunctionContext.class, "FunctionContext");
+
+ final TestResultSender testResultSender = new TestResultSender();
+
+ mockContext.checking(new Expectations() {
+ {
+ oneOf(mockCache).getHDFSStores();
+ will(throwException(new RuntimeException("expected")));
+ oneOf(mockFunctionContext).getResultSender();
+ will(returnValue(testResultSender));
+ }
+ });
+
+ final ListHDFSStoresFunction function = createListHDFSStoresFunction(mockCache, mockMember);
+
+ function.execute(mockFunctionContext);
+
+ try {
+ testResultSender.getResults();
+ } catch (Throwable throwable) {
+ assertTrue(throwable instanceof RuntimeException);
+ assertEquals("expected", throwable.getMessage());
+ throw throwable;
+ }
+ }
+
+ protected ListHDFSStoresFunction createListHDFSStoresFunction(final Cache cache, DistributedMember member) {
+ return new TestListHDFSStoresFunction(cache, member);
+ }
+
+ protected static class TestListHDFSStoresFunction extends ListHDFSStoresFunction {
+ private static final long serialVersionUID = 1L;
+
+ private final Cache cache;
+
+ DistributedMember member;
+
+ @Override
+ protected DistributedMember getDistributedMemberId(Cache cache) {
+ return member;
+ }
+
+ public TestListHDFSStoresFunction(final Cache cache, DistributedMember member) {
+ assert cache != null: "The Cache cannot be null!";
+ this.cache = cache;
+ this.member = member;
+ }
+
+ @Override
+ protected Cache getCache() {
+ return cache;
+ }
+ }
+
+ protected static class TestResultSender implements ResultSender {
+
+ private final List<Object> results = new LinkedList<Object>();
+
+ private Throwable t;
+
+ protected List<Object> getResults() throws Throwable {
+ if (t != null) {
+ throw t;
+ }
+ return Collections.unmodifiableList(results);
+ }
+
+ public void lastResult(final Object lastResult) {
+ results.add(lastResult);
+ }
+
+ public void sendResult(final Object oneResult) {
+ results.add(oneResult);
+ }
+
+ public void sendException(final Throwable t) {
+ this.t = t;
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9f3f10fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/configuration/domain/CacheElementJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/configuration/domain/CacheElementJUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/configuration/domain/CacheElementJUnitTest.java
index 57d1c7e..dca5d0b 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/configuration/domain/CacheElementJUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/configuration/domain/CacheElementJUnitTest.java
@@ -120,6 +120,7 @@ public class CacheElementJUnitTest {
assertEntry("cache-server", order++, entries.next());
assertEntry("pool", order++, entries.next());
assertEntry("disk-store", order++, entries.next());
+ assertEntry("hdfs-store", order++, entries.next());
assertEntry("pdx", order++, entries.next());
assertEntry("region-attributes", order++, entries.next());
assertEntry("jndi-bindings", order++, entries.next());
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9f3f10fd/geode-core/src/test/java/com/gemstone/gemfire/test/dunit/internal/JUnit4DistributedTestCase.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/test/dunit/internal/JUnit4DistributedTestCase.java b/geode-core/src/test/java/com/gemstone/gemfire/test/dunit/internal/JUnit4DistributedTestCase.java
index 8678095..c06f4db 100755
--- a/geode-core/src/test/java/com/gemstone/gemfire/test/dunit/internal/JUnit4DistributedTestCase.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/test/dunit/internal/JUnit4DistributedTestCase.java
@@ -35,6 +35,7 @@ import org.junit.Rule;
import com.gemstone.gemfire.admin.internal.AdminDistributedSystemImpl;
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.Region;
+import com.gemstone.gemfire.cache.hdfs.internal.hoplog.HoplogConfig;
import com.gemstone.gemfire.cache.query.QueryTestUtils;
import com.gemstone.gemfire.cache.query.internal.QueryObserverHolder;
import com.gemstone.gemfire.cache30.ClientServerTestCase;
@@ -414,6 +415,7 @@ public abstract class JUnit4DistributedTestCase implements DistributedTestFixtur
assertNotNull("defaultDiskStoreName must not be null", defaultDiskStoreName);
setTestMethodName(methodName);
GemFireCacheImpl.setDefaultDiskStoreName(defaultDiskStoreName);
+ System.setProperty(HoplogConfig.ALLOW_LOCAL_HDFS_PROP, "true");
setUpCreationStackGenerator();
}
@@ -566,6 +568,7 @@ public abstract class JUnit4DistributedTestCase implements DistributedTestFixtur
// clear system properties -- keep alphabetized
System.clearProperty("gemfire.log-level");
+ System.clearProperty(HoplogConfig.ALLOW_LOCAL_HDFS_PROP);
System.clearProperty("jgroups.resolve_dns");
if (InternalDistributedSystem.systemAttemptingReconnect != null) {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9f3f10fd/geode-core/src/test/java/com/gemstone/gemfire/test/junit/categories/HoplogTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/test/junit/categories/HoplogTest.java b/geode-core/src/test/java/com/gemstone/gemfire/test/junit/categories/HoplogTest.java
new file mode 100644
index 0000000..08987a5
--- /dev/null
+++ b/geode-core/src/test/java/com/gemstone/gemfire/test/junit/categories/HoplogTest.java
@@ -0,0 +1,7 @@
+package com.gemstone.gemfire.test.junit.categories;
+/**
+ * JUnit Test Category that specifies a test with very narrow and well defined
+ * scope. Any complex dependencies and interactions are stubbed or mocked.
+ */
+public interface HoplogTest {
+}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9f3f10fd/geode-core/src/test/resources/com/gemstone/gemfire/codeAnalysis/sanctionedDataSerializables.txt
----------------------------------------------------------------------
diff --git a/geode-core/src/test/resources/com/gemstone/gemfire/codeAnalysis/sanctionedDataSerializables.txt b/geode-core/src/test/resources/com/gemstone/gemfire/codeAnalysis/sanctionedDataSerializables.txt
index fe21fbf..0dda2e6 100644
--- a/geode-core/src/test/resources/com/gemstone/gemfire/codeAnalysis/sanctionedDataSerializables.txt
+++ b/geode-core/src/test/resources/com/gemstone/gemfire/codeAnalysis/sanctionedDataSerializables.txt
@@ -78,6 +78,46 @@ com/gemstone/gemfire/cache/client/internal/locator/ServerLocationRequest,2
fromData,9,2a2bb80003b50002b1
toData,9,2ab400022bb80004b1
+com/gemstone/gemfire/cache/hdfs/internal/HDFSGatewayEventImpl,2
+fromData,17,2a2bb7001b2a2bb8001cc0001db50009b1
+toData,14,2a2bb700172ab400092bb80018b1
+
+com/gemstone/gemfire/cache/hdfs/internal/PersistedEventImpl,2
+fromData,104,2a2bb900110100b80012b500042a2bb900110100b500072a04b7000a99000e2a2bb80013b50005a700402a05b7000a9900302bb800134d2cc7000b2a01b50005a7001cb8001499000e2a2cb80015b50005a7000b2a2cb80016b50005a7000b2a2bb80017b50005b1
+toData,107,2b2ab40004b40008b9000902002b2ab40007b9000902002a04b7000a9900142ab40005c0000bc0000b2bb8000ca7003d2a05b7000a99002d2ab40005c1000d9900182ab40005c0000d4d2cb9000e01002bb8000fa700162ab400052bb8000fa7000b2ab400052bb80010b1
+
+com/gemstone/gemfire/cache/hdfs/internal/SortedHDFSQueuePersistedEvent,2
+fromData,14,2a2bb7000d2a2bb8000eb5000ab1
+toData,14,2a2bb7000b2ab4000a2bb8000cb1
+
+com/gemstone/gemfire/cache/hdfs/internal/SortedHoplogPersistedEvent,2
+fromData,37,2a2bb700092ab6000a9900112a2bb8000bc0000cb50002a7000d2a2bb9000d0100b50003b1
+toData,34,2a2bb700062ab40002c700102b2ab40003b900070300a7000b2ab400022bb80008b1
+
+com/gemstone/gemfire/cache/hdfs/internal/UnsortedHDFSQueuePersistedEvent,2
+fromData,14,2a2bb7000c2a2bb8000db50008b1
+toData,14,2a2bb7000a2ab400082bb8000bb1
+
+com/gemstone/gemfire/cache/hdfs/internal/UnsortedHoplogPersistedEvent,2
+fromData,17,2a2bb700072a2bb80008b60009b50003b1
+toData,17,2a2bb700042ab40003b800052bb80006b1
+
+com/gemstone/gemfire/cache/hdfs/internal/hoplog/CompactionStatus,2
+fromData,21,2a2bb900060100b500022a2bb900070100b50003b1
+toData,21,2b2ab40002b9000402002b2ab40003b900050200b1
+
+com/gemstone/gemfire/cache/hdfs/internal/hoplog/FlushStatus,2
+fromData,11,2a2bb900060100b50004b1
+toData,11,2b2ab40004b900050200b1
+
+com/gemstone/gemfire/cache/hdfs/internal/hoplog/HDFSFlushQueueArgs,2
+fromData,19,2a2bb80008b500042a2bb900090100b50005b1
+toData,19,2ab400042bb800062b2ab40005b900070300b1
+
+com/gemstone/gemfire/cache/hdfs/internal/hoplog/HDFSForceCompactionArgs,2
+fromData,29,2a2bb8000bb500042a2bb9000c0100b500052a2bb9000d0100b50007b1
+toData,29,2ab400042bb800082b2ab40005b9000902002b2ab40007b9000a0200b1
+
com/gemstone/gemfire/cache/query/internal/CqEntry,2
fromData,17,2a2bb80009b500022a2bb80009b50003b1
toData,17,2ab400022bb8000b2ab400032bb8000bb1
@@ -325,8 +365,8 @@ fromData,22,2a2bb900130100b500022a2bb80014c00015b50003b1
toData,19,2b2ab40002b9001102002ab400032bb80012b1
com/gemstone/gemfire/distributed/internal/membership/gms/messages/InstallViewMessage,2
-fromData,49,2a2bb700112a2bb900120100b500072ab800132bb90012010032b500052a2bb80014c00015b500022a2bb80014b50006b1
-toData,45,2a2bb7000d2b2ab40007b9000e02002b2ab40005b6000fb9000e02002ab400022bb800102ab400062bb80010b1
+fromData,49,2a2bb700122a2bb900130100b500072ab800142bb90013010032b500042a2bb80015c00016b500022a2bb80015b50005b1
+toData,45,2a2bb7000e2b2ab40007b9000f02002b2ab40004b60010b9000f02002ab400022bb800112ab400052bb80011b1
com/gemstone/gemfire/distributed/internal/membership/gms/messages/JoinRequestMessage,2
fromData,38,2a2bb80019c0001ab500042a2bb80019b500052a2bb8001bb500022a2bb9001c0100b6001db1
@@ -707,8 +747,8 @@ fromData,27,2a2bb80013b500042a2bb80013b500062a2bb900140100b50008b1
toData,27,2ab400042bb800112ab400062bb800112b2ab40008b900120200b1
com/gemstone/gemfire/internal/admin/remote/RemoteRegionAttributes,2
-fromData,404,2a2bb80080b500082a2bb80080b5000a2a2bb80081b5000d2a2bb80080b5007a2a2bb80082c00083b5000f2a2bb80082c00083b500112a2bb80082c00084b500132a2bb80082c00084b500152a2bb80082c00084b500172a2bb80080b500192a2bb80082c00084b5001b2a2bb80080b5001d2a2bb80082c00085b5001f2a2bb80082c00086b500212a2bb900870100b500232a2bb900870100b500252a2bb900880100b500272a2bb900890100b5002b2a2bb900880100b5002d2a2bb900870100b5002f2a2bb900870100b500312a2bb900870100b500332a2bb900870100b500352a2bb900870100b500372a2bb80082c0008ab5003b2a2bb80082c0008bc0008bb5003d2a2bb80082c0008cc0008cb5003f2a2bb900870100b5007f2a2bb80082c0008db500412a2bb80082c0008eb500432a2bb80082c0008fb500452a2bb80082c00002b500042a2bb900870100b500472a2bb80080b500392a2bb900870100b5004b2a2bb80081b5004e2a2bb900870100b500052a2bb900870100b500292a2bb80080b500522a2bb900870100b50054b1
-toData,353,2ab400082bb800782ab4000a2bb800782ab4000d2bb800792ab4007a2bb800782ab4000f2bb8007b2ab400112bb8007b2ab400132bb8007b2ab400152bb8007b2ab400172bb8007b2ab400192bb800782ab4001b2bb8007b2ab4001d2bb800782ab4001f2bb8007b2ab400212bb8007b2b2ab40023b9007c02002b2ab40025b9007c02002b2ab40027b9007d02002b2ab4002bb9007e02002b2ab4002db9007d02002b2ab4002fb9007c02002b2ab40031b9007c02002b2ab40033b9007c02002b2ab40035b9007c02002b2ab40037b9007c02002ab4003b2bb8007b2ab4003d2bb8007b2ab4003f2bb8007b2b2ab4007fb9007c02002ab400412bb8007b2ab400432bb8007b2ab400452bb8007b2ab400042bb8007b2b2ab40047b9007c02002ab400392bb800782b2ab4004bb9007c02002ab4004e2bb800792b2ab40005b9007c02002b2ab40029b9007c02002ab400522bb800782b2ab40054b9007c0200b1
+fromData,412,2a2bb80084b500082a2bb80084b5000a2a2bb80085b5000d2a2bb80084b5007e2a2bb80086c00087b5000f2a2bb80086c00087b500112a2bb80086c00088b500132a2bb80086c00088b500152a2bb80086c00088b500172a2bb80084b500192a2bb80086c00088b5001b2a2bb80084b5001d2a2bb80086c00089b5001f2a2bb80086c0008ab500212a2bb9008b0100b500232a2bb9008b0100b500252a2bb9008c0100b500272a2bb9008d0100b5002b2a2bb9008c0100b5002d2a2bb9008b0100b5002f2a2bb9008b0100b500312a2bb9008b0100b500332a2bb9008b0100b500352a2bb9008b0100b500372a2bb80086c0008eb5003b2a2bb80086c0008fc0008fb5003d2a2bb80086c00090c00090b5003f2a2bb9008b0100b500832a2bb80086c00091b500412a2bb80086c00092b500432a2bb80086c00093b500452a2bb80086c00002b500042a2bb9008b0100b500472a2bb80084b500392a2bb9008b0100b5004b2a2bb80085b5004e2a2bb9008b0100b500052a2bb9008b0100b500292a2bb80084b500562a2bb9008b0100b500582a2bb80084b50052b1
+toData,361,2ab400082bb8007c2ab4000a2bb8007c2ab4000d2bb8007d2ab4007e2bb8007c2ab4000f2bb8007f2ab400112bb8007f2ab400132bb8007f2ab400152bb8007f2ab400172bb8007f2ab400192bb8007c2ab4001b2bb8007f2ab4001d2bb8007c2ab4001f2bb8007f2ab400212bb8007f2b2ab40023b9008002002b2ab40025b9008002002b2ab40027b9008102002b2ab4002bb9008202002b2ab4002db9008102002b2ab4002fb9008002002b2ab40031b9008002002b2ab40033b9008002002b2ab40035b9008002002b2ab40037b9008002002ab4003b2bb8007f2ab4003d2bb8007f2ab4003f2bb8007f2b2ab40083b9008002002ab400412bb8007f2ab400432bb8007f2ab400452bb8007f2ab400042bb8007f2b2ab40047b9008002002ab400392bb8007c2b2ab4004bb9008002002ab4004e2bb8007d2b2ab40005b9008002002b2ab40029b9008002002ab400562bb8007c2b2ab40058b9008002002ab400522bb8007cb1
com/gemstone/gemfire/internal/admin/remote/RemoteRegionSnapshot,2
fromData,59,2a2bb80029b500032a2bb8002ac00009b5000c2a2bb8002ac00005b500072a2bb9002b0100b500102a2bb9002b0100b500122a2bb8002ab5001cb1
@@ -843,8 +883,8 @@ fromData,1,b1
toData,1,b1
com/gemstone/gemfire/internal/cache/AbstractRegion,2
-toData,6,2a2bb80176b1
-fromData,8,bb017759b70178bf
+toData,6,2a2bb80184b1
+fromData,8,bb018559b70186bf
com/gemstone/gemfire/internal/cache/AbstractUpdateOperation$AbstractUpdateMessage,2
fromData,16,2a2bb700192a2bb9001a0100b5000db1
@@ -947,8 +987,8 @@ fromData,14,2a2bb7001a2a2bb8001bb50004b1
toData,14,2a2bb700182ab400042bb80019b1
com/gemstone/gemfire/internal/cache/DistributedCacheOperation$CacheOperationMessage,2
-fromData,318,2bb9009501003d2bb9009501003e2a1cb500962a1c2bb600972a2bb80098b500232a2bb900990100b8009ab500092a1c1100807e99000704a7000403b500042a1c10087e99000704a7000403b500581c1102007e99000b2a2bb8009bb500882a1c1104007e99000704a7000403b500072a1c10407e99000704a7000403b5001d2ab4001d9900382bb900990100360415049a000b2a03b5001ea7001b150404a0000b2a04b5001ea7000dbb009c59129db7009ebf2a2bb8009fb5001f1c1101007e99000704a700040336042a1c1108007e99000704a7000403b500a015049900162abb00a159b700a2b5000e2ab4000e2bb800a31c1110007e99001c1c1120007e99000704a700040336052a15052bb800a4b5000a1d1104007e9900232a04b5000f2ac100a59900172ac000a51d1101007e99000704a7000403b600a6b1
-toData,202,033d033e2a1cb600a73d2a1db600a83e2b1cb900a902002b1db900a902002ab4000d9e000d2b2ab4000db900aa02002ab400232bb800ab2b2ab40009b400acb900ad02002ab40088c6000b2ab400882bb800ae2ab4001d9900542b2ab4001e99000704a7000403b900ad02002ab4001eb800af36042ab4001e9a001f2ab4001fc10020990015013a052ab4001fc00020c000203a06a7000c2ab4001f3a05013a061504190519062bb800b02ab4000ec6000b2ab4000e2bb800b12ab4000ac6000b2ab4000a2bb800b1b1
+fromData,338,2bb9009501003d2bb9009501003e2a1cb500962a1c2bb600972a2bb80098b500232a2bb900990100b8009ab500092a1c1100807e99000704a7000403b500042a1c10087e99000704a7000403b500581c1102007e99000b2a2bb8009bb500882a1c1104007e99000704a7000403b500072a1c10407e99000704a7000403b5001d2ab4001d9900382bb900990100360415049a000b2a03b5001ea7001b150404a0000b2a04b5001ea7000dbb009c59129db7009ebf2a2bb8009fb5001f1c1101007e99000704a700040336042a1c1108007e99000704a7000403b500a015049900162abb00a159b700a2b5000e2ab4000e2bb800a31c1110007e99001c1c1120007e99000704a700040336052a15052bb800a4b5000a1d1104007e9900372a04b5000f2ac100a599002b2ac000a51d1102007e99000704a7000403b600a62ac000a51d1101007e99000704a7000403b600a7b1
+toData,202,033d033e2a1cb600a83d2a1db600a93e2b1cb900aa02002b1db900aa02002ab4000d9e000d2b2ab4000db900ab02002ab400232bb800ac2b2ab40009b400adb900ae02002ab40088c6000b2ab400882bb800af2ab4001d9900542b2ab4001e99000704a7000403b900ae02002ab4001eb800b036042ab4001e9a001f2ab4001fc10020990015013a052ab4001fc00020c000203a06a7000c2ab4001f3a05013a061504190519062bb800b12ab4000ec6000b2ab4000e2bb800b22ab4000ac6000b2ab4000a2bb800b2b1
com/gemstone/gemfire/internal/cache/DistributedClearOperation$ClearRegionMessage,2
fromData,53,2a2bb700212ab800222bb90023010032b500022a2bb80024c00025b500062a2bb80024c00026b500172a2bb80024c00027b50011b1
@@ -966,8 +1006,8 @@ com/gemstone/gemfire/internal/cache/DistributedPutAllOperation$PutAllEntryData,1
toData,236,2ab4000a4e2ab4000c3a042d2bb8003d1904c1003e9a00081904c700192b03b9003f02001904c0003ec0003e2bb80040a700341904c1004199001f1904c000413a052b04b9003f02001905b9004201002bb80040a700102b04b9003f020019042bb800432b2ab40012b40044b9003f02002ab4000636052ab40026c6000a150507809136052ab40017c6001d15051008809136052ab40017c1004599000b150510208091360515051080809136052b1505b9003f02002ab40026c6000b2ab400262bb8003d2ab40017c6000b2ab400172bb800462ab6002899000b2ab400142bb800462ab400082bb80047b1
com/gemstone/gemfire/internal/cache/DistributedPutAllOperation$PutAllMessage,2
-fromData,197,2a2bb7003e2a2bb8003fc00040b500072a2bb8004188b500172a2ab40017bd0042b500082ab400179e00722bb800434dbb004459b700454e03360415042ab40017a200202ab400081504bb0042592b2ab4000715042c2db7004653840401a7ffdd2bb9004701003604150499002f2bb800483a0503360615062ab40017a2001d2ab4000815063219051506b60049c0004ab50030840601a7ffe02ab4004b1140007e99000e2a2bb8003fc0004cb5000d2a2ab4004b1180007e99000704a7000403b5001cb1
-toData,181,2a2bb7004d2ab400072bb8004e2ab40017852bb8004f2ab400179e008bbb0050592ab40017b700514d033e2ab400080332b40052c10026360403360515052ab40017a200531d9a00122ab40008150532b40030c60005043e2ab40008150532b400303a062c1906b60053572ab4000815053201b500302ab400081505322b1504b600542ab400081505321906b50030840501a7ffaa2b1db9005502001d9900082c2bb800562ab4000dc6000b2ab4000d2bb8004eb1
+fromData,197,2a2bb700402a2bb80041c00042b500082a2bb8004388b500182a2ab40018bd0044b500092ab400189e00722bb800454dbb004659b700474e03360415042ab40018a200202ab400091504bb0044592b2ab4000815042c2db7004853840401a7ffdd2bb9004901003604150499002f2bb8004a3a0503360615062ab40018a2001d2ab4000915063219051506b6004bc0004cb50032840601a7ffe02ab4004d1140007e99000e2a2bb80041c0004eb5000e2a2ab4004d1180007e99000704a7000403b5001db1
+toData,181,2a2bb7004f2ab400082bb800502ab40018852bb800512ab400189e008bbb0052592ab40018b700534d033e2ab400090332b40054c10028360403360515052ab40018a200531d9a00122ab40009150532b40032c60005043e2ab40009150532b400323a062c1906b60055572ab4000915053201b500322ab400091505322b1504b600562ab400091505321906b50032840501a7ffaa2b1db9005702001d9900082c2bb800582ab4000ec6000b2ab4000e2bb80050b1
com/gemstone/gemfire/internal/cache/DistributedRegionFunctionStreamingMessage,2
fromData,171,2a2bb700622bb9006301003d1c047e9900142a2bb900640100b500092ab40009b800651c077e99000d2a2bb900640100b500061c057e99000e2a2bb80066c00067b500072bb800664e2dc100689900252a03b5000e2a2dc00068b80069b500082ab40008c7001b2a2dc00068b5004da700102a2dc0006ab500082a04b5000e2a2bb80066c0006bb5000a2a2bb8006cb5000c2a2bb8006db5000b2a1c10407e99000704a7000403b5000db1
@@ -989,8 +1029,8 @@ fromData,17,2a2bb80005b500022a2bb80005b50003b1
toData,17,2ab400022bb800042ab400032bb80004b1
com/gemstone/gemfire/internal/cache/EntryEventImpl,2
-fromData,214,2a2bb8001bc0001cb5001d2bb8001b4d2bb8001b4e2abb001e592c2d01b7001fb500202a2bb900210100b80022b500232a2bb900240100b500092ab400202bb8001bb600252a2bb8001bc00026b5000a2bb9002701009900112a2bb8001bc00028b50008a700322bb9002701009900212a2bb80029b5002a2a2ab4002ab500062a2ab4002ab8002bb50005a7000b2a2bb8001bb500052bb9002701009900192a2bb80029b5002c2a2ab4002cb8002bb50007a7000b2a2bb8001bb500072a2bb8002db5002e2a2bb8002fb5000b2a2bb80030b50014b1
-toData,312,2ab4001d2bb801602ab6008c2bb801602ab40020b6018d2bb801602b2ab40023b4018eb9018f02002b2ab4000911c03f7eb9019002002ab6004b2bb801602ab4000a2bb801602ab40008c6000704a70004033d2b1cb9019102001c99000e2ab400082bb80160a700682ab600414e2dc100823604150499000e2dc00082b900b8010036042b1504b901910200150499003b2ab4002ac6000e2ab4002a2bb80192a7002e2ab40006c6000e2ab400062bb80192a7001c2dc000823a051905b900c601002bb80193a700082d2bb801602ab700434d2cc100823e1d99000d2cc00082b900b801003e2b1db9019102001d9900292ab4002cc6000e2ab4002c2bb80192a7001c2cc000823a041904b900c601002bb80193a700082c2bb801602ab4002ec001942bb801952ab600582bb801602ab400142bb80196b1
+fromData,214,2a2bb8001dc0001eb5001f2bb8001d4d2bb8001d4e2abb0020592c2d01b70021b500222a2bb900230100b80024b500252a2bb900260100b500082ab400222bb8001db600272a2bb8001dc00028b500092bb9002901009900112a2bb8001dc0002ab50007a700322bb9002901009900212a2bb8002bb5002c2a2ab4002cb500052a2ab4002cb8002db50004a7000b2a2bb8001db500042bb9002901009900192a2bb8002bb5002e2a2ab4002eb8002db50006a7000b2a2bb8001db500062a2bb8002fb500302a2bb80031b5000a2a2bb80032b50016b1
+toData,312,2ab400202bb801632ab6008f2bb801632ab40023b6018c2bb801632b2ab40026b4018db9018e02002b2ab4000911c03f7eb9018f02002ab6004e2bb801632ab4000a2bb801632ab40008c6000704a70004033d2b1cb9019002001c99000e2ab400082bb80163a700682ab600444e2dc100853604150499000e2dc00085b900bb010036042b1504b901900200150499003b2ab4002dc6000e2ab4002d2bb80191a7002e2ab40006c6000e2ab400062bb80191a7001c2dc000853a051905b900c901002bb80192a700082d2bb801632ab700464d2cc100853e1d99000d2cc00085b900bb01003e2b1db9019002001d9900292ab4002fc6000e2ab4002f2bb80191a7001c2cc000853a041904b900c901002bb80192a700082c2bb801632ab40031c001932bb801942ab6005b2bb801632ab400172bb80195b1
com/gemstone/gemfire/internal/cache/EntrySnapshot,2
fromData,50,2a03b500052bb9004101003d1c9900112abb000759b70042b50004a7000e2abb000359b70043b500042ab400042bb60044b1
@@ -1079,8 +1119,8 @@ fromData,107,2a2bb9001b0100b500032bb9001b01003d2a2bb8001cb500122ab40003b80014990
toData,125,2b2ab40003b9000f02002ab4000dc6000704a70004033d1c2ab4000dc1001199000705a700040380913d2b1cb9000f02002ab400122bb800132ab40003b800149a00232ab600159a000e2ab400022bb80016a700112ab40002c00017c000172bb800182b2ab40004b9001903002ab4000dc6000b2ab4000d2bb8001ab1
com/gemstone/gemfire/internal/cache/InitialImageOperation$FilterInfoMessage,2
-fromData,230,2a2bb7008c2a2bb8008db500202ab4000403322bb8008db5003d2ab4000403322bb8008db500402ab4000403322bb8008db500422ab4000403322bb8008db500442ab4000403322bb8008db500462ab4000403322bb8008db500482ab4000403322bb8008db5004a2ab4000403322bb8008db5004c2ab4000404322bb8008db5003d2ab4000404322bb8008db500402ab4000404322bb8008db500422ab4000404322bb8008db500442ab4000404322bb8008db500462ab4000404322bb8008db500482ab4000404322bb8008db5004a2ab4000404322bb8008db5004c2a2bb8008db50033b1
-toData,284,2a2bb7008a2ab40020c000312bb8008b2ab400040332b4003dc000312bb8008b2ab400040332b40040c000312bb8008b2ab400040332b40042c000312bb8008b2ab400040332b40044c000312bb8008b2ab400040332b40046c000312bb8008b2ab400040332b40048c000312bb8008b2ab400040332b4004ac000312bb8008b2ab400040332b4004cc000312bb8008b2ab400040432b4003dc000312bb8008b2ab400040432b40040c000312bb8008b2ab400040432b40042c000312bb8008b2ab400040432b40044c000312bb8008b2ab400040432b40046c000312bb8008b2ab400040432b40048c000312bb8008b2ab400040432b4004ac000312bb8008b2ab400040432b4004cc000312bb8008b2ab40033c000312bb8008bb1
+fromData,230,2a2bb7008b2a2bb8008cb500202ab4000403322bb8008cb5003d2ab4000403322bb8008cb500402ab4000403322bb8008cb500422ab4000403322bb8008cb500442ab4000403322bb8008cb500462ab4000403322bb8008cb500482ab4000403322bb8008cb5004a2ab4000403322bb8008cb5004c2ab4000404322bb8008cb5003d2ab4000404322bb8008cb500402ab4000404322bb8008cb500422ab4000404322bb8008cb500442ab4000404322bb8008cb500462ab4000404322bb8008cb500482ab4000404322bb8008cb5004a2ab4000404322bb8008cb5004c2a2bb8008cb50033b1
+toData,284,2a2bb700892ab40020c000312bb8008a2ab400040332b4003dc000312bb8008a2ab400040332b40040c000312bb8008a2ab400040332b40042c000312bb8008a2ab400040332b40044c000312bb8008a2ab400040332b40046c000312bb8008a2ab400040332b40048c000312bb8008a2ab400040332b4004ac000312bb8008a2ab400040332b4004cc000312bb8008a2ab400040432b4003dc000312bb8008a2ab400040432b40040c000312bb8008a2ab400040432b40042c000312bb8008a2ab400040432b40044c000312bb8008a2ab400040432b40046c000312bb8008a2ab400040432b40048c000312bb8008a2ab400040432b4004ac000312bb8008a2ab400040432b4004cc000312bb8008a2ab40033c000312bb8008ab1
com/gemstone/gemfire/internal/cache/InitialImageOperation$ImageReplyMessage,2
fromData,224,2a2bb7001d2bb8001e4d014e2cc600102cb6001f9e00092c03b600204e2dc1002199000e2a2dc00022b50010a700082a2cb500102a2bb900230100b500112a2bb900230100b500122a2bb900230100b500132a2bb900240100b500142a2bb900230100b500152a2bb80025b500042a2bb900240100b500032a2bb900240100b500162ab4001699000f2abb0026592bb70027b500022bb900280100360415049b00102abb0029591504b7002ab5000103360515051504a200292bb8002bc0002c3a062bb8002d37072ab4000119061607b8002eb9002f030057840501a7ffd6b1
@@ -1194,8 +1234,8 @@ fromData,16,2a2bb700152a2bb900160100b50003b1
toData,16,2a2bb700172b2ab40003b900180200b1
com/gemstone/gemfire/internal/cache/RemoteDestroyMessage,2
-fromData,131,2a2bb7008b2a2bb8008cb7008d2a2bb8008cb5000c2a2bb9008e0100b8008fb5000e2ab400901102007e99000e2a2bb8008cc00091b500102ab400901104007e99000e2a2bb8008cc00034b500662a2bb8008cc00092b500122ab400059900122bb9008e0100572a2bb80093b700222a2bb8008cb500082a2bb8008cc00094b50017b1
-toData,135,2a2bb700952ab6006c2bb800962ab4000c2bb800962b2ab4000eb40097b9009802002ab40010c6000b2ab400102bb800962ab40066c6000b2ab400662bb800962ab400122bb800962ab4000599002a2b2ab4000699000704a7000403b9009802002ab40006b800993d1c2ab7009a2ab600702bb8009b2ab400082bb800962ab400172bb80096b1
+fromData,131,2a2bb7008c2a2bb8008db7008e2a2bb8008db5000c2a2bb9008f0100b80090b5000e2ab400911102007e99000e2a2bb8008dc00092b500102ab400911104007e99000e2a2bb8008dc00035b500672a2bb8008dc00093b500122ab400059900122bb9008f0100572a2bb80094b700232a2bb8008db500082a2bb8008dc00095b50017b1
+toData,135,2a2bb700962ab6006d2bb800972ab4000c2bb800972b2ab4000eb40098b9009902002ab40010c6000b2ab400102bb800972ab40067c6000b2ab400672bb800972ab400122bb800972ab4000599002a2b2ab4000699000704a7000403b9009902002ab40006b8009a3d1c2ab7009b2ab600712bb8009c2ab400082bb800972ab400172bb80097b1
com/gemstone/gemfire/internal/cache/RemoteDestroyMessage$DestroyReplyMessage,2
fromData,52,2a2bb700232bb9002401003d1c047e99000704a70004033e1c057e99000704a700040336041d99000d2a15042bb80025b50009b1
@@ -1624,8 +1664,8 @@ fromData,36,2a2bb700252a2bb900260100b500022a2bb900260100b500032a2bb900260100b500
toData,36,2a2bb700272b2ab40002b9002802002b2ab40003b9002802002b2ab40004b900280200b1
com/gemstone/gemfire/internal/cache/partitioned/GetMessage,2
-fromData,43,2a2bb700542a2bb80055b500052a2bb80055b500062a2bb80055c00056b500072a2bb900570100b50008b1
-toData,40,2a2bb700582ab400052bb800592ab400062bb800592ab400072bb800592b2ab40008b9005a0200b1
+fromData,43,2a2bb700552a2bb80056b500052a2bb80056b500062a2bb80056c00057b500072a2bb900580100b50008b1
+toData,40,2a2bb700592ab400052bb8005a2ab400062bb8005a2ab400072bb8005a2b2ab40008b9005b0200b1
com/gemstone/gemfire/internal/cache/partitioned/GetMessage$GetReplyMessage,2
fromData,77,2a2bb7002a2bb9002b01003d1c10087e99000704a7000403593e9900091c10f77e913d2a1cb500072a2bb8002cb5002d1c049f000b2a2bb8002eb5002f1d99000e2a2bb80030c00031b5000ab1
@@ -1712,8 +1752,8 @@ fromData,49,2a2bb700392a2bb8003ab500062a2bb9003b0100b8003cb500082a2bb8003ac0003d
toData,43,2a2bb7003f2ab700122bb800402b2ab40008b40041b9004202002ab4000a2bb800402ab4000c2bb80040b1
com/gemstone/gemfire/internal/cache/partitioned/PartitionMessage,2
-fromData,58,2a2bb700742a2bb900750100b500052a2ab400052bb600762a2bb900770100b5000e2bb80078b20079b6007a9b000d2a2bb9007b0100b5000ab1
-toData,104,2a2bb7007f033d2a1cb600803d2b1cb9008102002ab4001099000d2b2ab40010b9008202002ab40008029f000d2b2ab40008b9008202002ab40006c6000b2ab400062bb800832b2ab4000eb9008202002bb80084b20079b6007a9b000d2b2ab4000ab900850200b1
+fromData,58,2a2bb700732a2bb900740100b500052a2ab400052bb600752a2bb900760100b5000e2bb80077b20078b600799b000d2a2bb9007a0100b5000ab1
+toData,104,2a2bb7007e033d2a1cb6007f3d2b1cb9008002002ab4001099000d2b2ab40010b9008102002ab40008029f000d2b2ab40008b9008102002ab40006c6000b2ab400062bb800822b2ab4000eb9008102002bb80083b20078b600799b000d2b2ab4000ab900840200b1
com/gemstone/gemfire/internal/cache/partitioned/PartitionedRegionFunctionStreamingMessage,2
fromData,17,2a2bb7003c2a2bb8003dc0003eb50003b1
@@ -1728,16 +1768,16 @@ fromData,16,2a2bb700092a2bb9000a0100b50007b1
toData,16,2a2bb7000b2b2ab40007b9000c0200b1
com/gemstone/gemfire/internal/cache/partitioned/PutAllPRMessage,2
-fromData,183,2a2bb7003f2a2bb8004088b80009b5000a2ab400411110007e99000e2a2bb80042c00043b5003d2a2bb80042b500102a2bb8004488b500052a2ab40005bd000bb5000c2ab400059e006f2bb800454dbb004659b700474e03360415042ab40005a2001d2ab4000c1504bb000b592b0115042c2db7004853840401a7ffe02bb9004901003604150499002f2bb8004a3a0503360615062ab40005a2001d2ab4000c15063219051506b6004bc0004cb5004d840601a7ffe0b1
-toData,210,2a2bb7004e2ab4000ac7000d14004f2bb80051a7000f2ab4000ab60052852bb800512ab4003dc6000b2ab4003d2bb800532ab400102bb800532ab40005852bb800542ab400059e008bbb0055592ab40005b700564d033e2ab4000c0332b60022c10057360403360515052ab40005a200531d9a00122ab4000c150532b4004dc60005043e2ab4000c150532b4004d3a062c1906b60058572ab4000c15053201b5004d2ab4000c1505322b1504b600592ab4000c1505321906b5004d840501a7ffaa2b1db9005a02001d9900082c2bb8005bb1
+fromData,183,2a2bb700402a2bb8004188b80009b5000a2ab400421110007e99000e2a2bb80043c00044b5003e2a2bb80043b500102a2bb8004588b500052a2ab40005bd000bb5000c2ab400059e006f2bb800464dbb004759b700484e03360415042ab40005a2001d2ab4000c1504bb000b592b0115042c2db7004953840401a7ffe02bb9004a01003604150499002f2bb8004b3a0503360615062ab40005a2001d2ab4000c15063219051506b6004cc0004db5004e840601a7ffe0b1
+toData,210,2a2bb7004f2ab4000ac7000d1400502bb80052a7000f2ab4000ab60053852bb800522ab4003ec6000b2ab4003e2bb800542ab400102bb800542ab40005852bb800552ab400059e008bbb0056592ab40005b700574d033e2ab4000c0332b60023c10058360403360515052ab40005a200531d9a00122ab4000c150532b4004ec60005043e2ab4000c150532b4004e3a062c1906b60059572ab4000c15053201b5004e2ab4000c1505322b1504b6005a2ab4000c1505321906b5004e840501a7ffaa2b1db9005b02001d9900082c2bb8005cb1
com/gemstone/gemfire/internal/cache/partitioned/PutAllPRMessage$PutAllReplyMessage,2
fromData,27,2a2bb7001b2a2bb9001c0100b500032a2bb8001dc0001eb50002b1
toData,24,2a2bb7001f2b2ab40003b9002002002ab400022bb80021b1
com/gemstone/gemfire/internal/cache/partitioned/PutMessage,2
-fromData,260,2a2bb7005d2bb9005e01003d2a2bb8005fb600602a2bb8005fb500172a2bb900610100b500182a2bb900620100b80063b500191cb200647e99000b2a2bb80065b5001a1cb200667e99000e2a2bb8005fc00067b5001c2abb006859b70069b5001d2ab4001d2bb8006a2ab4006b1120007e99000b2a2bb8005fb500222ab4006c9900162abb006d59b7006eb500282ab400282bb8006a2a1cb2006f7e91b500072ab4000999000e2a2bb80070b5000da7002e2ab4000704a0000e2a2bb8005fb70071a7000b2a2bb80070b700721cb200737e99000b2a2bb80070b5000d2ab4006b1140007e99000e2a2bb8005fc00074b500252ab4006b1180007e9900082a04b50075b1
-toData,358,014d2ab40021b60076b9007701003e2ab4000cb60078c600161d9900122ab4000b99000b2a04b50009a700082a03b50009a7000d4ebb007a592db7007bbf2a2bb7007c2ab400073e2ab4001ac600091db20064803e2ab400079900282ab40011c7000a2ab6007dc6001a2ab4007e9900132ab4000cb60078c600091db20073803e2ab4001cc600091db20066803e2b1db9007f02002ab600802bb800812ab600822bb800812b2ab40018b9008303002b2ab40019b40084b9007f02002ab4001ac6000b2ab4001a2bb800812ab4001cc6000b2ab4001c2bb800812ab4001d2bb800852ab40022c6000b2ab400222bb800812ab4006c99000b2ab400282bb800852ab4000999002f2ab40086b800874da7000f3a04bb008959128ab7008bbf2ab4000cb600782bb8008c2cb6008db6008ea700262ab400072ab400112ab6007d2bb8008f1db200737e99000e2ab4000cb600782bb8008c2ab40025c6000b2ab400252bb80081b1
+fromData,273,2a2bb7005e2bb9005f01003d2a2bb80060b600612a2bb80060b500182a2bb900620100b500192a2bb900630100b80064b5001a1cb200657e99000b2a2bb80066b5001b1cb200677e99000e2a2bb80060c00068b5001d1cb200697e9900082a04b5006a2abb006b59b7006cb5001e2ab4001e2bb8006d2ab4006e1120007e99000b2a2bb80060b500232ab4006f9900162abb007059b70071b500292ab400292bb8006d2a1cb200727e91b500072ab4000999000e2a2bb80073b5000da7002e2ab4000704a0000e2a2bb80060b70074a7000b2a2bb80073b700751cb200767e99000b2a2bb80073b5000d2ab4006e1140007e99000e2a2bb80060c00077b500262ab4006e1180007e9900082a04b50078b1
+toData,374,014d2ab40022b60079b9007a01003e2ab4000cb6007bc600161d9900122ab4000b99000b2a04b50009a700082a03b50009a7000d4ebb007d592db7007ebf2a2bb7007f2ab400073e2ab4001bc600091db20065803e2ab400079900282ab40011c7000a2ab60080c6001a2ab400819900132ab4000cb6007bc600091db20076803e2ab4001dc600091db20067803e2ab4000cb600829900091db20069803e2b1db9008302002ab600842bb800852ab600862bb800852b2ab40019b9008703002b2ab4001ab40088b9008302002ab4001bc6000b2ab4001b2bb800852ab4001dc6000b2ab4001d2bb800852ab4001e2bb800892ab40023c6000b2ab400232bb800852ab4006f99000b2ab400292bb800892ab4000999002f2ab4008ab8008b4da7000f3a04bb008d59128eb7008fbf2ab4000cb6007b2bb800902cb60091b60092a700262ab400072ab400112ab600802bb800931db200767e99000e2ab4000cb6007b2bb800902ab40026c6000b2ab400262bb80085b1
com/gemstone/gemfire/internal/cache/partitioned/PutMessage$PutReplyMessage,2
fromData,48,2a2bb700252a2bb900260100b500032a2bb900270100b80028b500022a2bb80029b500062a2bb80029c0002ab50007b1
@@ -1989,8 +2029,8 @@ fromData,67,2a2bb700192a2bb8001ab60018b500032abb000759b7000bb500062bb9001b01003d
toData,91,2a2bb700122ab40003b800132bb800142ab40006c6003f2b2ab40006b900150100b9001602002ab40006b9001701004d2cb9000d010099001a2cb9000e0100c0000f4e2b2db60018b900160200a7ffe3a7000a2b03b900160200b1
com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventImpl,2
-fromData,183,2bb9007301003d1c10119f00032a04b5002a2a2bb900740100b500272a2bb900740100b500281c1011a200232bc1007599001c2bb80076b20077a60012bb0078592bc00075b20079b7007a4c2a2bb8007bc0007cb500292a2bb8007db500102a2bb9007e0100b5002d2a2bb6007f2a2bb80080b5002f2a2bb8007bc0001fb500202a2bb900810100b500132a2bb900820100b500172a2bb900740100b500092a2bb900820100b80004b500052a2bb900820100b5001ab1
-toData,133,2ab600262b1011b9006802002b2ab40027b9006902002b2ab40028b9006902002ab400292bb8006a2ab400102bb8006b2b2ab4002db9006c02002a2bb6006d2ab6002e2bb8006e2ab400202bb8006a2b2ab40013b9006f02002b2ab40017b9007003002b2ab40009b9006902002b2ab40005b60071b9007003002b2ab60072b900700300b1
+fromData,183,2bb9006d01003d1c10119f00032a04b500282a2bb9006e0100b500252a2bb9006e0100b500261c1011a200232bc1006f99001c2bb80070b20071a60012bb0072592bc0006fb20073b700744c2a2bb80075c00076b500272a2bb80077b5000e2a2bb900780100b5002b2a2bb600792a2bb8007ab5002d2a2bb80075c0001db5001e2a2bb9007b0100b500112a2bb9007c0100b500152a2bb9006e0100b500072a2bb9007c0100b80004b500052a2bb9007c0100b50018b1
+toData,133,2ab600242b1011b9006202002b2ab40025b9006302002b2ab40026b9006302002ab400272bb800642ab4000e2bb800652b2ab4002bb9006602002a2bb600672ab6002c2bb800682ab4001e2bb800642b2ab40011b9006902002b2ab40015b9006a03002b2ab40007b9006302002b2ab40005b6006bb9006a03002b2ab6006cb9006a0300b1
com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueBatchRemovalMessage,2
fromData,17,2a2bb7003a2a2bb8003bc0003cb50004b1