Skip to content

Instantly share code, notes, and snippets.

@scrogson
Last active December 11, 2019 05:49
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save scrogson/d4e11b23b946ef9fa2c7e09a4b38709d to your computer and use it in GitHub Desktop.
Save scrogson/d4e11b23b946ef9fa2c7e09a4b38709d to your computer and use it in GitHub Desktop.
Rustler Segfault - OwnedEnv::send_and_clear
==14241== Memcheck, a memory error detector
==14241== Copyright (C) 2002-2017, and GNU GPL'd, by Julian Seward et al.
==14241== Using Valgrind-3.13.0 and LibVEX; rerun with -h for copyright info
==14241== Command: /home/scrogson/otp/bin/x86_64-unknown-linux-gnu/beam.valgrind.smp -S 8:8 -SDcpu 8:8 -- -root /home/scrogson/otp -progname /home/scrogson/otp/bin/cerl\ -valgrind -- -home /home/scrogson -- -kernel shell_history enabled -- --track-origins=yes -kernel shell_history enabled -pa /usr/local/lib/elixir/bin/../lib/eex/ebin /usr/local/lib/elixir/bin/../lib/elixir/ebin /usr/local/lib/elixir/bin/../lib/ex_unit/ebin /usr/local/lib/elixir/bin/../lib/iex/ebin /usr/local/lib/elixir/bin/../lib/logger/ebin /usr/local/lib/elixir/bin/../lib/mix/ebin -elixir ansi_enabled true -noshell -s elixir start_cli -- -- -extra /usr/local/bin/mix test
==14241==
==14241== Warning: set address range perms: large range [0x643d000, 0x4643d000) (noaccess)
warning: variable "i" is unused (if the variable is not meant to be used, prefix it with an underscore)
test/franz_test.exs:17: FranzTest."test polling for new messages"/1
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 0,
partition: 0,
payload: 'test',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 1,
partition: 0,
payload: 'testing',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 2,
partition: 0,
payload: 'holy moly',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 3,
partition: 0,
payload: 'wtf',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 4,
partition: 0,
payload: 'where are my messages?',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 5,
partition: 0,
payload: 'how bout now?',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 6,
partition: 0,
payload: 'there was an error',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 7,
partition: 0,
payload: 'omg',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 8,
partition: 0,
payload: 'test',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 9,
partition: 0,
payload: 'how bout now?',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 10,
partition: 0,
payload: 'and now?',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 11,
partition: 0,
payload: 'why?',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 12,
partition: 0,
payload: 'why is this crashing?',
timestamp: 1575993215363,
topic: "test"
}}
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 13,
partition: 0,
payload: 'why?',
timestamp: 1575993222592,
topic: "test"
}}
.
Finished in 12.7 seconds
1 test, 0 failures
Randomized with seed 586174
==14241==
==14241== HEAP SUMMARY:
==14241== in use at exit: 25,200,562 bytes in 32,700 blocks
==14241== total heap usage: 248,110 allocs, 215,410 frees, 201,160,144 bytes allocated
==14241==
==14241== LEAK SUMMARY:
==14241== definitely lost: 96 bytes in 1 blocks
==14241== indirectly lost: 0 bytes in 0 blocks
==14241== possibly lost: 1,108,959 bytes in 4,762 blocks
==14241== still reachable: 23,937,154 bytes in 27,914 blocks
==14241== suppressed: 154,353 bytes in 23 blocks
==14241== Rerun with --leak-check=full to see details of leaked memory
==14241==
==14241== For counts of detected and suppressed errors, rerun with: -v
==14241== ERROR SUMMARY: 0 errors from 0 contexts (suppressed: 0 from 0)
==17569== Memcheck, a memory error detector
==17569== Copyright (C) 2002-2017, and GNU GPL'd, by Julian Seward et al.
==17569== Using Valgrind-3.13.0 and LibVEX; rerun with -h for copyright info
==17569== Command: /home/scrogson/otp/bin/x86_64-unknown-linux-gnu/beam.valgrind.smp -S 8:8 -SDcpu 8:8 -- -root /home/scrogson/otp -progname /home/scrogson/otp/bin/cerl\ -valgrind -- -home /home/scrogson -- -kernel shell_history enabled -- --track-origins=yes -kernel shell_history enabled -pa /usr/local/lib/elixir/bin/../lib/eex/ebin /usr/local/lib/elixir/bin/../lib/elixir/ebin /usr/local/lib/elixir/bin/../lib/ex_unit/ebin /usr/local/lib/elixir/bin/../lib/iex/ebin /usr/local/lib/elixir/bin/../lib/logger/ebin /usr/local/lib/elixir/bin/../lib/mix/ebin -elixir ansi_enabled true -noshell -s elixir start_cli -- -- -extra /usr/local/bin/mix test
==17569==
==17569== Warning: set address range perms: large range [0x643d000, 0x4643d000) (noaccess)
warning: variable "i" is unused (if the variable is not meant to be used, prefix it with an underscore)
test/franz_test.exs:17: FranzTest."test polling for new messages"/1
{:ok,
%Franz.Message{
headers: [],
key: nil,
offset: 0,
partition: 0,
payload: 'test',
timestamp: 1575993215363,
topic: "test"
}}
==17569== Thread 35 tokio-runtime-wo:
==17569== Invalid write of size 8
==17569== at 0x364ABF: enif_make_new_map (erl_nif.c:3116)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4C869743: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== Address 0x479a28f8 is 1,096 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x364AD2: enif_make_new_map (erl_nif.c:3118)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4C869743: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== Address 0x479a2900 is 1,104 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x364ADD: enif_make_new_map (erl_nif.c:3119)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4C869743: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== Address 0x479a2908 is 1,112 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x364AED: enif_make_new_map (erl_nif.c:3120)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4C869743: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== Address 0x479a2910 is 1,120 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x364C2C: enif_make_map_put (erl_nif.c:3169)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F19F: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4C869743: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== Address 0x479a2900 is 1,104 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x380430: erts_maps_put (erl_map.c:1721)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F19F: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2900 is 1,104 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x380466: erts_maps_put (erl_map.c:1728)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F19F: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2908 is 1,112 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380514: erts_maps_put (erl_map.c:1733)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F19F: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2918 is 1,128 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380534: erts_maps_put (erl_map.c:1734)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F19F: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2920 is 1,136 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380558: erts_maps_put (erl_map.c:1736)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F19F: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2928 is 1,144 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380571: erts_maps_put (erl_map.c:1737)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F19F: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2930 is 1,152 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x38058E: erts_maps_put (erl_map.c:1738)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F19F: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2938 is 1,160 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x3805AA: erts_maps_put (erl_map.c:1739)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F19F: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2940 is 1,168 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x362244: enif_make_list_from_array (erl_nif.c:1944)
==17569== by 0x4CCAEF22: rustler::wrapper::list::make_list (list.rs:26)
==17569== by 0x4CCB1779: rustler::types::list::<impl rustler::types::Encoder for [T]>::encode (list.rs:122)
==17569== by 0x4C87B287: rustler::types::list::<impl rustler::types::Encoder for alloc::vec::Vec<T>>::encode (list.rs:101)
==17569== by 0x4C87425E: <core::option::Option<T> as rustler::types::Encoder>::encode (mod.rs:66)
==17569== by 0x4C86F247: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== Address 0x479a2948 is 1,176 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x362239: enif_make_list_from_array (erl_nif.c:1942)
==17569== by 0x4CCAEF22: rustler::wrapper::list::make_list (list.rs:26)
==17569== by 0x4CCB1779: rustler::types::list::<impl rustler::types::Encoder for [T]>::encode (list.rs:122)
==17569== by 0x4C87B287: rustler::types::list::<impl rustler::types::Encoder for alloc::vec::Vec<T>>::encode (list.rs:101)
==17569== by 0x4C87425E: <core::option::Option<T> as rustler::types::Encoder>::encode (mod.rs:66)
==17569== by 0x4C86F247: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== Address 0x479a2950 is 1,184 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x36226A: enif_make_list_from_array (erl_nif.c:1948)
==17569== by 0x4CCAEF22: rustler::wrapper::list::make_list (list.rs:26)
==17569== by 0x4CCB1779: rustler::types::list::<impl rustler::types::Encoder for [T]>::encode (list.rs:122)
==17569== by 0x4C87B287: rustler::types::list::<impl rustler::types::Encoder for alloc::vec::Vec<T>>::encode (list.rs:101)
==17569== by 0x4C87425E: <core::option::Option<T> as rustler::types::Encoder>::encode (mod.rs:66)
==17569== by 0x4C86F247: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== Address 0x479a29b0 is 1,280 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x364C2C: enif_make_map_put (erl_nif.c:3169)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4C869743: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== Address 0x479a2928 is 1,144 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x3805BD: erts_maps_put (erl_map.c:1744)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2938 is 1,160 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x3806B6: erts_maps_put (erl_map.c:1754)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29b8 is 1,288 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x3806D6: erts_maps_put (erl_map.c:1755)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29c0 is 1,296 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x3806F2: erts_maps_put (erl_map.c:1756)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2938 is 1,160 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x3806F6: erts_maps_put (erl_map.c:1756)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29c8 is 1,304 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x38072F: erts_maps_put (erl_map.c:1760)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2920 is 1,136 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x380763: erts_maps_put (erl_map.c:1763)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2940 is 1,168 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380766: erts_maps_put (erl_map.c:1763)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29d0 is 1,312 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x3809A0: erts_maps_put (erl_map.c:1795)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29b8 is 1,288 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380A7A: erts_maps_put (erl_map.c:1799)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29d8 is 1,320 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380AA1: erts_maps_put (erl_map.c:1800)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29e0 is 1,328 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380ABA: erts_maps_put (erl_map.c:1801)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29e8 is 1,336 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x380AC4: erts_maps_put (erl_map.c:1803)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2938 is 1,160 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x380B54: erts_maps_put (erl_map.c:1809)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2920 is 1,136 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x380B0B: erts_maps_put (erl_map.c:1810)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2920 is 1,136 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380B0E: erts_maps_put (erl_map.c:1810)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29c0 is 1,296 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x380B35: erts_maps_put (erl_map.c:1811)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2940 is 1,168 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380B38: erts_maps_put (erl_map.c:1811)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29f0 is 1,344 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380B9E: erts_maps_put (erl_map.c:1815)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29c8 is 1,304 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380BBA: erts_maps_put (erl_map.c:1816)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29f8 is 1,352 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380C31: erts_maps_put (erl_map.c:1828)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F299: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29d0 is 1,312 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x364C2C: enif_make_map_put (erl_nif.c:3169)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F399: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4C869743: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== Address 0x479a29d8 is 1,320 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x380BE3: erts_maps_put (erl_map.c:1821)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F399: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29c8 is 1,304 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380BE6: erts_maps_put (erl_map.c:1821)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F399: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2a18 is 1,384 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x380C0D: erts_maps_put (erl_map.c:1822)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F399: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a29f8 is 1,352 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x380C10: erts_maps_put (erl_map.c:1822)
==17569== by 0x364C66: enif_make_map_put (erl_nif.c:3177)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F399: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== Address 0x479a2a50 is 1,440 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x361482: enif_make_binary (erl_nif.c:1516)
==17569== by 0x4CCAF100: rustler::types::binary::Binary::from_owned (binary.rs:171)
==17569== by 0x4CCAF074: rustler::types::binary::OwnedBinary::release (binary.rs:120)
==17569== by 0x4CCB1285: rustler::types::string::<impl rustler::types::Encoder for str>::encode (string.rs:38)
==17569== by 0x4CCA6C86: rustler::types::string::<impl rustler::types::Encoder for alloc::string::String>::encode (string.rs:44)
==17569== by 0x4C86F448: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== Address 0x479a2a58 is 1,448 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x361490: enif_make_binary (erl_nif.c:1517)
==17569== by 0x4CCAF100: rustler::types::binary::Binary::from_owned (binary.rs:171)
==17569== by 0x4CCAF074: rustler::types::binary::OwnedBinary::release (binary.rs:120)
==17569== by 0x4CCB1285: rustler::types::string::<impl rustler::types::Encoder for str>::encode (string.rs:38)
==17569== by 0x4CCA6C86: rustler::types::string::<impl rustler::types::Encoder for alloc::string::String>::encode (string.rs:44)
==17569== by 0x4C86F448: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== Address 0x479a2a60 is 1,456 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 2
==17569== at 0x4C36753: memmove (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x35CBC9: sys_memcpy (sys.h:1078)
==17569== by 0x3614B5: enif_make_binary (erl_nif.c:1519)
==17569== by 0x4CCAF100: rustler::types::binary::Binary::from_owned (binary.rs:171)
==17569== by 0x4CCAF074: rustler::types::binary::OwnedBinary::release (binary.rs:120)
==17569== by 0x4CCB1285: rustler::types::string::<impl rustler::types::Encoder for str>::encode (string.rs:38)
==17569== by 0x4CCA6C86: rustler::types::string::<impl rustler::types::Encoder for alloc::string::String>::encode (string.rs:44)
==17569== by 0x4C86F448: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== Address 0x479a2a68 is 1,464 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x2BA0D4: build_proc_bin (binary.c:67)
==17569== by 0x2BA183: erts_build_proc_bin (binary.c:84)
==17569== by 0x3614E7: enif_make_binary (erl_nif.c:1521)
==17569== by 0x4CCAF100: rustler::types::binary::Binary::from_owned (binary.rs:171)
==17569== by 0x4CCAF074: rustler::types::binary::OwnedBinary::release (binary.rs:120)
==17569== by 0x4CCB1285: rustler::types::string::<impl rustler::types::Encoder for str>::encode (string.rs:38)
==17569== by 0x4CCA6C86: rustler::types::string::<impl rustler::types::Encoder for alloc::string::String>::encode (string.rs:44)
==17569== by 0x4C86F448: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== Address 0x479a2a70 is 1,472 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x2BA0EA: build_proc_bin (binary.c:68)
==17569== by 0x2BA183: erts_build_proc_bin (binary.c:84)
==17569== by 0x3614E7: enif_make_binary (erl_nif.c:1521)
==17569== by 0x4CCAF100: rustler::types::binary::Binary::from_owned (binary.rs:171)
==17569== by 0x4CCAF074: rustler::types::binary::OwnedBinary::release (binary.rs:120)
==17569== by 0x4CCB1285: rustler::types::string::<impl rustler::types::Encoder for str>::encode (string.rs:38)
==17569== by 0x4CCA6C86: rustler::types::string::<impl rustler::types::Encoder for alloc::string::String>::encode (string.rs:44)
==17569== by 0x4C86F448: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== Address 0x479a2a78 is 1,480 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x2BA0F9: build_proc_bin (binary.c:69)
==17569== by 0x2BA183: erts_build_proc_bin (binary.c:84)
==17569== by 0x3614E7: enif_make_binary (erl_nif.c:1521)
==17569== by 0x4CCAF100: rustler::types::binary::Binary::from_owned (binary.rs:171)
==17569== by 0x4CCAF074: rustler::types::binary::OwnedBinary::release (binary.rs:120)
==17569== by 0x4CCB1285: rustler::types::string::<impl rustler::types::Encoder for str>::encode (string.rs:38)
==17569== by 0x4CCA6C86: rustler::types::string::<impl rustler::types::Encoder for alloc::string::String>::encode (string.rs:44)
==17569== by 0x4C86F448: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== Address 0x479a2a80 is 1,488 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x2BA110: build_proc_bin (binary.c:71)
==17569== by 0x2BA183: erts_build_proc_bin (binary.c:84)
==17569== by 0x3614E7: enif_make_binary (erl_nif.c:1521)
==17569== by 0x4CCAF100: rustler::types::binary::Binary::from_owned (binary.rs:171)
==17569== by 0x4CCAF074: rustler::types::binary::OwnedBinary::release (binary.rs:120)
==17569== by 0x4CCB1285: rustler::types::string::<impl rustler::types::Encoder for str>::encode (string.rs:38)
==17569== by 0x4CCA6C86: rustler::types::string::<impl rustler::types::Encoder for alloc::string::String>::encode (string.rs:44)
==17569== by 0x4C86F448: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== Address 0x479a2a88 is 1,496 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x2BA120: build_proc_bin (binary.c:72)
==17569== by 0x2BA183: erts_build_proc_bin (binary.c:84)
==17569== by 0x3614E7: enif_make_binary (erl_nif.c:1521)
==17569== by 0x4CCAF100: rustler::types::binary::Binary::from_owned (binary.rs:171)
==17569== by 0x4CCAF074: rustler::types::binary::OwnedBinary::release (binary.rs:120)
==17569== by 0x4CCB1285: rustler::types::string::<impl rustler::types::Encoder for str>::encode (string.rs:38)
==17569== by 0x4CCA6C86: rustler::types::string::<impl rustler::types::Encoder for alloc::string::String>::encode (string.rs:44)
==17569== by 0x4C86F448: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== Address 0x479a2a90 is 1,504 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid write of size 8
==17569== at 0x2BA128: build_proc_bin (binary.c:73)
==17569== by 0x2BA183: erts_build_proc_bin (binary.c:84)
==17569== by 0x3614E7: enif_make_binary (erl_nif.c:1521)
==17569== by 0x4CCAF100: rustler::types::binary::Binary::from_owned (binary.rs:171)
==17569== by 0x4CCAF074: rustler::types::binary::OwnedBinary::release (binary.rs:120)
==17569== by 0x4CCB1285: rustler::types::string::<impl rustler::types::Encoder for str>::encode (string.rs:38)
==17569== by 0x4CCA6C86: rustler::types::string::<impl rustler::types::Encoder for alloc::string::String>::encode (string.rs:44)
==17569== by 0x4C86F448: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== Address 0x479a2a98 is 1,512 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x2BA13C: build_proc_bin (binary.c:74)
==17569== by 0x2BA183: erts_build_proc_bin (binary.c:84)
==17569== by 0x3614E7: enif_make_binary (erl_nif.c:1521)
==17569== by 0x4CCAF100: rustler::types::binary::Binary::from_owned (binary.rs:171)
==17569== by 0x4CCAF074: rustler::types::binary::OwnedBinary::release (binary.rs:120)
==17569== by 0x4CCB1285: rustler::types::string::<impl rustler::types::Encoder for str>::encode (string.rs:38)
==17569== by 0x4CCA6C86: rustler::types::string::<impl rustler::types::Encoder for alloc::string::String>::encode (string.rs:44)
==17569== by 0x4C86F448: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== Address 0x479a2a78 is 1,480 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x364C2C: enif_make_map_put (erl_nif.c:3169)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F49A: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4C869743: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== Address 0x479a2a28 is 1,400 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x364C2C: enif_make_map_put (erl_nif.c:3169)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F59A: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4C869743: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== Address 0x479a2ad0 is 1,568 bytes inside a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
==17569== Invalid read of size 8
==17569== at 0x364C2C: enif_make_map_put (erl_nif.c:3169)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F69B: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4C869743: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== Address 0x479a2b40 is 8 bytes after a block of size 1,672 free'd
==17569== at 0x4C30D3B: free (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A24E: erts_sys_free (sys.c:881)
==17569== by 0x27731F: erts_free (erl_alloc.h:281)
==17569== by 0x2782DB: free_message_buffer (erl_message.c:198)
==17569== by 0x2783C3: erts_cleanup_message (erl_message.c:232)
==17569== by 0x2783E8: erts_cleanup_messages (erl_message.c:241)
==17569== by 0x3154EF: erts_deallocate_young_generation (erl_gc.c:2056)
==17569== by 0x3148D1: do_minor (erl_gc.c:1755)
==17569== by 0x313925: minor_collection (erl_gc.c:1468)
==17569== by 0x311A7E: garbage_collect (erl_gc.c:750)
==17569== by 0x3120D4: erts_garbage_collect_nobump (erl_gc.c:886)
==17569== by 0x1937BE: scheduler_gc_proc (erl_process.c:9179)
==17569== Block was alloc'd at
==17569== at 0x4C2FB0F: malloc (in /usr/lib/valgrind/vgpreload_memcheck-amd64-linux.so)
==17569== by 0x39A1B6: erts_sys_alloc (sys.c:857)
==17569== by 0x237629: erts_alloc (erl_alloc.h:251)
==17569== by 0x237BDF: erts_heap_alloc (utils.c:115)
==17569== by 0x35E704: alloc_heap_heavy (erl_nif.c:182)
==17569== by 0x35E63A: alloc_heap (erl_nif.c:165)
==17569== by 0x364AA2: enif_make_new_map (erl_nif.c:3111)
==17569== by 0x4CCB48C3: rustler::wrapper::map::map_new (map.rs:26)
==17569== by 0x4CCA7CE0: rustler::types::map::map_new (map.rs:9)
==17569== by 0x4C86F0C7: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569==
valgrind: m_mallocfree.c:307 (get_bszB_as_is): Assertion 'bszB_lo == bszB_hi' failed.
valgrind: Heap block lo/hi size mismatch: lo = 1776, hi = 1201285722.
This is probably caused by your program erroneously writing past the
end of a heap block and corrupting heap metadata. If you fix any
invalid writes reported by Memcheck, this assertion failure will
probably go away. Please try that before reporting this as a bug.
host stacktrace:
==17569== at 0x580441BA: ??? (in /usr/lib/valgrind/memcheck-amd64-linux)
==17569== by 0x580442D4: ??? (in /usr/lib/valgrind/memcheck-amd64-linux)
==17569== by 0x58044459: ??? (in /usr/lib/valgrind/memcheck-amd64-linux)
==17569== by 0x58052FC0: ??? (in /usr/lib/valgrind/memcheck-amd64-linux)
==17569== by 0x5803CECA: ??? (in /usr/lib/valgrind/memcheck-amd64-linux)
==17569== by 0x5803B5D3: ??? (in /usr/lib/valgrind/memcheck-amd64-linux)
==17569== by 0x5803FC9D: ??? (in /usr/lib/valgrind/memcheck-amd64-linux)
==17569== by 0x5803A8CB: ??? (in /usr/lib/valgrind/memcheck-amd64-linux)
==17569== by 0x58015434: ??? (in /usr/lib/valgrind/memcheck-amd64-linux)
==17569== by 0x100AEE5F4F: ???
==17569== by 0x100A136F1F: ???
==17569== by 0x3D62F: ???
==17569== by 0x1002043F5F: ???
==17569== by 0x100A136F07: ???
==17569== by 0x100A136F1F: ???
==17569== by 0xA77F9: ???
==17569== by 0x100AEE5CA7: ???
==17569== by 0x97DE: ???
sched status:
running_tid=35
Thread 1: status = VgTs_WaitSys (lwpid 17569)
==17569== at 0x5D6303F: select (select.c:41)
==17569== by 0x39A790: erts_sys_main_thread (sys.c:1140)
==17569== by 0x1F05B3: erl_start (erl_init.c:2359)
==17569== by 0x15D4FB: main (erl_main.c:30)
Thread 2: status = VgTs_WaitSys (lwpid 17614)
==17569== at 0x5836384: read (read.c:27)
==17569== by 0x39A58C: signal_dispatcher_thread_func (sys.c:993)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 3: status = VgTs_WaitSys (lwpid 17615)
==17569== at 0x58329F3: futex_wait_cancelable (futex-internal.h:88)
==17569== by 0x58329F3: __pthread_cond_wait_common (pthread_cond_wait.c:502)
==17569== by 0x58329F3: pthread_cond_wait@@GLIBC_2.3.2 (pthread_cond_wait.c:655)
==17569== by 0x452628: ethr_cond_wait (ethr_mutex.c:1369)
==17569== by 0x228342: erts_cnd_wait (erl_threads.h:1782)
==17569== by 0x22E526: sys_msg_dispatcher_func (erl_trace.c:2258)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 4: status = VgTs_WaitSys (lwpid 17616)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x4537FC: ethr_event_wait (ethr_event.c:631)
==17569== by 0x30D47D: erts_tse_wait (erl_threads.h:2388)
==17569== by 0x30E04B: async_get (erl_async.c:345)
==17569== by 0x30E4D8: async_main (erl_async.c:469)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 5: status = VgTs_WaitSys (lwpid 17618)
==17569== at 0x5D6DBB7: epoll_wait (epoll_wait.c:30)
==17569== by 0x3A448D: check_fd_events (erl_poll.c:1815)
==17569== by 0x3A4623: erts_poll_wait (erl_poll.c:1913)
==17569== by 0x3A8C2E: erts_check_io (erl_check_io.c:1680)
==17569== by 0x186CC1: scheduler_wait (erl_process.c:3449)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x15E6CB: process_main (beam_emu.c:684)
==17569== by 0x192097: sched_thread_func (erl_process.c:8470)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 6: status = VgTs_WaitSys (lwpid 17619)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x30CD96: ethr_event_set (ethr_event.h:68)
==17569== by 0x30D3C8: erts_tse_set (erl_threads.h:2376)
==17569== by 0x30E32F: async_wakeup (erl_async.c:424)
==17569== by 0x2F596C: wakeup_unmanaged (erl_thr_progress.c:284)
==17569== by 0x2F72B7: wakeup_unmanaged_threads (erl_thr_progress.c:1219)
==17569== by 0x2F73E5: handle_wakeup_requests (erl_thr_progress.c:1254)
==17569== by 0x2F69B2: leader_update (erl_thr_progress.c:748)
==17569== by 0x2F6C58: erts_thr_progress_leader_update (erl_thr_progress.c:866)
==17569== by 0x193F41: erts_schedule (erl_process.c:9438)
==17569== by 0x15E6CB: process_main (beam_emu.c:684)
==17569== by 0x192097: sched_thread_func (erl_process.c:8470)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 7: status = VgTs_WaitSys (lwpid 17620)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x15E6CB: process_main (beam_emu.c:684)
==17569== by 0x192097: sched_thread_func (erl_process.c:8470)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 8: status = VgTs_WaitSys (lwpid 17621)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x15E6CB: process_main (beam_emu.c:684)
==17569== by 0x192097: sched_thread_func (erl_process.c:8470)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 9: status = VgTs_WaitSys (lwpid 17622)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x15E6CB: process_main (beam_emu.c:684)
==17569== by 0x192097: sched_thread_func (erl_process.c:8470)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 10: status = VgTs_WaitSys (lwpid 17623)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x15E6CB: process_main (beam_emu.c:684)
==17569== by 0x192097: sched_thread_func (erl_process.c:8470)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 11: status = VgTs_WaitSys (lwpid 17624)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x15E6CB: process_main (beam_emu.c:684)
==17569== by 0x192097: sched_thread_func (erl_process.c:8470)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 12: status = VgTs_WaitSys (lwpid 17625)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x15E6CB: process_main (beam_emu.c:684)
==17569== by 0x192097: sched_thread_func (erl_process.c:8470)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 13: status = VgTs_WaitSys (lwpid 17626)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1921C3: sched_dirty_cpu_thread_func (erl_process.c:8517)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 14: status = VgTs_WaitSys (lwpid 17627)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1921C3: sched_dirty_cpu_thread_func (erl_process.c:8517)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 15: status = VgTs_WaitSys (lwpid 17628)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1921C3: sched_dirty_cpu_thread_func (erl_process.c:8517)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 16: status = VgTs_WaitSys (lwpid 17629)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1921C3: sched_dirty_cpu_thread_func (erl_process.c:8517)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 17: status = VgTs_WaitSys (lwpid 17630)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1921C3: sched_dirty_cpu_thread_func (erl_process.c:8517)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 18: status = VgTs_WaitSys (lwpid 17631)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1921C3: sched_dirty_cpu_thread_func (erl_process.c:8517)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 19: status = VgTs_WaitSys (lwpid 17632)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1921C3: sched_dirty_cpu_thread_func (erl_process.c:8517)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 20: status = VgTs_WaitSys (lwpid 17633)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1921C3: sched_dirty_cpu_thread_func (erl_process.c:8517)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 21: status = VgTs_WaitSys (lwpid 17634)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1922FA: sched_dirty_io_thread_func (erl_process.c:8563)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 22: status = VgTs_WaitSys (lwpid 17635)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1922FA: sched_dirty_io_thread_func (erl_process.c:8563)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 23: status = VgTs_WaitSys (lwpid 17636)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1922FA: sched_dirty_io_thread_func (erl_process.c:8563)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 24: status = VgTs_WaitSys (lwpid 17637)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1922FA: sched_dirty_io_thread_func (erl_process.c:8563)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 25: status = VgTs_WaitSys (lwpid 17638)
==17569== at 0x58361AA: __lll_unlock_wake (lowlevellock.S:371)
==17569== by 0x58307DE: __pthread_mutex_unlock_usercnt (pthread_mutex_unlock.c:54)
==17569== by 0x58307DE: pthread_mutex_unlock (pthread_mutex_unlock.c:345)
==17569== by 0x4CC18A84: std::sys::unix::mutex::Mutex::unlock (mutex.rs:60)
==17569== by 0x4CC1E5D0: std::sys_common::mutex::Mutex::raw_unlock (try_lock.rs:62)
==17569== by 0x4CBF8A06: <std::sync::mutex::MutexGuard<T> as core::ops::drop::Drop>::drop (mutex.rs:449)
==17569== by 0x4CC4568E: core::ptr::real_drop_in_place (mod.rs:181)
==17569== by 0x4CC3BA0C: core::mem::drop (mod.rs:749)
==17569== by 0x4CC5BA9F: tokio::runtime::thread_pool::queue::global::Queue<T>::push (global.rs:127)
==17569== by 0x4CC2C1AA: tokio::runtime::thread_pool::queue::inject::Inject<T>::push (inject.rs:19)
==17569== by 0x4CC218F0: tokio::runtime::thread_pool::slice::Set::inject_task (slice.rs:69)
==17569== by 0x4CC21C1C: tokio::runtime::thread_pool::slice::Set::schedule::{{closure}} (slice.rs:106)
==17569== by 0x4CC5468B: tokio::runtime::thread_pool::current::get::{{closure}} (current.rs:61)
==17569== by 0x4CBFD9D6: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBE07: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC54618: tokio::runtime::thread_pool::current::get (current.rs:59)
==17569== by 0x4CC21BA0: tokio::runtime::thread_pool::slice::Set::schedule (slice.rs:99)
==17569== by 0x4C87EA67: tokio::runtime::thread_pool::slice::Set::spawn_typed (slice.rs:64)
==17569== by 0x4C862E7D: tokio::runtime::thread_pool::spawner::Spawner::spawn (spawner.rs:36)
==17569== by 0x4C87657E: tokio::runtime::thread_pool::ThreadPool::spawn (mod.rs:89)
==17569== by 0x4C88646B: tokio::runtime::Runtime::spawn (mod.rs:395)
==17569== by 0x4C8723A7: <franz::client::poll as rustler::nif::Nif>::RAW_FUNC::nif_func::wrapper::{{closure}}::poll (client.rs:114)
==17569== by 0x4C891834: <franz::client::poll as rustler::nif::Nif>::RAW_FUNC::nif_func::wrapper::{{closure}} (client.rs:108)
==17569== by 0x4C88222F: std::panicking::try::do_call (panicking.rs:289)
==17569== by 0x4CCC1D09: __rust_maybe_catch_panic (lib.rs:81)
==17569== by 0x4C881430: std::panicking::try (panicking.rs:267)
==17569== by 0x4C885DCF: std::panic::catch_unwind (panic.rs:395)
==17569== by 0x4C8721B2: <franz::client::poll as rustler::nif::Nif>::RAW_FUNC::nif_func::wrapper (client.rs:108)
==17569== by 0x4C872108: <franz::client::poll as rustler::nif::Nif>::RAW_FUNC::nif_func (client.rs:108)
==17569== by 0x35EBD9: erts_call_dirty_nif (erl_nif.c:396)
==17569== by 0x1786CE: erts_dirty_process_main (beam_emu.c:1279)
==17569== by 0x1922FA: sched_dirty_io_thread_func (erl_process.c:8563)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 26: status = VgTs_WaitSys (lwpid 17639)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1922FA: sched_dirty_io_thread_func (erl_process.c:8563)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 27: status = VgTs_WaitSys (lwpid 17640)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1922FA: sched_dirty_io_thread_func (erl_process.c:8563)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 28: status = VgTs_WaitSys (lwpid 17641)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1922FA: sched_dirty_io_thread_func (erl_process.c:8563)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 29: status = VgTs_WaitSys (lwpid 17642)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1922FA: sched_dirty_io_thread_func (erl_process.c:8563)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 30: status = VgTs_WaitSys (lwpid 17643)
==17569== at 0x5D67839: syscall (syscall.S:38)
==17569== by 0x45371B: wait__ (ethr_event.c:152)
==17569== by 0x45384C: ethr_event_twait (ethr_event.c:643)
==17569== by 0x17EA77: erts_tse_twait (erl_threads.h:2406)
==17569== by 0x186E19: scheduler_wait (erl_process.c:3484)
==17569== by 0x194127: erts_schedule (erl_process.c:9509)
==17569== by 0x178562: erts_dirty_process_main (beam_emu.c:1173)
==17569== by 0x1922FA: sched_dirty_io_thread_func (erl_process.c:8563)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 31: status = VgTs_WaitSys (lwpid 17644)
==17569== at 0x5D60CF6: ppoll (ppoll.c:39)
==17569== by 0x3BA7A5: check_fd_events (erl_poll.flbk.c:1847)
==17569== by 0x3BA973: erts_poll_wait_flbk (erl_poll.flbk.c:1913)
==17569== by 0x3A8BED: erts_check_io (erl_check_io.c:1675)
==17569== by 0x18649E: aux_thread (erl_process.c:3158)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 32: status = VgTs_WaitSys (lwpid 17645)
==17569== at 0x5D6DBB7: epoll_wait (epoll_wait.c:30)
==17569== by 0x3A44C3: check_fd_events (erl_poll.c:1818)
==17569== by 0x3A4623: erts_poll_wait (erl_poll.c:1913)
==17569== by 0x3A8C2E: erts_check_io (erl_check_io.c:1680)
==17569== by 0x18672F: poll_thread (erl_process.c:3256)
==17569== by 0x45293B: thr_wrapper (ethread.c:118)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 33: status = VgTs_WaitSys (lwpid 17670)
==17569== at 0x58329F3: futex_wait_cancelable (futex-internal.h:88)
==17569== by 0x58329F3: __pthread_cond_wait_common (pthread_cond_wait.c:502)
==17569== by 0x58329F3: pthread_cond_wait@@GLIBC_2.3.2 (pthread_cond_wait.c:655)
==17569== by 0x4CC9234D: std::sys::unix::condvar::Condvar::wait (condvar.rs:69)
==17569== by 0x4CC91D96: std::sys_common::condvar::Condvar::wait (condvar.rs:41)
==17569== by 0x4CC992E0: std::sync::condvar::Condvar::wait (condvar.rs:204)
==17569== by 0x4CBFFDFF: tokio::park::thread::Inner::park (thread.rs:114)
==17569== by 0x4CBFF832: <tokio::park::thread::ParkThread as tokio::park::Park>::park (thread.rs:68)
==17569== by 0x4CC1B475: <tokio::park::either::Either<A,B> as tokio::park::Park>::park (either.rs:29)
==17569== by 0x4CC1B519: <tokio::park::either::Either<A,B> as tokio::park::Park>::park (either.rs:29)
==17569== by 0x4CC1C951: tokio::runtime::park::Inner::park_driver (park.rs:181)
==17569== by 0x4CC1C1B7: tokio::runtime::park::Inner::park (park.rs:123)
==17569== by 0x4CC1BCF2: <tokio::runtime::park::Parker as tokio::park::Park>::park (park.rs:90)
==17569== by 0x4CBF2DD8: tokio::runtime::thread_pool::worker::GenerationGuard::park (worker.rs:510)
==17569== by 0x4CBF1E7A: tokio::runtime::thread_pool::worker::GenerationGuard::run (worker.rs:292)
==17569== by 0x4CBF181E: tokio::runtime::thread_pool::worker::Worker::run::{{closure}}::{{closure}}::{{closure}}::{{closure}} (worker.rs:175)
==17569== by 0x4CBFD506: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBAA2: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CBF18AC: tokio::runtime::thread_pool::worker::Worker::run::{{closure}}::{{closure}}::{{closure}} (worker.rs:151)
==17569== by 0x4CC2AB12: tokio::runtime::blocking::pool::Spawner::enter::{{closure}} (pool.rs:191)
==17569== by 0x4CBFC4CC: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBD4B: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC2A9CB: tokio::runtime::blocking::pool::Spawner::enter (pool.rs:176)
==17569== by 0x4CBF18EB: tokio::runtime::thread_pool::worker::Worker::run::{{closure}}::{{closure}} (worker.rs:150)
==17569== by 0x4CC5AFC6: tokio::runtime::global::with_state::{{closure}} (global.rs:100)
==17569== by 0x4CBFD88C: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBB7B: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC5AEA3: tokio::runtime::global::with_state (global.rs:83)
==17569== by 0x4CC5B25A: tokio::runtime::global::with_thread_pool (global.rs:75)
==17569== by 0x4CBF194B: tokio::runtime::thread_pool::worker::Worker::run::{{closure}} (worker.rs:149)
==17569== by 0x4CC544ED: tokio::runtime::thread_pool::current::set::{{closure}} (current.rs:47)
==17569== by 0x4CBFC7D8: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBF0C: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC543D6: tokio::runtime::thread_pool::current::set (current.rs:29)
==17569== by 0x4CBF15E2: tokio::runtime::thread_pool::worker::Worker::run (worker.rs:145)
==17569== by 0x4CBFAA59: tokio::runtime::thread_pool::Workers::spawn::{{closure}}::{{closure}} (mod.rs:124)
==17569== by 0x4CC20F43: <tokio::runtime::blocking::task::BlockingTask<T> as core::future::future::Future>::poll (task.rs:30)
==17569== by 0x4CC2D0F5: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4CC627B7: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== by 0x4CC44437: core::ops::function::FnOnce::call_once (function.rs:232)
==17569== by 0x4CBEB45D: <std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once (panic.rs:316)
==17569== by 0x4CC2EE04: std::panicking::try::do_call (panicking.rs:289)
==17569== by 0x4CCC1D09: __rust_maybe_catch_panic (lib.rs:81)
==17569== by 0x4CC2EA46: std::panicking::try (panicking.rs:267)
==17569== by 0x4CBEBAF4: std::panic::catch_unwind (panic.rs:395)
==17569== by 0x4CC628D2: tokio::task::harness::Harness<T,S>::poll::{{closure}} (harness.rs:101)
==17569== by 0x4CC2040E: tokio::loom::std::causal_cell::CausalCell<T>::with_mut (causal_cell.rs:41)
==17569== by 0x4CC61CE7: tokio::task::harness::Harness<T,S>::poll (harness.rs:100)
==17569== by 0x4CBF4607: tokio::task::raw::poll (raw.rs:162)
==17569== by 0x4CBF4446: tokio::task::raw::RawTask::poll (raw.rs:113)
==17569== by 0x4CC431BB: tokio::task::Task<S>::run (mod.rs:371)
==17569== by 0x4CC2BFAC: tokio::runtime::blocking::pool::run_task (pool.rs:355)
==17569== by 0x4CC2B8F8: tokio::runtime::blocking::pool::Inner::run2 (pool.rs:281)
==17569== by 0x4CC2B6D0: tokio::runtime::blocking::pool::Inner::run::{{closure}}::{{closure}} (pool.rs:266)
==17569== by 0x4CC5B0E5: tokio::runtime::global::with_state::{{closure}} (global.rs:100)
==17569== by 0x4CBFD05B: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBCC7: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC5AEEA: tokio::runtime::global::with_state (global.rs:83)
==17569== by 0x4CC5B205: tokio::runtime::global::with_thread_pool (global.rs:75)
==17569== by 0x4CBF0F7D: tokio::runtime::thread_pool::spawner::Spawner::enter (spawner.rs:44)
==17569== by 0x4CC5AE10: tokio::runtime::spawner::Spawner::enter (spawner.rs:32)
==17569== by 0x4CC2B70E: tokio::runtime::blocking::pool::Inner::run::{{closure}} (pool.rs:266)
==17569== by 0x4CC280E7: tokio::time::clock::Clock::enter (clock.rs:30)
==17569== by 0x4CC00A51: tokio::runtime::time::variant::with_default (time.rs:43)
==17569== by 0x4CC2B687: tokio::runtime::blocking::pool::Inner::run (pool.rs:265)
==17569== by 0x4CC2B590: tokio::runtime::blocking::pool::Spawner::spawn_thread::{{closure}} (pool.rs:249)
==17569== by 0x4CC43E9C: std::sys_common::backtrace::__rust_begin_short_backtrace (backtrace.rs:136)
==17569== by 0x4CC2915D: std::thread::Builder::spawn_unchecked::{{closure}}::{{closure}} (mod.rs:469)
==17569== by 0x4CBEB42B: <std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once (panic.rs:316)
==17569== by 0x4CC2EDB2: std::panicking::try::do_call (panicking.rs:289)
==17569== by 0x4CCC1D09: __rust_maybe_catch_panic (lib.rs:81)
==17569== by 0x4CC2E6F9: std::panicking::try (panicking.rs:267)
==17569== by 0x4CBEBA7D: std::panic::catch_unwind (panic.rs:395)
==17569== by 0x4CC28F4D: std::thread::Builder::spawn_unchecked::{{closure}} (mod.rs:468)
==17569== by 0x4CC43F73: core::ops::function::FnOnce::call_once{{vtable-shim}} (function.rs:232)
==17569== by 0x4CCB6C7E: <alloc::boxed::Box<F> as core::ops::function::FnOnce<A>>::call_once (boxed.rs:969)
==17569== by 0x4CCC112F: call_once<(),alloc::boxed::Box<FnOnce<()>>> (boxed.rs:969)
==17569== by 0x4CCC112F: start_thread (thread.rs:13)
==17569== by 0x4CCC112F: std::sys::unix::thread::Thread::new::thread_start (thread.rs:79)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 34: status = VgTs_WaitSys (lwpid 17671)
==17569== at 0x58329F3: futex_wait_cancelable (futex-internal.h:88)
==17569== by 0x58329F3: __pthread_cond_wait_common (pthread_cond_wait.c:502)
==17569== by 0x58329F3: pthread_cond_wait@@GLIBC_2.3.2 (pthread_cond_wait.c:655)
==17569== by 0x4CC9234D: std::sys::unix::condvar::Condvar::wait (condvar.rs:69)
==17569== by 0x4CC91D96: std::sys_common::condvar::Condvar::wait (condvar.rs:41)
==17569== by 0x4CC992E0: std::sync::condvar::Condvar::wait (condvar.rs:204)
==17569== by 0x4CC1C76E: tokio::runtime::park::Inner::park_condvar (park.rs:151)
==17569== by 0x4CC1C175: tokio::runtime::park::Inner::park (park.rs:125)
==17569== by 0x4CC1BCF2: <tokio::runtime::park::Parker as tokio::park::Park>::park (park.rs:90)
==17569== by 0x4CBF2DD8: tokio::runtime::thread_pool::worker::GenerationGuard::park (worker.rs:510)
==17569== by 0x4CBF1E7A: tokio::runtime::thread_pool::worker::GenerationGuard::run (worker.rs:292)
==17569== by 0x4CBF181E: tokio::runtime::thread_pool::worker::Worker::run::{{closure}}::{{closure}}::{{closure}}::{{closure}} (worker.rs:175)
==17569== by 0x4CBFD506: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBAA2: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CBF18AC: tokio::runtime::thread_pool::worker::Worker::run::{{closure}}::{{closure}}::{{closure}} (worker.rs:151)
==17569== by 0x4CC2AB12: tokio::runtime::blocking::pool::Spawner::enter::{{closure}} (pool.rs:191)
==17569== by 0x4CBFC4CC: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBD4B: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC2A9CB: tokio::runtime::blocking::pool::Spawner::enter (pool.rs:176)
==17569== by 0x4CBF18EB: tokio::runtime::thread_pool::worker::Worker::run::{{closure}}::{{closure}} (worker.rs:150)
==17569== by 0x4CC5AFC6: tokio::runtime::global::with_state::{{closure}} (global.rs:100)
==17569== by 0x4CBFD88C: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBB7B: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC5AEA3: tokio::runtime::global::with_state (global.rs:83)
==17569== by 0x4CC5B25A: tokio::runtime::global::with_thread_pool (global.rs:75)
==17569== by 0x4CBF194B: tokio::runtime::thread_pool::worker::Worker::run::{{closure}} (worker.rs:149)
==17569== by 0x4CC544ED: tokio::runtime::thread_pool::current::set::{{closure}} (current.rs:47)
==17569== by 0x4CBFC7D8: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBF0C: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC543D6: tokio::runtime::thread_pool::current::set (current.rs:29)
==17569== by 0x4CBF15E2: tokio::runtime::thread_pool::worker::Worker::run (worker.rs:145)
==17569== by 0x4CBFAA59: tokio::runtime::thread_pool::Workers::spawn::{{closure}}::{{closure}} (mod.rs:124)
==17569== by 0x4CC20F43: <tokio::runtime::blocking::task::BlockingTask<T> as core::future::future::Future>::poll (task.rs:30)
==17569== by 0x4CC2D0F5: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4CC627B7: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== by 0x4CC44437: core::ops::function::FnOnce::call_once (function.rs:232)
==17569== by 0x4CBEB45D: <std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once (panic.rs:316)
==17569== by 0x4CC2EE04: std::panicking::try::do_call (panicking.rs:289)
==17569== by 0x4CCC1D09: __rust_maybe_catch_panic (lib.rs:81)
==17569== by 0x4CC2EA46: std::panicking::try (panicking.rs:267)
==17569== by 0x4CBEBAF4: std::panic::catch_unwind (panic.rs:395)
==17569== by 0x4CC628D2: tokio::task::harness::Harness<T,S>::poll::{{closure}} (harness.rs:101)
==17569== by 0x4CC2040E: tokio::loom::std::causal_cell::CausalCell<T>::with_mut (causal_cell.rs:41)
==17569== by 0x4CC61CE7: tokio::task::harness::Harness<T,S>::poll (harness.rs:100)
==17569== by 0x4CBF4607: tokio::task::raw::poll (raw.rs:162)
==17569== by 0x4CBF4446: tokio::task::raw::RawTask::poll (raw.rs:113)
==17569== by 0x4CC431BB: tokio::task::Task<S>::run (mod.rs:371)
==17569== by 0x4CC2BFAC: tokio::runtime::blocking::pool::run_task (pool.rs:355)
==17569== by 0x4CC2B8F8: tokio::runtime::blocking::pool::Inner::run2 (pool.rs:281)
==17569== by 0x4CC2B6D0: tokio::runtime::blocking::pool::Inner::run::{{closure}}::{{closure}} (pool.rs:266)
==17569== by 0x4CC5B0E5: tokio::runtime::global::with_state::{{closure}} (global.rs:100)
==17569== by 0x4CBFD05B: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBCC7: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC5AEEA: tokio::runtime::global::with_state (global.rs:83)
==17569== by 0x4CC5B205: tokio::runtime::global::with_thread_pool (global.rs:75)
==17569== by 0x4CBF0F7D: tokio::runtime::thread_pool::spawner::Spawner::enter (spawner.rs:44)
==17569== by 0x4CC5AE10: tokio::runtime::spawner::Spawner::enter (spawner.rs:32)
==17569== by 0x4CC2B70E: tokio::runtime::blocking::pool::Inner::run::{{closure}} (pool.rs:266)
==17569== by 0x4CC280E7: tokio::time::clock::Clock::enter (clock.rs:30)
==17569== by 0x4CC00A51: tokio::runtime::time::variant::with_default (time.rs:43)
==17569== by 0x4CC2B687: tokio::runtime::blocking::pool::Inner::run (pool.rs:265)
==17569== by 0x4CC2B590: tokio::runtime::blocking::pool::Spawner::spawn_thread::{{closure}} (pool.rs:249)
==17569== by 0x4CC43E9C: std::sys_common::backtrace::__rust_begin_short_backtrace (backtrace.rs:136)
==17569== by 0x4CC2915D: std::thread::Builder::spawn_unchecked::{{closure}}::{{closure}} (mod.rs:469)
==17569== by 0x4CBEB42B: <std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once (panic.rs:316)
==17569== by 0x4CC2EDB2: std::panicking::try::do_call (panicking.rs:289)
==17569== by 0x4CCC1D09: __rust_maybe_catch_panic (lib.rs:81)
==17569== by 0x4CC2E6F9: std::panicking::try (panicking.rs:267)
==17569== by 0x4CBEBA7D: std::panic::catch_unwind (panic.rs:395)
==17569== by 0x4CC28F4D: std::thread::Builder::spawn_unchecked::{{closure}} (mod.rs:468)
==17569== by 0x4CC43F73: core::ops::function::FnOnce::call_once{{vtable-shim}} (function.rs:232)
==17569== by 0x4CCB6C7E: <alloc::boxed::Box<F> as core::ops::function::FnOnce<A>>::call_once (boxed.rs:969)
==17569== by 0x4CCC112F: call_once<(),alloc::boxed::Box<FnOnce<()>>> (boxed.rs:969)
==17569== by 0x4CCC112F: start_thread (thread.rs:13)
==17569== by 0x4CCC112F: std::sys::unix::thread::Thread::new::thread_start (thread.rs:79)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 35: status = VgTs_Runnable (lwpid 17672)
==17569== at 0x364C2C: enif_make_map_put (erl_nif.c:3169)
==17569== by 0x4CCB4975: rustler::wrapper::map::map_put (map.rs:36)
==17569== by 0x4CCA4C6D: rustler::types::map::<impl rustler::term::Term>::map_put (map.rs:118)
==17569== by 0x4C86F854: <franz::client::Message as rustler::types::Encoder>::encode (client.rs:30)
==17569== by 0x4C8900FF: franz::client::spawn_client::{{closure}}::{{closure}} (client.rs:164)
==17569== by 0x4C882CA6: rustler::env::OwnedEnv::send_and_clear::{{closure}} (env.rs:179)
==17569== by 0x4C88314D: rustler::env::OwnedEnv::run (env.rs:157)
==17569== by 0x4C88268E: rustler::env::OwnedEnv::send_and_clear (env.rs:179)
==17569== by 0x4C890C8E: franz::client::spawn_client::{{closure}} (client.rs:156)
==17569== by 0x4C8851E9: <std::future::GenFuture<T> as core::future::future::Future>::poll (future.rs:44)
==17569== by 0x4C861FE7: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4C869743: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== by 0x4C88D117: core::ops::function::FnOnce::call_once (function.rs:232)
==17569== by 0x4C885C7C: <std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once (panic.rs:316)
==17569== by 0x4C88242F: std::panicking::try::do_call (panicking.rs:289)
==17569== by 0x4CCC1D09: __rust_maybe_catch_panic (lib.rs:81)
==17569== by 0x4C882096: std::panicking::try (panicking.rs:267)
==17569== by 0x4C885D63: std::panic::catch_unwind (panic.rs:395)
==17569== by 0x4C869591: tokio::task::harness::Harness<T,S>::poll::{{closure}} (harness.rs:101)
==17569== by 0x4C88994E: tokio::loom::std::causal_cell::CausalCell<T>::with_mut (causal_cell.rs:41)
==17569== by 0x4C867E60: tokio::task::harness::Harness<T,S>::poll (harness.rs:100)
==17569== by 0x4C88C0E5: tokio::task::raw::poll (raw.rs:162)
==17569== by 0x4CBF4446: tokio::task::raw::RawTask::poll (raw.rs:113)
==17569== by 0x4CC4327B: tokio::task::Task<S>::run (mod.rs:371)
==17569== by 0x4CBF2A07: tokio::runtime::thread_pool::worker::GenerationGuard::run_task (worker.rs:466)
==17569== by 0x4CBF2216: tokio::runtime::thread_pool::worker::GenerationGuard::process_available_work (worker.rs:324)
==17569== by 0x4CBF1DF3: tokio::runtime::thread_pool::worker::GenerationGuard::run (worker.rs:289)
==17569== by 0x4CBF181E: tokio::runtime::thread_pool::worker::Worker::run::{{closure}}::{{closure}}::{{closure}}::{{closure}} (worker.rs:175)
==17569== by 0x4CBFD506: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBAA2: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CBF18AC: tokio::runtime::thread_pool::worker::Worker::run::{{closure}}::{{closure}}::{{closure}} (worker.rs:151)
==17569== by 0x4CC2AB12: tokio::runtime::blocking::pool::Spawner::enter::{{closure}} (pool.rs:191)
==17569== by 0x4CBFC4CC: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBD4B: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC2A9CB: tokio::runtime::blocking::pool::Spawner::enter (pool.rs:176)
==17569== by 0x4CBF18EB: tokio::runtime::thread_pool::worker::Worker::run::{{closure}}::{{closure}} (worker.rs:150)
==17569== by 0x4CC5AFC6: tokio::runtime::global::with_state::{{closure}} (global.rs:100)
==17569== by 0x4CBFD88C: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBB7B: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC5AEA3: tokio::runtime::global::with_state (global.rs:83)
==17569== by 0x4CC5B25A: tokio::runtime::global::with_thread_pool (global.rs:75)
==17569== by 0x4CBF194B: tokio::runtime::thread_pool::worker::Worker::run::{{closure}} (worker.rs:149)
==17569== by 0x4CC544ED: tokio::runtime::thread_pool::current::set::{{closure}} (current.rs:47)
==17569== by 0x4CBFC7D8: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBF0C: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC543D6: tokio::runtime::thread_pool::current::set (current.rs:29)
==17569== by 0x4CBF15E2: tokio::runtime::thread_pool::worker::Worker::run (worker.rs:145)
==17569== by 0x4CBFAA59: tokio::runtime::thread_pool::Workers::spawn::{{closure}}::{{closure}} (mod.rs:124)
==17569== by 0x4CC20F43: <tokio::runtime::blocking::task::BlockingTask<T> as core::future::future::Future>::poll (task.rs:30)
==17569== by 0x4CC2D0F5: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4CC627B7: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== by 0x4CC44437: core::ops::function::FnOnce::call_once (function.rs:232)
==17569== by 0x4CBEB45D: <std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once (panic.rs:316)
==17569== by 0x4CC2EE04: std::panicking::try::do_call (panicking.rs:289)
==17569== by 0x4CCC1D09: __rust_maybe_catch_panic (lib.rs:81)
==17569== by 0x4CC2EA46: std::panicking::try (panicking.rs:267)
==17569== by 0x4CBEBAF4: std::panic::catch_unwind (panic.rs:395)
==17569== by 0x4CC628D2: tokio::task::harness::Harness<T,S>::poll::{{closure}} (harness.rs:101)
==17569== by 0x4CC2040E: tokio::loom::std::causal_cell::CausalCell<T>::with_mut (causal_cell.rs:41)
==17569== by 0x4CC61CE7: tokio::task::harness::Harness<T,S>::poll (harness.rs:100)
==17569== by 0x4CBF4607: tokio::task::raw::poll (raw.rs:162)
==17569== by 0x4CBF4446: tokio::task::raw::RawTask::poll (raw.rs:113)
==17569== by 0x4CC431BB: tokio::task::Task<S>::run (mod.rs:371)
==17569== by 0x4CC2BFAC: tokio::runtime::blocking::pool::run_task (pool.rs:355)
==17569== by 0x4CC2B8F8: tokio::runtime::blocking::pool::Inner::run2 (pool.rs:281)
==17569== by 0x4CC2B6D0: tokio::runtime::blocking::pool::Inner::run::{{closure}}::{{closure}} (pool.rs:266)
==17569== by 0x4CC5B0E5: tokio::runtime::global::with_state::{{closure}} (global.rs:100)
==17569== by 0x4CBFD05B: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBCC7: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC5AEEA: tokio::runtime::global::with_state (global.rs:83)
==17569== by 0x4CC5B205: tokio::runtime::global::with_thread_pool (global.rs:75)
==17569== by 0x4CBF0F7D: tokio::runtime::thread_pool::spawner::Spawner::enter (spawner.rs:44)
==17569== by 0x4CC5AE10: tokio::runtime::spawner::Spawner::enter (spawner.rs:32)
==17569== by 0x4CC2B70E: tokio::runtime::blocking::pool::Inner::run::{{closure}} (pool.rs:266)
==17569== by 0x4CC280E7: tokio::time::clock::Clock::enter (clock.rs:30)
==17569== by 0x4CC00A51: tokio::runtime::time::variant::with_default (time.rs:43)
==17569== by 0x4CC2B687: tokio::runtime::blocking::pool::Inner::run (pool.rs:265)
==17569== by 0x4CC2B590: tokio::runtime::blocking::pool::Spawner::spawn_thread::{{closure}} (pool.rs:249)
==17569== by 0x4CC43E9C: std::sys_common::backtrace::__rust_begin_short_backtrace (backtrace.rs:136)
==17569== by 0x4CC2915D: std::thread::Builder::spawn_unchecked::{{closure}}::{{closure}} (mod.rs:469)
==17569== by 0x4CBEB42B: <std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once (panic.rs:316)
==17569== by 0x4CC2EDB2: std::panicking::try::do_call (panicking.rs:289)
==17569== by 0x4CCC1D09: __rust_maybe_catch_panic (lib.rs:81)
==17569== by 0x4CC2E6F9: std::panicking::try (panicking.rs:267)
==17569== by 0x4CBEBA7D: std::panic::catch_unwind (panic.rs:395)
==17569== by 0x4CC28F4D: std::thread::Builder::spawn_unchecked::{{closure}} (mod.rs:468)
==17569== by 0x4CC43F73: core::ops::function::FnOnce::call_once{{vtable-shim}} (function.rs:232)
==17569== by 0x4CCB6C7E: <alloc::boxed::Box<F> as core::ops::function::FnOnce<A>>::call_once (boxed.rs:969)
==17569== by 0x4CCC112F: call_once<(),alloc::boxed::Box<FnOnce<()>>> (boxed.rs:969)
==17569== by 0x4CCC112F: start_thread (thread.rs:13)
==17569== by 0x4CCC112F: std::sys::unix::thread::Thread::new::thread_start (thread.rs:79)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 36: status = VgTs_WaitSys (lwpid 17673)
==17569== at 0x58329F3: futex_wait_cancelable (futex-internal.h:88)
==17569== by 0x58329F3: __pthread_cond_wait_common (pthread_cond_wait.c:502)
==17569== by 0x58329F3: pthread_cond_wait@@GLIBC_2.3.2 (pthread_cond_wait.c:655)
==17569== by 0x4CC9234D: std::sys::unix::condvar::Condvar::wait (condvar.rs:69)
==17569== by 0x4CC91D96: std::sys_common::condvar::Condvar::wait (condvar.rs:41)
==17569== by 0x4CC992E0: std::sync::condvar::Condvar::wait (condvar.rs:204)
==17569== by 0x4CC1C76E: tokio::runtime::park::Inner::park_condvar (park.rs:151)
==17569== by 0x4CC1C175: tokio::runtime::park::Inner::park (park.rs:125)
==17569== by 0x4CC1BCF2: <tokio::runtime::park::Parker as tokio::park::Park>::park (park.rs:90)
==17569== by 0x4CBF2DD8: tokio::runtime::thread_pool::worker::GenerationGuard::park (worker.rs:510)
==17569== by 0x4CBF1E7A: tokio::runtime::thread_pool::worker::GenerationGuard::run (worker.rs:292)
==17569== by 0x4CBF181E: tokio::runtime::thread_pool::worker::Worker::run::{{closure}}::{{closure}}::{{closure}}::{{closure}} (worker.rs:175)
==17569== by 0x4CBFD506: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBAA2: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CBF18AC: tokio::runtime::thread_pool::worker::Worker::run::{{closure}}::{{closure}}::{{closure}} (worker.rs:151)
==17569== by 0x4CC2AB12: tokio::runtime::blocking::pool::Spawner::enter::{{closure}} (pool.rs:191)
==17569== by 0x4CBFC4CC: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBD4B: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC2A9CB: tokio::runtime::blocking::pool::Spawner::enter (pool.rs:176)
==17569== by 0x4CBF18EB: tokio::runtime::thread_pool::worker::Worker::run::{{closure}}::{{closure}} (worker.rs:150)
==17569== by 0x4CC5AFC6: tokio::runtime::global::with_state::{{closure}} (global.rs:100)
==17569== by 0x4CBFD88C: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBB7B: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC5AEA3: tokio::runtime::global::with_state (global.rs:83)
==17569== by 0x4CC5B25A: tokio::runtime::global::with_thread_pool (global.rs:75)
==17569== by 0x4CBF194B: tokio::runtime::thread_pool::worker::Worker::run::{{closure}} (worker.rs:149)
==17569== by 0x4CC544ED: tokio::runtime::thread_pool::current::set::{{closure}} (current.rs:47)
==17569== by 0x4CBFC7D8: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBF0C: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC543D6: tokio::runtime::thread_pool::current::set (current.rs:29)
==17569== by 0x4CBF15E2: tokio::runtime::thread_pool::worker::Worker::run (worker.rs:145)
==17569== by 0x4CBFAA59: tokio::runtime::thread_pool::Workers::spawn::{{closure}}::{{closure}} (mod.rs:124)
==17569== by 0x4CC20F43: <tokio::runtime::blocking::task::BlockingTask<T> as core::future::future::Future>::poll (task.rs:30)
==17569== by 0x4CC2D0F5: tokio::task::core::Core<T>::poll (core.rs:128)
==17569== by 0x4CC627B7: tokio::task::harness::Harness<T,S>::poll::{{closure}}::{{closure}} (harness.rs:120)
==17569== by 0x4CC44437: core::ops::function::FnOnce::call_once (function.rs:232)
==17569== by 0x4CBEB45D: <std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once (panic.rs:316)
==17569== by 0x4CC2EE04: std::panicking::try::do_call (panicking.rs:289)
==17569== by 0x4CCC1D09: __rust_maybe_catch_panic (lib.rs:81)
==17569== by 0x4CC2EA46: std::panicking::try (panicking.rs:267)
==17569== by 0x4CBEBAF4: std::panic::catch_unwind (panic.rs:395)
==17569== by 0x4CC628D2: tokio::task::harness::Harness<T,S>::poll::{{closure}} (harness.rs:101)
==17569== by 0x4CC2040E: tokio::loom::std::causal_cell::CausalCell<T>::with_mut (causal_cell.rs:41)
==17569== by 0x4CC61CE7: tokio::task::harness::Harness<T,S>::poll (harness.rs:100)
==17569== by 0x4CBF4607: tokio::task::raw::poll (raw.rs:162)
==17569== by 0x4CBF4446: tokio::task::raw::RawTask::poll (raw.rs:113)
==17569== by 0x4CC431BB: tokio::task::Task<S>::run (mod.rs:371)
==17569== by 0x4CC2BFAC: tokio::runtime::blocking::pool::run_task (pool.rs:355)
==17569== by 0x4CC2B8F8: tokio::runtime::blocking::pool::Inner::run2 (pool.rs:281)
==17569== by 0x4CC2B6D0: tokio::runtime::blocking::pool::Inner::run::{{closure}}::{{closure}} (pool.rs:266)
==17569== by 0x4CC5B0E5: tokio::runtime::global::with_state::{{closure}} (global.rs:100)
==17569== by 0x4CBFD05B: std::thread::local::LocalKey<T>::try_with (local.rs:262)
==17569== by 0x4CBFBCC7: std::thread::local::LocalKey<T>::with (local.rs:239)
==17569== by 0x4CC5AEEA: tokio::runtime::global::with_state (global.rs:83)
==17569== by 0x4CC5B205: tokio::runtime::global::with_thread_pool (global.rs:75)
==17569== by 0x4CBF0F7D: tokio::runtime::thread_pool::spawner::Spawner::enter (spawner.rs:44)
==17569== by 0x4CC5AE10: tokio::runtime::spawner::Spawner::enter (spawner.rs:32)
==17569== by 0x4CC2B70E: tokio::runtime::blocking::pool::Inner::run::{{closure}} (pool.rs:266)
==17569== by 0x4CC280E7: tokio::time::clock::Clock::enter (clock.rs:30)
==17569== by 0x4CC00A51: tokio::runtime::time::variant::with_default (time.rs:43)
==17569== by 0x4CC2B687: tokio::runtime::blocking::pool::Inner::run (pool.rs:265)
==17569== by 0x4CC2B590: tokio::runtime::blocking::pool::Spawner::spawn_thread::{{closure}} (pool.rs:249)
==17569== by 0x4CC43E9C: std::sys_common::backtrace::__rust_begin_short_backtrace (backtrace.rs:136)
==17569== by 0x4CC2915D: std::thread::Builder::spawn_unchecked::{{closure}}::{{closure}} (mod.rs:469)
==17569== by 0x4CBEB42B: <std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once (panic.rs:316)
==17569== by 0x4CC2EDB2: std::panicking::try::do_call (panicking.rs:289)
==17569== by 0x4CCC1D09: __rust_maybe_catch_panic (lib.rs:81)
==17569== by 0x4CC2E6F9: std::panicking::try (panicking.rs:267)
==17569== by 0x4CBEBA7D: std::panic::catch_unwind (panic.rs:395)
==17569== by 0x4CC28F4D: std::thread::Builder::spawn_unchecked::{{closure}} (mod.rs:468)
==17569== by 0x4CC43F73: core::ops::function::FnOnce::call_once{{vtable-shim}} (function.rs:232)
==17569== by 0x4CCB6C7E: <alloc::boxed::Box<F> as core::ops::function::FnOnce<A>>::call_once (boxed.rs:969)
==17569== by 0x4CCC112F: call_once<(),alloc::boxed::Box<FnOnce<()>>> (boxed.rs:969)
==17569== by 0x4CCC112F: start_thread (thread.rs:13)
==17569== by 0x4CCC112F: std::sys::unix::thread::Thread::new::thread_start (thread.rs:79)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 37: status = VgTs_WaitSys (lwpid 17674)
==17569== at 0x5D60BF9: poll (poll.c:29)
==17569== by 0x4CB5838D: poll (poll2.h:41)
==17569== by 0x4CB5838D: rd_kafka_transport_poll (rdkafka_transport.c:968)
==17569== by 0x4CB583FE: rd_kafka_transport_io_serve (rdkafka_transport.c:818)
==17569== by 0x4CB417CB: rd_kafka_broker_ops_io_serve (rdkafka_broker.c:3027)
==17569== by 0x4CB41DF8: rd_kafka_broker_consumer_serve (rdkafka_broker.c:4290)
==17569== by 0x4CB42C9C: rd_kafka_broker_serve (rdkafka_broker.c:4392)
==17569== by 0x4CB4324C: rd_kafka_broker_thread_main (rdkafka_broker.c:4544)
==17569== by 0x4CB95DD6: _thrd_wrapper_function (tinycthread.c:576)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 38: status = VgTs_WaitSys (lwpid 17675)
==17569== at 0x5832F85: futex_abstimed_wait_cancelable (futex-internal.h:205)
==17569== by 0x5832F85: __pthread_cond_wait_common (pthread_cond_wait.c:539)
==17569== by 0x5832F85: pthread_cond_timedwait@@GLIBC_2.3.2 (pthread_cond_wait.c:667)
==17569== by 0x4CB95F98: cnd_timedwait (tinycthread.c:462)
==17569== by 0x4CB5DE45: rd_kafka_q_serve (rdkafka_queue.c:462)
==17569== by 0x4CB2F7FB: rd_kafka_thread_main (rdkafka.c:1857)
==17569== by 0x4CB95DD6: _thrd_wrapper_function (tinycthread.c:576)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 39: status = VgTs_WaitSys (lwpid 17676)
==17569== at 0x5832F85: futex_abstimed_wait_cancelable (futex-internal.h:205)
==17569== by 0x5832F85: __pthread_cond_wait_common (pthread_cond_wait.c:539)
==17569== by 0x5832F85: pthread_cond_timedwait@@GLIBC_2.3.2 (pthread_cond_wait.c:667)
==17569== by 0x4CB95F98: cnd_timedwait (tinycthread.c:462)
==17569== by 0x4CB5DC86: rd_kafka_q_pop_serve (rdkafka_queue.c:390)
==17569== by 0x4CB4158E: rd_kafka_broker_ops_serve (rdkafka_broker.c:2984)
==17569== by 0x4CB41640: rd_kafka_broker_ops_io_serve (rdkafka_broker.c:3035)
==17569== by 0x4CB42EC6: rd_kafka_broker_internal_serve (rdkafka_broker.c:3189)
==17569== by 0x4CB42EC6: rd_kafka_broker_serve (rdkafka_broker.c:4388)
==17569== by 0x4CB433E9: rd_kafka_broker_thread_main (rdkafka_broker.c:4432)
==17569== by 0x4CB95DD6: _thrd_wrapper_function (tinycthread.c:576)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Thread 40: status = VgTs_WaitSys (lwpid 17677)
==17569== at 0x5D60BF9: poll (poll.c:29)
==17569== by 0x4CB5838D: poll (poll2.h:41)
==17569== by 0x4CB5838D: rd_kafka_transport_poll (rdkafka_transport.c:968)
==17569== by 0x4CB583FE: rd_kafka_transport_io_serve (rdkafka_transport.c:818)
==17569== by 0x4CB417CB: rd_kafka_broker_ops_io_serve (rdkafka_broker.c:3027)
==17569== by 0x4CB41DF8: rd_kafka_broker_consumer_serve (rdkafka_broker.c:4290)
==17569== by 0x4CB42C9C: rd_kafka_broker_serve (rdkafka_broker.c:4392)
==17569== by 0x4CB4324C: rd_kafka_broker_thread_main (rdkafka_broker.c:4544)
==17569== by 0x4CB95DD6: _thrd_wrapper_function (tinycthread.c:576)
==17569== by 0x582C6DA: start_thread (pthread_create.c:463)
==17569== by 0x5D6D88E: clone (clone.S:95)
Note: see also the FAQ in the source distribution.
It contains workarounds to several common problems.
In particular, if Valgrind aborted or crashed after
identifying problems in your program, there's a good chance
that fixing those problems will prevent Valgrind aborting or
crashing, especially if it happened in m_mallocfree.c.
If that doesn't help, please report this bug to: www.valgrind.org
In the bug report, send all the above text, the valgrind
version, and what OS and version you are using. Thanks.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment