natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix version check in InProgressSequences serialization 

Patch by marcuse; reviewed by Sam Tunnicliffe for CASSANDRA-19348
This commit is contained in:
Marcus Eriksson 2024-01-31 12:52:16 +01:00
parent baef2447bb
commit 60fe2dc61d
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/java/org/apache/cassandra/tcm/sequences/InProgressSequences.java
View File

@ -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();