houjie created TUBEMQ-368:
-----------------------------
Summary: 在调用tubemq::TubeMQConsumer shutdown() 时, 会有小概率直接core掉
Key: TUBEMQ-368
URL: https://issues.apache.org/jira/browse/TUBEMQ-368
Project: Apache TubeMQ
Issue Type: Bug
Components: Client
Environment: linux
Reporter: houjie
在调用tubemq::TubeMQConsumer shutdown() 时, 发现会有小概率直接core掉
在附件中上传了现场
{quote}#0 0x00002b939d73cc8e in __memcmp_sse4_1 () from /lib64/libc.so.6
#1 0x00002b939ce788b3 in std::string::compare(std::string const&) const () from
/lib64/libstdc++.so.6
#2 0x0000000000528c2e in operator< <char, std::char_traits<char>,
std::allocator<char> > (__rhs="", __lhs="")
at /usr/include/c++/4.8.2/bits/basic_string.h:2571
#3 operator() (this=<optimized out>, __y="", __x="") at
/usr/include/c++/4.8.2/bits/stl_function.h:235
#4 std::_Rb_tree<std::string, std::pair<std::string const,
tubemq::PartitionExt>, std::_Select1st<std::pair<std::string const,
tubemq::PartitionExt> >, std::less<std::string>,
std::allocator<std::pair<std::string const, tubemq::PartitionExt> >
>::_M_lower_bound (
__x=0x2b93f00250f0, __y=0x2b93f0011f90, __y@entry=0x4a9d148, __k="",
this=0x4a9d140) at /usr/include/c++/4.8.2/bits/stl_tree.h:1141
#5 0x000000000052d65a in std::_Rb_tree<std::string, std::pair<std::string
const, tubemq::PartitionExt>, std::_Select1st<std::pair<std::string const,
tubemq::PartitionExt> >, std::less<std::string>,
std::allocator<std::pair<std::string const, tubemq::PartitionExt> > >::find
(this=this@entry=0x4a9d140, __k="") at
/usr/include/c++/4.8.2/bits/stl_tree.h:1792
#6 0x0000000000529a4d in find (__x="", this=0x4a9d140) at
/usr/include/c++/4.8.2/bits/stl_map.h:822
Python Exception <type 'exceptions.IndexError'> list index out of range:
#7 tubemq::RmtDataCacheCsm::GetPartitionByBroker (this=this@entry=0x4a9cf90,
broker_info=..., partition_list=empty std::list)
at /root/access_platform_group/TubeMQ-Client-Cpp/src/rmt_data_cache.cc:334
#8 0x000000000050b57d in tubemq::BaseConsumer::reSetBrokerHBTimer
(this=0x4a9cd90, broker=...)
at /root/access_platform_group/TubeMQ-Client-Cpp/src/baseconsumer.cc:1500
#9 0x000000000050b900 in tubemq::BaseConsumer::__lambda14::operator()
(__closure=0x2b93dc030070, error=..., response_context=...)
at /root/access_platform_group/TubeMQ-Client-Cpp/src/baseconsumer.cc:801
#10 0x000000000050be10 in std::_Function_handler<void(tubemq::ErrorCode, const
tubemq::ResponseContext&),
tubemq::BaseConsumer::processHeartBeat2Broker(tubemq::NodeInfo)::__lambda14>::_M_invoke(const
std::_Any_data &, tubemq::ErrorCode, const tubemq::ResponseContext &) (
__functor=..., __args#0=..., __args#1=...) at
/usr/include/c++/4.8.2/functional:2071
#11 0x0000000000538318 in operator() (__args#1=...,
__args#0=<error reading variable: access outside bounds of object referenced
via synthetic pointer>, this=0x2b93a7133810)
at /usr/include/c++/4.8.2/functional:2471
#12 tubemq::Promise<tubemq::ResponseContext>::callbackAndNotify
(this=this@entry=0x2b93d4001670)
at /root/access_platform_group/TubeMQ-Client-Cpp/src/future.h:130
#13 0x000000000053201d in SetValue (value=..., this=0x2b93d4001670) at
/root/access_platform_group/TubeMQ-Client-Cpp/src/future.h:102
#14 tubemq::ClientConnection::requestCallback (this=this@entry=0x2b93d0915898,
request_id=46829, err=err@entry=0x0,
check_out=check_out@entry=0x2b93a7133930) at
/root/access_platform_group/TubeMQ-Client-Cpp/src/client_connection.cc:248
#15 0x0000000000532531 in tubemq::ClientConnection::checkPackageDone
(this=0x2b93d0915898)
at /root/access_platform_group/TubeMQ-Client-Cpp/src/client_connection.cc:221
#16 0x0000000000532c05 in tubemq::ClientConnection::__lambda7::operator()
(ec=..., len=<optimized out>, __closure=0x2b93a7133b10)
at /root/access_platform_group/TubeMQ-Client-Cpp/src/client_connection.cc:178
#17 0x00000000005351d8 in operator() (this=0x2b93a7133b10)
at
/root/access_platform_group/TubeMQ-Client-Cpp/build/third_party/include/asio/detail/bind_handler.hpp:181
#18
asio_handler_invoke<asio::detail::binder2<tubemq::ClientConnection::asyncRead()::__lambda7,
std::error_code, long unsigned int> > (
function=...) at
/root/access_platform_group/TubeMQ-Client-Cpp/build/third_party/include/asio/handler_invoke_hook.hpp:87
#19
invoke<asio::detail::binder2<tubemq::ClientConnection::asyncRead()::__lambda7,
std::error_code, long unsigned int>,
tubemq::ClientConnection::asyncRead()::__lambda7> (context=..., function=...)
at
/root/access_platform_group/TubeMQ-Client-Cpp/build/third_party/include/asio/detail/handler_invoke_helpers.hpp:54
#20
complete<asio::detail::binder2<tubemq::ClientConnection::asyncRead()::__lambda7,
std::error_code, long unsigned int> > (
handler=..., function=..., this=0x2b93a7133ae0)
at
/root/access_platform_group/TubeMQ-Client-Cpp/build/third_party/include/asio/detail/handler_work.hpp:424
#21 asio::detail::reactive_socket_recv_op<asio::mutable_buffers_1,
tubemq::ClientConnection::asyncRead()::__lambda7,
asio::execution::any_executor<asio::execution::context_as_t<asio::execution_context&>,
asio::execution::detail::blocking::never_t<0>,
asio::execution::prefer_only<asio::execution::detail::blocking::possibly_t<0>
>,
asio::execution::prefer_only<asio::execution::detail::outstanding_work::tracked_t<0>
>,
asio::execution::prefer_only<asio::execution::detail::outstanding_work::untracked_t<0>
>,
asio::execution::prefer_only<asio::execution::detail::relationship::fork_t<0>
>,
asio::execution::prefer_only<asio::execution::detail::relationship::continuation_t<0>
> > >::do_complete(void *, asio::detail::operation *, const asio::error_code
&, std::size_t) (owner=0x2b93d0026c30, base=<optimized out>)
at
/root/access_platform_group/TubeMQ-Client-Cpp/build/third_party/include/asio/detail/reactive_socket_recv_op.hpp:144
#22 0x0000000000501c19 in complete (bytes_transferred=<optimized out>, ec=...,
owner=0x2b93d0026c30, this=<optimized out>)
at
/root/access_platform_group/TubeMQ-Client-Cpp/build/third_party/include/asio/detail/scheduler_operation.hpp:39
#23 asio::detail::scheduler::do_run_one (this=this@entry=0x2b93d0026c30,
lock=..., this_thread=..., ec=...)
at
/root/access_platform_group/TubeMQ-Client-Cpp/build/third_party/include/asio/detail/impl/scheduler.ipp:480
#24 0x0000000000502401 in asio::detail::scheduler::run
(this=this@entry=0x2b93d0026c30, ec=...)
at
/root/access_platform_group/TubeMQ-Client-Cpp/build/third_party/include/asio/detail/impl/scheduler.ipp:203
#25 0x000000000051f1c9 in run (this=<optimized out>)
at
/root/access_platform_group/TubeMQ-Client-Cpp/build/third_party/include/asio/impl/io_context.ipp:62
#26 tubemq::Executor::StartWorker (this=<optimized out>, io_context=...)
at /root/access_platform_group/TubeMQ-Client-Cpp/src/executor_pool.cc:42
#27 0x0000000000522b42 in operator()<std::shared_ptr<asio::io_context>&, void>
(__object=<optimized out>, this=<optimized out>)
at /usr/include/c++/4.8.2/functional:601
#28 __call<void, 0ul, 1ul> (__args=<optimized out>, this=<optimized out>) at
/usr/include/c++/4.8.2/functional:1296
#29 operator()<, void> (this=<optimized out>) at
/usr/include/c++/4.8.2/functional:1355
#30 _M_invoke<> (this=<optimized out>) at /usr/include/c++/4.8.2/functional:1732
#31 operator() (this=<optimized out>) at /usr/include/c++/4.8.2/functional:1720
---Type <return> to continue, or q <return> to quit---
#32 std::thread::_Impl<std::_Bind_simple<std::_Bind<std::_Mem_fn<void
(tubemq::Executor::*)(std::shared_ptr<asio::io_context>)> (tubemq::Executor*,
std::shared_ptr<asio::io_context>)> ()> >::_M_run() (this=<optimized out>) at
/usr/include/c++/4.8.2/thread:115
#33 0x00002b939ce70220 in ?? () from /lib64/libstdc++.so.6
#34 0x00002b939c0c6e25 in start_thread () from /lib64/libpthread.so.0
#35 0x00002b939d6d435d in clone () from /lib64/libc.so.6
{quote}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
