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 <[email protected]> Authored: Wed Oct 21 13:32:18 2015 -0700 Committer: Dan Smith <[email protected]> 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
