Method name refactor in DistributedPrimitive + Builder for AsyncLeaderElector
Change-Id: I59be6e66665c0b12d02106bd5c722e9fa38dd7a1
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultCatalystTypeSerializerFactory.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultCatalystTypeSerializerFactory.java
index 6c709ce..78fcedd 100644
--- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultCatalystTypeSerializerFactory.java
+++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultCatalystTypeSerializerFactory.java
@@ -54,29 +54,29 @@
}
@Override
- public T read(Class<T> clazz, BufferInput<?> input,
- io.atomix.catalyst.serializer.Serializer serializer) {
- int size = input.readInt();
- byte[] payload = new byte[size];
- input.read(payload);
+ public void write(T object, BufferOutput<?> buffer,
+ io.atomix.catalyst.serializer.Serializer serializer) {
try {
- return this.serializer.decode(payload);
+ byte[] payload = this.serializer.encode(object);
+ buffer.writeInt(payload.length);
+ buffer.write(payload);
} catch (Exception e) {
- log.warn("Failed to deserialize as type {}", clazz, e);
- Throwables.propagate(e);
- return null;
+ log.warn("Failed to serialize {}", object, e);
}
}
@Override
- public void write(T object, BufferOutput<?> output,
- io.atomix.catalyst.serializer.Serializer serializer) {
+ public T read(Class<T> type, BufferInput<?> buffer,
+ io.atomix.catalyst.serializer.Serializer serializer) {
+ int size = buffer.readInt();
try {
- byte[] payload = this.serializer.encode(object);
- output.writeInt(payload.length);
- output.write(payload);
+ byte[] payload = new byte[size];
+ buffer.read(payload);
+ return this.serializer.decode(payload);
} catch (Exception e) {
- log.warn("Failed to serialize {}", object, e);
+ log.warn("Failed to deserialize as type {}. Payload size: {}", type, size, e);
+ Throwables.propagate(e);
+ return null;
}
}
}