Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
jorgeantonio21 committed Feb 6, 2025
1 parent c851198 commit 10c9c65
Showing 1 changed file with 17 additions and 10 deletions.
27 changes: 17 additions & 10 deletions atoma-bin/atoma_node.rs
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
use std::{
path::{Path, PathBuf}, str::FromStr, sync::Arc
path::{Path, PathBuf},
str::FromStr,
sync::Arc,
};

use anyhow::{Context, Result};
Expand Down Expand Up @@ -215,15 +217,20 @@ async fn main() -> Result<()> {
async move {
let p2p_node =
AtomaP2pNode::start(config.p2p, Arc::new(keystore), p2p_event_sender, false)?;
let _ = Box::pin(p2p_node.run(p2p_node_service_shutdown_receiver).await.map_err(|e| {
error!(
target = "atoma-node-service",
event = "p2p_node_service_shutdown",
error = %e,
"P2P node service shutdown"
);
anyhow::anyhow!(e)
}));
let _ = Box::pin(
p2p_node
.run(p2p_node_service_shutdown_receiver)
.await
.map_err(|e| {
error!(
target = "atoma-node-service",
event = "p2p_node_service_shutdown",
error = %e,
"P2P node service shutdown"
);
anyhow::anyhow!(e)
}),
);
Ok::<(), anyhow::Error>(())
},
shutdown_sender.clone(),
Expand Down

0 comments on commit 10c9c65

Please sign in to comment.