| commit | 361664ee4ea4a662f52cb988143bb178daa8f1ce | [log] [tgz] |
|---|---|---|
| author | Yuta HIGUCHI <y-higuchi@onlab.us> | Thu Nov 06 17:28:47 2014 -0800 |
| committer | Yuta HIGUCHI <y-higuchi@onlab.us> | Thu Nov 06 18:06:12 2014 -0800 |
| tree | 56bb5423f38c0976df4f1576a6efa7070660e5bd | |
| parent | f3346a557a447c524852deb84d8e77e4b8806a6f [diff] [blame] |
Add sample accessing database service to Foo Change-Id: I514c57a278dea368448d284eb5bf0d41bb0013e3
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocol.java b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocol.java index 56dba79..9a792bb 100644 --- a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocol.java +++ b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocol.java
@@ -105,6 +105,7 @@ private static final KryoNamespace DATABASE = KryoNamespace.newBuilder() .register(ReadRequest.class) .register(WriteRequest.class) + .register(WriteRequest.Type.class) .register(InternalReadResult.class) .register(InternalWriteResult.class) .register(InternalReadResult.Status.class) @@ -135,6 +136,7 @@ byte[].class) .build(); + // serializer used for CopyCat Protocol public static final KryoSerializer SERIALIZER = new KryoSerializer() { @Override protected void setupKryoPool() {