Git-Mirrors/xmr-btc-swap
1
0
Fork 0
mirror of https://github.com/comit-network/xmr-btc-swap.git synced 2025-11-30 20:46:33 -05:00
Code Issues Projects Releases Packages Wiki Activity

use Span::current() to pass down to tracing span to spawned tasks

Browse source
This commit is contained in:
binarybaron 2023-08-24 18:17:41 +02:00
parent dac9d96c39
commit 8719896fdb
2 changed files with 8 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

16
swap/src/api/request.rs
View file

@ -178,7 +178,6 @@ impl Request {
async fn handle_cmd(
self,
context: Arc<Context>,
tracing_span: Span,
) -> Result<serde_json::Value> {
match self.cmd {
Method::SuspendCurrentSwap => {
@ -265,8 +264,6 @@ impl Request {
} => {
context.swap_lock.acquire_swap_lock(swap_id).await?;
let tracing_span_clone = tracing_span.clone();
tokio::spawn(async move {
tokio::select! {
biased;
@ -311,7 +308,7 @@ impl Request {
let (event_loop, mut event_loop_handle) =
EventLoop::new(swap_id, swarm, seller_peer_id)?;
let event_loop = tokio::spawn(event_loop.run().instrument(tracing_span_clone.clone()));
let event_loop = tokio::spawn(event_loop.run().instrument(Span::current()));
let max_givable = || bitcoin_wallet.max_giveable(TxLock::script_size());
let estimate_fee = |amount| bitcoin_wallet.estimate_fee(TxLock::weight(), amount);
@ -394,7 +391,7 @@ impl Request {
.release_swap_lock()
.await
.expect("Could not release swap lock");
}.instrument(tracing_span));
}.instrument(Span::current()));
Ok(json!({
"swapId": swap_id.to_string(),
@ -402,7 +399,6 @@ impl Request {
}
Method::Resume { swap_id } => {
context.swap_lock.acquire_swap_lock(swap_id).await?;
let tracing_span_clone = tracing_span.clone();
tokio::spawn(async move {
tokio::select! {
@ -449,7 +445,7 @@ impl Request {
let (event_loop, event_loop_handle) =
EventLoop::new(swap_id, swarm, seller_peer_id)?;
let handle = tokio::spawn(event_loop.run().instrument(tracing_span_clone));
let handle = tokio::spawn(event_loop.run().instrument(Span::current()));
let monero_receive_address = context.db.get_monero_address(swap_id).await?;
let swap = Swap::from_db(
@ -495,7 +491,7 @@ impl Request {
.release_swap_lock()
.await
.expect("Could not release swap lock");
}.instrument(tracing_span));
}.instrument(Span::current()));
Ok(json!({
"result": "ok",
}))
@ -725,9 +721,9 @@ impl Request {
}
pub async fn call(self, context: Arc<Context>) -> Result<serde_json::Value> {
let method_span = self.cmd.get_tracing_span(self.log_reference.clone());
let method_span = self.cmd.get_tracing_span(self.log_reference.clone()).clone();
self.handle_cmd(context, method_span.clone())
self.handle_cmd(context)
.instrument(method_span)
.await
}