bastion-rs · o0Ignition0o · Sep 24, 2020 · Sep 24, 2020 · Sep 24, 2020 · Sep 24, 2020
diff --git a/.github/workflows/clippy.yml b/.github/workflows/clippy.yml
diff --git a/.github/workflows/miri.yml b/.github/workflows/miri.yml
@@ -14,7 +14,7 @@ jobs:
       - name: Install
         uses: actions-rs/toolchain@v1
         with:
-          toolchain: nightly-2020-06-22
+          toolchain: nightly-2021-03-20
           override: true
       - uses: davidB/rust-cargo-make@v1
         with:
@@ -24,13 +24,4 @@ jobs:
           RUST_BACKTRACE: full
           RUST_LOG: 'trace'
         run: |
-          rustup component add miri
-          cargo miri setup
-          cargo clean
-          # Do some Bastion shake
-          cd src/bastion && \
-            cargo miri test --features lever/nightly -- -Zmiri-disable-isolation -Zmiri-ignore-leaks -- dispatcher && \
-            cargo miri test --features lever/nightly -- -Zmiri-disable-isolation -Zmiri-ignore-leaks -- path && \
-            cargo miri test --features lever/nightly -- -Zmiri-disable-isolation -Zmiri-ignore-leaks -- broadcast && \
-            cargo miri test --features lever/nightly -- -Zmiri-disable-isolation -Zmiri-ignore-leaks -- children_ref && \
-            cd -
+          tools/miri.sh
diff --git a/.github/workflows/sanitizers.yml b/.github/workflows/sanitizers.yml
@@ -15,7 +15,7 @@ jobs:
       - name: Install
         uses: actions-rs/toolchain@v1
         with:
-          toolchain: nightly-2020-03-08
+          toolchain: nightly-2021-03-20
           override: true
       - uses: davidB/rust-cargo-make@v1
         with:

diff --git a/README.md b/README.md
@@ -2,82 +2,73 @@
   <img src="https://github.com/bastion-rs/bastion/blob/master/img/bastion.png"><br>
 </div>
 
------------------
-
-<h1 align="center">Highly-available Distributed Fault-tolerant Runtime</h1>
+---
 
-<table align=left style='float: left; margin: 4px 10px 0px 0px; border: 1px solid #000000;'>
-<tr>
-  <td>Latest Release</td>
-  <td>
-    <a href="https://crates.io/crates/bastion">
-    <img alt="Crates.io" src="https://img.shields.io/crates/v/bastion.svg?style=popout-square">
-    </a>
-  </td>
-</tr>
-<tr>
-  <td></td>
-</tr>
-<tr>
-  <td>License</td>
-  <td>
-    <a href="https://github.com/bastion-rs/bastion/blob/master/LICENSE">
-    <img alt="Crates.io" src="https://img.shields.io/crates/l/bastion.svg?style=popout-square">
-    </a>
-</td>
-</tr>
-<tr>
-  <td>Doc [Bastion]</td>
-  <td>
-    <a href="https://docs.rs/bastion">
-    <img alt="Documentation (Bastion)" src="https://img.shields.io/badge/rustdoc-bastion-blue.svg" />
-    </a>
-  </td>
-</tr>
-<tr>
+<table>
+  <tr>
+    <td>Latest Release</td>
+    <td>
+      <a href="https://crates.io/crates/bastion">
+      <img alt="Crates.io" src="https://img.shields.io/crates/v/bastion.svg?style=popout-square">
+      </a>
+    </td>
+    <td>License</td>
+    <td>
+      <a href="https://github.com/bastion-rs/bastion/blob/master/LICENSE">
+      <img alt="Crates.io" src="https://img.shields.io/crates/l/bastion.svg?style=popout-square">
+      </a>
+    </td>
+  </tr>
+  <tr>
+    <td>Doc [Bastion]</td>
+    <td>
+      <a href="https://docs.rs/bastion">
+      <img alt="Documentation (Bastion)" src="https://img.shields.io/badge/rustdoc-bastion-blue.svg" />
+      </a>
+    </td>
+    <td>Downloads</td>
+    <td>
+      <a href="https://crates.io/crates/bastion">
+      <img alt="Crates.io" src="https://img.shields.io/crates/d/bastion.svg?style=popout-square">
+      </a>
+    </td>
+  </tr>
+  <tr>
   <td>Doc [Bastion Executor]</td>
-  <td>
-    <a href="https://docs.rs/bastion-executor">
-    <img alt="Documentation (Bastion Executor)" src="https://img.shields.io/badge/rustdoc-bastion_executor-blue.svg" />
-    </a>
-  </td>
-</tr>
-<tr>
-  <td>Doc [LightProc]</td>
-  <td>
-    <a href="https://docs.rs/lightproc">
-    <img alt="Documentation (LightProc)" src="https://img.shields.io/badge/rustdoc-lightproc-blue.svg" />
-    </a>
-  </td>
-</tr>
-<tr>
-  <td>Build Status</td>
-  <td>
-    <a href="https://github.com/bastion-rs/bastion/actions">
-    <img alt="Build Status" src="https://github.com/bastion-rs/bastion/workflows/CI/badge.svg" />
-    </a>
-  </td>
-</tr>
-<tr>
-  <td>Downloads</td>
-  <td>
-    <a href="https://crates.io/crates/bastion">
-    <img alt="Crates.io" src="https://img.shields.io/crates/d/bastion.svg?style=popout-square">
-    </a>
-  </td>
-</tr>
-<tr>
-	<td>Discord</td>
-	<td>
-		<a href="https://discord.gg/DqRqtRT">
-		<img src="https://img.shields.io/discord/628383521450360842.svg?logo=discord" />
-		</a>
-	</td>
-</tr>
+    <td>
+      <a href="https://docs.rs/bastion-executor">
+      <img alt="Documentation (Bastion Executor)" src="https://img.shields.io/badge/rustdoc-bastion_executor-blue.svg" />
+      </a>
+    </td>
+    <td>Discord</td>
+    <td>
+      <a href="https://discord.gg/DqRqtRT">
+      <img src="https://img.shields.io/discord/628383521450360842.svg?logo=discord" />
+      </a>
+    </td>
+  </tr>
+  <tr>
+  </tr>
+  <tr>
+    <td>Doc [LightProc]</td>
+    <td>
+      <a href="https://docs.rs/lightproc">
+      <img alt="Documentation (LightProc)" src="https://img.shields.io/badge/rustdoc-lightproc-blue.svg" />
+      </a>
+    </td>
+    <td>Build Status</td>
+    <td>
+      <a href="https://github.com/bastion-rs/bastion/actions">
+      <img alt="Build Status" src="https://github.com/bastion-rs/bastion/workflows/CI/badge.svg" />
+      </a>
+    </td>
+  </tr>
 </table>
 
 ---
 
+<h1 align="center">Highly-available Distributed Fault-tolerant Runtime</h1>
+
 Bastion is a highly-available, fault-tolerant runtime system with dynamic, dispatch-oriented, lightweight process model. It supplies actor-model-like concurrency with a lightweight process implementation and utilizes all of the system resources efficiently guaranteeing of at-most-once message delivery.
 
 ---
@@ -87,6 +78,23 @@ Bastion is a highly-available, fault-tolerant runtime system with dynamic, dispa
 Bastion comes with a default one-for-one strategy root supervisor.
 You can use this to launch automatically supervised tasks.
 
+## Get Started
+
+Include bastion to your project with:
+```toml
+bastion = "0.4"
+```
+
+### Documentation
+
+Official documentation is hosted on [docs.rs](https://docs.rs/bastion).
+
+### Examples
+
+Check the [getting started example](https://github.com/bastion-rs/bastion/blob/master/src/bastion/examples/getting_started.rs) in <code>bastion/examples</code>
+
+[Examples](https://github.com/bastion-rs/bastion/blob/master/src/bastion/examples) cover possible use cases of the crate.
+
 ## Features
 * Message-based communication makes this project a lean mesh of actor system.
     * Without web servers, weird shenanigans, forced trait implementations, and static dispatch.
@@ -144,50 +152,37 @@ It's independent of it's framework implementation. It uses lightproc to encapsul
 ### [Agnostik](https://github.com/bastion-rs/agnostik)
 Agnostik is a layer between your application and the executor for your async stuff. It lets you switch the executors smooth and easy without having to change your applications code. Valid features are `runtime_bastion` (default), `runtime_tokio`, `runtime_asyncstd` and `runtime_nostd` (coming soon).
 
-## Get Started
-Check the [getting started example](https://github.com/bastion-rs/bastion/blob/master/src/bastion/examples/getting_started.rs) in <code>bastion/examples</code>
-
-[Examples](https://github.com/bastion-rs/bastion/blob/master/src/bastion/examples) cover possible use cases of the crate.
-
-Include bastion to your project with:
-```toml
-bastion = "0.4"
-```
-
-For more information please check [Bastion Documentation](https://docs.rs/bastion)
-
 ## Architecture of the Runtime
 Runtime is structured by the user. Only root supervision comes in batteries-included fashion.
 Worker code, worker group redundancy, supervisors and their supervision strategies are defined by the user.
 
-## License
-
-Licensed under either of
-
- * Apache License, Version 2.0 ([LICENSE-APACHE](LICENSE-APACHE) or http://www.apache.org/licenses/LICENSE-2.0)
- * MIT license ([LICENSE-MIT](LICENSE-MIT) or http://opensource.org/licenses/MIT)
-
-at your option.
-
-## Documentation
+Supervision strategies define how child actor failures are handled, how often a child can fail, and how long to wait before a child actor is recreated. As the name suggests, One-For-One strategy means the supervision strategy is applied only to the failed child. All-For-One strategy means that the supervision strategy is applied to all the actor siblings as well. One-for-one supervision is used at the root supervisor, while child groups may have different strategies like rest-for-one or one-for-all.
 
-Official documentation is hosted on [docs.rs](https://docs.rs/bastion).
+![Bastion Architecture](img/bastion-architecture.png)
 
-## Getting Help
+## Community
+### Getting Help
 Please head to our [Discord](https://discord.gg/DqRqtRT) or use [StackOverflow](https://stackoverflow.com/questions/tagged/bastion)
 
-## Discussion and Development
+### Discussion and Development
 We use [Discord](https://discord.gg/DqRqtRT) for development discussions. Also please don't hesitate to open issues on GitHub ask for features, report bugs, comment on design and more!
 More interaction and more ideas are better!
 
-## Contributing to Bastion [![Open Source Helpers](https://www.codetriage.com/bastion-rs/bastion/badges/users.svg)](https://www.codetriage.com/bastion-rs/bastion)
+### Contributing to Bastion [![Open Source Helpers](https://www.codetriage.com/bastion-rs/bastion/badges/users.svg)](https://www.codetriage.com/bastion-rs/bastion)
 
 All contributions, bug reports, bug fixes, documentation improvements, enhancements and ideas are welcome.
 
 A detailed overview on how to contribute can be found in the  [CONTRIBUTING guide](https://github.com/bastion-rs/.github/blob/master/CONTRIBUTING.md) on GitHub[.](https://youtu.be/w55YCDzZjvA)
 
 ## License
 
+Licensed under either of
+
+ * Apache License, Version 2.0 ([LICENSE-APACHE](LICENSE-APACHE) or http://www.apache.org/licenses/LICENSE-2.0)
+ * MIT license ([LICENSE-MIT](LICENSE-MIT) or http://opensource.org/licenses/MIT)
+
+at your option.
+
 [![FOSSA Status](https://app.fossa.io/api/projects/git%2Bgithub.com%2Fbastion-rs%2Fbastion.svg?type=large)](https://app.fossa.io/projects/git%2Bgithub.com%2Fbastion-rs%2Fbastion?ref=badge_large)
 
 [![FOSSA Status](https://app.fossa.io/api/projects/git%2Bgithub.com%2Fbastion-rs%2Fbastion.svg?type=shield)](https://app.fossa.io/projects/git%2Bgithub.com%2Fbastion-rs%2Fbastion?ref=badge_shield)
diff --git a/img/bastion-architecture.png b/img/bastion-architecture.png
diff --git a/src/bastion-executor/Cargo.toml b/src/bastion-executor/Cargo.toml
@@ -5,7 +5,7 @@ name = "bastion-executor"
 # - Update CHANGELOG.md.
 #   - npm install -g auto-changelog && auto-changelog at the root
 # - Create "v0.x.y" git tag at the root of the project.
-version = "0.3.7-alpha.0"
+version = "0.4.1"
 description = "Cache affine NUMA-aware executor for Rust"
 authors = ["Mahmut Bulut <[email protected]>"]
 keywords = ["fault-tolerant", "runtime", "actor", "system"]
@@ -25,34 +25,41 @@ travis-ci = { repository = "bastion-rs/bastion", branch = "master" }
 maintenance = { status = "actively-developed" }
 
 [features]
-unstable = ["numanji", "allocator-suite", "jemallocator"]
+unstable = []
+tokio-runtime = ["tokio"]
 
 [dependencies]
-lightproc = "0.3.5"
 bastion-utils = "0.3.2"
+# lightproc = "0.3"
+lightproc =  { git = "https://github.com/bastion-rs/bastion.git" }
 # lightproc = { path = "../lightproc" }
 # bastion-utils = { path = "../bastion-utils" }
 
-crossbeam-utils = "0.7"
-crossbeam-channel = "0.4"
-crossbeam-epoch = "0.8"
+crossbeam-utils = "0.8"
+crossbeam-channel = "0.5"
+crossbeam-epoch = "0.9"
 lazy_static = "1.4"
 libc = "0.2"
 num_cpus = "1.13"
 pin-utils = "0.1.0"
 
 # Allocator
-numanji = { version = "^0.1", optional = true, default-features = false }
-allocator-suite = { version = "^0.1", optional = true, default-features = false }
-arrayvec = { version = "0.5.1", features = ["array-sizes-129-255"]}
+arrayvec = { version = "0.7.0" }
 futures-timer = "3.0.2"
+once_cell = "1.4.0"
+lever = "0.1"
+tracing = "0.1.19"
+crossbeam-queue = "0.3.0"
 
-[target.'cfg(not(any(target_os = "android", target_os = "linux")))'.dependencies]
-jemallocator = { version = "^0.3", optional = true, default-features = false }
+# Feature tokio
+tokio = {version = "1.1", features = ["rt", "rt-multi-thread"], optional = true }
 
 [target.'cfg(target_os = "windows")'.dependencies]
 winapi = { version = "^0.3.8", features = ["basetsd"] }
 
 [dev-dependencies]
-proptest = "^0.10"
+tokio = {version = "1.1", features = ["rt", "rt-multi-thread", "macros"] }
+tokio-test = "0.4.0"
+proptest = "^1.0"
 futures = "0.3.5"
+tracing-subscriber = "0.2.11"