aerospike-client-rust
aerospike-client-rust copied to clipboard
WaitGroup explicitly poisoned on batch_get
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: <:commands::particle_type::particletype as core::convert::from>>::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: <:commands::batch_read_command::batchreadcommand as aerospike::commands::command>::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: <:guard> 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<:guard>::{{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: <:boxed::box> 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: <:boxed::box> 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: <:boxed::box> as core::ops::function::Fn >::call at /rustc/7737e0b5c4103216d6fd8cf941b7ab9bdbaace7c/library/alloc/src/boxed.rs:1867:9 20: <:boxed::box> 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