Consolidate all the pub aync utils to native_async

Author: TheBlueMatt

fuzz/src/chanmon_consistency.rs

@@ -74,11 +74,11 @@ use lightning::sign::{
 	SignerProvider,
 };
 use lightning::types::payment::{PaymentHash, PaymentPreimage, PaymentSecret};
-use lightning::util::async_poll::{MaybeSend, MaybeSync};
 use lightning::util::config::UserConfig;
 use lightning::util::errors::APIError;
 use lightning::util::hash_tables::*;
 use lightning::util::logger::Logger;
+use lightning::util::native_async::{MaybeSend, MaybeSync};
 use lightning::util::ser::{LengthReadable, ReadableArgs, Writeable, Writer};
 use lightning::util::test_channel_signer::{EnforcementState, SignerOp, TestChannelSigner};
 use lightning::util::test_utils::TestWalletSource;

fuzz/src/full_stack.rs

@@ -63,10 +63,10 @@ use lightning::sign::{
 	SignerProvider,
 };
 use lightning::types::payment::{PaymentHash, PaymentPreimage, PaymentSecret};
-use lightning::util::async_poll::{MaybeSend, MaybeSync};
 use lightning::util::config::{ChannelConfig, UserConfig};
 use lightning::util::hash_tables::*;
 use lightning::util::logger::Logger;
+use lightning::util::native_async::{MaybeSend, MaybeSync};
 use lightning::util::ser::{Readable, Writeable};
 use lightning::util::test_channel_signer::{EnforcementState, TestChannelSigner};
 use lightning::util::test_utils::TestWalletSource;
@@ -1954,8 +1954,8 @@ pub fn write_fst_seeds(path: &str) {
 
 #[cfg(test)]
 mod tests {
-	use lightning::util::async_poll::{MaybeSend, MaybeSync};
 	use lightning::util::logger::{Logger, Record};
+	use lightning::util::native_async::{MaybeSend, MaybeSync};
 	use std::collections::HashMap;
 	use std::sync::{Arc, Mutex};
 

lightning-background-processor/src/lib.rs

@@ -55,9 +55,9 @@ use lightning::routing::utxo::UtxoLookup;
 #[cfg(not(c_bindings))]
 use lightning::sign::EntropySource;
 use lightning::sign::{ChangeDestinationSource, ChangeDestinationSourceSync, OutputSpender};
-#[cfg(not(c_bindings))]
-use lightning::util::async_poll::MaybeSend;
 use lightning::util::logger::Logger;
+#[cfg(not(c_bindings))]
+use lightning::util::native_async::MaybeSend;
 use lightning::util::persist::{
 	KVStore, KVStoreSync, KVStoreSyncWrapper, CHANNEL_MANAGER_PERSISTENCE_KEY,
 	CHANNEL_MANAGER_PERSISTENCE_PRIMARY_NAMESPACE, CHANNEL_MANAGER_PERSISTENCE_SECONDARY_NAMESPACE,

lightning/src/chain/chainmonitor.rs

@@ -51,10 +51,9 @@ use crate::sign::ecdsa::EcdsaChannelSigner;
 use crate::sign::{EntropySource, PeerStorageKey, SignerProvider};
 use crate::sync::{Mutex, MutexGuard, RwLock, RwLockReadGuard};
 use crate::types::features::{InitFeatures, NodeFeatures};
-use crate::util::async_poll::{MaybeSend, MaybeSync};
 use crate::util::errors::APIError;
 use crate::util::logger::{Logger, WithContext};
-use crate::util::native_async::FutureSpawner;
+use crate::util::native_async::{FutureSpawner, MaybeSend, MaybeSync};
 use crate::util::persist::{KVStore, MonitorName, MonitorUpdatingPersisterAsync};
 #[cfg(peer_storage)]
 use crate::util::ser::{VecWriter, Writeable};

lightning/src/ln/funding.rs

@@ -22,7 +22,7 @@ use crate::ln::msgs;
 use crate::ln::types::ChannelId;
 use crate::ln::LN_MAX_MSG_LEN;
 use crate::prelude::*;
-use crate::util::async_poll::MaybeSend;
+use crate::util::native_async::MaybeSend;
 use crate::util::wallet_utils::{
 	CoinSelection, CoinSelectionSource, CoinSelectionSourceSync, Input,
 };

lightning/src/sign/mod.rs

@@ -56,7 +56,7 @@ use crate::ln::script::ShutdownScript;
 use crate::offers::invoice::UnsignedBolt12Invoice;
 use crate::types::features::ChannelTypeFeatures;
 use crate::types::payment::PaymentPreimage;
-use crate::util::async_poll::MaybeSend;
+use crate::util::native_async::MaybeSend;
 use crate::util::ser::{ReadableArgs, Writeable};
 use crate::util::transaction_utils;
 

lightning/src/util/async_poll.rs

@@ -164,31 +164,3 @@ const DUMMY_WAKER_VTABLE: RawWakerVTable = RawWakerVTable::new(
 pub(crate) fn dummy_waker() -> Waker {
 	unsafe { Waker::from_raw(RawWaker::new(core::ptr::null(), &DUMMY_WAKER_VTABLE)) }
 }
-
-/// Marker trait to optionally implement `Sync` under std.
-///
-/// This is not exported to bindings users as async is only supported in Rust.
-#[cfg(feature = "std")]
-pub use core::marker::Sync as MaybeSync;
-
-#[cfg(not(feature = "std"))]
-/// Marker trait to optionally implement `Sync` under std.
-///
-/// This is not exported to bindings users as async is only supported in Rust.
-pub trait MaybeSync {}
-#[cfg(not(feature = "std"))]
-impl<T> MaybeSync for T where T: ?Sized {}
-
-/// Marker trait to optionally implement `Send` under std.
-///
-/// This is not exported to bindings users as async is only supported in Rust.
-#[cfg(feature = "std")]
-pub use core::marker::Send as MaybeSend;
-
-#[cfg(not(feature = "std"))]
-/// Marker trait to optionally implement `Send` under std.
-///
-/// This is not exported to bindings users as async is only supported in Rust.
-pub trait MaybeSend {}
-#[cfg(not(feature = "std"))]
-impl<T> MaybeSend for T where T: ?Sized {}

lightning/src/util/mod.rs

@@ -20,7 +20,7 @@ pub mod mut_global;
 
 pub mod anchor_channel_reserves;
 
-pub mod async_poll;
+pub(crate) mod async_poll;
 #[cfg(fuzzing)]
 pub mod base32;
 #[cfg(not(fuzzing))]

lightning/src/util/native_async.rs

@@ -9,8 +9,9 @@
 
 #[cfg(all(test, feature = "std"))]
 use crate::sync::{Arc, Mutex};
-use crate::util::async_poll::{MaybeSend, MaybeSync};
 
+#[cfg(test)]
+use alloc::boxed::Box;
 #[cfg(all(test, not(feature = "std")))]
 use alloc::rc::Rc;
 
@@ -53,6 +54,34 @@ trait MaybeSendableFuture: Future<Output = ()> + MaybeSend + 'static {}
 #[cfg(test)]
 impl<F: Future<Output = ()> + MaybeSend + 'static> MaybeSendableFuture for F {}
 
+/// Marker trait to optionally implement `Sync` under std.
+///
+/// This is not exported to bindings users as async is only supported in Rust.
+#[cfg(feature = "std")]
+pub use core::marker::Sync as MaybeSync;
+
+#[cfg(not(feature = "std"))]
+/// Marker trait to optionally implement `Sync` under std.
+///
+/// This is not exported to bindings users as async is only supported in Rust.
+pub trait MaybeSync {}
+#[cfg(not(feature = "std"))]
+impl<T> MaybeSync for T where T: ?Sized {}
+
+/// Marker trait to optionally implement `Send` under std.
+///
+/// This is not exported to bindings users as async is only supported in Rust.
+#[cfg(feature = "std")]
+pub use core::marker::Send as MaybeSend;
+
+#[cfg(not(feature = "std"))]
+/// Marker trait to optionally implement `Send` under std.
+///
+/// This is not exported to bindings users as async is only supported in Rust.
+pub trait MaybeSend {}
+#[cfg(not(feature = "std"))]
+impl<T> MaybeSend for T where T: ?Sized {}
+
 /// A simple [`FutureSpawner`] which holds [`Future`]s until they are manually polled via
 /// [`Self::poll_futures`].
 #[cfg(all(test, feature = "std"))]

lightning/src/util/persist.rs

@@ -38,10 +38,10 @@ use crate::ln::types::ChannelId;
 use crate::sign::{ecdsa::EcdsaChannelSigner, EntropySource, SignerProvider};
 use crate::sync::Mutex;
 use crate::util::async_poll::{
-	dummy_waker, MaybeSend, MaybeSync, MultiResultFuturePoller, ResultFuture, TwoFutureJoiner,
+	dummy_waker, MultiResultFuturePoller, ResultFuture, TwoFutureJoiner,
 };
 use crate::util::logger::Logger;
-use crate::util::native_async::FutureSpawner;
+use crate::util::native_async::{FutureSpawner, MaybeSend, MaybeSync};
 use crate::util::ser::{Readable, ReadableArgs, Writeable};
 use crate::util::wakers::Notifier;