Skip to content

Commit

Permalink
chore: cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
Frando committed Jul 12, 2023
1 parent 4562ff5 commit 9f8884e
Showing 1 changed file with 3 additions and 6 deletions.
9 changes: 3 additions & 6 deletions iroh/src/sync/live.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ use iroh_net::{tls::PeerId, MagicEndpoint};
use iroh_sync::sync::{InsertOrigin, Replica, SignedEntry};
use serde::{Deserialize, Serialize};
use tokio::{sync::mpsc, task::JoinError};
use tracing::error;
use tracing::{debug, error};

const CHANNEL_CAP: usize = 8;

Expand Down Expand Up @@ -120,15 +120,12 @@ impl Actor {

Self {
gossip,
// replica,
endpoint,
// gossip_stream: gossip_subscription,
insert_entry_rx: insert_rx,
insert_entry_tx: insert_tx,
to_actor_rx,
sync_state: Default::default(),
pending_syncs: Default::default(),
// initial_peers,
pending_joins: Default::default(),
docs: Default::default(),
subscription: sub,
Expand Down Expand Up @@ -191,9 +188,9 @@ impl Actor {
let endpoint = self.endpoint.clone();
let doc = doc.clone();
async move {
println!("> connect and sync with {peer}");
debug!("sync with {peer}");
let res = connect_and_sync(&endpoint, &doc, peer, &[]).await;
println!("> sync with {peer} done: {res:?}");
debug!("> synced with {peer}: {res:?}");
(topic, peer, res)
}
.boxed()
Expand Down

0 comments on commit 9f8884e

Please sign in to comment.