You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ds...@apache.org on 2015/10/26 19:28:54 UTC
[31/50] [abbrv] incubator-geode git commit: GEODE-370: Using
SerialDistributionMessage for serializers
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/develop
Commit: 593d176f713af6570ff6378fc4b7f884d880033a
Parents: 9390a62
Author: Dan Smith <up...@apache.org>
Authored: Wed Oct 21 13:32:18 2015 -0700
Committer: Dan Smith <up...@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