nizhikov commented on code in PR #10314:
URL: https://github.com/apache/ignite/pull/10314#discussion_r1069255142
##########
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/serializer/RecordDataV1Serializer.java:
##########
@@ -1293,6 +1303,25 @@ WALRecord readPlainRecord(RecordType type,
ByteBufferBackedDataInput in,
break;
+ case CONSISTENT_CUT_START_RECORD:
+ long mst = in.readLong();
+ long lst = in.readLong();
+
+ res = new ConsistentCutStartRecord(new UUID(mst, lst));
+
+ break;
+
+ case CONSISTENT_CUT_FINISH_RECORD:
+ long mstSignBits = in.readLong();
+ long lstSignBits = in.readLong();
+
+ Set<GridCacheVersion> before = readVersions(in);
Review Comment:
before -> included
##########
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/serializer/RecordDataV1Serializer.java:
##########
@@ -1293,6 +1303,25 @@ WALRecord readPlainRecord(RecordType type,
ByteBufferBackedDataInput in,
break;
+ case CONSISTENT_CUT_START_RECORD:
+ long mst = in.readLong();
+ long lst = in.readLong();
+
+ res = new ConsistentCutStartRecord(new UUID(mst, lst));
+
+ break;
+
+ case CONSISTENT_CUT_FINISH_RECORD:
+ long mstSignBits = in.readLong();
+ long lstSignBits = in.readLong();
+
+ Set<GridCacheVersion> before = readVersions(in);
+ Set<GridCacheVersion> after = readVersions(in);
Review Comment:
after -> excluded
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
