Cuprate/cuprate
Cuprate/cuprate
1
0
Fork 0
mirror of https://github.com/Cuprate/cuprate.git synced 2025-02-02 03:06:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix CI

Browse source
This commit is contained in:
Boog900 2024-10-15 18:16:43 +01:00
parent d1b9e6bb92
commit cd6749e8f7
No known key found for this signature in database
GPG key ID: 42AB1287CB0041C2
2 changed files with 5 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
binaries/cuprated/src/txpool/incoming_tx.rs
View file

@ -332,7 +332,6 @@ async fn rerelay_stem_tx(
let incoming_tx = let incoming_tx =
IncomingTxBuilder::new(DandelionTx(Bytes::copy_from_slice(&tx_blob)), *tx_hash); IncomingTxBuilder::new(DandelionTx(Bytes::copy_from_slice(&tx_blob)), *tx_hash);
// TODO: fill this in properly.
let incoming_tx = incoming_tx let incoming_tx = incoming_tx
.with_routing_state(state) .with_routing_state(state)
.with_state_in_db(Some(State::Stem)) .with_state_in_db(Some(State::Stem))

10
p2p/p2p/src/lib.rs
View file

@ -18,7 +18,7 @@ use cuprate_p2p_core::{
pub mod block_downloader; pub mod block_downloader;
mod broadcast; mod broadcast;
mod client_pool; pub mod client_pool;
pub mod config; pub mod config;
pub mod connection_maintainer; pub mod connection_maintainer;
pub mod constants; pub mod constants;
@ -26,7 +26,7 @@ mod inbound_server;
use block_downloader::{BlockBatch, BlockDownloaderConfig, ChainSvcRequest, ChainSvcResponse}; use block_downloader::{BlockBatch, BlockDownloaderConfig, ChainSvcRequest, ChainSvcResponse};
pub use broadcast::{BroadcastRequest, BroadcastSvc}; pub use broadcast::{BroadcastRequest, BroadcastSvc};
pub use client_pool::ClientPoolDropGuard; pub use client_pool::{ClientPool, ClientPoolDropGuard};
pub use config::{AddressBookConfig, P2PConfig}; pub use config::{AddressBookConfig, P2PConfig};
use connection_maintainer::MakeConnectionRequest; use connection_maintainer::MakeConnectionRequest;
@ -83,7 +83,7 @@ where
let outbound_handshaker = outbound_handshaker_builder.build(); let outbound_handshaker = outbound_handshaker_builder.build();
let client_pool = client_pool::ClientPool::new(); let client_pool = ClientPool::new();
let (make_connection_tx, make_connection_rx) = mpsc::channel(3); let (make_connection_tx, make_connection_rx) = mpsc::channel(3);
@ -133,7 +133,7 @@ where
#[derive(Clone)] #[derive(Clone)]
pub struct NetworkInterface<N: NetworkZone> { pub struct NetworkInterface<N: NetworkZone> {
/// A pool of free connected peers. /// A pool of free connected peers.
pool: Arc<client_pool::ClientPool<N>>, pool: Arc<ClientPool<N>>,
/// A [`Service`] that allows broadcasting to all connected peers. /// A [`Service`] that allows broadcasting to all connected peers.
broadcast_svc: BroadcastSvc<N>, broadcast_svc: BroadcastSvc<N>,
/// A channel to request extra connections. /// A channel to request extra connections.
@ -174,7 +174,7 @@ impl<N: NetworkZone> NetworkInterface<N> {
} }
/// Borrows the `ClientPool`, for access to connected peers. /// Borrows the `ClientPool`, for access to connected peers.
pub const fn client_pool(&self) -> &Arc<client_pool::ClientPool<N>> { pub const fn client_pool(&self) -> &Arc<ClientPool<N>> {
&self.pool &self.pool
} }
} }