Skip to content

Commit fbdb480

Browse files
authored
Merge pull request #186 from Dstack-TEE/rpc-req-id
rpc: Add request id
2 parents 532e9b4 + 442c691 commit fbdb480

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

ra-rpc/src/rocket_helper.rs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,14 @@ macro_rules! declare_prpc_routes {
8181
$crate::declare_prpc_routes!(path: "/<method>", $post, $get, $state, $handler, trim: $trim_prefix);
8282
};
8383
(path: $path: literal, $post:ident, $get:ident, $state:ty, $handler:ty, trim: $trim_prefix:literal) => {
84+
fn next_req_id() -> u64 {
85+
use std::sync::atomic::{AtomicU64, Ordering};
86+
static NEXT_REQ_ID: AtomicU64 = AtomicU64::new(0);
87+
NEXT_REQ_ID.fetch_add(1, Ordering::Relaxed)
88+
}
89+
8490
#[rocket::post($path, data = "<data>")]
91+
#[tracing::instrument(level = "INFO", skip_all, fields(id = next_req_id(), method = %method))]
8592
async fn $post<'a: 'd, 'd>(
8693
state: &'a $crate::rocket_helper::deps::State<$state>,
8794
method: &'a str,
@@ -100,6 +107,7 @@ macro_rules! declare_prpc_routes {
100107
}
101108

102109
#[rocket::get($path)]
110+
#[tracing::instrument(level = "INFO", skip_all, fields(id = next_req_id(), method = %method))]
103111
async fn $get(
104112
state: &$crate::rocket_helper::deps::State<$state>,
105113
method: &str,

0 commit comments

Comments
 (0)