Skip to content

Commit

Permalink
Add more tracing around shuffle
Browse files Browse the repository at this point in the history
  • Loading branch information
akoshelev committed Jun 15, 2024
1 parent 00376d0 commit 9c4e4b7
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions ipa-core/src/protocol/ipa_prf/shuffle/base.rs
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ where
}
}

#[tracing::instrument(name = "h1_shuffle", skip_all, fields(%batch_size))]
async fn run_h1<C, I, S, Zl, Zr>(
ctx: &C,
batch_size: usize,
Expand Down Expand Up @@ -79,6 +80,7 @@ where
Ok(res)
}

#[tracing::instrument(name = "h2_shuffle", skip_all, fields(%batch_size))]
async fn run_h2<C, I, S, Zl, Zr>(
ctx: &C,
batch_size: usize,
Expand Down Expand Up @@ -151,6 +153,7 @@ where
Ok(res)
}

#[tracing::instrument(name = "h3_shuffle", skip_all, fields(%batch_size))]
async fn run_h3<C, S, Zl, Zr>(
ctx: &C,
batch_size: usize,
Expand Down Expand Up @@ -289,6 +292,7 @@ where

// ---------------------------- helper communication ------------------------------------ //

#[tracing::instrument(name = "send_to", skip_all, fields(step, direction, sz = items.len()))]
async fn send_to_peer<C, S>(
items: &[S],
ctx: &C,
Expand All @@ -311,6 +315,7 @@ where
Ok(())
}

#[tracing::instrument(name = "receive_from", skip_all, fields(step, direction, sz = batch_size))]
async fn receive_from_peer_into<C, S>(
buf: &mut Vec<S>,
batch_size: usize,
Expand Down

0 comments on commit 9c4e4b7

Please sign in to comment.