Renamed to 'anode'

Author: ekoutanov

Cargo.toml

@@ -1,5 +1,5 @@
 [workspace]
 members = [
-    "libmutex",
-    "libmutex-bench",
+    "anode",
+    "anode-bench",
 ]

README.md

@@ -1,8 +1,8 @@
 [package]
-name = "libmutex-bench"
+name = "anode-bench"
 version = "0.0.0"
 edition = "2021"
 
 [dependencies]
-libmutex = { version = "0.1.0", path = "../libmutex" }
+anode = { version = "0.1.0", path = "../anode" }
 parking_lot = { version = "0.12.1" }

libmutex-bench/Cargo.toml anode-bench/Cargo.toml

@@ -1,8 +1,8 @@
 use std::time::Duration;
-use libmutex::executor::{Executor, Queue, ThreadPool};
-use libmutex_bench::{args, exec_harness};
-use libmutex_bench::exec_harness::{ExtendedOptions, Options};
-use libmutex_bench::exec_harness::print::{Header, Separator};
+use anode::executor::{Executor, Queue, ThreadPool};
+use anode_bench::{args, exec_harness};
+use anode_bench::exec_harness::{ExtendedOptions, Options};
+use anode_bench::exec_harness::print::{Header, Separator};
 
 fn main() {
     const QUEUE: Queue = Queue::Bounded(10000);

libmutex-bench/LICENSE anode-bench/LICENSE

@@ -5,9 +5,9 @@
 // http://opensource.org/licenses/MIT>, at your option. This file may not be
 // copied, modified, or distributed except according to those terms.
 
-use libmutex_bench::args::ArgRange;
-use libmutex_bench::{args, pl_harness};
-use libmutex_bench::pl_shims::{ArrivalOrderedLock, ParkingLotLock, ReadBiasedLock, StdLock, StochasticLock, WriteBiasedLock};
+use anode_bench::args::ArgRange;
+use anode_bench::{args, pl_harness};
+use anode_bench::pl_shims::{ArrivalOrderedLock, ParkingLotLock, ReadBiasedLock, StdLock, StochasticLock, WriteBiasedLock};
 
 fn run_all(
     args: &[ArgRange],

libmutex-bench/src/args.rs anode-bench/src/args.rs

@@ -1,14 +1,14 @@
 use std::sync::{Mutex, RwLock};
-use libmutex::xlock::{ArrivalOrdered, LegacyReadBiased, LegacyWriteBiased, Stochastic};
-use libmutex::xlock::ReadBiased;
-use libmutex::xlock::WriteBiased;
-use libmutex::xlock::XLock;
-use libmutex_bench::quad_harness::{ExtendedOptions, Options};
-use libmutex_bench::{args, quad_harness};
+use anode::xlock::{ArrivalOrdered, LegacyReadBiased, LegacyWriteBiased, Stochastic};
+use anode::xlock::ReadBiased;
+use anode::xlock::WriteBiased;
+use anode::xlock::XLock;
+use anode_bench::quad_harness::{ExtendedOptions, Options};
+use anode_bench::{args, quad_harness};
 use std::time::Duration;
-use libmutex::spinlock::SpinLock;
-use libmutex_bench::lock_spec::LockSpec;
-use libmutex_bench::quad_harness::print::{Header, Separator};
+use anode::spinlock::SpinLock;
+use anode_bench::lock_spec::LockSpec;
+use anode_bench::quad_harness::print::{Header, Separator};
 
 fn main() {
     let args = args::parse(&["readers", "writers", "downgraders", "upgraders", "duration"]);

libmutex-bench/src/bin/exec_bench.rs anode-bench/src/bin/exec_bench.rs

@@ -1,11 +1,11 @@
-use libmutex::executor::{Executor};
+use anode::executor::{Executor};
 use std::sync::atomic::{AtomicBool, AtomicU64, Ordering};
 use std::sync::{Arc};
 use std::thread;
 use std::time::{Duration, Instant};
-use libmutex::spinlock::SpinLock;
-use libmutex::wait;
-use libmutex::wait::Wait;
+use anode::spinlock::SpinLock;
+use anode::wait;
+use anode::wait::Wait;
 use crate::rate::Elapsed;
 
 pub mod print;

libmutex-bench/src/bin/pl_bench.rs anode-bench/src/bin/pl_bench.rs

@@ -1,6 +1,6 @@
-use libmutex::spinlock::{SpinGuard, SpinLock};
-use libmutex::remedy::Remedy;
-use libmutex::xlock::{LockReadGuard, LockWriteGuard, Moderator, UpgradeOutcome, XLock};
+use anode::spinlock::{SpinGuard, SpinLock};
+use anode::remedy::Remedy;
+use anode::xlock::{LockReadGuard, LockWriteGuard, Moderator, UpgradeOutcome, XLock};
 use std::marker::PhantomData;
 use std::ops::{Deref, DerefMut};
 use std::sync::{MutexGuard, RwLock, RwLockReadGuard, RwLockWriteGuard};

libmutex-bench/src/bin/quad_bench.rs anode-bench/src/bin/quad_bench.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 use std::thread;
 use std::time::Duration;
-use libmutex::xlock::{ReadBiased, XLock};
+use anode::xlock::{ReadBiased, XLock};
 use crate::lock_spec::LockSpec;
 
 #[test]

libmutex-bench/src/exec_harness.rs anode-bench/src/exec_harness.rs

@@ -5,7 +5,7 @@
 // http://opensource.org/licenses/MIT>, at your option. This file may not be
 // copied, modified, or distributed except according to those terms.
 
-use libmutex::xlock::{ArrivalOrdered, ReadBiased, Stochastic, WriteBiased, XLock};
+use anode::xlock::{ArrivalOrdered, ReadBiased, Stochastic, WriteBiased, XLock};
 use crate::pl_harness::RwLock;
 
 pub struct ReadBiasedLock<T>(XLock<T, ReadBiased>);

libmutex-bench/src/exec_harness/print.rs anode-bench/src/exec_harness/print.rs

@@ -1,5 +1,5 @@
 use crate::lock_spec::{LockSpec, ReadGuardSpec, WriteGuardSpec};
-use libmutex::xlock::UpgradeOutcome;
+use anode::xlock::UpgradeOutcome;
 use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::{Arc, Barrier};
 use std::{hint, thread};

libmutex-bench/src/lib.rs anode-bench/src/lib.rs

@@ -1,5 +1,5 @@
-use libmutex_bench::{pl_harness, pl_shims};
-use libmutex_bench::pl_harness::RwLock;
+use anode_bench::{pl_harness, pl_shims};
+use anode_bench::pl_harness::RwLock;
 
 #[test]
 fn pl_micro_bench_read_biased() {

libmutex-bench/src/lock_spec.rs anode-bench/src/lock_spec.rs

@@ -1,9 +1,9 @@
 use std::any;
 use std::time::Duration;
-use libmutex::xlock::{ArrivalOrdered, ReadBiased, Stochastic, WriteBiased, XLock};
-use libmutex_bench::lock_spec::LockSpec;
-use libmutex_bench::quad_harness;
-use libmutex_bench::quad_harness::{Addable, BoxedInt, ExtendedOptions, Options};
+use anode::xlock::{ArrivalOrdered, ReadBiased, Stochastic, WriteBiased, XLock};
+use anode_bench::lock_spec::LockSpec;
+use anode_bench::quad_harness;
+use anode_bench::quad_harness::{Addable, BoxedInt, ExtendedOptions, Options};
 
 #[test]
 fn quad_micro_bench_read_biased_int() {

libmutex-bench/src/lock_spec/tests.rs anode-bench/src/lock_spec/tests.rs

@@ -1,9 +1,9 @@
 use std::any;
 use std::time::Duration;
-use libmutex::spinlock::SpinLock;
-use libmutex_bench::lock_spec::LockSpec;
-use libmutex_bench::quad_harness;
-use libmutex_bench::quad_harness::{Addable, BoxedInt, ExtendedOptions, Options};
+use anode::spinlock::SpinLock;
+use anode_bench::lock_spec::LockSpec;
+use anode_bench::quad_harness;
+use anode_bench::quad_harness::{Addable, BoxedInt, ExtendedOptions, Options};
 
 #[test]
 fn quad_micro_bench_int() {

libmutex-bench/src/pl_harness.rs anode-bench/src/pl_harness.rs

@@ -0,0 +1,12 @@
+[package]
+name = "anode"
+version = "0.1.0"
+edition = "2021"
+readme = "../README.md"
+authors = ["Emil Koutanov"]
+license = "MIT"
+description = "Concurrency library for Rust."
+repository = "https://github.com/obsidiandynamics/anode"
+
+[dev-dependencies]
+rand = "0.8.5"

libmutex-bench/src/pl_shims.rs anode-bench/src/pl_shims.rs

@@ -1,4 +1,4 @@
-use libmutex::rand::{clock_seed, Probability, Rand64, Seeded, Xorshift};
+use anode::rand::{clock_seed, Probability, Rand64, Seeded, Xorshift};
 
 fn main() {
     //TODO

libmutex-bench/src/quad_harness.rs anode-bench/src/quad_harness.rs

@@ -15,7 +15,7 @@ pub trait Monitor<S: ?Sized> {
     ///
     /// # Examples
     /// ```
-    /// use libmutex::monitor::{Monitor, SpeculativeMonitor};
+    /// use anode::monitor::{Monitor, SpeculativeMonitor};
     /// struct State {
     ///     foo: u64
     /// }
@@ -34,7 +34,7 @@ pub trait Monitor<S: ?Sized> {
     ///
     /// # Examples
     /// ```
-    /// use libmutex::monitor::{Monitor, SpeculativeMonitor};
+    /// use anode::monitor::{Monitor, SpeculativeMonitor};
     /// struct State {
     ///     foo: u64,
     ///     bar: u64,

libmutex-bench/src/quad_harness/print.rs anode-bench/src/quad_harness/print.rs

@@ -12,7 +12,7 @@ pub trait Rand64 {
     ///
     /// # Example
     /// ```
-    /// use libmutex::rand::{Probability, Rand64, Xorshift};
+    /// use anode::rand::{Probability, Rand64, Xorshift};
     /// let mut rng = Xorshift::default();
     /// println!("{}", rng.gen_bool(Probability::new(1.0 / 3.0)));
     /// ```
@@ -39,7 +39,7 @@ impl Probability {
     ///
     /// # Example
     /// ```
-    /// use libmutex::rand::Probability;
+    /// use anode::rand::Probability;
     /// let p = Probability::new(0.25);
     /// assert_eq!(0.25, p.into());
     /// ```

libmutex-bench/src/rate.rs anode-bench/src/rate.rs

@@ -70,7 +70,7 @@ impl<T> RefUnwindSafe for UnwindableRefCell<T> {}
 ///
 /// # Examples (not compiled)
 /// ```
-/// use libmutex::test_utils::spawn_blocked;
+/// use anode::test_utils::spawn_blocked;
 /// let thread = spawn_blocked(|| {
 ///     // wait_for_something_important
 /// });