+----------------------------------------------------------------------+
core
+----------------------------------------------------------------------+
- local_peers
-> connect a consumer (leaf) to core2 [line 132]
-> core1: 5@invalid-node [line 134]
-> core2: 8@invalid-node [line 135]
-> leaf: 9@invalid-node [line 136]
-> expect(atom_value, filter_type).from(leaf).to(core2).with(join_atom::value, filter_type{"b"}) [line 139]
-> expect(atom::peer, actor).from(self).to(core1).with(_, core2) [line 143]
-> query peer information from core1 [line 145]
-> run handshake between peers [line 156]
AddressSanitizer:DEADLYSIGNAL
=================================================================
==6273==ERROR: AddressSanitizer: SEGV on unknown address 0x000000000000 (pc 0x000115054871 bp 0x7ffee13eac70 sp 0x7ffee13eac50 T0)
==6273==The signal is caused by a READ memory access.
==6273==Hint: address points to the zero page.
#0 0x115054870 in std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> >::__is_long() const string:1406
#1 0x115054eb8 in std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> >::__get_pointer() const string:1500
#2 0x115054e74 in std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> >::data() const string:1228
#3 0x11503c284 in std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> >::c_str() const string:1226
#4 0x11503c253 in caf::logger::line_builder::operator<<(std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&) logger.cpp:271
#5 0x114fb2dd4 in caf::inbound_path::inbound_path(caf::intrusive_ptr<caf::stream_manager>, caf::stream_slots, caf::intrusive_ptr<caf::actor_control_block>, std::__1::pair<unsigned short, std::type_info const*>) inbound_path.cpp:80
#6 0x114fb3d14 in caf::inbound_path::inbound_path(caf::intrusive_ptr<caf::stream_manager>, caf::stream_slots, caf::intrusive_ptr<caf::actor_control_block>, std::__1::pair<unsigned short, std::type_info const*>) inbound_path.cpp:77
#7 0x115205c25 in caf::scheduled_actor::make_inbound_path(caf::intrusive_ptr<caf::stream_manager>, caf::stream_slots, caf::intrusive_ptr<caf::actor_control_block>, std::__1::pair<unsigned short, std::type_info const*>) scheduled_actor.cpp:892
#8 0x11536da5d in caf::stream_manager::add_unchecked_inbound_path_impl(std::__1::pair<unsigned short, std::type_info const*>) stream_manager.cpp:315
#9 0x110be9823 in unsigned short caf::stream_manager::add_unchecked_inbound_path<broker::node_message>(caf::stream<broker::node_message> const&) stream_manager.hpp:250
#10 0x110be9191 in broker::detail::core_policy::ack_peering(caf::stream<broker::node_message> const&, caf::actor const&) core_policy.cc:284
#11 0x1106d5727 in broker::core_actor(caf::stateful_actor<broker::core_state, caf::event_based_actor>*, std::__1::vector<broker::topic, std::__1::allocator<broker::topic> >, broker::broker_options, broker::endpoint::clock*)::$_18::operator()(caf::stream<broker::node_message> const&, std::__1::vector<broker::topic, std::__1::allocator<broker::topic> >&, caf::actor&) const core_actor.cc:319
#12 0x1106d38a7 in caf::unit_t caf::lfinvoker<true, broker::core_actor(caf::stateful_actor<broker::core_state, caf::event_based_actor>*, std::__1::vector<broker::topic, std::__1::allocator<broker::topic> >, broker::broker_options, broker::endpoint::clock*)::$_18>::operator()<caf::stream<broker::node_message>&, std::__1::vector<broker::topic, std::__1::allocator<broker::topic> >&, caf::actor&>(caf::stream<broker::node_message>&&&, std::__1::vector<broker::topic, std::__1::allocator<broker::topic> >&&&, caf::actor&&&) match_case.hpp:92
#13 0x1106d3060 in decltype(fp(get<0l>(fp1), get<1l>(fp1), get<2l>(fp1))) caf::detail::apply_args<caf::lfinvoker<true, broker::core_actor(caf::stateful_actor<broker::core_state, caf::event_based_actor>*, std::__1::vector<broker::topic, std::__1::allocator<broker::topic> >, broker::broker_options, broker::endpoint::clock*)::$_18>, 0l, 1l, 2l, caf::detail::pseudo_tuple<caf::stream<broker::node_message>, std::__1::vector<broker::topic, std::__1::allocator<broker::topic> >, caf::actor> >(caf::lfinvoker<true, broker::core_actor(caf::stateful_actor<broker::core_state, caf::event_based_actor>*, std::__1::vector<broker::topic, std::__1::allocator<broker::topic> >, broker::broker_options, broker::endpoint::clock*)::$_18>&, caf::detail::int_list<0l, 1l, 2l>, caf::detail::pseudo_tuple<caf::stream<broker::node_message>, std::__1::vector<broker::topic, std::__1::allocator<broker::topic> >, caf::actor>&) apply_args.hpp:38
#14 0x1106d2d1f in caf::trivial_match_case<broker::core_actor(caf::stateful_actor<broker::core_state, caf::event_based_actor>*, std::__1::vector<broker::topic, std::__1::allocator<broker::topic> >, broker::broker_options, broker::endpoint::clock*)::$_18>::invoke(caf::detail::invoke_result_visitor&, caf::type_erased_tuple&) match_case.hpp:164
#15 0x114d064c9 in caf::detail::behavior_impl::invoke(caf::detail::invoke_result_visitor&, caf::type_erased_tuple&) behavior_impl.cpp:102
#16 0x114d06de9 in caf::detail::behavior_impl::invoke(caf::detail::invoke_result_visitor&, caf::message&) behavior_impl.cpp:135
#17 0x1152177a9 in caf::behavior::operator()(caf::detail::invoke_result_visitor&, caf::message&) behavior.hpp:115
#18 0x1151fdb58 in caf::scheduled_actor::handle_open_stream_msg(caf::mailbox_element&) scheduled_actor.cpp:1120
#19 0x1151fae76 in caf::scheduled_actor::categorize(caf::mailbox_element&) scheduled_actor.cpp:619
#20 0x115200ea4 in caf::scheduled_actor::consume(caf::mailbox_element&) scheduled_actor.cpp:676
#21 0x1151df25b in caf::scheduled_actor::reactivate(caf::mailbox_element&) scheduled_actor.cpp:786
#22 0x1151ddfe3 in caf::scheduled_actor::mailbox_visitor::operator()(caf::mailbox_element&) scheduled_actor.cpp:358
#23 0x11526dd24 in caf::intrusive::task_result caf::scheduled_actor::mailbox_visitor::operator()<caf::intrusive::drr_cached_queue<caf::policy::normal_messages> >(unsigned long, caf::intrusive::drr_cached_queue<caf::policy::normal_messages>&, caf::mailbox_element&) scheduled_actor.hpp:234
#24 0x11526dc7e in decltype(decltype(std::__1::__declval<caf::scheduled_actor::mailbox_visitor&>(0)) std::__1::declval<caf::scheduled_actor::mailbox_visitor&>()()(decltype(std::__1::__declval<caf::scheduled_actor::mailbox_visitor&>(0)) std::__1::declval<std::__1::integral_constant<unsigned long, 1ul> >()(), decltype(std::__1::__declval<caf::scheduled_actor::mailbox_visitor&>(0)) std::__1::declval<caf::intrusive::drr_cached_queue<caf::policy::normal_messages>&>()(), std::forward<caf::intrusive::drr_cached_queue<caf::policy::normal_messages>&>(fp)...)) caf::intrusive::wdrr_fixed_multiplexed_queue<caf::policy::categorized, caf::intrusive::drr_cached_queue<caf::policy::urgent_messages>, caf::intrusive::drr_cached_queue<caf::policy::normal_messages>, caf::intrusive::drr_queue<caf::policy::upstream_messages>, caf::intrusive::wdrr_dynamic_multiplexed_queue<caf::policy::downstream_messages> >::new_round_recursion_helper<1ul, caf::intrusive::drr_cached_queue<caf::policy::normal_messages>, caf::scheduled_actor::mailbox_visitor>::operator()<caf::mailbox_element&>(caf::intrusive::drr_cached_queue<caf::policy::normal_messages>&&&...) wdrr_fixed_multiplexed_queue.hpp:170
#25 0x11526cc85 in caf::intrusive::new_round_result caf::intrusive::drr_cached_queue<caf::policy::normal_messages>::new_round<caf::intrusive::wdrr_fixed_multiplexed_queue<caf::policy::categorized, caf::intrusive::drr_cached_queue<caf::policy::urgent_messages>, caf::intrusive::drr_cached_queue<caf::policy::normal_messages>, caf::intrusive::drr_queue<caf::policy::upstream_messages>, caf::intrusive::wdrr_dynamic_multiplexed_queue<caf::policy::downstream_messages> >::new_round_recursion_helper<1ul, caf::intrusive::drr_cached_queue<caf::policy::normal_messages>, caf::scheduled_actor::mailbox_visitor> >(unsigned long, caf::intrusive::wdrr_fixed_multiplexed_queue<caf::policy::categorized, caf::intrusive::drr_cached_queue<caf::policy::urgent_messages>, caf::intrusive::drr_cached_queue<caf::policy::normal_messages>, caf::intrusive::drr_queue<caf::policy::upstream_messages>, caf::intrusive::wdrr_dynamic_multiplexed_queue<caf::policy::downstream_messages> >::new_round_recursion_helper<1ul, caf::intrusive::drr_cached_queue<caf::policy::normal_messages>, caf::scheduled_actor::mailbox_visitor>&) drr_cached_queue.hpp:190
#26 0x11526c256 in std::__1::enable_if<(1ul) != (caf::intrusive::wdrr_fixed_multiplexed_queue<caf::policy::categorized, caf::intrusive::drr_cached_queue<caf::policy::urgent_messages>, caf::intrusive::drr_cached_queue<caf::policy::normal_messages>, caf::intrusive::drr_queue<caf::policy::upstream_messages>, caf::intrusive::wdrr_dynamic_multiplexed_queue<caf::policy::downstream_messages> >::num_queues), caf::intrusive::new_round_result>::type caf::intrusive::wdrr_fixed_multiplexed_queue<caf::policy::categorized, caf::intrusive::drr_cached_queue<caf::policy::urgent_messages>, caf::intrusive::drr_cached_queue<caf::policy::normal_messages>, caf::intrusive::drr_queue<caf::policy::upstream_messages>, caf::intrusive::wdrr_dynamic_multiplexed_queue<caf::policy::downstream_messages> >::new_round_recursion<1ul, caf::scheduled_actor::mailbox_visitor>(unsigned long, caf::scheduled_actor::mailbox_visitor&) wdrr_fixed_multiplexed_queue.hpp:200
#27 0x11526b10f in std::__1::enable_if<(0ul) != (caf::intrusive::wdrr_fixed_multiplexed_queue<caf::policy::categorized, caf::intrusive::drr_cached_queue<caf::policy::urgent_messages>, caf::intrusive::drr_cached_queue<caf::policy::normal_messages>, caf::intrusive::drr_queue<caf::policy::upstream_messages>, caf::intrusive::wdrr_dynamic_multiplexed_queue<caf::policy::downstream_messages> >::num_queues), caf::intrusive::new_round_result>::type caf::intrusive::wdrr_fixed_multiplexed_queue<caf::policy::categorized, caf::intrusive::drr_cached_queue<caf::policy::urgent_messages>, caf::intrusive::drr_cached_queue<caf::policy::normal_messages>, caf::intrusive::drr_queue<caf::policy::upstream_messages>, caf::intrusive::wdrr_dynamic_multiplexed_queue<caf::policy::downstream_messages> >::new_round_recursion<0ul, caf::scheduled_actor::mailbox_visitor>(unsigned long, caf::scheduled_actor::mailbox_visitor&) wdrr_fixed_multiplexed_queue.hpp:207
#28 0x11526ac68 in caf::intrusive::new_round_result caf::intrusive::wdrr_fixed_multiplexed_queue<caf::policy::categorized, caf::intrusive::drr_cached_queue<caf::policy::urgent_messages>, caf::intrusive::drr_cached_queue<caf::policy::normal_messages>, caf::intrusive::drr_queue<caf::policy::upstream_messages>, caf::intrusive::wdrr_dynamic_multiplexed_queue<caf::policy::downstream_messages> >::new_round<caf::scheduled_actor::mailbox_visitor>(unsigned long, caf::scheduled_actor::mailbox_visitor&) wdrr_fixed_multiplexed_queue.hpp:93
#29 0x1151e6d7f in caf::intrusive::new_round_result caf::intrusive::fifo_inbox<caf::scheduled_actor::mailbox_policy>::new_round<caf::scheduled_actor::mailbox_visitor>(unsigned long, caf::scheduled_actor::mailbox_visitor&) fifo_inbox.hpp:174
#30 0x1151e272c in caf::scheduled_actor::resume(caf::execution_unit*, unsigned long) scheduled_actor.cpp:399
#31 0x1153b8812 in caf::scheduler::test_coordinator::try_run_once() test_coordinator.cpp:110
#32 0x10e8f1a6e in test_coordinator_fixture<(anonymous namespace)::config>::consume_message() dsl.hpp:580
#33 0x10e94fd67 in unsigned long test_coordinator_fixture<(anonymous namespace)::config>::run_until<test_coordinator_fixture<(anonymous namespace)::config>::run()::'lambda'()>(test_coordinator_fixture<(anonymous namespace)::config>::run()::'lambda'()) dsl.hpp:643
#34 0x10e94f094 in test_coordinator_fixture<(anonymous namespace)::config>::run() dsl.hpp:628
#35 0x10e8e6873 in local_tests::(anonymous namespace)::test123::run_test_impl() core.cc:157
#36 0x10e8dd27a in caf::test::test_impl<local_tests::(anonymous namespace)::test123>::run_test_impl() unit_test.hpp:277
#37 0x10f020550 in caf::test::engine::run(bool, std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&, int, int, std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&, std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&, std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&, std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char> > const&) unit_test_impl.hpp:372
#38 0x10f02ac58 in caf::test::main(int, char**) unit_test_impl.hpp:571
#39 0x10f02dac1 in main test.cpp:63
#40 0x7fff65d2c3d4 in start (libdyld.dylib:x86_64+0x163d4)