geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From upthewatersp...@apache.org
Subject [4/4] incubator-geode git commit: GEODE-370: Using SerialDistributionMessage for serializers
Date Thu, 22 Oct 2015 20:14:04 GMT
GEODE-370: Using SerialDistributionMessage for serializers

DataSerializers were being sent using PooledDistributionMessage. That
meant they could  be processed out of order. When DataSerializers were
added out of order to a client queue, some serializers would be lost.


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/593d176f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/593d176f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/593d176f

Branch: refs/heads/feature/GEODE-409
Commit: 593d176f713af6570ff6378fc4b7f884d880033a
Parents: 9390a62
Author: Dan Smith <upthewaterspout@apache.org>
Authored: Wed Oct 21 13:32:18 2015 -0700
Committer: Dan Smith <upthewaterspout@apache.org>
Committed: Thu Oct 22 13:12:59 2015 -0700

----------------------------------------------------------------------
 .../com/gemstone/gemfire/internal/InternalDataSerializer.java   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/593d176f/gemfire-core/src/main/java/com/gemstone/gemfire/internal/InternalDataSerializer.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/InternalDataSerializer.java
b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/InternalDataSerializer.java
index 09f9280..27ba141 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/InternalDataSerializer.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/InternalDataSerializer.java
@@ -65,7 +65,6 @@ import com.gemstone.gemfire.GemFireIOException;
 import com.gemstone.gemfire.GemFireRethrowable;
 import com.gemstone.gemfire.Instantiator;
 import com.gemstone.gemfire.InternalGemFireError;
-import com.gemstone.gemfire.InternalGemFireException;
 import com.gemstone.gemfire.SerializationException;
 import com.gemstone.gemfire.SystemFailure;
 import com.gemstone.gemfire.ToDataException;
@@ -76,7 +75,7 @@ import com.gemstone.gemfire.distributed.internal.DMStats;
 import com.gemstone.gemfire.distributed.internal.DistributionManager;
 import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem;
 import com.gemstone.gemfire.distributed.internal.LonerDistributionManager;
-import com.gemstone.gemfire.distributed.internal.PooledDistributionMessage;
+import com.gemstone.gemfire.distributed.internal.SerialDistributionMessage;
 import com.gemstone.gemfire.internal.cache.EnumListenerEvent;
 import com.gemstone.gemfire.internal.cache.EventID;
 import com.gemstone.gemfire.internal.cache.GemFireCacheImpl;
@@ -3475,7 +3474,7 @@ public abstract class InternalDataSerializer extends DataSerializer
implements D
    * distributed cache of a new <code>DataSerializer</code> being
    * registered.
    */
-  public static final class RegistrationMessage extends PooledDistributionMessage {
+  public static final class RegistrationMessage extends SerialDistributionMessage {
     /** The id of the <code>DataSerializer</code> that was
      * registered
      * since 5.7 an int instead of a byte


Mime
View raw message