Skip to content

Commit 27c605b

Browse files
cr: bring back trace call
1 parent faea222 commit 27c605b

File tree

1 file changed

+19
-0
lines changed

1 file changed

+19
-0
lines changed

src/task/builder.rs

+19
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,11 @@ impl Builder {
5454
{
5555
let wrapped = self.build(future);
5656

57+
kv_log_macro::trace!("spawn", {
58+
task_id: wrapped.tag.id().0,
59+
parent_task_id: TaskLocalsWrapper::get_current(|t| t.id().0).unwrap_or(0),
60+
});
61+
5762
let task = wrapped.tag.task().clone();
5863
let smol_task = smol::Task::spawn(wrapped).into();
5964

@@ -69,6 +74,11 @@ impl Builder {
6974
{
7075
let wrapped = self.build(future);
7176

77+
kv_log_macro::trace!("spawn_local", {
78+
task_id: wrapped.tag.id().0,
79+
parent_task_id: TaskLocalsWrapper::get_current(|t| t.id().0).unwrap_or(0),
80+
});
81+
7282
let task = wrapped.tag.task().clone();
7383
let smol_task = smol::Task::local(wrapped).into();
7484

@@ -89,6 +99,10 @@ impl Builder {
8999
let res = future.await;
90100
let _ = sender.send(res);
91101
});
102+
kv_log_macro::trace!("spawn_local", {
103+
task_id: wrapped.tag.id().0,
104+
parent_task_id: TaskLocalsWrapper::get_current(|t| t.id().0).unwrap_or(0),
105+
});
92106

93107
let task = wrapped.tag.task().clone();
94108
wasm_bindgen_futures::spawn_local(wrapped);
@@ -111,6 +125,11 @@ impl Builder {
111125
let _ = sender.send(res);
112126
});
113127

128+
kv_log_macro::trace!("spawn_local", {
129+
task_id: wrapped.tag.id().0,
130+
parent_task_id: TaskLocalsWrapper::get_current(|t| t.id().0).unwrap_or(0),
131+
});
132+
114133
let task = wrapped.tag.task().clone();
115134
wasm_bindgen_futures::spawn_local(wrapped);
116135

0 commit comments

Comments
 (0)