Dummy Distributed Data Store for testing replication

[controller.git] / opendaylight / md-sal / sal-dummy-distributed-datastore / src / main / java / org / opendaylight / controller / dummy / datastore / Main.java

diff --git a/opendaylight/md-sal/sal-dummy-distributed-datastore/src/main/java/org/opendaylight/controller/dummy/datastore/Main.java b/opendaylight/md-sal/sal-dummy-distributed-datastore/src/main/java/org/opendaylight/controller/dummy/datastore/Main.java
new file mode 100644 (file)
index 0000000..81da1f8
--- /dev/null
+++ b/opendaylight/md-sal/sal-dummy-distributed-datastore/src/main/java/org/opendaylight/controller/dummy/datastore/Main.java
@@ -0,0 +1,62 @@
+/*
+ * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.controller.dummy.datastore;
+
+import akka.actor.ActorSystem;
+import com.typesafe.config.ConfigFactory;
+import org.kohsuke.args4j.CmdLineParser;
+import org.kohsuke.args4j.Option;
+
+public class Main {
+    @Option(name="-member-name", usage="Sets the member name", required = true)
+    public String memberName;
+
+    @Option(name="-max-delay-millis", usage = "Sets the maximum delay that should be applied for any append entry. Only applies when cause-trouble is present.")
+    public int maxDelayInMillis = 500;
+
+    @Option(name="-cause-trouble", usage="If present turns on artificial failures")
+    public boolean causeTrouble = false;
+
+    @Option(name="-drop-replies", usage = "If present drops replies. Only applies when cause-trouble is present.")
+    public boolean dropReplies = false;
+
+    public void run(){
+        ActorSystem actorSystem = ActorSystem.create("opendaylight-cluster-data", ConfigFactory.load(memberName).getConfig("odl-cluster-data"));
+
+        Configuration configuration = new Configuration(maxDelayInMillis, dropReplies, causeTrouble);
+
+        actorSystem.actorOf(DummyShardManager.props(configuration, memberName, new String[] {"inventory", "default", "toaster", "topology"}, "operational"), "shardmanager-operational");
+        actorSystem.actorOf(DummyShardManager.props(configuration, memberName, new String[] {"inventory", "default", "toaster", "topology"}, "config"), "shardmanager-config");
+    }
+
+    @Override
+    public String toString() {
+        return "Main{" +
+                "memberName='" + memberName + '\'' +
+                ", maxDelayInMillis=" + maxDelayInMillis +
+                ", causeTrouble=" + causeTrouble +
+                ", dropReplies=" + dropReplies +
+                '}';
+    }
+
+    public static void main(String[] args){
+        Main bean = new Main();
+        CmdLineParser parser = new CmdLineParser(bean);
+
+        try {
+            parser.parseArgument(args);
+            System.out.println(bean.toString());
+            bean.run();
+        } catch(Exception e){
+            System.err.println(e.getMessage());
+            parser.printUsage(System.err);
+        }
+    }
+
+}