org.opendaylight.controller.remote.rpc.registry.gossip

Class Gossiper

java.lang.Object

akka.actor.UntypedActor

org.opendaylight.controller.cluster.common.actor.AbstractUntypedActor

org.opendaylight.controller.cluster.common.actor.AbstractUntypedActorWithMetering

org.opendaylight.controller.remote.rpc.registry.gossip.Gossiper

All Implemented Interfaces:

akka.actor.Actor, ExecuteInSelfActor

public class Gossiper
extends AbstractUntypedActorWithMetering

Gossiper that syncs bucket store across nodes in the cluster.

It keeps a local scheduler that periodically sends Gossip ticks to itself to send bucket store's bucket versions to a randomly selected remote gossiper.

When bucket versions are received from a remote gossiper, it is compared with bucket store's bucket versions. Which ever buckets are newer locally, are sent to remote gossiper. If any bucket is older in bucket store, a gossip status is sent to remote gossiper so that it can send the newer buckets.

When a bucket is received from a remote gossiper, its sent to the bucket store for update.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Field Summary

Fields inherited from class org.opendaylight.controller.cluster.common.actor.AbstractUntypedActor

LOG

Method Summary

Modifier and Type	Method and Description
protected void	handleReceive(Object message) Receive and handle an incoming message.
void	postStop()
void	preStart()
static akka.actor.Props	props(RemoteRpcProviderConfig config)

Methods inherited from class org.opendaylight.controller.cluster.common.actor.AbstractUntypedActorWithMetering

getActorNameOverride

Methods inherited from class org.opendaylight.controller.cluster.common.actor.AbstractUntypedActor

executeInSelf, ignoreMessage, isValidSender, onReceive, unknownMessage

Methods inherited from class akka.actor.UntypedActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, preRestart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.actor.Actor

$init$, noSender

Method Detail

props

public static akka.actor.Props props(RemoteRpcProviderConfig config)

preStart

public void preStart()

Specified by:

preStart in interface akka.actor.Actor

Overrides:

preStart in class akka.actor.UntypedActor

postStop

public void postStop()

Specified by:

postStop in interface akka.actor.Actor

Overrides:

postStop in class akka.actor.UntypedActor

handleReceive

protected void handleReceive(Object message)

Description copied from class: AbstractUntypedActor

Receive and handle an incoming message. If the implementation does not handle this particular message, it should call AbstractUntypedActor.ignoreMessage(Object) or AbstractUntypedActor.unknownMessage(Object).

Specified by:

handleReceive in class AbstractUntypedActor

Parameters:

message - the incoming message