Fix misplacement of originatingHostId in stats metadata

patch by Jacek Lewandowski; reviewed by Benjamin Lerer for CASSANDRA-16619
This commit is contained in:
jacek-lewandowski 2021-05-13 12:24:08 +02:00 committed by Benjamin Lerer
parent 9783d47b9f
commit d35f36cd05
21 changed files with 48 additions and 46 deletions

View File

@ -285,12 +285,6 @@ public class StatsMetadata extends MetadataComponent
size += CommitLogPosition.serializer.serializedSize(component.commitLogIntervals.lowerBound().orElse(CommitLogPosition.NONE));
if (version.hasCommitLogIntervals())
size += commitLogPositionSetSerializer.serializedSize(component.commitLogIntervals);
if (version.hasOriginatingHostId())
{
size += 1; // boolean: is originatingHostId present
if (component.originatingHostId != null)
size += UUIDSerializer.serializer.serializedSize(component.originatingHostId, version.correspondingMessagingVersion());
}
if (version.hasPendingRepair())
{
@ -304,6 +298,13 @@ public class StatsMetadata extends MetadataComponent
size += TypeSizes.sizeof(component.isTransient);
}
if (version.hasOriginatingHostId())
{
size += 1; // boolean: is originatingHostId present
if (component.originatingHostId != null)
size += UUIDSerializer.serializer.serializedSize(component.originatingHostId, version.correspondingMessagingVersion());
}
return size;
}
@ -337,18 +338,6 @@ public class StatsMetadata extends MetadataComponent
CommitLogPosition.serializer.serialize(component.commitLogIntervals.lowerBound().orElse(CommitLogPosition.NONE), out);
if (version.hasCommitLogIntervals())
commitLogPositionSetSerializer.serialize(component.commitLogIntervals, out);
if (version.hasOriginatingHostId())
{
if (component.originatingHostId != null)
{
out.writeByte(1);
UUIDSerializer.serializer.serialize(component.originatingHostId, out, 0);
}
else
{
out.writeByte(0);
}
}
if (version.hasPendingRepair())
{
@ -367,6 +356,19 @@ public class StatsMetadata extends MetadataComponent
{
out.writeBoolean(component.isTransient);
}
if (version.hasOriginatingHostId())
{
if (component.originatingHostId != null)
{
out.writeByte(1);
UUIDSerializer.serializer.serialize(component.originatingHostId, out, 0);
}
else
{
out.writeByte(0);
}
}
}
public StatsMetadata deserialize(Version version, DataInputPlus in) throws IOException
@ -439,10 +441,6 @@ public class StatsMetadata extends MetadataComponent
else
commitLogIntervals = new IntervalSet<CommitLogPosition>(commitLogLowerBound, commitLogUpperBound);
UUID originatingHostId = null;
if (version.hasOriginatingHostId() && in.readByte() != 0)
originatingHostId = UUIDSerializer.serializer.deserialize(in, 0);
UUID pendingRepair = null;
if (version.hasPendingRepair() && in.readByte() != 0)
{
@ -451,6 +449,10 @@ public class StatsMetadata extends MetadataComponent
boolean isTransient = version.hasIsTransient() && in.readBoolean();
UUID originatingHostId = null;
if (version.hasOriginatingHostId() && in.readByte() != 0)
originatingHostId = UUIDSerializer.serializer.deserialize(in, 0);
return new StatsMetadata(partitionSizes,
columnCounts,
commitLogIntervals,

View File

@ -1,8 +1,8 @@
Data.db
Filter.db
Statistics.db
TOC.txt
Digest.crc32
CompressionInfo.db
Index.db
TOC.txt
Filter.db
Summary.db
Statistics.db
Digest.crc32
Data.db

View File

@ -1,8 +1,8 @@
Data.db
Filter.db
Statistics.db
TOC.txt
Digest.crc32
CompressionInfo.db
Index.db
TOC.txt
Filter.db
Summary.db
Statistics.db
Digest.crc32
Data.db

View File

@ -1,8 +1,8 @@
Data.db
Filter.db
Statistics.db
TOC.txt
Digest.crc32
CompressionInfo.db
Index.db
TOC.txt
Filter.db
Summary.db
Statistics.db
Digest.crc32
Data.db

View File

@ -1,8 +1,8 @@
Data.db
Filter.db
Statistics.db
TOC.txt
Digest.crc32
CompressionInfo.db
Index.db
TOC.txt
Filter.db
Summary.db
Statistics.db
Digest.crc32
Data.db