aerospike-client-rust icon indicating copy to clipboard operation
aerospike-client-rust copied to clipboard

WaitGroup explicitly poisoned on batch_get

Open codekidX opened this issue 2 years ago • 0 comments

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

codekidX avatar Apr 21 '22 09:04 codekidX