Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

WaitGroup explicitly poisoned on batch_get #120

Open
codekidX opened this issue Apr 21, 2022 · 0 comments
Open

WaitGroup explicitly poisoned on batch_get #120

codekidX opened this issue Apr 21, 2022 · 0 comments

Comments

@codekidX
Copy link

I have created this GUI client - https://github.com/codekidX/sparrow for Aerospike and it is using this crate to run queries. On calling batch_get for a specific set I'm receiving the following error.

thread 'main' panicked at 'WaitGroup explicitly poisoned!', /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/scoped-pool-1.0.0/src/lib.rs:457:13

Stacktrace
thread '' panicked at 'internal error: entered unreachable code', /Users/ashish/Projects/aerospike-client-rust/src/commands/particle_type.rs:73:18
stack backtrace:
   0: rust_begin_unwind
             at /rustc/7737e0b5c4103216d6fd8cf941b7ab9bdbaace7c/library/std/src/panicking.rs:584:5
   1: core::panicking::panic_fmt
             at /rustc/7737e0b5c4103216d6fd8cf941b7ab9bdbaace7c/library/core/src/panicking.rs:143:14
   2: core::panicking::panic
             at /rustc/7737e0b5c4103216d6fd8cf941b7ab9bdbaace7c/library/core/src/panicking.rs:48:5
   3: >::from
             at /Users/ashish/Projects/aerospike-client-rust/src/commands/particle_type.rs:73:18
   4: aerospike::msgpack::decoder::unpack_blob
             at /Users/ashish/Projects/aerospike-client-rust/src/msgpack/decoder.rs:94:11
   5: aerospike::msgpack::decoder::unpack_value
             at /Users/ashish/Projects/aerospike-client-rust/src/msgpack/decoder.rs:131:16
   6: aerospike::msgpack::decoder::unpack_map
             at /Users/ashish/Projects/aerospike-client-rust/src/msgpack/decoder.rs:83:19
   7: aerospike::msgpack::decoder::unpack_value
             at /Users/ashish/Projects/aerospike-client-rust/src/msgpack/decoder.rs:119:24
   8: aerospike::msgpack::decoder::unpack_list
             at /Users/ashish/Projects/aerospike-client-rust/src/msgpack/decoder.rs:66:19
   9: aerospike::msgpack::decoder::unpack_value_list
             at /Users/ashish/Projects/aerospike-client-rust/src/msgpack/decoder.rs:38:5
  10: aerospike::value::bytes_to_particle
             at /Users/ashish/Projects/aerospike-client-rust/src/value.rs:585:23
  11: aerospike::commands::batch_read_command::BatchReadCommand::parse_record
             at /Users/ashish/Projects/aerospike-client-rust/src/commands/batch_read_command.rs:191:21
  12: aerospike::commands::batch_read_command::BatchReadCommand::parse_group
             at /Users/ashish/Projects/aerospike-client-rust/src/commands/batch_read_command.rs:140:19
  13: ::parse_result
             at /Users/ashish/Projects/aerospike-client-rust/src/commands/batch_read_command.rs:233:29
  14: aerospike::commands::batch_read_command::BatchReadCommand::execute
             at /Users/ashish/Projects/aerospike-client-rust/src/commands/batch_read_command.rs:119:31
  15: aerospike::batch::batch_executor::BatchExecutor::execute_batch_jobs::{{closure}}::{{closure}}
             at /Users/ashish/Projects/aerospike-client-rust/src/batch/batch_executor.rs:81:43
  16: ::run
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/scoped-pool-1.0.0/src/lib.rs:509:31
  17: scoped_pool::Pool::run_thread
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/scoped-pool-1.0.0/src/lib.rs:185:21
  18: scoped_pool::Pool::expand::{{closure}}
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/scoped-pool-1.0.0/src/lib.rs:160:31
note: Some details are omitted, run with `RUST_BACKTRACE=full` for a verbose backtrace.
thread 'main' panicked at 'WaitGroup explicitly poisoned!', /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/scoped-pool-1.0.0/src/lib.rs:457:13
stack backtrace:
   0: std::panicking::begin_panic
             at /rustc/7737e0b5c4103216d6fd8cf941b7ab9bdbaace7c/library/std/src/panicking.rs:616:12
   1: scoped_pool::WaitGroup::join
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/scoped-pool-1.0.0/src/lib.rs:457:13
   2: scoped_pool::Scope::join
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/scoped-pool-1.0.0/src/lib.rs:341:9
   3: scoped_pool::Scope::zoom::{{closure}}
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/scoped-pool-1.0.0/src/lib.rs:328:16
   4:  as core::ops::drop::Drop>::drop
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/scopeguard-0.1.2/src/lib.rs:63:9
   5: core::ptr::drop_in_place::{{closure}}>>
             at /rustc/7737e0b5c4103216d6fd8cf941b7ab9bdbaace7c/library/core/src/ptr/mod.rs:188:1
   6: scoped_pool::Scope::zoom
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/scoped-pool-1.0.0/src/lib.rs:332:5
   7: scoped_pool::Pool::scoped
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/scoped-pool-1.0.0/src/lib.rs:117:9
   8: aerospike::batch::batch_executor::BatchExecutor::execute_batch_jobs
             at /Users/ashish/Projects/aerospike-client-rust/src/batch/batch_executor.rs:74:9
   9: aerospike::batch::batch_executor::BatchExecutor::execute_batch_read
             at /Users/ashish/Projects/aerospike-client-rust/src/batch/batch_executor.rs:58:9
  10: aerospike::client::Client::batch_get
             at /Users/ashish/Projects/aerospike-client-rust/src/client.rs:235:9
  11: app::query_set
             at ./src/main.rs:123:11
  12: app::main::{{closure}}
             at ./src/main.rs:149:25
  13:  as core::ops::function::Fn>::call
             at /rustc/7737e0b5c4103216d6fd8cf941b7ab9bdbaace7c/library/alloc/src/boxed.rs:1867:9
  14: tauri::manager::WindowManager::run_invoke_handler
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/tauri-1.0.0-rc.6/src/manager.rs:1008:5
  15: tauri::window::Window::on_message
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/tauri-1.0.0-rc.6/src/window.rs:634:11
  16: tauri::manager::WindowManager::prepare_ipc_handler::{{closure}}
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/tauri-1.0.0-rc.6/src/manager.rs:719:19
  17:  as core::ops::function::Fn>::call
             at /rustc/7737e0b5c4103216d6fd8cf941b7ab9bdbaace7c/library/alloc/src/boxed.rs:1867:9
  18: tauri_runtime_wry::create_ipc_handler::{{closure}}
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/tauri-runtime-wry-0.3.5/src/lib.rs:2822:5
  19:  as core::ops::function::Fn>::call
             at /rustc/7737e0b5c4103216d6fd8cf941b7ab9bdbaace7c/library/alloc/src/boxed.rs:1867:9
  20:  as core::ops::function::Fn>::call
             at /rustc/7737e0b5c4103216d6fd8cf941b7ab9bdbaace7c/library/alloc/src/boxed.rs:1867:9
  21: wry::webview::wkwebview::InnerWebView::new::did_receive
             at /Users/ashish/.cargo/registry/src/github.com-1ecc6299db9ec823/wry-0.14.0/src/webview/wkwebview/mod.rs:89:11
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant