assert false during cancel replica

[BorysTheDev]

libc.so.6!__pthread_kill_implementation(int no_tid, int signo, pthread_t threadid) (pthread_kill.c:44)
libc.so.6!__pthread_kill_internal(int signo, pthread_t threadid) (pthread_kill.c:78)
libc.so.6!__GI___pthread_kill(pthread_t threadid, int signo) (pthread_kill.c:89)
libc.so.6!__GI_raise(int sig) (raise.c:26)
libc.so.6!__GI_abort() (abort.c:79)
google::DumpStackTraceAndExit() (/home/borys/projects/dragonfly/build-dbg/_deps/glog-src/src/utilities.cc:178)
google::LogMessage::Fail() (/home/borys/projects/dragonfly/build-dbg/_deps/glog-src/src/logging.cc:1949)
google::LogMessage::SendToLog(google::LogMessage * const this) (/home/borys/projects/dragonfly/build-dbg/_deps/glog-src/src/logging.cc:1923)
google::LogMessage::Flush(google::LogMessage * const this) (/home/borys/projects/dragonfly/build-dbg/_deps/glog-src/src/logging.cc:1780)
google::LogMessageFatal::~LogMessageFatal(google::LogMessageFatal * const this) (/home/borys/projects/dragonfly/build-dbg/_deps/glog-src/src/logging.cc:2560)
__assert_fail(const char * assertion, const char * file, unsigned int line, const char * function) (/home/borys/projects/dragonfly/helio/base/init.cc:21)
dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split<dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split(unsigned int)::{lambda(auto:1 const&)#1}>(dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split(unsigned int)::{lambda(auto:1 const&)#1}&&, dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>*)::{lambda(auto:1*, unsigned int, bool)#3}::operator()<dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Bucket>(dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Bucket*, unsigned int, bool) const(const struct {...} * const __closure, dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Bucket * bucket, unsigned int slot, bool probe) (/home/borys/projects/dragonfly/src/core/dash_internal.h:1294)
dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Bucket::ForEachSlotImpl<dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Bucket*, dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split<dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split(unsigned int)::{lambda(auto:1 const&)#1}>(dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split(unsigned int)::{lambda(auto:1 const&)#1}&&, dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>*)::{lambda(auto:1*, unsigned int, bool)#3}>(dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Bucket*, dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split<dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split(unsigned int)::{lambda(auto:1 const&)#1}>(dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split(unsigned int)::{lambda(auto:1 const&)#1}&&, dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>*)::{lambda(auto:1*, unsigned int, bool)#3}&&) const(const dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Bucket * const this, dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Bucket * obj, struct {...} && cb) (/home/borys/projects/dragonfly/src/core/dash_internal.h:348)
dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Bucket::ForEachSlot<dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split<dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split(unsigned int)::{lambda(auto:1 const&)#1}>(dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split(unsigned int)::{lambda(auto:1 const&)#1}&&, dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>*)::{lambda(auto:1*, unsigned int, bool)#3}>(dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split(unsigned int)::{lambda(auto:1 const&)#1}&&)(dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Bucket * const this, struct {...} && cb) (/home/borys/projects/dragonfly/src/core/dash_internal.h:362)
dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split<dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split(unsigned int)::{lambda(auto:1 const&)#1}>(dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split(unsigned int)::{lambda(auto:1 const&)#1}&&, dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>*)(dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy> * const this, struct {...} && hfn, dfly::detail::Segment<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy> * dest_right) (/home/borys/projects/dragonfly/src/core/dash_internal.h:1306)
dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::Split(dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy> * const this, uint32_t seg_id) (/home/borys/projects/dragonfly/src/core/dash.h:884)
dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::InsertInternal<dfly::CompactObj, dfly::CompactObj, dfly::(anonymous namespace)::PrimeEvictionPolicy>(dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy> * const this, dfly::CompactObj && key, dfly::CompactObj && value, dfly::(anonymous namespace)::PrimeEvictionPolicy & ev, dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::InsertMode mode) (/home/borys/projects/dragonfly/src/core/dash.h:850)
dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy>::InsertNew<dfly::CompactObj, dfly::CompactObj, dfly::(anonymous namespace)::PrimeEvictionPolicy>(dfly::DashTable<dfly::CompactObj, dfly::CompactObj, dfly::detail::PrimeTablePolicy> * const this, dfly::CompactObj && key, dfly::CompactObj && value, dfly::(anonymous namespace)::PrimeEvictionPolicy & ev) (/home/borys/projects/dragonfly/src/core/dash.h:144)
dfly::DbSlice::AddOrFindInternal(dfly::DbSlice * const this, const dfly::DbSlice::Context & cntx, std::string_view key) (/home/borys/projects/dragonfly/src/server/db_slice.cc:563)
dfly::DbSlice::AddOrFind(dfly::DbSlice * const this, const dfly::DbSlice::Context & cntx, std::string_view key) (/home/borys/projects/dragonfly/src/server/db_slice.cc:493)
dfly::DbSlice::AddOrUpdateInternal(dfly::DbSlice * const this, const dfly::DbSlice::Context & cntx, std::string_view key, dfly::PrimeValue obj, uint64_t expire_at_ms, bool force_update) (/home/borys/projects/dragonfly/src/server/db_slice.cc:878)
dfly::DbSlice::AddOrUpdate(dfly::DbSlice * const this, const dfly::DbSlice::Context & cntx, std::string_view key, dfly::PrimeValue obj, uint64_t expire_at_ms) (/home/borys/projects/dragonfly/src/server/db_slice.cc:906)
dfly::RdbLoader::LoadItemsBuffer(dfly::RdbLoader * const this, dfly::DbIndex db_ind, const dfly::RdbLoader::ItemsBuf & ib) (/home/borys/projects/dragonfly/src/server/rdb_load.cc:2456)
operator()(const struct {...} * const __closure) (/home/borys/projects/dragonfly/src/server/rdb_load.cc:2423)
std::__invoke_impl<void, dfly::RdbLoader::FlushShardAsync(dfly::ShardId)::<lambda()>&>(std::__invoke_other, struct {...} &)(struct {...} & __f) (/usr/include/c++/11/bits/invoke.h:61)
std::__invoke_r<void, dfly::RdbLoader::FlushShardAsync(dfly::ShardId)::<lambda()>&>(struct {...} &)(struct {...} & __fn) (/usr/include/c++/11/bits/invoke.h:111)
std::_Function_handler<void(), dfly::RdbLoader::FlushShardAsync(dfly::ShardId)::<lambda()> >::_M_invoke(const std::_Any_data &)(const std::_Any_data & __functor) (/usr/include/c++/11/bits/std_function.h:290)
std::function<void ()>::operator()() const(const std::function<void()> * const this) (/usr/include/c++/11/bits/std_function.h:590)
dfly::TaskQueue::TaskLoop(dfly::TaskQueue * const this) (/home/borys/projects/dragonfly/src/core/task_queue.cc:66)
operator()(const struct {...} * const __closure) (/home/borys/projects/dragonfly/src/core/task_queue.cc:29)
std::__invoke_impl<void, dfly::TaskQueue::Start(std::string_view)::<lambda()> >(std::__invoke_other, struct {...} &&)(struct {...} && __f) (/usr/include/c++/11/bits/invoke.h:61)
std::__invoke<dfly::TaskQueue::Start(std::string_view)::<lambda()> >(struct {...} &&)(struct {...} && __fn) (/usr/include/c++/11/bits/invoke.h:96)
std::__apply_impl<dfly::TaskQueue::Start(std::string_view)::<lambda()>, std::tuple<> >(struct {...} &&, std::tuple<> &&, std::index_sequence)(struct {...} && __f, std::tuple<> && __t) (/usr/include/c++/11/tuple:1854)
std::apply<dfly::TaskQueue::Start(std::string_view)::<lambda()>, std::tuple<> >(struct {...} &&, std::tuple<> &&)(struct {...} && __f, std::tuple<> && __t) (/usr/include/c++/11/tuple:1865)
util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::run_(util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::FbCntx &&)(util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> > * const this, util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::FbCntx && c) (/home/borys/projects/dragonfly/helio/util/fibers/detail/fiber_interface.h:283)
operator()(util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::FbCntx &&) const(const struct {...} * const __closure, util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::FbCntx && caller) (/home/borys/projects/dragonfly/helio/util/fibers/detail/fiber_interface.h:264)
std::__invoke_impl<boost::context::fiber, util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::WorkerFiberImpl<util::fb2::FixedStackAllocator>(std::string_view, const boost::context::preallocated&, util::fb2::FixedStackAllocator&&, dfly::TaskQueue::Start(std::string_view)::<lambda()>&&)::<lambda(util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::FbCntx&&)>&, boost::context::fiber>(std::__invoke_other, struct {...} &)(struct {...} & __f) (/usr/include/c++/11/bits/invoke.h:61)
std::__invoke<util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::WorkerFiberImpl<util::fb2::FixedStackAllocator>(std::string_view, const boost::context::preallocated&, util::fb2::FixedStackAllocator&&, dfly::TaskQueue::Start(std::string_view)::<lambda()>&&)::<lambda(util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::FbCntx&&)>&, boost::context::fiber>(struct {...} &)(struct {...} & __fn) (/usr/include/c++/11/bits/invoke.h:97)
std::invoke<util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::WorkerFiberImpl<util::fb2::FixedStackAllocator>(std::string_view, const boost::context::preallocated&, util::fb2::FixedStackAllocator&&, dfly::TaskQueue::Start(std::string_view)::<lambda()>&&)::<lambda(util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::FbCntx&&)>&, boost::context::fiber>(struct {...} &)(struct {...} & __fn) (/usr/include/c++/11/functional:98)
boost::context::detail::fiber_record<boost::context::fiber, util::fb2::FixedStackAllocator, util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::WorkerFiberImpl<util::fb2::FixedStackAllocator>(std::string_view, const boost::context::preallocated&, util::fb2::FixedStackAllocator&&, dfly::TaskQueue::Start(std::string_view)::<lambda()>&&)::<lambda(util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::FbCntx&&)> >::run(boost::context::detail::fcontext_t)(boost::context::detail::fiber_record<boost::context::fiber, util::fb2::FixedStackAllocator, util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::WorkerFiberImpl<util::fb2::FixedStackAllocator>(std::string_view, const boost::context::preallocated&, util::fb2::FixedStackAllocator&&, dfly::TaskQueue::Start(std::string_view)::<lambda()>&&)::<lambda(util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::FbCntx&&)> > * const this, boost::context::detail::fcontext_t fctx) (/usr/include/boost/context/fiber_fcontext.hpp:143)
boost::context::detail::fiber_entry<boost::context::detail::fiber_record<boost::context::fiber, util::fb2::FixedStackAllocator, util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::WorkerFiberImpl<util::fb2::FixedStackAllocator>(std::string_view, const boost::context::preallocated&, util::fb2::FixedStackAllocator&&, dfly::TaskQueue::Start(std::string_view)::<lambda()>&&)::<lambda(util::fb2::detail::WorkerFiberImpl<dfly::TaskQueue::Start(std::string_view)::<lambda()> >::FbCntx&&)> > >