This mass-switches versioned resources to use Sodium SR1 streaming
format.
JIRA: CONTROLLER-1919
Change-Id: Ic712fa04e16c68481eeecccc61d8e6a7dfabac52
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
* @return Current {@link ABIVersion}
*/
public static @NonNull ABIVersion current() {
* @return Current {@link ABIVersion}
*/
public static @NonNull ABIVersion current() {
public static final short NEON_SR2_VERSION = 10;
public static final short SODIUM_SR1_VERSION = 11;
public static final short MAGNESIUM_VERSION = 12;
public static final short NEON_SR2_VERSION = 10;
public static final short SODIUM_SR1_VERSION = 11;
public static final short MAGNESIUM_VERSION = 12;
- public static final short CURRENT_VERSION = NEON_SR2_VERSION;
+ public static final short CURRENT_VERSION = SODIUM_SR1_VERSION;
private DataStoreVersions() {
private DataStoreVersions() {
final PayloadVersion version = PayloadVersion.readFrom(in);
switch (version) {
case BORON:
final PayloadVersion version = PayloadVersion.readFrom(in);
switch (version) {
case BORON:
- return new ShardSnapshotState(readSnapshot(in), true);
+ return new ShardSnapshotState(readSnapshot(in), true);
case SODIUM_SR1:
case MAGNESIUM:
return new ShardSnapshotState(readSnapshot(in), false);
case SODIUM_SR1:
case MAGNESIUM:
return new ShardSnapshotState(readSnapshot(in), false);
@Override
PayloadVersion version() {
@Override
PayloadVersion version() {
- return PayloadVersion.NEON_SR2;
+ return PayloadVersion.SODIUM_SR1;
}
private Object writeReplace() {
}
private Object writeReplace() {
* @return Current {@link PayloadVersion}
*/
public static @NonNull PayloadVersion current() {
* @return Current {@link PayloadVersion}
*/
public static @NonNull PayloadVersion current() {
@Test
public void testCandidateSerialization() throws IOException {
final CommitTransactionPayload payload = CommitTransactionPayload.create(nextTransactionId(), candidate);
@Test
public void testCandidateSerialization() throws IOException {
final CommitTransactionPayload payload = CommitTransactionPayload.create(nextTransactionId(), candidate);
- assertEquals("payload size", 169, payload.size());
+ assertEquals("payload size", 156, payload.size());
}
final byte[] bytes = bos.toByteArray();
}
final byte[] bytes = bos.toByteArray();
- assertEquals(242, bytes.length);
+ assertEquals(236, bytes.length);
ShardDataTreeSnapshot deserialized;
try (ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(bytes))) {
ShardDataTreeSnapshot deserialized;
try (ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(bytes))) {
}
final byte[] bytes = bos.toByteArray();
}
final byte[] bytes = bos.toByteArray();
- assertEquals(390, bytes.length);
+ assertEquals(384, bytes.length);
ShardDataTreeSnapshot deserialized;
try (ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(bytes))) {
ShardDataTreeSnapshot deserialized;
try (ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(bytes))) {