Create Rust iml-state-machine

WIP

Signed-off-by: Joe Grund <[email protected]>

Cargo.toml

@@ -25,6 +25,7 @@ members = [
     'iml-services/iml-service-queue',
     'iml-services/iml-stats',
     'iml-sfa',
+    'iml-state-machine',
     'iml-system-test-utils',
     'iml-systemd',
     'iml-timer',

iml-state-machine/Cargo.toml

@@ -0,0 +1,9 @@
+[package]
+name = "iml-state-machine"
+version = "0.1.0"
+authors = ["IML Team <[email protected]>"]
+edition = "2018"
+
+[dependencies]
+futures = "0.3"
+petgraph = "0.5"

iml-state-machine/README.md

@@ -0,0 +1,27 @@
+# IML State Machine Model
+
+```
+                       ┌────────────────────────────────────────────┐
+                       │                                            │
+                       │                Client mount                │
+                       │                                            │
+                       │                                            │
+                       └────────────────────────────────────────────┘
+                                              │
+                                              │
+                                              │
+                                              │
+                                              │
+                       ┌───────Depends on─────┴────────Depends On─────────┐
+                       │                                                  │
+                       │                                                  │
+                       │                                                  │
+                       │                                                  │
+                       ▼                                                  ▼
+┌────────────────────────────────────────────┐     ┌────────────────────────────────────────────┐
+│                                            │     │                                            │
+│                    LNet                    │     │                 Filesystem                 │
+│                                            │     │                                            │
+│                                            │     │                                            │
+└────────────────────────────────────────────┘     └────────────────────────────────────────────┘
+```

iml-state-machine/src/lnet.rs

@@ -0,0 +1,88 @@
+// Copyright (c) 2020 DDN. All rights reserved.
+// Use of this source code is governed by a MIT-style
+// license that can be found in the LICENSE file.
+
+use futures::{Future, FutureExt};
+use petgraph::graph::DiGraph;
+use std::{ io, pin::Pin};
+
+pub enum LnetStates {
+    Unconfigured,
+    Unloaded,
+    Down,
+    Up,
+}
+
+impl Default for LnetStates {
+    fn default() -> Self {
+        Self::Unconfigured
+    }
+}
+
+impl LnetStates {
+    fn step(self, next: &Self) {
+        match (self, next) {
+            (Self::Unconfigured, Self::Unloaded) => {}
+            (Self::Unloaded, Self::Down) => {}
+            (Self::Down, Self::Up) => {}
+            (Self::Up, Self::Down) => {}
+            (Self::Down, Self::Unloaded) => {}
+            (Self::Unloaded, Self::Unconfigured) => {}
+            _ => {}
+        };
+    }
+}
+
+async fn configure() -> Result<(), io::Error> {
+    Ok(())
+}
+
+async fn load() -> Result<(), io::Error> {
+    Ok(())
+}
+
+async fn start() -> Result<(), io::Error> {
+    Ok(())
+}
+
+async fn stop() -> Result<(), io::Error> {
+    Ok(())
+}
+
+async fn unload() -> Result<(), io::Error> {
+    Ok(())
+}
+
+async fn unconfigure() -> Result<(), io::Error> {
+    Ok(())
+}
+
+type BoxedFuture = Pin<Box<dyn Future<Output = Result<(), io::Error>> + Send>>;
+
+type Transition = Box<dyn Fn() -> BoxedFuture + Send + Sync>;
+
+fn mk_transition<Fut>(f: fn() -> Fut) -> Transition
+where
+    Fut: Future<Output = Result<(), io::Error>> + Send + 'static,
+{
+    Box::new(move || f().boxed())
+}
+
+fn build_graph() -> DiGraph::<LnetStates, Transition> {
+    let mut deps = DiGraph::<LnetStates, Transition>::new();
+
+    let unconfigured = deps.add_node(LnetStates::Unconfigured);
+    let unloaded = deps.add_node(LnetStates::Unloaded);
+    let down = deps.add_node(LnetStates::Down);
+    let up = deps.add_node(LnetStates::Up);
+
+    deps.add_edge(unconfigured, unloaded, mk_transition(configure));
+    deps.add_edge(unloaded, down, mk_transition(load));
+    deps.add_edge(down, up, mk_transition(start));
+    deps.add_edge(up, down, mk_transition(stop));
+    deps.add_edge(down, unloaded, mk_transition(unload));
+    deps.add_edge(unloaded, unconfigured, mk_transition(unconfigure));
+
+    deps
+
+}

iml-state-machine/src/main.rs

@@ -0,0 +1,9 @@
+// Copyright (c) 2020 DDN. All rights reserved.
+// Use of this source code is governed by a MIT-style
+// license that can be found in the LICENSE file.
+
+mod lnet;
+
+fn main() {
+    println!("Hello, world!");
+}