Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-08-12 01:50:19 +03:00
Code Issues Packages Projects Releases Wiki Activity

perf: Box::pin iroh::endpoint::Builder::bind

Browse Source 
It is has a size of 13k and increases the size of all futures calling it as a result,
while only being used for initialization.
This commit is contained in:
link2xt
2026-08-03 11:38:42 +00:00
committed by l
parent fab974f31e
commit 8e60ed7d89
2 changed files with 25 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/imex/transfer.rs
View File

@@ -97,12 +97,14 @@ impl BackupProvider {
/// [`Accounts::stop_io`]: crate::accounts::Accounts::stop_io
pub async fn prepare(context: &Context) -> Result<Self> {
let relay_mode = RelayMode::Disabled;
let endpoint = Endpoint::builder()
.tls_x509() // For compatibility with iroh <0.34.0
.alpns(vec![BACKUP_ALPN.to_vec()])
.relay_mode(relay_mode)
.bind()
.await?;
let endpoint = Box::pin(
Endpoint::builder()
.tls_x509() // For compatibility with iroh <0.34.0
.alpns(vec![BACKUP_ALPN.to_vec()])
.relay_mode(relay_mode)
.bind(),
)
.await?;
let node_addr = endpoint.node_addr().await?;
// Acquire global "ongoing" mutex.
@@ -308,12 +310,14 @@ pub async fn get_backup2(
let mut transport_config = iroh::endpoint::TransportConfig::default();
transport_config.max_idle_timeout(Some(Duration::from_secs(60).try_into()?));
let endpoint = Endpoint::builder()
.tls_x509() // For compatibility with iroh <0.34.0
.relay_mode(relay_mode)
.transport_config(transport_config)
.bind()
.await?;
let endpoint = Box::pin(
Endpoint::builder()
.tls_x509() // For compatibility with iroh <0.34.0
.relay_mode(relay_mode)
.transport_config(transport_config)
.bind(),
)
.await?;
let conn = endpoint.connect(node_addr, BACKUP_ALPN).await?;
let (mut send_stream, mut recv_stream) = conn.open_bi().await?;

16
src/peer_channels.rs
View File

@@ -253,13 +253,15 @@ impl Context {
RelayMode::Default
};
let endpoint = Endpoint::builder()
.tls_x509() // For compatibility with iroh <0.34.0
.secret_key(secret_key)
.alpns(vec![GOSSIP_ALPN.to_vec()])
.relay_mode(relay_mode)
.bind()
.await?;
let endpoint = Box::pin(
Endpoint::builder()
.tls_x509() // For compatibility with iroh <0.34.0
.secret_key(secret_key)
.alpns(vec![GOSSIP_ALPN.to_vec()])
.relay_mode(relay_mode)
.bind(),
)
.await?;
// create gossip
// Allow messages up to 128 KB in size.