Skip to content

Commit

Permalink
chore: remove dbg! output
Browse files Browse the repository at this point in the history
  • Loading branch information
jkomyno committed Nov 28, 2023
1 parent 50f8601 commit e1867df
Show file tree
Hide file tree
Showing 4 changed files with 0 additions and 10 deletions.
1 change: 0 additions & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 0 additions & 1 deletion query-engine/core/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,6 @@ schema = { path = "../schema" }
elapsed = { path = "../../libs/elapsed" }
lru = "0.7.7"
enumflags2 = "0.7"
wasm-rs-dbg.workspace = true

pin-project = "1"
wasm-bindgen-futures = "0.4"
Expand Down
6 changes: 0 additions & 6 deletions query-engine/core/src/executor/task.rs
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,6 @@ mod arch {
broadcast::{self},
oneshot::{self},
};
use wasm_rs_dbg::dbg;

// Wasm-compatible alternative to `tokio::task::JoinHandle<T>`.
// `pin_project` enables pin-projection and a `Pin`-compatible implementation of the `Future` trait.
Expand All @@ -78,19 +77,14 @@ mod arch {
type Output = Result<T, oneshot::error::RecvError>;

fn poll(mut self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>) -> std::task::Poll<Self::Output> {
dbg!("JoinHandle::poll");

// the `self.project()` method is provided by the `pin_project` macro
core::pin::Pin::new(&mut self.receiver).poll(cx)
}
}

impl<T> JoinHandle<T> {
pub fn abort(&mut self) {
dbg!("JoinHandle::abort");

if let Some(sx_exit) = self.sx_exit.as_ref() {
dbg!("JoinHandle::abort - Send sx_exit");
sx_exit.send(()).ok();
}
}
Expand Down
2 changes: 0 additions & 2 deletions query-engine/core/src/interactive_transactions/actors.rs
Original file line number Diff line number Diff line change
Expand Up @@ -392,7 +392,6 @@ pub(crate) fn spawn_client_list_clear_actor(
loop {
tokio::select! {
result = rx.recv() => {
dbg!("spawn_controlled - AFTER rx.recv(): {:?}", result.is_some());
match result {
Some((id, closed_tx)) => {
trace!("removing {} from client list", id);
Expand All @@ -411,7 +410,6 @@ pub(crate) fn spawn_client_list_clear_actor(
}
},
_ = rx_exit.recv() => {
dbg!("spawn_controlled - AFTER rx_exit.recv()");
break;
},
}
Expand Down

0 comments on commit e1867df

Please sign in to comment.