홍길동 / onos

Go to a project
Toggle navigation Toggle navigation pinning
Madan Jampani
bd1f0265 1 parent 932c6ba1

Registering new batch read/write request classes with kryo

Inline Side-by-side
Showing 1 changed file with 8 additions and 0 deletions
...@@ -45,11 +45,15 @@ import org.onlab.onos.store.serializers.ImmutableListSerializer; ...@@ -45,11 +45,15 @@ import org.onlab.onos.store.serializers.ImmutableListSerializer;
45 import org.onlab.onos.store.serializers.ImmutableMapSerializer; 45 import org.onlab.onos.store.serializers.ImmutableMapSerializer;
46 import org.onlab.onos.store.serializers.ImmutableSetSerializer; 46 import org.onlab.onos.store.serializers.ImmutableSetSerializer;
47 import org.onlab.onos.store.serializers.KryoSerializer; 47 import org.onlab.onos.store.serializers.KryoSerializer;
48 +import org.onlab.onos.store.service.BatchReadRequest;
49 +import org.onlab.onos.store.service.BatchWriteRequest;
48 import org.onlab.onos.store.service.ReadRequest; 50 import org.onlab.onos.store.service.ReadRequest;
49 import org.onlab.onos.store.service.ReadResult; 51 import org.onlab.onos.store.service.ReadResult;
52 +import org.onlab.onos.store.service.ReadStatus;
50 import org.onlab.onos.store.service.VersionedValue; 53 import org.onlab.onos.store.service.VersionedValue;
51 import org.onlab.onos.store.service.WriteRequest; 54 import org.onlab.onos.store.service.WriteRequest;
52 import org.onlab.onos.store.service.WriteResult; 55 import org.onlab.onos.store.service.WriteResult;
56 +import org.onlab.onos.store.service.WriteStatus;
53 import org.onlab.util.KryoNamespace; 57 import org.onlab.util.KryoNamespace;
54 import org.slf4j.Logger; 58 import org.slf4j.Logger;
55 59
...@@ -112,6 +116,10 @@ public class ClusterMessagingProtocol ...@@ -112,6 +116,10 @@ public class ClusterMessagingProtocol
112 .register(InternalReadResult.Status.class) 116 .register(InternalReadResult.Status.class)
113 .register(WriteResult.class) 117 .register(WriteResult.class)
114 .register(ReadResult.class) 118 .register(ReadResult.class)
119 + .register(BatchReadRequest.class)
120 + .register(BatchWriteRequest.class)
121 + .register(ReadStatus.class)
122 + .register(WriteStatus.class)
115 .register(InternalWriteResult.Status.class) 123 .register(InternalWriteResult.Status.class)
116 .register(VersionedValue.class) 124 .register(VersionedValue.class)
117 .build(); 125 .build();
......