pankaj

Merge branch 'master' of ssh://gerrit.onlab.us:29418/onos-next

1 /** 1 /**
2 * Distributed cluster store and messaging subsystem implementation. 2 * Distributed cluster store and messaging subsystem implementation.
3 */ 3 */
4 -package org.onlab.onos.store.cluster.impl;
...\ No newline at end of file ...\ No newline at end of file
4 +package org.onlab.onos.store.cluster.impl;
......
...@@ -10,6 +10,8 @@ import com.google.common.collect.ImmutableMap; ...@@ -10,6 +10,8 @@ import com.google.common.collect.ImmutableMap;
10 10
11 /** 11 /**
12 * Anti-Entropy advertisement message. 12 * Anti-Entropy advertisement message.
13 + * <p>
14 + * Message to advertise the information this node holds.
13 * 15 *
14 * @param <ID> ID type 16 * @param <ID> ID type
15 */ 17 */
......
...@@ -11,6 +11,13 @@ import org.onlab.onos.store.device.impl.VersionedValue; ...@@ -11,6 +11,13 @@ import org.onlab.onos.store.device.impl.VersionedValue;
11 import com.google.common.collect.ImmutableMap; 11 import com.google.common.collect.ImmutableMap;
12 import com.google.common.collect.ImmutableSet; 12 import com.google.common.collect.ImmutableSet;
13 13
14 +/**
15 + * Anti-Entropy reply message.
16 + * <p>
17 + * Message to send in reply to advertisement or another reply.
18 + * Suggest to the sender about the more up-to-date data this node has,
19 + * and request for more recent data that the receiver has.
20 + */
14 public class AntiEntropyReply<ID, VALUE> extends ClusterMessage { 21 public class AntiEntropyReply<ID, VALUE> extends ClusterMessage {
15 22
16 private final NodeId sender; 23 private final NodeId sender;
......
1 /** 1 /**
2 * Cluster messaging APIs for the use by the various distributed stores. 2 * Cluster messaging APIs for the use by the various distributed stores.
3 */ 3 */
4 -package org.onlab.onos.store.cluster.messaging;
...\ No newline at end of file ...\ No newline at end of file
4 +package org.onlab.onos.store.cluster.messaging;
......