mirror/async-std
2
0
Fork 1
mirror of https://github.com/async-rs/async-std.git synced 2025-03-05 01:29:43 +00:00
Code Issues Releases Wiki Activity

cr: bring back trace call

Browse source
This commit is contained in:
dignifiedquire 2020-05-07 20:56:52 +02:00
parent faea222b9c
commit 27c605b4c9
1 changed files with 19 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/task/builder.rs
View file

@ -54,6 +54,11 @@ impl Builder {
{ {
let wrapped = self.build(future); let wrapped = self.build(future);
kv_log_macro::trace!("spawn", {
task_id: wrapped.tag.id().0,
parent_task_id: TaskLocalsWrapper::get_current(|t| t.id().0).unwrap_or(0),
});
let task = wrapped.tag.task().clone(); let task = wrapped.tag.task().clone();
let smol_task = smol::Task::spawn(wrapped).into(); let smol_task = smol::Task::spawn(wrapped).into();
@ -69,6 +74,11 @@ impl Builder {
{ {
let wrapped = self.build(future); let wrapped = self.build(future);
kv_log_macro::trace!("spawn_local", {
task_id: wrapped.tag.id().0,
parent_task_id: TaskLocalsWrapper::get_current(|t| t.id().0).unwrap_or(0),
});
let task = wrapped.tag.task().clone(); let task = wrapped.tag.task().clone();
let smol_task = smol::Task::local(wrapped).into(); let smol_task = smol::Task::local(wrapped).into();
@ -89,6 +99,10 @@ impl Builder {
let res = future.await; let res = future.await;
let _ = sender.send(res); let _ = sender.send(res);
}); });
kv_log_macro::trace!("spawn_local", {
task_id: wrapped.tag.id().0,
parent_task_id: TaskLocalsWrapper::get_current(|t| t.id().0).unwrap_or(0),
});
let task = wrapped.tag.task().clone(); let task = wrapped.tag.task().clone();
wasm_bindgen_futures::spawn_local(wrapped); wasm_bindgen_futures::spawn_local(wrapped);
@ -111,6 +125,11 @@ impl Builder {
let _ = sender.send(res); let _ = sender.send(res);
}); });
kv_log_macro::trace!("spawn_local", {
task_id: wrapped.tag.id().0,
parent_task_id: TaskLocalsWrapper::get_current(|t| t.id().0).unwrap_or(0),
});
let task = wrapped.tag.task().clone(); let task = wrapped.tag.task().clone();
wasm_bindgen_futures::spawn_local(wrapped); wasm_bindgen_futures::spawn_local(wrapped);