(cassandra) 01/03: Fix version check in InProgressSequences serialization

[marcuse]

This is an automated email from the ASF dual-hosted git repository.

marcuse pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git

commit 60fe2dc61d3ea3d241e7e624f7a3ef94bd427b2f
Author: Marcus Eriksson <marc...@apache.org>
AuthorDate: Wed Jan 31 12:52:16 2024 +0100

    Fix version check in InProgressSequences serialization
    
    Patch by marcuse; reviewed by Sam Tunnicliffe for CASSANDRA-19348
---
 .../org/apache/cassandra/tcm/sequences/InProgressSequences.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/src/java/org/apache/cassandra/tcm/sequences/InProgressSequences.java 
b/src/java/org/apache/cassandra/tcm/sequences/InProgressSequences.java
index a8b2b16259..86b449c346 100644
--- a/src/java/org/apache/cassandra/tcm/sequences/InProgressSequences.java
+++ b/src/java/org/apache/cassandra/tcm/sequences/InProgressSequences.java
@@ -223,7 +223,7 @@ public class InProgressSequences implements 
MetadataValue<InProgressSequences>
             out.writeInt(t.state.size());
             for (Map.Entry<MultiStepOperation.SequenceKey, 
MultiStepOperation<?>> entry : t.state.entrySet())
             {
-                if (Version.UNKNOWN.isBefore(V2))
+                if (version.isBefore(V2))
                 {
                     NodeId.serializer.serialize((NodeId) entry.getKey(), out, 
version);
                     MultiStepOperation<?> seq = entry.getValue();
@@ -249,7 +249,7 @@ public class InProgressSequences implements 
MetadataValue<InProgressSequences>
             ImmutableMap.Builder<MultiStepOperation.SequenceKey, 
MultiStepOperation<?>> res = ImmutableMap.builder();
             for (int i = 0; i < ipsSize; i++)
             {
-                if (Version.UNKNOWN.isBefore(V2))
+                if (version.isBefore(V2))
                 {
                     NodeId nodeId = NodeId.serializer.deserialize(in, version);
                     MultiStepOperation.Kind kind = 
MultiStepOperation.Kind.valueOf(in.readUTF());
@@ -273,7 +273,7 @@ public class InProgressSequences implements 
MetadataValue<InProgressSequences>
             size += sizeof(t.state.size());
             for (Map.Entry<MultiStepOperation.SequenceKey, 
MultiStepOperation<?>> entry : t.state.entrySet())
             {
-                if (Version.UNKNOWN.isBefore(V2))
+                if (version.isBefore(V2))
                 {
                     size += NodeId.serializer.serializedSize((NodeId) 
entry.getKey(), version);
                     MultiStepOperation<?> seq = entry.getValue();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org