2 * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.controller.cluster.raft;
11 import akka.actor.ActorRef;
12 import akka.actor.ActorSelection;
13 import akka.actor.ActorSystem;
14 import akka.actor.Props;
15 import akka.event.Logging;
16 import akka.event.LoggingAdapter;
17 import com.google.common.base.Preconditions;
18 import com.google.protobuf.GeneratedMessage;
19 import java.io.Serializable;
20 import java.util.HashMap;
22 import org.opendaylight.controller.cluster.raft.protobuff.client.messages.Payload;
23 import org.opendaylight.controller.protobuff.messages.cluster.raft.AppendEntriesMessages;
24 import org.opendaylight.controller.protobuff.messages.cluster.raft.test.MockPayloadMessages;
26 public class MockRaftActorContext implements RaftActorContext {
29 private ActorSystem system;
30 private ActorRef actor;
31 private long index = 0;
32 private long lastApplied = 0;
33 private final ElectionTerm electionTerm;
34 private ReplicatedLog replicatedLog;
35 private Map<String, String> peerAddresses = new HashMap<>();
36 private ConfigParams configParams;
38 public MockRaftActorContext(){
44 public MockRaftActorContext(String id, ActorSystem system, ActorRef actor){
49 final String id1 = id;
50 electionTerm = new ElectionTerm() {
52 * Identifier of the actor whose election term information this is
54 private final String id = id1;
55 private long currentTerm = 0;
56 private String votedFor = "";
59 public long getCurrentTerm() {
64 public String getVotedFor() {
69 public void update(long currentTerm, String votedFor){
70 this.currentTerm = currentTerm;
71 this.votedFor = votedFor;
73 // TODO : Write to some persistent state
76 @Override public void updateAndPersist(long currentTerm,
78 update(currentTerm, votedFor);
82 configParams = new DefaultConfigParamsImpl();
88 public void initReplicatedLog(){
89 this.replicatedLog = new SimpleReplicatedLog();
90 this.replicatedLog.append(new MockReplicatedLogEntry(1, 1, new MockPayload("")));
93 @Override public ActorRef actorOf(Props props) {
94 return system.actorOf(props);
97 @Override public ActorSelection actorSelection(String path) {
98 return system.actorSelection(path);
101 @Override public String getId() {
105 @Override public ActorRef getActor() {
109 @Override public ElectionTerm getTermInformation() {
113 public void setIndex(long index){
117 @Override public long getCommitIndex() {
121 @Override public void setCommitIndex(long commitIndex) {
122 this.index = commitIndex;
125 @Override public void setLastApplied(long lastApplied){
126 this.lastApplied = lastApplied;
129 @Override public long getLastApplied() {
134 public void setReplicatedLog(ReplicatedLog replicatedLog) {
135 this.replicatedLog = replicatedLog;
138 @Override public ReplicatedLog getReplicatedLog() {
139 return replicatedLog;
142 @Override public ActorSystem getActorSystem() {
146 @Override public LoggingAdapter getLogger() {
147 return Logging.getLogger(system, this);
150 @Override public Map<String, String> getPeerAddresses() {
151 return peerAddresses;
154 @Override public String getPeerAddress(String peerId) {
155 return peerAddresses.get(peerId);
158 @Override public void addToPeers(String name, String address) {
159 peerAddresses.put(name, address);
162 @Override public void removePeer(String name) {
163 peerAddresses.remove(name);
166 @Override public ActorSelection getPeerActorSelection(String peerId) {
167 String peerAddress = getPeerAddress(peerId);
168 if(peerAddress != null){
169 return actorSelection(peerAddress);
174 @Override public void setPeerAddress(String peerId, String peerAddress) {
175 Preconditions.checkState(peerAddresses.containsKey(peerId));
176 peerAddresses.put(peerId, peerAddress);
179 public void setPeerAddresses(Map<String, String> peerAddresses) {
180 this.peerAddresses = peerAddresses;
184 public ConfigParams getConfigParams() {
188 public void setConfigParams(ConfigParams configParams) {
189 this.configParams = configParams;
192 public static class SimpleReplicatedLog extends AbstractReplicatedLogImpl {
193 @Override public void appendAndPersist(
194 ReplicatedLogEntry replicatedLogEntry) {
195 append(replicatedLogEntry);
199 public int dataSize() {
203 @Override public void removeFromAndPersist(long index) {
208 public static class MockPayload extends Payload implements Serializable {
209 private static final long serialVersionUID = 3121380393130864247L;
210 private String value = "";
212 public MockPayload(){
216 public MockPayload(String s) {
220 @Override public Map<GeneratedMessage.GeneratedExtension, String> encode() {
221 Map<GeneratedMessage.GeneratedExtension, String> map = new HashMap<GeneratedMessage.GeneratedExtension, String>();
222 map.put(MockPayloadMessages.value, value);
226 @Override public Payload decode(
227 AppendEntriesMessages.AppendEntries.ReplicatedLogEntry.Payload payloadProtoBuff) {
228 String value = payloadProtoBuff.getExtension(MockPayloadMessages.value);
235 return value.length();
238 @Override public String getClientPayloadClassName() {
239 return MockPayload.class.getName();
243 public String toString() {
248 public static class MockReplicatedLogEntry implements ReplicatedLogEntry, Serializable {
249 private static final long serialVersionUID = 1L;
251 private final long term;
252 private final long index;
253 private final Payload data;
255 public MockReplicatedLogEntry(long term, long index, Payload data){
262 @Override public Payload getData() {
266 @Override public long getTerm() {
270 @Override public long getIndex() {
276 return getData().size();
280 public static class MockReplicatedLogBuilder {
281 private final ReplicatedLog mockLog = new SimpleReplicatedLog();
283 public MockReplicatedLogBuilder createEntries(int start, int end, int term) {
284 for (int i=start; i<end; i++) {
285 this.mockLog.append(new ReplicatedLogImplEntry(i, term, new MockRaftActorContext.MockPayload("foo" + i)));
290 public MockReplicatedLogBuilder addEntry(int index, int term, MockPayload payload) {
291 this.mockLog.append(new ReplicatedLogImplEntry(index, term, payload));
295 public ReplicatedLog build() {