rumqttd 0.3.0

��!

	



  !"#


$%  !"#

&'()*	




+	




,-./0123  !"#


45	



0123  !"#

6789:  !"#

;67




  !"#

789:  !"#

<




=




4>?




@5%  !"#


A;67



B

CD6789:  !"#


EFGHIJKLM()*N9:  !"#

012OP


QRS  !"#

TD6789:  !"#
 
UVWXYZ[\]




7




4^%  !"#

#
_`abcd	



efghijklS  !"#


m789:  !"#


	



45%  !"#

nNS  !"#

o45%  !"#


p









q  !"#


r789:  !"#

stuvwx0123  !"#


yz{|nN9:  !"#

}~




%  !"#
,
'FGHIJKLM()*�
�
�
�
�
YZ[\lS  !"#

$
�
�
�
�
�

�
�
�
78S  !"#



NS  !"#


�
	




,-./  !"#


m�
CD6789:  !"#
 
	



m>%  !"#


m^	



$
�
�
	




23  !"#

*NS  !"#


N9:  !"#

UVWXYZ[\lS  !"#


�
�
�
:  !"#



5%  !"#


�
012O


�
D6789:  !"#

�
�
	




^	



 
�
�
A;67




]



	




r78S  !"#

"
_`abcd




nS  !"#

(
#*�
�
�
�
�
YZ[\]



(
#�
�
�
�
�

�
�
�
CD6789:  !"#

78S  !"#


$�
	



�
	




	




	



�
0123  !"#


n5%  !"#


4�
CD6789:  !"#

4B  !"#


�
A;67




*N9:  !"#

�
CD6789:  !"#

mB
"
�
	




	



&
!�
�
�
�
�
�
�
�
�




�
A;







�
�
	



S  !"#

�
�
0123  !"#

89:  !"#

�
�
5	








A�
CD6789:  !"#

>?


*
%�
�
�
�
�
�
�
A;67



5	



�
�
�
�
  !"#


�
	



67




	


&
!�
�
�
	



(
#�
�
�
�
�
�
�
�




$
�
�
�
�
�
�





m5	




tuvwx0123  !"#


�
9:  !"#



9:  !"#
"
�
	



	


*
%�
JKLM()*�
�
�
�
�
YZ[\lS  !"#

"
"
"""""""""""""""	"	"
"
"""""
"
""""""""""""4"	"�"	"�"	"�""3"""""""""""""""""	 " �"!"!W"""""#"#"$"$"%"%"	&"&�
"	'"'�
"	("(�"	)")�"	*"*�"+"+",","	-"-�"	.".�"	/"/�
"0"0"1"1"2"2"3"3"4"4"5"5"6"6"7"7"8"8"9"9":":";";"<"<"="=(">">"?"?"@"@"A"A"B"B"C"C"D"D"E"E"	F"F�"	G"G�
"	H"H�	"I"I]"J"J<"K"K^"L"L5"	M"M�
"N"N"O"O"P"P"Q"Q"R"R"S"S"T"T"	U"U�"	V"V�"	W"W�"	X"X�"	Y"Y�
"	Z"Z�"	["[�"	\"\�
"]"]"^"^"_"_"	`"`�
"	a"a�
"	b"b�"	c"c�"d"d"	e"e�
"	f"f�
"	g"g�"	h"h�"	i"i�
"	j"j�"k"k"l"l"m"m"	n"n�"o"o"p"p"q"q"r"r"s"s"t"t"u"u3"	v"v�"	w"w�"x"x"	y"y�
"	z"z�"	{"{�
"	|"|�"}"}"~"~""P"�
"�
�
"�
"�
�
"�
"�
�
"
�
"�
\"�
"�
�"�
"�
�"�
"�
�"�
"�
�"�
"�
�
"�
"�
�"�
"�
�
"�
"�
�"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"
�
"�
+"�
"�
"
�
"�
Z"�
"�
�
"�
"�
�
"�
"�
�
"�
"�
�"�
"�
�"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"
�
"�
g"�
"�
�"�
"�
�"�
"�
"
�
"�
"�
"�
�"�
"�
�"�
"�
�"�
"�
"�
"�
"
�
"�
E"�
"�
�"�
"�
�
"�
"�
�"�
"�
�"�
"�
"�
"�
"�
"�
"�
"�
"�
"�
"
�
"�
h*	
�
C N*
�� N*	^�
 N*	5� N*
�
�
 N*	�
 N*
�� N*
�
�
 N*
	�
� N*	
u� N*	m�
 N*}9 N*

�
�
 N*dH N*	`�
 N*
��
 N*
��
 N*	@� N*
��
 *
�
�
 K*	�
i K*
�
� *		� *~~ N*
�
�
 N*kk N*
�
� N*	7�
 N*	� N*	�n N*
�
�
 N*	 �
 G*
!�
 �
*
"�
�
 N*
#�
�
 N*	$�
 N*	%�
 N*&�� �*'�� �*
(�
�
 *
)�� **** *
+�� N*
,�
�
 N*
-1�
 �*
.8� �*	/?�
 *
0��
 N*
1�
� N*	2�
 N*3y N*
4�
�
 N*	5�
+ N*6,D N*
7��
 N*	8S� N*	9�
) N*	:X�
 N*
;�� N*<Yz N*
=�� {*	>�
  N*
?�
�
 N*
@�
�
 N*
A��
 N*
B��
 N*C
" N*	D�
A N*E�� �*F�
�
 �*	GPP �*H�� �*
I�� {*
J�
�
 (*K�� �*L�� �
*
M�
�
 *
N�
�
 N*
O�
�
 N*	P�F N*	Q� N*	R=� N*	S� N*
T�
� N*
U��
 *	VQ�
 -*W�
� �
*
Xg�
 �
*	YR! �*
Z[�
 �*[�� �
*\�
�
 �*
]�� N*	^�

 N*
_�
�
 N*
`a� �*
a�s �*
b�
_ �
*c�� �*d
B N*e�� �*f�� �*g�
�
 �*	htt �*i�
�
 �
*jvv *	k�6 N*l<r N*
m�
�
 N*
n�
�
 *
o�
�
 N*
p�� N*	q�U N*
r�� N*sxx N*
t�
�
 N*
u�b �*
v�
�
 2*	w�0 >*
x�� N*
y�
�
 (*z�
�
 �*	{ �
*
|�� *	}3� N*	~�
o N*	� #*
�
�E #*�
� �*�
4�
 �*�
�
� �*�
�
�
 �
*�
��
 �
*�
� �
*�
�
�
 �
*�
�
 �
*�
� �
*
�
.� K*
�
$� K*�
�
� N*
�
;�
 N*�
�
�
 N*�
�� N*�
�� N*�
�
�
 N*
�
�q N*
�
l�
 N*�
�� N*
�
I�
 N*�
�� N*
�
V�
 N*
�
�c N*�
�
� N*
�
�
 N*�
�� N*
�
�e J*�
�
�
 N*�
�� �
*�
��
 �*�
�
� �*�
��
 �*�
� �
*�
�% �*�
�
�
 N*
�
� N*�
�� N*�
�
� N*	�
ff N*�
�� �*�
��
 2*�
��
 >*	�
w N*�
��
 �*�
�
�
 �*�
�
�
 *
�
�
/ *
�
�T N*�
�
�
 N*�
\� �*�
�� �*�
�
& �*
�
LW �
*
�
h: �*
�
Z� N*
�
M�
 N*�
�� N*�
�� N*	�
j' N*	�
 222<&mio::net::tcp::TcpStream as std::io::Read>::read2H_ZN3std6thread5local4lazy21LazyKeyInner$LT$T$GT$3get17h1184db2f8891bf4eE23tokio::net::tcp::listener::TcpListener::poll_accept2B_ZN3mio3sys4unix8awakener4pipe8Awakener6wakeup17h43200e4a3debbaadE2@/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/rt.rs2cache_bin_alloc_easy2�
/home/tekjar/Workspace/rumqtt/target/release/build/jemalloc-sys-b530a4442beadd74/out/build/../jemalloc/include/jemalloc/internal/cache_bin.h2v_ZN83_$LT$alloc..boxed..Box$LT$F$GT$$u20$as$u20$core..ops..function..FnOnce$LT$A$GT$$GT$9call_once17hf207c3654ee300a0E2std::rt::lang_start_internal24_ZN14event_listener5Event6listen17h6d2077d8c010153cE2	isdalloct2@_ZN3std6thread5local17LocalKey$LT$T$GT$4with17h3ba5eae7d8300283E2�
tokio::runtime::basic_scheduler::<impl tokio::runtime::task::Schedule for alloc::sync::Arc<tokio::runtime::basic_scheduler::Shared>>::schedule2$async_channel::Receiver<T>::try_recv26rumqttlog::router::router::Router::handle_acks_request2G_ZN5alloc7raw_vec19RawVec$LT$T$C$A$GT$11allocate_in17h73b6a8e7b2c8bb0cE2I/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libcore/intrinsics.rs28std::panicking::update_panic_count::PANIC_COUNT::__getit2I<std::collections::hash::map::DefaultHasher as core::hash::Hasher>::write2)std::thread::local::LocalKey<T>::try_with2L_ZN5tokio2io6driver6Driver4turn17hf488afaa958caf61E.llvm.647322449668808947323<&mut S as futures_core::stream::Stream>::poll_next2B/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/time.rs26<tokio::io::driver::Driver as tokio::park::Park>::park2?_ZN3std10sys_common3net11TcpListener6accept17h735eb04fed6003b9E2u/home/tekjar/Workspace/rumqtt/target/release/build/jemalloc-sys-b530a4442beadd74/out/build/../jemalloc/src/jemalloc.c2librumqttd::router2S<tokio::net::tcp::stream::TcpStream as tokio::io::async_read::AsyncRead>::poll_read2C/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/panic.rs21std::sys::unix::thread::Thread::new::thread_start2*concurrent_queue::bounded::Bounded<T>::pop2e_ZN71_$LT$event_listener..EventListener$u20$as$u20$core..ops..drop..Drop$GT$4drop17h648c090c68249ce6E2/_ZN5alloc5slice4hack6to_vec17h90096f43c3d51555E2�
_ZN5tokio7runtime15basic_scheduler124_$LT$impl$u20$tokio..runtime..task..Schedule$u20$for$u20$alloc..sync..Arc$LT$tokio..runtime..basic_scheduler..Shared$GT$$GT$8schedule17h15c6132582be5ce8E2E/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/liballoc/alloc.rs2std::panicking::panicking27_ZN3std3net3tcp11TcpListener6accept17h00c9f951cc770138E2(_ZN3std3sys4unix3cvt17h0f5a0938f3657cb0E2F_ZN9hashbrown3map24HashMap$LT$K$C$V$C$S$GT$6remove17hdefc07d084859ec3E2�
/home/tekjar/Workspace/rumqtt/target/release/build/jemalloc-sys-b530a4442beadd74/out/build/../jemalloc/include/jemalloc/internal/tcache_inlines.h2O_ZN9rumqttlog6router6router6Router23fresh_acks_notification17h7af978c6fd855c8fE2
_rjem_mallocx2l_ZN78_$LT$event_listener..EventListener$u20$as$u20$core..future..future..Future$GT$4poll17h19cbfb78a53e7f5aE2event_listener::List::notify2H/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libcore/slice/mod.rs2"std::panicking::update_panic_count2Y_ZN60_$LT$std..time..Instant$u20$as$u20$core..ops..arith..Sub$GT$3sub17hdf250b9c6df84a4aE2Q_ZN51_$LT$$RF$std..fs..File$u20$as$u20$std..io..Read$GT$4read17h07cc5e1a75c2213fE2 std::sys::unix::time::inner::now2I/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/sys/unix/fs.rs2-bytes::bytes_mut::BytesMut::extend_from_slice2-alloc::raw_vec::RawVec<T,A>::with_capacity_in28tokio::io::poll_evented::PollEvented<E>::poll_read_ready2B_ZN5alloc7raw_vec19RawVec$LT$T$C$A$GT$7reserve17h184af5059befa139E2;<tokio::time::driver::Driver<T> as tokio::park::Park>::park2)std::sys::unix::time::inner::Instant::now2M_ZN5tokio7runtime4task7harness20Harness$LT$T$C$S$GT$4poll17h0b57856926bf4614E2^_ZN63_$LT$$RF$std..net..tcp..TcpStream$u20$as$u20$std..io..Write$GT$5write17h5df5cd220ee819c1E2mqtt4bytes::read::mqtt_read27rumqttlog::router::router::Router::register_acks_waiter2hashbrown::map::make_hash2@/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/fs.rs2std::time::Instant::now2 std::rt::lang_start::{{closure}}2=_ZN5tokio7runtime4task5waker11wake_by_val17h25470315d8ce1eccE2\_ZN62_$LT$$RF$mio..net..tcp..TcpStream$u20$as$u20$std..io..Read$GT$4read17hf264371131e3c241E2S_ZN5tokio4sync4task12atomic_waker11AtomicWaker15register_by_ref17h5e8f6ba95cca3cf6E23_ZN14event_listener4List6notify17hdad417bd4c1c71f3E2]_ZN62_$LT$alloc..alloc..Global$u20$as$u20$core..alloc..AllocRef$GT$5alloc17hd6a15d543b55194dE2q_ZN74_$LT$tokio..time..driver..Driver$LT$T$GT$$u20$as$u20$tokio..park..Park$GT$12park_timeout17hca9c6353cb62c9d8E2E/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/liballoc/boxed.rs2H_ZN5tokio6macros10scoped_tls18ScopedKey$LT$T$GT$3set17hb5bb07b691f71113E2+tokio::runtime::task::state::State::ref_dec2H/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libcore/task/wake.rs2G/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/panicking.rs2&std::sys_common::net::TcpStream::write23tokio::net::tcp::stream::TcpStream::poll_write_priv2Unknown2_ZN97_$LT$core..future..from_generator..GenFuture$LT$T$GT$$u20$as$u20$core..future..future..Future$GT$4poll17h2b6f0a19ee18db07E2arena_slab_reg_alloc2(core::slice::<impl [T]>::copy_from_slice2alloc::slice::hack::to_vec2(rumqttlog::router::router::Router::reply2<_ZN5tokio7runtime4task5waker10drop_waker17hc067fa8f3f37ead1E2=_ZN5tokio4time5wheel14Wheel$LT$T$GT$4poll17h04f8d338a2b7b830E2A<tokio::time::delay::Delay as core::future::future::Future>::poll2;_ZN3std10sys_common3net9TcpStream5write17h591e308f62f055d0E29rumqttlog::router::router::Router::handle_connection_data24tokio::time::driver::registration::Registration::new24<&mio::net::tcp::TcpStream as std::io::Write>::write2 alloc::slice::<impl [T]>::to_vec2std::sys::unix::os::errno2_ZN97_$LT$core..future..from_generator..GenFuture$LT$T$GT$$u20$as$u20$core..future..future..Future$GT$4poll17h86f91722bdd564daE26tokio::io::registration::Registration::poll_read_ready2:_ZN3std10sys_common3net9TcpStream4read17hbf75dd1b279be848E2tokio::runtime::context::enter2,std::sys::unix::net::Socket::recv_with_flags25_ZN3std3sys4unix2fd8FileDesc4read17had690875e4ebf8e6E2N_ZN3mio4poll19enqueue_with_wakeup17h6a3b63b7118bad2cE.llvm.85790931899926534002,tokio::macros::scoped_tls::ScopedKey<T>::set23_ZN4core4task4wake8RawWaker3new17hca817676d47314a9E2write2%alloc::vec::Vec<T>::extend_from_slice24<&std::net::tcp::TcpStream as std::io::Write>::write2)_ZN3std9panicking3try17h78f4c77016541848E2&hashbrown::map::HashMap<K,V,S>::remove2_start26rumqttlog::router::router::Router::append_to_commitlog2O<std::panic::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once2O_ZN3std10sys_common9backtrace28__rust_begin_short_backtrace17h13e3bdffb8914c53E2A_ZN10mqtt4bytes7packets7connack7ConnAck5write17h5b05ac66f9875ba4E2_ZN97_$LT$core..future..from_generator..GenFuture$LT$T$GT$$u20$as$u20$core..future..future..Future$GT$4poll17h6d88cd2d0e5dda03E2C_ZN9rumqttlog6router9commitlog9CommitLog6append17he2b575889196daf7E2L_ZN9rumqttlog6router6router6Router20register_acks_waiter17h57b53219db4bd13dE24_ZN3std3sys4unix3net6Socket4read17he48dc05ffc3f1028E2_rjem_je_arena_ralloc22librumqttd::Connector::new_connection::{{closure}}2
_rjem_rallocx20mio::sys::unix::awakener::pipe::Awakener::wakeup2__pthread_enable_asynccancel2]_ZN63_$LT$tokio..io..driver..Driver$u20$as$u20$tokio..park..Park$GT$4park17h589239e50c8637c0E2I_ZN5tokio4time6driver12registration12Registration3new17h61393518f4691ce4E2s/home/tekjar/Workspace/rumqtt/target/release/build/jemalloc-sys-b530a4442beadd74/out/build/../jemalloc/src/tcache.c2G_ZN16concurrent_queue7bounded16Bounded$LT$T$GT$3pop17h430a0a344d3ccea8E21tokio::runtime::task::harness::Harness<T,S>::poll2main2alloc::alloc::alloc2K/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/sys/unix/weak.rs2=_ZN4core10intrinsics19copy_nonoverlapping17h14b5eb00ccf66143E2+_ZN3mio4poll4Poll5poll117h3c49e7278afaa723E2L_ZN5alloc7raw_vec19RawVec$LT$T$C$A$GT$16with_capacity_in17hc3ac6af6810327dcE22_ZN3std3sys4unix2fs4File5write17h0b071787e520d949E2?_ZN3std6thread5local4fast12Key$LT$T$GT$3get17h556622e4a2660a8eE2a_ZN65_$LT$tokio..io..driver..Handle$u20$as$u20$tokio..park..Unpark$GT$6unpark17h534a2a2bcd551819E2E/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libcore/option.rs2 tokio::util::wake::clone_arc_raw2start_thread2T_ZN3std3sys4unix3net6Socket6accept28_$u7b$$u7b$closure$u7d$$u7d$17h92122d56943a22d0E2%std::thread::local::LocalKey<T>::with2Z_ZN4core3ops8function6FnOnce40call_once$u7b$$u7b$vtable.shim$u7d$$u7d$17h46f6553d201de33fE2@_ZN3std6thread5local17LocalKey$LT$T$GT$4with17h88d1758e1c351fb9E2/_ZN4core3ptr13drop_in_place17hfb57194a10ecb0f1E2,mqtt4bytes::packets::connack::ConnAck::write2N_ZN3std9panicking18update_panic_count11PANIC_COUNT7__getit17h6e621ba688da1e9aE2S_ZN52_$LT$$RF$std..fs..File$u20$as$u20$std..io..Write$GT$5write17h5c9234243249670aE2a_ZN62_$LT$$RF$mut$u20$S$u20$as$u20$futures_core..stream..Stream$GT$9poll_next17h8bdbdf000eaf5227E2_ZN97_$LT$core..future..from_generator..GenFuture$LT$T$GT$$u20$as$u20$core..future..future..Future$GT$4poll17hf30116b275f7f5eeE2G_ZN5tokio3net3tcp6stream9TcpStream15poll_write_priv17h138f5795c2748147E2__lll_lock_wait21_ZN3std3sys4unix2fs4File4read17hd96f002ffc33126dE2�
/home/tekjar/Workspace/rumqtt/target/release/build/jemalloc-sys-b530a4442beadd74/out/build/../jemalloc/include/jemalloc/internal/jemalloc_internal_inlines_c.h23_ZN5tokio7runtime7context5enter17hfffdcf77a371e020E2std::panic::catch_unwind2&mio::net::tcp::TcpListener::accept_std2><tokio::io::driver::Driver as tokio::park::Park>::park_timeout2F_ZN5tokio3net3tcp6stream9TcpStream14poll_read_priv17h575332e13323b557E2�
_ZN101_$LT$std..panic..AssertUnwindSafe$LT$F$GT$$u20$as$u20$core..ops..function..FnOnce$LT$$LP$$RP$$GT$$GT$9call_once17h88094c23d1d33fefE2E_ZN9rumqttlog6router10watermarks10Watermarks4acks17hb630412d97e3a29cE2__recv2z_ZN87_$LT$tokio..net..tcp..stream..TcpStream$u20$as$u20$tokio..io..async_read..AsyncRead$GT$9poll_read17h4f1b9f525e3fbaf5E26_ZN5tokio4util4wake13clone_arc_raw17h48f7ecb10b5a32ccE2�
_ZN5tokio7runtime15basic_scheduler124_$LT$impl$u20$tokio..runtime..task..Schedule$u20$for$u20$alloc..sync..Arc$LT$tokio..runtime..basic_scheduler..Shared$GT$$GT$8schedule28_$u7b$$u7b$closure$u7d$$u7d$17h02de6dbabfaa9f30E.llvm.18348564995793839002H_ZN5tokio6macros10scoped_tls18ScopedKey$LT$T$GT$3set17h5a6e2b4231134e12E2T<alloc::vec::Vec<T> as alloc::vec::SpecExtend<&T,core::slice::Iter<T>>>::spec_extend2C<alloc::boxed::Box<F> as core::ops::function::FnOnce<A>>::call_once2R_ZN4core5slice29_$LT$impl$u20$$u5b$T$u5d$$GT$15copy_from_slice17h0c1f1f14285328f2E22_ZN10mqtt4bytes4read9mqtt_read17h2e3273231261089aE24<alloc::string::String as core::clone::Clone>::clone2M/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/sys/unix/thread.rs2v_ZN83_$LT$alloc..boxed..Box$LT$F$GT$$u20$as$u20$core..ops..function..FnOnce$LT$A$GT$$GT$9call_once17h66e0c6190e34816bE2B_ZN13async_channel17Receiver$LT$T$GT$8try_recv17h52b4211ed1ee84c3E2D_ZN3std3sys4unix6thread6Thread3new12thread_start17h30687bc0b1c3cd55E20_ZN10librumqttd6Broker5start17h6f9310c76060a3baE2
arena_sdalloc23_ZN3std3sys4unix4time5inner3now17h3b5b8f6b1662e01aE21_ZN3std9panicking3try7do_call17h3559ee6be71549e2E2J/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/thread/local.rs2L_ZN3std3sys4unix4time5inner7Instant19checked_sub_instant17h8872951e65977a96E2L/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/sys_common/net.rs2imalloc_body2&mio::poll::SetReadiness::set_readiness2$_ZN7rumqttd4main17hd9abdb97ff904970E2std::sys::unix::cvt25core::ops::function::FnOnce::call_once{{vtable.shim}}2h_ZN74_$LT$tokio..time..delay..Delay$u20$as$u20$core..future..future..Future$GT$4poll17h1a698ea31d9b6593E2clone2[_ZN60_$LT$alloc..string..String$u20$as$u20$core..clone..Clone$GT$5clone17h0be5b128f194f6dcE2__GI___pthread_mutex_lock2%std::sys_common::net::TcpStream::read25_ZN9rumqttlog8volatile3Log6append17h75bf8e10d26b05eaE2K_ZN9rumqttlog6router6router6Router19append_to_commitlog17h3436f6d09dda0a07E2G_ZN16concurrent_queue7bounded16Bounded$LT$T$GT$3pop17h99d8c6b1290fe288E2read2=tokio::sync::task::atomic_waker::AtomicWaker::register_by_ref2B_ZN5tokio7runtime15basic_scheduler7Spawner3pop17h7696f74be3b248d6E2Q_ZN3std2rt19lang_start_internal28_$u7b$$u7b$closure$u7d$$u7d$17h44dc84346eeba462E2B_ZN5alloc3vec12Vec$LT$T$GT$17extend_from_slice17h553eb1ed4270ed71E2(alloc::raw_vec::RawVec<T>::with_capacity2syscall2'mio::sys::unix::epoll::Selector::select2tcache_dalloc_small2__GI___pthread_mutex_unlock2!alloc::vec::Vec<T>::with_capacity2mio::poll::Poll::poll2%std::thread::local::fast::Key<T>::get2R<core::future::from_generator::GenFuture<T> as core::future::future::Future>::poll2/rumqttlog::router::watermarks::Watermarks::acks2�
tokio::runtime::basic_scheduler::<impl tokio::runtime::task::Schedule for alloc::sync::Arc<tokio::runtime::basic_scheduler::Shared>>::schedule::{{closure}}29std::sys::unix::time::inner::Instant::checked_sub_instant2"std::time::Instant::duration_since2std::sys::unix::fs::File::read2std::sys::unix::cvt_r2N_ZN9rumqttlog6router6router6Router22handle_connection_data17he0d8128234035b92E2tokio::io::driver::Driver::turn28_ZN3std4time7Instant14duration_since17h4d72b6014220b740E2><event_listener::EventListener as core::ops::drop::Drop>::drop22tokio::net::tcp::stream::TcpStream::poll_read_priv2<_ZN3mio3net3tcp11TcpListener10accept_std17h0d5ef9ac5d4ae24bE2:rumqttlog::router::router::Router::fresh_acks_notification2K_ZN5tokio4sync4task12atomic_waker11AtomicWaker8register17h1f528daeacc216f1E2'tokio::time::driver::Driver<T>::process2C/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/liballoc/vec.rs2_rjem_je_arena_ralloc_no_move2imalloc_no_sample2I<tokio::future::poll_fn::PollFn<F> as core::future::future::Future>::poll2_rjem_sdallocx2__clock_gettime2_ZN97_$LT$core..future..from_generator..GenFuture$LT$T$GT$$u20$as$u20$core..future..future..Future$GT$4poll17hca80e59e2a0a7415E2>_ZN5alloc3vec12Vec$LT$T$GT$13with_capacity17h1121cb43f957d303E2M_ZN5tokio2io12registration12Registration15poll_read_ready17h5ae8ef70610ede1aE2>_ZN5tokio7runtime4task5state5State7ref_dec17hc06aa0f40cd2fe43E2@_ZN3std3sys4unix4time8Timespec12sub_timespec17h54d2cb81ef3953e1E2event_listener::Inner::lock2event_listener::Event::listen2
bitmap_sfu2@_ZN13async_channel15Sender$LT$T$GT$8try_send17hac9fe72e83bf7950E2__libc_start_main2tcache_alloc_small2I_ZN5alloc5slice29_$LT$impl$u20$$u5b$T$u5d$$GT$6to_vec17hc8479785c3a2ab6eE2iralloct2std::panicking::try::do_call2E<event_listener::EventListener as core::future::future::Future>::poll2_ZN97_$LT$core..future..from_generator..GenFuture$LT$T$GT$$u20$as$u20$core..future..future..Future$GT$4poll17h90aa7fd45e3249a0E2;_ZN4core6option15Option$LT$T$GT$6as_ref17hf911afd5194c992eE2 rumqttlog::volatile::Log::append26_ZN3std3sys4unix3net6Socket6accept17h975faf0c2ee809f6E22<std::time::Instant as core::ops::arith::Sub>::sub2h_ZN74_$LT$tokio..time..driver..Driver$LT$T$GT$$u20$as$u20$tokio..park..Park$GT$4park17h821ed1dc19d6a2f6E2core::ptr::drop_in_place2f_ZN63_$LT$tokio..io..driver..Driver$u20$as$u20$tokio..park..Park$GT$12park_timeout17h23c4bf96250742e2E2:tokio::runtime::task::state::State::transition_to_notified2(tokio::runtime::task::waker::wake_by_val2,_ZN3std4time7Instant3now17h28c1cd9b08b0f12aE26tokio::sync::task::atomic_waker::AtomicWaker::register2std::panicking::try2I/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/sys/unix/os.rs2F/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/io/error.rs2mio::poll::Poll::poll126<alloc::alloc::Global as core::alloc::AllocRef>::alloc2C_ZN3mio3sys4unix8awakener4pipe8Awakener7cleanup17h707547f673ae73c8E2I/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/sys/unix/fd.rs2)std::sys_common::net::TcpListener::accept29_ZN3std2io5error5Error13last_os_error17hb86cd9f13363d662E2~_ZN89_$LT$tokio..net..tcp..stream..TcpStream$u20$as$u20$tokio..io..async_write..AsyncWrite$GT$10poll_write17hf400f65bc85802dfE2arena_malloc2@_ZN13async_channel15Sender$LT$T$GT$8try_send17hc16182ee6270ddf1E2_ZN97_$LT$core..future..from_generator..GenFuture$LT$T$GT$$u20$as$u20$core..future..future..Future$GT$4poll17h64dfa0aec8597e49E2_ZN97_$LT$core..future..from_generator..GenFuture$LT$T$GT$$u20$as$u20$core..future..future..Future$GT$4poll17h613a3634c584e5cbE2J/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/sys/unix/net.rs2"async_channel::Sender<T>::try_send2C_ZN5bytes9bytes_mut8BytesMut17extend_from_slice17h9b478f8832fa222cE29_ZN3std9panicking18update_panic_count17h8f00b760093dd889E2$std::io::error::Error::last_os_error2)std::rt::lang_start_internal::{{closure}}2�
_ZN81_$LT$std..collections..hash..map..DefaultHasher$u20$as$u20$core..hash..Hasher$GT$5write17h073626262ec373a4E.llvm.1754506321431339618726rumqttlog::tracker::Tracker::update_watermarks_tracker2D_ZN3std6thread5local17LocalKey$LT$T$GT$8try_with17h77ac69ec46b76a9dE2>_ZN3std3sys4unix3net6Socket6accept7accept417h7b01ae241944ff57E2/_ZN3std5panic12catch_unwind17hfe46f382761b3d41E2/_ZN9hashbrown3map9make_hash17h156a26427ed71697E2@_ZN3std3sys4unix3net6Socket15recv_with_flags17h50a2945657dae06eE2
rumqttd::main2$alloc::raw_vec::RawVec<T,A>::reserve2/rumqttlog::router::commitlog::CommitLog::append2*_ZN3mio4poll4Poll4poll17h07fcbbc55a924ef0E2S_ZN5tokio4time6driver12registration12Registration12poll_elapsed17h73aa2ffa42536e98E2�
/home/tekjar/Workspace/rumqtt/target/release/build/jemalloc-sys-b530a4442beadd74/out/build/../jemalloc/include/jemalloc/internal/bit_util.h2core::option::Option<T>::as_ref2sz_index2size_lookup2
epoll_wait2=tokio::time::driver::registration::Registration::poll_elapsed2H_ZN5tokio3net3tcp8listener11TcpListener11poll_accept17he1b781a895cbd157E2__send2=_ZN3mio4poll12SetReadiness13set_readiness17hb843f82b04ec8d2fE2C_ZN3mio4poll19ReadinessQueueInner12dequeue_node17h6c2e21131ce451dcE2;_ZN3std3sys4unix4time5inner7Instant3now17hd8fe0cc47fce0947E2-_ZN3std3sys4unix2os5errno17h62ab6047424694a9E2:<tokio::io::driver::Handle as tokio::park::Unpark>::unpark21mio::sys::unix::awakener::pipe::Awakener::cleanup2G/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/liballoc/raw_vec.rs20std::sys::unix::net::Socket::accept::{{closure}}2H_ZN16concurrent_queue7bounded16Bounded$LT$T$GT$4push17h5adaea6cdd1d9f17E2N_ZN5tokio7runtime4task5state5State22transition_to_notified17h8a3f1d571ccfcd56E2"tokio::time::wheel::Wheel<T>::poll2 _rjem_je_arena_tcache_fill_small2!std::sys::unix::net::Socket::read2J/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/sys/unix/mod.rs2J<tokio::runtime::basic_scheduler::Shared as tokio::util::wake::Wake>::wake2K_ZN9rumqttlog6router6router6Router19handle_acks_request17h061ccf1f2350b67aE2H_ZN3std2rt10lang_start28_$u7b$$u7b$closure$u7d$$u7d$17h7890cf4f1b943649E2^_ZN63_$LT$alloc..vec..Vec$LT$T$GT$$u20$as$u20$core..clone..Clone$GT$5clone17h20caaf7ded9fd670E23_ZN3std2rt19lang_start_internal17he05790f0cb2000dfE22<&std::net::tcp::TcpStream as std::io::Read>::read2=_ZN5tokio7runtime4task5waker11clone_waker17h26d451156d7591c1E2r/home/tekjar/Workspace/rumqtt/target/release/build/jemalloc-sys-b530a4442beadd74/out/build/../jemalloc/src/arena.c2*_ZN10librumqttd6router17hf75e1cbced378535E2,std::sys::unix::net::Socket::accept::accept42mio::poll::enqueue_with_wakeup26_ZN9rumqttlog7tracker7Tracker4next17h1df03d43163856c7E2,std::sys::unix::time::Timespec::sub_timespec2U_ZN5tokio2io12poll_evented20PollEvented$LT$E$GT$15poll_read_ready17h2414279da24b1e5aE2_ZN97_$LT$core..future..from_generator..GenFuture$LT$T$GT$$u20$as$u20$core..future..future..Future$GT$4poll17h8b608cdb550730ccE22_ZN14event_listener5Inner4lock17h449e63cca45ed4e8E2std::sys::unix::fs::File::write2librumqttd::Broker::start2�
/home/tekjar/Workspace/rumqtt/target/release/build/jemalloc-sys-b530a4442beadd74/out/build/../jemalloc/include/jemalloc/internal/bitmap.h2E/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/liballoc/slice.rs2)_ZN5alloc5alloc5alloc17h7b58ed5939df216dE2"std::net::tcp::TcpListener::accept2)<&std::fs::File as std::io::Write>::write27_ZN3mio9event_imp5Ready10from_usize17h9366587f3cfb18fcE2(alloc::raw_vec::RawVec<T,A>::allocate_in2[_ZN10librumqttd9Connector14new_connection28_$u7b$$u7b$closure$u7d$$u7d$17h9b06595b01c07885E2v_ZN88_$LT$tokio..future..poll_fn..PollFn$LT$F$GT$$u20$as$u20$core..future..future..Future$GT$4poll17hced6e5d903e8aec4E2B_ZN5tokio4time6driver15Driver$LT$T$GT$7process17had18e92221143909E2
sz_index2size2%core::intrinsics::copy_nonoverlapping2-tokio::runtime::basic_scheduler::Spawner::pop2>_ZN5tokio7runtime4task5state5State7ref_inc17h3cb97d0c48a1fe5bE2"std::sys::unix::fd::FileDesc::read2 _rjem_je_tcache_alloc_small_hard2isfree2!rumqttlog::tracker::Tracker::next23_ZN5tokio7runtime7context5enter17h2ed81f26f715c39cE2
sz_size2index21<alloc::vec::Vec<T> as core::clone::Clone>::clone2E_ZN5alloc7raw_vec15RawVec$LT$T$GT$13with_capacity17hefedde2ee34ff7ebE2/_ZN3std9panicking9panicking17ha252f8a903716c2fE2*_ZN3std3sys4unix5cvt_r17h759d2715a7f79aa6E2@_ZN3std6thread5local17LocalKey$LT$T$GT$4with17h662d7adc26e332adE26_ZN3std3sys4unix2fd8FileDesc5write17h660045098be4384bE2^_ZN63_$LT$$RF$mio..net..tcp..TcpStream$u20$as$u20$std..io..Write$GT$5write17he8085b33121f3093E29tokio::runtime::task::state::State::transition_to_running2F/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/liballoc/string.rs2core::task::wake::RawWaker::new2E_ZN5tokio2io10async_read9AsyncRead13poll_read_buf17h26cb2467b492b686E2+concurrent_queue::bounded::Bounded<T>::push2	iallocztm2\_ZN62_$LT$$RF$std..net..tcp..TcpStream$u20$as$u20$std..io..Read$GT$4read17h7f4907b367b47843E2'<&std::fs::File as std::io::Read>::read2(tokio::runtime::task::waker::clone_waker2:_ZN3mio3sys4unix5epoll8Selector6select17h6486fe021fb4cb54E2.std::thread::local::lazy::LazyKeyInner<T>::get2,mio::poll::ReadinessQueueInner::dequeue_node2!mio::event_imp::Ready::from_usize2q_ZN83_$LT$tokio..runtime..basic_scheduler..Shared$u20$as$u20$tokio..util..wake..Wake$GT$4wake17h0f6aa68d0c76e71bE2ffs_lu2M_ZN5tokio7runtime4task5state5State21transition_to_running17h5a85865c1bf34bc0E2C<tokio::time::driver::Driver<T> as tokio::park::Park>::park_timeout2#std::sys::unix::fd::FileDesc::write2<_ZN9rumqttlog6router6router6Router5reply17h70cfe6fa2570374bE2#std::sys::unix::net::Socket::accept28std::sys_common::backtrace::__rust_begin_short_backtrace2K/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/sys/unix/time.rs2L_ZN9rumqttlog7tracker7Tracker25update_watermarks_tracker17ha857c9eabfb7633eE2E/rustc/c7087fe00d2ba919df1d813c040a5d47e43b0fe7/src/libstd/net/tcp.rs21tokio::io::registration::Registration::poll_ready2+tokio::runtime::task::state::State::ref_inc2'tokio::runtime::task::waker::drop_waker2a_ZN5tokio2io12registration12Registration10poll_ready17h45ca9e04ec371baaE.llvm.64732244966880894732�
_ZN109_$LT$alloc..vec..Vec$LT$T$GT$$u20$as$u20$alloc..vec..SpecExtend$LT$$RF$T$C$core..slice..Iter$LT$T$GT$$GT$$GT$11spec_extend17h32f0aeef16ab407bE2�
/home/tekjar/Workspace/rumqtt/target/release/build/jemalloc-sys-b530a4442beadd74/out/build/../jemalloc/include/jemalloc/internal/sz.h2�
/home/tekjar/Workspace/rumqtt/target/release/build/jemalloc-sys-b530a4442beadd74/out/build/../jemalloc/include/jemalloc/internal/arena_inlines_b.h2V<tokio::net::tcp::stream::TcpStream as tokio::io::async_write::AsyncWrite>::poll_write2imalloc2sz_size2index_compute2_rjem_je_tcache_event_hard2/tokio::io::async_read::AsyncRead::poll_read_buf2cpu2count