Repository: incubator-geode Updated Branches: refs/heads/feature/GEODE-370 [created] 90cce1dee
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/90cce1de Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/90cce1de Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/90cce1de Branch: refs/heads/feature/GEODE-370 Commit: 90cce1dee5006e0ca57331fad054a7919d035f39 Parents: 25bce96 Author: Dan Smith <[email protected]> Authored: Wed Oct 21 13:32:18 2015 -0700 Committer: Dan Smith <[email protected]> Committed: Wed Oct 21 13:32:18 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/90cce1de/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
