switched to parking_lot_rt fork

Cargo.toml

@@ -24,7 +24,6 @@ libc = "0.2.153"
 nix = { version = "0.27", features = ["signal"] }
 object-id = "0.1.3"
 oneshot = { version = "0.1.6", default-features = false, features = ["std"] }
-parking_lot = "0.12.1"
 pin-project = "1.1.5"
 rmodbus = { version = "0.9.4", optional = true }
 roboplc-derive = { version = "0.1" }
@@ -43,6 +42,7 @@ env_logger = "0.10"
 log = "0.4.21"
 metrics-exporter-prometheus = { version = "0.14.0", optional = true, default-features = false, features = ["http-listener"] }
 metrics = { version = "0.22.3", optional = true }
+parking_lot_rt = "0.12.1"
 
 [features]
 eapi = ["eva-common", "eva-sdk", "busrt", "tokio", "hostname"]

src/buf.rs

 use std::collections::VecDeque;
 
-use parking_lot::Mutex;
+use parking_lot_rt::Mutex;
 
 /// A capacity-limited thread-safe deque-based data buffer
 pub struct DataBuffer<T> {

src/comm/mod.rs

-use parking_lot::MutexGuard;
+use parking_lot_rt::MutexGuard;
 use std::{
     io::{Read, Write},
     net::SocketAddr,

src/comm/serial.rs

@@ -3,7 +3,7 @@ use crate::{Error, Result};
 use super::Client;
 use super::Communicator;
 use super::Protocol;
-use parking_lot::{Mutex, MutexGuard};
+use parking_lot_rt::{Mutex, MutexGuard};
 use serial::prelude::*;
 use serial::SystemPort;
 use std::io;

src/comm/tcp.rs

@@ -5,7 +5,7 @@ use super::{
     ChatFn, Client, CommReader, Communicator, ConnectionOptions, Protocol, Stream, Timeouts,
 };
 use core::fmt;
-use parking_lot::{Mutex, MutexGuard};
+use parking_lot_rt::{Mutex, MutexGuard};
 use std::io::{Read, Write};
 use std::net::{self, TcpStream};
 use std::net::{SocketAddr, ToSocketAddrs};

src/controller.rs

@@ -15,7 +15,7 @@ use crate::{
     thread_rt::{Builder, RTParams, Scheduling},
     DataDeliveryPolicy, Error, Result,
 };
-use parking_lot::RwLock;
+use parking_lot_rt::RwLock;
 pub use roboplc_derive::WorkerOpts;
 use signal_hook::{
     consts::{SIGINT, SIGTERM},

src/hub.rs

 use std::sync::Arc;
 
-use parking_lot::Mutex;
+use parking_lot_rt::Mutex;
 
 use crate::pchannel::{self, Receiver, Sender};
 use crate::{DataDeliveryPolicy, Error, Result};

src/hub_async.rs

 use std::future::Future;
 use std::sync::Arc;
 
-use parking_lot::Mutex;
+use parking_lot_rt::Mutex;
 
 use crate::pchannel_async::{self, Receiver, Sender};
 use crate::{DataDeliveryPolicy, Error, Result};

src/io/modbus/server.rs

@@ -5,7 +5,7 @@ use crate::{
     Error, Result,
 };
 use binrw::{BinRead, BinWrite};
-use parking_lot::Mutex;
+use parking_lot_rt::Mutex;
 use rmodbus::{
     server::{context::ModbusContext, storage::ModbusStorage, ModbusFrame},
     ModbusFrameBuf, ModbusProto,

src/lib.rs

@@ -11,6 +11,8 @@ use thread_rt::{RTParams, Scheduling};
 pub use log::LevelFilter;
 pub use roboplc_derive::DataPolicy;
 
+pub use parking_lot_rt::{Condvar, Mutex, Once, RwLock};
+
 #[cfg(feature = "metrics")]
 pub use metrics;
 

src/pchannel.rs

@@ -2,7 +2,7 @@ use std::{sync::Arc, time::Duration};
 
 use crate::{pdeque::Deque, DataDeliveryPolicy, Error, Result};
 use object_id::UniqueId;
-use parking_lot::{Condvar, Mutex};
+use parking_lot_rt::{Condvar, Mutex};
 
 /// An abstract trait for data channels and hubs
 pub trait DataChannel<T: DataDeliveryPolicy> {

src/pchannel_async.rs

@@ -12,7 +12,7 @@ use std::{
 
 use crate::{pdeque::Deque, DataDeliveryPolicy, Error, Result};
 use object_id::UniqueId;
-use parking_lot::{Condvar, Mutex};
+use parking_lot_rt::{Condvar, Mutex};
 use pin_project::{pin_project, pinned_drop};
 
 type ClientId = usize;

src/semaphore.rs

 use std::sync::Arc;
 
-use parking_lot::{Condvar, Mutex};
+use parking_lot_rt::{Condvar, Mutex};
 
 /// A lightweight real-time safe semaphore
 pub struct Semaphore {